Refactor package names for K'Streams/Flink commons (8086a1f8) · Commits · Sören Henning / theodolite

Commit 8086a1f8 authored 3 years ago by Sören Henning

Browse files

Refactor package names for K'Streams/Flink commons

parent 17fd04fa

No related branches found

No related tags found

Checking pipeline status

Hide whitespace changes

Inline Side-by-side

Showing

theodolite-benchmarks/flink-commons/src/main/java/rocks/theodolite/benchmarks/commons/flink/ConfigurationKeys.java 1 addition, 1 deletion

...heodolite/benchmarks/commons/flink/ConfigurationKeys.java
theodolite-benchmarks/flink-commons/src/main/java/rocks/theodolite/benchmarks/commons/flink/KafkaConnectorFactory.java 3 additions, 3 deletions

...olite/benchmarks/commons/flink/KafkaConnectorFactory.java
theodolite-benchmarks/flink-commons/src/main/java/rocks/theodolite/benchmarks/commons/flink/StateBackends.java 1 addition, 1 deletion

...ks/theodolite/benchmarks/commons/flink/StateBackends.java
theodolite-benchmarks/flink-commons/src/main/java/rocks/theodolite/benchmarks/commons/flink/TupleType.java 1 addition, 1 deletion

.../rocks/theodolite/benchmarks/commons/flink/TupleType.java
theodolite-benchmarks/flink-commons/src/main/java/rocks/theodolite/benchmarks/commons/flink/serialization/FlinkKafkaKeyValueSerde.java 2 additions, 2 deletions

.../commons/flink/serialization/FlinkKafkaKeyValueSerde.java
theodolite-benchmarks/flink-commons/src/main/java/rocks/theodolite/benchmarks/commons/flink/serialization/StatsSerializer.java 1 addition, 1 deletion

...nchmarks/commons/flink/serialization/StatsSerializer.java
theodolite-benchmarks/flink-commons/src/main/java/rocks/theodolite/benchmarks/commons/flink/util/SerializableSupplier.java 1 addition, 1 deletion

...e/benchmarks/commons/flink/util/SerializableSupplier.java
theodolite-benchmarks/kstreams-commons/src/main/java/rocks/theodolite/benchmarks/commons/kstreams/ConfigurationKeys.java 1 addition, 1 deletion

...dolite/benchmarks/commons/kstreams/ConfigurationKeys.java
theodolite-benchmarks/kstreams-commons/src/main/java/rocks/theodolite/benchmarks/commons/kstreams/KafkaStreamsBuilder.java 1 addition, 1 deletion

...lite/benchmarks/commons/kstreams/KafkaStreamsBuilder.java
theodolite-benchmarks/uc1-flink/src/main/java/theodolite/uc1/application/HistoryServiceFlinkJob.java 1 addition, 1 deletion

...va/theodolite/uc1/application/HistoryServiceFlinkJob.java
theodolite-benchmarks/uc1-kstreams/src/main/java/theodolite/uc1/streamprocessing/Uc1KafkaStreamsBuilder.java 1 addition, 1 deletion

...eodolite/uc1/streamprocessing/Uc1KafkaStreamsBuilder.java
theodolite-benchmarks/uc2-flink/src/main/java/theodolite/uc2/application/HistoryServiceFlinkJob.java 3 additions, 3 deletions

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

.../main/java/theodolite/uc2/application/HistoryService.java
theodolite-benchmarks/uc2-kstreams/src/main/java/theodolite/uc2/streamprocessing/Uc2KafkaStreamsBuilder.java 1 addition, 1 deletion

...eodolite/uc2/streamprocessing/Uc2KafkaStreamsBuilder.java
theodolite-benchmarks/uc3-flink/src/main/java/theodolite/uc3/application/HistoryServiceFlinkJob.java 3 additions, 3 deletions

...va/theodolite/uc3/application/HistoryServiceFlinkJob.java
theodolite-benchmarks/uc3-kstreams/src/main/java/theodolite/uc3/application/HistoryService.java 1 addition, 1 deletion

.../main/java/theodolite/uc3/application/HistoryService.java
theodolite-benchmarks/uc3-kstreams/src/main/java/theodolite/uc3/streamprocessing/Uc3KafkaStreamsBuilder.java 1 addition, 1 deletion

...eodolite/uc3/streamprocessing/Uc3KafkaStreamsBuilder.java
theodolite-benchmarks/uc4-flink/src/main/java/theodolite/uc4/application/AggregationServiceFlinkJob.java 3 additions, 3 deletions

...heodolite/uc4/application/AggregationServiceFlinkJob.java
theodolite-benchmarks/uc4-kstreams/src/main/java/theodolite/uc4/application/AggregationService.java 1 addition, 1 deletion

...n/java/theodolite/uc4/application/AggregationService.java
theodolite-benchmarks/uc4-kstreams/src/main/java/theodolite/uc4/streamprocessing/Uc4KafkaStreamsBuilder.java 1 addition, 1 deletion

...eodolite/uc4/streamprocessing/Uc4KafkaStreamsBuilder.java

with 29 additions and 29 deletions

Please register or to comment