diff --git a/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/kafka/KafkaActivePowerRecordReader.java b/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/kafka/KafkaActivePowerRecordReader.java index 453b5c7eba4796114f22f77cb4ad409d2d3d4fde..56f5a681097046e94c8a77427e7864c9edfcdede 100644 --- a/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/kafka/KafkaActivePowerRecordReader.java +++ b/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/kafka/KafkaActivePowerRecordReader.java @@ -1,7 +1,9 @@ package theodolite.commons.beam.kafka; import io.confluent.kafka.serializers.KafkaAvroDeserializer; -import java.util.Properties; + +import java.util.HashMap; + import org.apache.beam.sdk.coders.AvroCoder; import org.apache.beam.sdk.io.kafka.KafkaIO; import org.apache.beam.sdk.transforms.PTransform; @@ -26,7 +28,7 @@ public class KafkaActivePowerRecordReader extends */ @SuppressWarnings({"unchecked", "rawtypes"}) public KafkaActivePowerRecordReader(final String bootstrapServer, final String inputTopic, - final Properties consumerConfig) { + final HashMap consumerConfig) { super(); // Check if boostrap server and inputTopic are defined diff --git a/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/kafka/KafkaActivePowerTimestampReader.java b/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/kafka/KafkaActivePowerTimestampReader.java index f5fe21f805646531c4c4070a5562089ed48193e6..0b22745bfc7b3d82e1ae0f6fd930d98ed6e98665 100644 --- a/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/kafka/KafkaActivePowerTimestampReader.java +++ b/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/kafka/KafkaActivePowerTimestampReader.java @@ -10,6 +10,7 @@ import org.apache.beam.sdk.values.PCollection; import org.apache.kafka.common.serialization.StringDeserializer; import titan.ccp.model.records.ActivePowerRecord; +import java.util.HashMap; import java.util.Properties; /** @@ -28,7 +29,7 @@ public class KafkaActivePowerTimestampReader extends */ @SuppressWarnings({"unchecked", "rawtypes"}) public KafkaActivePowerTimestampReader(final String bootstrapServer, final String inputTopic, - final Properties consumerConfig) { + final HashMap consumerConfig) { super(); // Check if boostrap server and inputTopic are defined diff --git a/theodolite-benchmarks/settings.gradle b/theodolite-benchmarks/settings.gradle index dc76ef7428632728d36502556827de41ecd86d86..00fc6c637883a1b6d687a72122bd38d09517a069 100644 --- a/theodolite-benchmarks/settings.gradle +++ b/theodolite-benchmarks/settings.gradle @@ -8,6 +8,7 @@ include 'beam-commons' include 'uc1-beam' include 'uc2-beam' include 'uc3-beam' +include 'uc4-beam' include 'uc1-load-generator' include 'uc1-kstreams' diff --git a/theodolite-benchmarks/uc4-beam-samza/build.gradle b/theodolite-benchmarks/uc4-beam-samza/build.gradle index a52d84afcd77a392acd47d2b42ba55711b0488cb..7a3184836d36dca9c0fe8d44a1b1a2a3b40d117d 100644 --- a/theodolite-benchmarks/uc4-beam-samza/build.gradle +++ b/theodolite-benchmarks/uc4-beam-samza/build.gradle @@ -1,30 +1,11 @@ plugins { - id 'theodolite.kstreams' + id 'theodolite.beam' } -allprojects { - repositories { - maven { - url 'https://packages.confluent.io/maven/' - } - mavenCentral() - } -} - - dependencies { - compile group: 'org.apache.beam', name: 'beam-sdks-java-core', version: '2.22.0' compile group: 'org.apache.beam', name: 'beam-runners-samza', version: '2.22.0' - - compile('org.apache.beam:beam-sdks-java-io-kafka:2.22.0'){ - exclude group: 'org.apache.kafka', module: 'kafka-clients' - } - compile group: 'org.slf4j', name: 'slf4j-simple', version: '1.7.30' - - runtime 'org.apache.beam:beam-runners-direct-java:2.22.0' - runtime 'org.slf4j:slf4j-api:1.7.32' - runtime 'org.slf4j:slf4j-jdk14:1.7.32' + compile project(':uc4-beam') } -mainClassName = "application.Uc4ApplicationBeam" +mainClassName = "application.Uc4BeamSamza"