Skip to content

Commit 1c6ddc0

Browse files
authored
Use AvroBulletRecord for bullet storm example (#4)
1 parent 191cbbf commit 1c6ddc0

File tree

2 files changed

+11
-4
lines changed

2 files changed

+11
-4
lines changed

examples/storm/pom.xml

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -26,8 +26,9 @@
2626
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
2727
<maven.compiler.source>1.8</maven.compiler.source>
2828
<maven.compiler.target>1.8</maven.compiler.target>
29-
<bullet.storm.version>0.6.2</bullet.storm.version>
30-
<bullet.core.version>0.1.2</bullet.core.version>
29+
<bullet.storm.version>0.8.2</bullet.storm.version>
30+
<bullet.core.version>0.4.0</bullet.core.version>
31+
<bullet.record.version>0.2.0</bullet.record.version>
3132
<storm.version>1.0.3</storm.version>
3233
</properties>
3334

@@ -95,6 +96,11 @@
9596
<artifactId>bullet-storm</artifactId>
9697
<version>${bullet.storm.version}</version>
9798
</dependency>
99+
<dependency>
100+
<groupId>com.yahoo.bullet</groupId>
101+
<artifactId>bullet-record</artifactId>
102+
<version>${bullet.record.version}</version>
103+
</dependency>
98104
</dependencies>
99105
<build>
100106
<plugins>

examples/storm/src/main/java/com/yahoo/bullet/storm/examples/RandomSpout.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,8 @@
55
*/
66
package com.yahoo.bullet.storm.examples;
77

8-
import com.yahoo.bullet.BulletConfig;
8+
import com.yahoo.bullet.common.BulletConfig;
9+
import com.yahoo.bullet.record.AvroBulletRecord;
910
import com.yahoo.bullet.record.BulletRecord;
1011
import lombok.extern.slf4j.Slf4j;
1112
import org.apache.storm.spout.SpoutOutputCollector;
@@ -137,7 +138,7 @@ public void nextTuple() {
137138
}
138139

139140
private BulletRecord generateRecord() {
140-
BulletRecord record = new BulletRecord();
141+
BulletRecord record = new AvroBulletRecord();
141142
String uuid = UUID.randomUUID().toString();
142143

143144
record.setString(STRING, uuid);

0 commit comments

Comments
 (0)