Migrate remaining UCs to new Beam service
Showing
- theodolite-benchmarks/uc1-beam-flink/src/main/java/application/Uc1BeamFlink.java 2 additions, 0 deletions...c1-beam-flink/src/main/java/application/Uc1BeamFlink.java
- theodolite-benchmarks/uc1-beam-samza/src/main/java/application/Uc1BeamSamza.java 8 additions, 10 deletions...c1-beam-samza/src/main/java/application/Uc1BeamSamza.java
- theodolite-benchmarks/uc1-beam/src/main/java/application/PipelineFactory.java 2 additions, 2 deletions...s/uc1-beam/src/main/java/application/PipelineFactory.java
- theodolite-benchmarks/uc2-beam-flink/src/main/java/application/Uc2BeamFlink.java 3 additions, 3 deletions...c2-beam-flink/src/main/java/application/Uc2BeamFlink.java
- theodolite-benchmarks/uc2-beam-samza/src/main/java/application/Uc2BeamSamza.java 3 additions, 2 deletions...c2-beam-samza/src/main/java/application/Uc2BeamSamza.java
- theodolite-benchmarks/uc2-beam/src/main/java/application/PipelineFactory.java 6 additions, 15 deletions...s/uc2-beam/src/main/java/application/PipelineFactory.java
- theodolite-benchmarks/uc3-beam-flink/src/main/java/application/Uc3BeamFlink.java 4 additions, 17 deletions...c3-beam-flink/src/main/java/application/Uc3BeamFlink.java
- theodolite-benchmarks/uc3-beam-samza/src/main/java/application/Uc3BeamSamza.java 4 additions, 16 deletions...c3-beam-samza/src/main/java/application/Uc3BeamSamza.java
- theodolite-benchmarks/uc3-beam/src/main/java/application/PipelineFactory.java 38 additions, 35 deletions...s/uc3-beam/src/main/java/application/PipelineFactory.java
- theodolite-benchmarks/uc4-beam-flink/src/main/java/application/Uc4BeamFlink.java 5 additions, 19 deletions...c4-beam-flink/src/main/java/application/Uc4BeamFlink.java
- theodolite-benchmarks/uc4-beam-samza/src/main/java/application/Uc4BeamSamza.java 8 additions, 20 deletions...c4-beam-samza/src/main/java/application/Uc4BeamSamza.java
- theodolite-benchmarks/uc4-beam/src/main/java/application/PipelineFactory.java 99 additions, 57 deletions...s/uc4-beam/src/main/java/application/PipelineFactory.java
Loading
Please register or sign in to comment