Introduce AbstractPipeline + rework uc1-beam-flink
Showing
- theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/AbstractBeamService.java 17 additions, 31 deletions...ain/java/theodolite/commons/beam/AbstractBeamService.java
- theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/AbstractPipeline.java 44 additions, 0 deletions...c/main/java/theodolite/commons/beam/AbstractPipeline.java
- theodolite-benchmarks/settings.gradle 2 additions, 0 deletionstheodolite-benchmarks/settings.gradle
- theodolite-benchmarks/uc1-beam-flink/build.gradle 2 additions, 1 deletiontheodolite-benchmarks/uc1-beam-flink/build.gradle
- theodolite-benchmarks/uc1-beam-flink/src/main/java/application/Uc1BeamFlink.java 41 additions, 0 deletions...c1-beam-flink/src/main/java/application/Uc1BeamFlink.java
- theodolite-benchmarks/uc1-beam/build.gradle 5 additions, 0 deletionstheodolite-benchmarks/uc1-beam/build.gradle
- theodolite-benchmarks/uc1-beam/src/main/java/application/LogKeyValue.java 24 additions, 0 deletions...marks/uc1-beam/src/main/java/application/LogKeyValue.java
- theodolite-benchmarks/uc1-beam/src/main/java/application/MapToGson.java 21 additions, 0 deletions...chmarks/uc1-beam/src/main/java/application/MapToGson.java
- theodolite-benchmarks/uc1-beam/src/main/java/application/Uc1BeamPipeline.java 65 additions, 0 deletions...s/uc1-beam/src/main/java/application/Uc1BeamPipeline.java
Loading
Please register or sign in to comment