Migrate to Avro records, upgrade to Flink 1.12 (37946776) · Commits · Sören Henning / theodolite

Commit 37946776 authored 4 years ago by Sören Henning

Browse files

Migrate to Avro records, upgrade to Flink 1.12

parent 9e9543cc

No related branches found

No related tags found

Checking pipeline status

Hide whitespace changes

Inline Side-by-side

Showing

theodolite-benchmarks/build.gradle 8 additions, 12 deletions

theodolite-benchmarks/build.gradle
theodolite-benchmarks/flink-commons/build.gradle 4 additions, 7 deletions

theodolite-benchmarks/flink-commons/build.gradle
theodolite-benchmarks/flink-commons/src/main/java/theodolite/commons/flink/serialization/FlinkMonitoringRecordSerde.java 0 additions, 126 deletions

...mmons/flink/serialization/FlinkMonitoringRecordSerde.java
theodolite-benchmarks/uc1-application-flink/src/main/java/theodolite/uc1/application/ConfigurationKeys.java 2 additions, 0 deletions

...in/java/theodolite/uc1/application/ConfigurationKeys.java
theodolite-benchmarks/uc1-application-flink/src/main/java/theodolite/uc1/application/HistoryServiceFlinkJob.java 14 additions, 7 deletions

...va/theodolite/uc1/application/HistoryServiceFlinkJob.java
theodolite-benchmarks/uc1-application-flink/src/main/resources/META-INF/application.properties 2 additions, 0 deletions

...-flink/src/main/resources/META-INF/application.properties
theodolite-benchmarks/uc2-application-flink/src/main/java/theodolite/uc2/application/ConfigurationKeys.java 2 additions, 0 deletions

...in/java/theodolite/uc2/application/ConfigurationKeys.java
theodolite-benchmarks/uc2-application-flink/src/main/java/theodolite/uc2/application/HistoryServiceFlinkJob.java 15 additions, 15 deletions

...va/theodolite/uc2/application/HistoryServiceFlinkJob.java
theodolite-benchmarks/uc2-application-flink/src/main/java/theodolite/uc2/application/StatsAggregateFunction.java 1 addition, 1 deletion

...va/theodolite/uc2/application/StatsAggregateFunction.java
theodolite-benchmarks/uc2-application-flink/src/main/resources/META-INF/application.properties 1 addition, 0 deletions

...-flink/src/main/resources/META-INF/application.properties
theodolite-benchmarks/uc3-application-flink/src/main/java/theodolite/uc3/application/ConfigurationKeys.java 2 additions, 0 deletions

...in/java/theodolite/uc3/application/ConfigurationKeys.java
theodolite-benchmarks/uc3-application-flink/src/main/java/theodolite/uc3/application/HistoryServiceFlinkJob.java 10 additions, 14 deletions

...va/theodolite/uc3/application/HistoryServiceFlinkJob.java
theodolite-benchmarks/uc3-application-flink/src/main/java/theodolite/uc3/application/StatsAggregateFunction.java 2 additions, 2 deletions

...va/theodolite/uc3/application/StatsAggregateFunction.java
theodolite-benchmarks/uc3-application-flink/src/main/resources/META-INF/application.properties 1 addition, 0 deletions

...-flink/src/main/resources/META-INF/application.properties
theodolite-benchmarks/uc4-application-flink/src/main/java/theodolite/uc4/application/AggregationServiceFlinkJob.java 20 additions, 24 deletions

...heodolite/uc4/application/AggregationServiceFlinkJob.java
theodolite-benchmarks/uc4-application-flink/src/main/java/theodolite/uc4/application/ConfigurationKeys.java 2 additions, 0 deletions

...in/java/theodolite/uc4/application/ConfigurationKeys.java
theodolite-benchmarks/uc4-application-flink/src/main/java/theodolite/uc4/application/JoinAndDuplicateCoFlatMapFunction.java 1 addition, 1 deletion

...te/uc4/application/JoinAndDuplicateCoFlatMapFunction.java
theodolite-benchmarks/uc4-application-flink/src/main/java/theodolite/uc4/application/JoinAndDuplicateKeyedBroadcastProcessFunction.java 1 addition, 1 deletion

...cation/JoinAndDuplicateKeyedBroadcastProcessFunction.java
theodolite-benchmarks/uc4-application-flink/src/main/java/theodolite/uc4/application/RecordAggregationProcessWindowFunction.java 5 additions, 7 deletions

...4/application/RecordAggregationProcessWindowFunction.java
theodolite-benchmarks/uc4-application-flink/src/main/resources/META-INF/application.properties 1 addition, 0 deletions

...-flink/src/main/resources/META-INF/application.properties

with 94 additions and 217 deletions

Please register or to comment