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

BAEL-1463: Privatize Everything.

Browse Source
This commit is contained in:
DomWos 2018-10-16 10:39:18 +02:00
parent 99a840fd03
commit a0a393cdfc
5 changed files with 12 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
libraries-data/src/main/java/com/baeldung/storm/bolt/AggregatingBolt.java
View File

@ -14,7 +14,7 @@ import java.util.List;
import java.util.Map; import java.util.Map;
public class AggregatingBolt extends BaseWindowedBolt { public class AggregatingBolt extends BaseWindowedBolt {
OutputCollector outputCollector; private OutputCollector outputCollector;
@Override @Override
public void prepare(Map stormConf, TopologyContext context, OutputCollector collector) { public void prepare(Map stormConf, TopologyContext context, OutputCollector collector) {
this.outputCollector = collector; this.outputCollector = collector;

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

@ -4,7 +4,6 @@ import com.baeldung.storm.model.AggregatedWindow;
import com.fasterxml.jackson.annotation.JsonAutoDetect; import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor; import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.ObjectWriter;
import org.apache.storm.task.OutputCollector; import org.apache.storm.task.OutputCollector;
import org.apache.storm.task.TopologyContext; import org.apache.storm.task.TopologyContext;
import org.apache.storm.topology.OutputFieldsDeclarer; import org.apache.storm.topology.OutputFieldsDeclarer;
@ -20,9 +19,9 @@ import java.util.Map;
public class FileWritingBolt extends BaseRichBolt { public class FileWritingBolt extends BaseRichBolt {
public static Logger logger = LoggerFactory.getLogger(FileWritingBolt.class); public static Logger logger = LoggerFactory.getLogger(FileWritingBolt.class);
BufferedWriter writer; private BufferedWriter writer;
String filePath; private String filePath;
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();

8
libraries-data/src/main/java/com/baeldung/storm/model/User.java
View File

@ -1,10 +1,10 @@
package com.baeldung.storm.model; package com.baeldung.storm.model;
public class User { public class User {
String username; private String username;
String password; private String password;
String email; private String email;
int age; private int age;
public String getUsername() { public String getUsername() {
return username; return username;

4
libraries-data/src/main/java/com/baeldung/storm/spout/RandomIntSpout.java
View File

@ -13,8 +13,8 @@ import java.util.Random;
public class RandomIntSpout extends BaseRichSpout { public class RandomIntSpout extends BaseRichSpout {
Random random; private Random random;
SpoutOutputCollector outputCollector; private SpoutOutputCollector outputCollector;
@Override @Override
public void open(Map map, TopologyContext topologyContext, SpoutOutputCollector spoutOutputCollector) { public void open(Map map, TopologyContext topologyContext, SpoutOutputCollector spoutOutputCollector) {

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

@ -13,8 +13,8 @@ import java.util.Map;
import java.util.Random; import java.util.Random;
public class RandomNumberSpout extends BaseRichSpout { public class RandomNumberSpout extends BaseRichSpout {
Random random; private Random random;
SpoutOutputCollector collector; private SpoutOutputCollector collector;
@Override @Override
public void open(Map map, TopologyContext topologyContext, SpoutOutputCollector spoutOutputCollector) { public void open(Map map, TopologyContext topologyContext, SpoutOutputCollector spoutOutputCollector) {