Migrate UC4 (fka UC2) for Flink
Co-authored-by:
Nico Biernat <stu209212@mail.uni-kiel.de>
parent
b206d512
No related branches found
No related tags found
Showing
- theodolite-benchmarks/settings.gradle 1 addition, 1 deletiontheodolite-benchmarks/settings.gradle
- theodolite-benchmarks/uc4-application-flink/.settings/org.eclipse.jdt.ui.prefs 3 additions, 0 deletions.../uc4-application-flink/.settings/org.eclipse.jdt.ui.prefs
- theodolite-benchmarks/uc4-application-flink/.settings/qa.eclipse.plugin.checkstyle.prefs 4 additions, 0 deletions...cation-flink/.settings/qa.eclipse.plugin.checkstyle.prefs
- theodolite-benchmarks/uc4-application-flink/.settings/qa.eclipse.plugin.pmd.prefs 4 additions, 0 deletions...4-application-flink/.settings/qa.eclipse.plugin.pmd.prefs
- theodolite-benchmarks/uc4-application-flink/Dockerfile 3 additions, 0 deletionstheodolite-benchmarks/uc4-application-flink/Dockerfile
- theodolite-benchmarks/uc4-application-flink/build.gradle 1 addition, 0 deletionstheodolite-benchmarks/uc4-application-flink/build.gradle
- theodolite-benchmarks/uc4-application-flink/src/main/java/theodolite/uc4/application/AggregationServiceFlinkJob.java 329 additions, 0 deletions...heodolite/uc4/application/AggregationServiceFlinkJob.java
- theodolite-benchmarks/uc4-application-flink/src/main/java/theodolite/uc4/application/ChildParentsFlatMapFunction.java 101 additions, 0 deletions...eodolite/uc4/application/ChildParentsFlatMapFunction.java
- theodolite-benchmarks/uc4-application-flink/src/main/java/theodolite/uc4/application/ConfigurationKeys.java 37 additions, 0 deletions...in/java/theodolite/uc4/application/ConfigurationKeys.java
- theodolite-benchmarks/uc4-application-flink/src/main/java/theodolite/uc4/application/JoinAndDuplicateCoFlatMapFunction.java 57 additions, 0 deletions...te/uc4/application/JoinAndDuplicateCoFlatMapFunction.java
- theodolite-benchmarks/uc4-application-flink/src/main/java/theodolite/uc4/application/JoinAndDuplicateKeyedBroadcastProcessFunction.java 53 additions, 0 deletions...cation/JoinAndDuplicateKeyedBroadcastProcessFunction.java
- theodolite-benchmarks/uc4-application-flink/src/main/java/theodolite/uc4/application/RecordAggregationProcessWindowFunction.java 96 additions, 0 deletions...4/application/RecordAggregationProcessWindowFunction.java
- theodolite-benchmarks/uc4-application-flink/src/main/java/theodolite/uc4/application/util/ImmutableSensorRegistrySerializer.java 24 additions, 0 deletions...4/application/util/ImmutableSensorRegistrySerializer.java
- theodolite-benchmarks/uc4-application-flink/src/main/java/theodolite/uc4/application/util/ImmutableSetSerializer.java 47 additions, 0 deletions...eodolite/uc4/application/util/ImmutableSetSerializer.java
- theodolite-benchmarks/uc4-application-flink/src/main/java/theodolite/uc4/application/util/SensorParentKey.java 46 additions, 0 deletions...java/theodolite/uc4/application/util/SensorParentKey.java
- theodolite-benchmarks/uc4-application-flink/src/main/java/theodolite/uc4/application/util/SensorParentKeySerializer.java 27 additions, 0 deletions...olite/uc4/application/util/SensorParentKeySerializer.java
- theodolite-benchmarks/uc4-application-flink/src/main/resources/META-INF/application.properties 15 additions, 0 deletions...-flink/src/main/resources/META-INF/application.properties
Loading
Please register or sign in to comment