Skip to content
Snippets Groups Projects
Commit cfab1593 authored by Lorenz Boguhn's avatar Lorenz Boguhn Committed by Lorenz Boguhn
Browse files

Renaming KafkaAggregatedPowerRecordReader to KafkaActivePowerRecordReader

parent bdf1bea7
No related branches found
No related tags found
1 merge request!187Migrate Beam benchmark implementation
...@@ -14,7 +14,7 @@ import titan.ccp.model.records.ActivePowerRecord; ...@@ -14,7 +14,7 @@ import titan.ccp.model.records.ActivePowerRecord;
/** /**
* Simple {@link PTransform} that read from Kafka using {@link KafkaIO}. * Simple {@link PTransform} that read from Kafka using {@link KafkaIO}.
*/ */
public class KafkaAggregatedPowerRecordReader extends public class KafkaActivePowerRecordReader extends
PTransform<PBegin, PCollection<KV<String, ActivePowerRecord>>> { PTransform<PBegin, PCollection<KV<String, ActivePowerRecord>>> {
private static final long serialVersionUID = 2603286150183186115L; private static final long serialVersionUID = 2603286150183186115L;
...@@ -25,8 +25,8 @@ public class KafkaAggregatedPowerRecordReader extends ...@@ -25,8 +25,8 @@ public class KafkaAggregatedPowerRecordReader extends
* Instantiates a {@link PTransform} that reads from Kafka with the given Configuration. * Instantiates a {@link PTransform} that reads from Kafka with the given Configuration.
*/ */
@SuppressWarnings({"unchecked", "rawtypes"}) @SuppressWarnings({"unchecked", "rawtypes"})
public KafkaAggregatedPowerRecordReader(final String bootstrapServer, final String inputTopic, public KafkaActivePowerRecordReader(final String bootstrapServer, final String inputTopic,
final Properties consumerConfig) { final Properties consumerConfig) {
super(); super();
// Check if boostrap server and inputTopic are defined // Check if boostrap server and inputTopic are defined
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment