Change KafkaConsumer from HashMap to Map
refactor uc4-beam a bit
Showing
- theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/AbstractPipeline.java 6 additions, 5 deletions...c/main/java/theodolite/commons/beam/AbstractPipeline.java
- theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/kafka/KafkaActivePowerRecordReader.java 2 additions, 4 deletions...lite/commons/beam/kafka/KafkaActivePowerRecordReader.java
- theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/kafka/KafkaActivePowerTimestampReader.java 2 additions, 4 deletions...e/commons/beam/kafka/KafkaActivePowerTimestampReader.java
- theodolite-benchmarks/uc1-beam/src/main/java/application/Uc1BeamPipeline.java 2 additions, 1 deletion...s/uc1-beam/src/main/java/application/Uc1BeamPipeline.java
- theodolite-benchmarks/uc2-beam/src/main/java/application/Uc2BeamPipeline.java 2 additions, 1 deletion...s/uc2-beam/src/main/java/application/Uc2BeamPipeline.java
- theodolite-benchmarks/uc3-beam/src/main/java/application/Uc3BeamPipeline.java 2 additions, 1 deletion...s/uc3-beam/src/main/java/application/Uc3BeamPipeline.java
- theodolite-benchmarks/uc4-beam/src/main/java/application/Uc4BeamPipeline.java 7 additions, 6 deletions...s/uc4-beam/src/main/java/application/Uc4BeamPipeline.java
Loading
Please register or sign in to comment