iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fixes according to comments.

Browse Source
This commit is contained in:
DomWos 2018-10-22 11:51:37 +02:00
parent a0a393cdfc
commit 6fa2361283
2 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
libraries-data/src/main/java/com/baeldung/storm/bolt/FileWritingBolt.java
View File

@ -22,6 +22,7 @@ public class FileWritingBolt extends BaseRichBolt {
private BufferedWriter writer; private BufferedWriter writer;
private String filePath; private String filePath;
private ObjectMapper objectMapper; private ObjectMapper objectMapper;
@Override @Override
public void prepare(Map map, TopologyContext topologyContext, OutputCollector outputCollector) { public void prepare(Map map, TopologyContext topologyContext, OutputCollector outputCollector) {
objectMapper = new ObjectMapper(); objectMapper = new ObjectMapper();
@ -55,6 +56,15 @@ public class FileWritingBolt extends BaseRichBolt {
this.filePath = filePath; this.filePath = filePath;
} }
@Override
public void cleanup() {
try {
writer.close();
} catch (IOException e) {
logger.error("Failed to close the writer!");
}
}
@Override @Override
public void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) { public void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) {

2
libraries-data/src/main/java/com/baeldung/storm/spout/RandomNumberSpout.java
View File

@ -26,7 +26,7 @@ public class RandomNumberSpout extends BaseRichSpout {
public void nextTuple() { public void nextTuple() {
Utils.sleep(1000); Utils.sleep(1000);
//This will select random int from the range (-1000, 1000) //This will select random int from the range (-1000, 1000)
int operation = random.nextInt(1000 + 1 + 1000) - 1000; int operation = random.nextInt(101);
long timestamp = System.currentTimeMillis(); long timestamp = System.currentTimeMillis();
Values values = new Values(operation, timestamp); Values values = new Values(operation, timestamp);