Change Scottys GroupId (#55)

* change groupId to registered groupId for publishing to maven central #41 * change artifact Id and add requirements to pom * sign pom file with gpg * add gpg plugin and nexus staging plugin * remove duplicate dependency
TU-Berlin-DIMA · Mar 19, 2023 · 526e95b · 526e95b
1 parent b8f57b0
commit 526e95b
Show file tree

Hide file tree

Showing 327 changed files with 3,103 additions and 3,031 deletions.
diff --git a/README.md b/README.md
@@ -104,7 +104,7 @@ Then you can use the library in your maven project.
 
 ```xml
 <dependency> 
- <groupId>de.tub.dima.scotty</groupId>
+ <groupId>stream.scotty</groupId>
  <artifactId>flink-connector</artifactId>
  <version>0.4</version>
 </dependency>

diff --git a/beam-connector/pom.xml b/beam-connector/pom.xml
@@ -3,8 +3,8 @@
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <parent>
-        <artifactId>parent</artifactId>
-        <groupId>de.tub.dima.scotty</groupId>
+        <artifactId>scotty</artifactId>
+        <groupId>stream.scotty</groupId>
         <version>0.4</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
@@ -36,17 +36,17 @@
             <version>1.2</version>
         </dependency>
         <dependency>
-            <groupId>de.tub.dima.scotty</groupId>
+            <groupId>stream.scotty</groupId>
             <artifactId>core</artifactId>
             <version>${scotty.version}</version>
         </dependency>
         <dependency>
-            <groupId>de.tub.dima.scotty</groupId>
+            <groupId>stream.scotty</groupId>
             <artifactId>slicing</artifactId>
             <version>${scotty.version}</version>
         </dependency>
         <dependency>
-            <groupId>de.tub.dima.scotty</groupId>
+            <groupId>stream.scotty</groupId>
             <artifactId>state</artifactId>
             <version>${scotty.version}</version>
         </dependency>

diff --git a/...mconnector/KeyedScottyWindowOperator.java → ...mconnector/KeyedScottyWindowOperator.java b/...mconnector/KeyedScottyWindowOperator.java → ...mconnector/KeyedScottyWindowOperator.java
@@ -1,12 +1,12 @@
-package de.tub.dima.scotty.beamconnector;
+package stream.scotty.beamconnector;
 
-import de.tub.dima.scotty.core.AggregateWindow;
-import de.tub.dima.scotty.core.windowFunction.AggregateFunction;
-import de.tub.dima.scotty.core.windowType.SlidingWindow;
-import de.tub.dima.scotty.core.windowType.TumblingWindow;
-import de.tub.dima.scotty.core.windowType.Window;
-import de.tub.dima.scotty.slicing.SlicingWindowOperator;
-import de.tub.dima.scotty.state.memory.MemoryStateFactory;
+import stream.scotty.core.AggregateWindow;
+import stream.scotty.core.windowFunction.AggregateFunction;
+import stream.scotty.core.windowType.SlidingWindow;
+import stream.scotty.core.windowType.TumblingWindow;
+import stream.scotty.core.windowType.Window;
+import stream.scotty.slicing.SlicingWindowOperator;
+import stream.scotty.state.memory.MemoryStateFactory;
 import org.apache.beam.sdk.transforms.DoFn;
 import org.apache.beam.sdk.values.KV;
 import org.joda.time.Instant;

diff --git a/benchmark/pom.xml b/benchmark/pom.xml
@@ -3,8 +3,8 @@
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <parent>
-        <artifactId>parent</artifactId>
-        <groupId>de.tub.dima.scotty</groupId>
+        <artifactId>scotty</artifactId>
+        <groupId>stream.scotty</groupId>
         <version>0.4</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
@@ -13,12 +13,12 @@
     <packaging>pom</packaging>
     <dependencies>
         <dependency>
-            <groupId>de.tub.dima.scotty</groupId>
+            <groupId>stream.scotty</groupId>
             <artifactId>slicing</artifactId>
             <version>0.4</version>
         </dependency>
         <dependency>
-            <groupId>de.tub.dima.scotty</groupId>
+            <groupId>stream.scotty</groupId>
             <artifactId>flink-connector</artifactId>
             <version>0.4</version>
         </dependency>

diff --git a/...ma/scotty/flinkBenchmark/AnalyzeTool.java → ...am/scotty/flinkBenchmark/AnalyzeTool.java b/...ma/scotty/flinkBenchmark/AnalyzeTool.java → ...am/scotty/flinkBenchmark/AnalyzeTool.java
@@ -1,4 +1,4 @@
-package de.tub.dima.scotty.flinkBenchmark;
+package stream.scotty.flinkBenchmark;
 
 import org.apache.commons.math3.stat.descriptive.SummaryStatistics;
 

diff --git a/...cotty/flinkBenchmark/BenchmarkConfig.java → ...cotty/flinkBenchmark/BenchmarkConfig.java b/...cotty/flinkBenchmark/BenchmarkConfig.java → ...cotty/flinkBenchmark/BenchmarkConfig.java
@@ -1,4 +1,4 @@
-package de.tub.dima.scotty.flinkBenchmark;
+package stream.scotty.flinkBenchmark;
 
 import java.util.List;
 

diff --git a/...a/scotty/flinkBenchmark/BenchmarkJob.java → ...m/scotty/flinkBenchmark/BenchmarkJob.java b/...a/scotty/flinkBenchmark/BenchmarkJob.java → ...m/scotty/flinkBenchmark/BenchmarkJob.java
@@ -1,8 +1,8 @@
-package de.tub.dima.scotty.flinkBenchmark;
+package stream.scotty.flinkBenchmark;
 
-import de.tub.dima.scotty.core.windowType.*;
-import de.tub.dima.scotty.flinkBenchmark.aggregations.SumAggregation;
-import de.tub.dima.scotty.flinkconnector.*;
+import stream.scotty.core.windowType.*;
+import stream.scotty.flinkBenchmark.aggregations.SumAggregation;
+import stream.scotty.flinkconnector.*;
 import org.apache.flink.api.java.tuple.*;
 import org.apache.flink.api.java.utils.ParameterTool;
 import org.apache.flink.streaming.api.TimeCharacteristic;
@@ -47,9 +47,9 @@ public BenchmarkJob(List<Window> assigner, StreamExecutionEnvironment env, final
 
 
 		DataStream<Tuple4<String, Integer, Long, Long>> messageStream = env
-			.addSource(new de.tub.dima.scotty.flinkBenchmark.LoadGeneratorSource(runtime, throughput,  gaps));
+			.addSource(new stream.scotty.flinkBenchmark.LoadGeneratorSource(runtime, throughput,  gaps));
 
-		messageStream.flatMap(new de.tub.dima.scotty.flinkBenchmark.ThroughputLogger<>(200, throughput));
+		messageStream.flatMap(new stream.scotty.flinkBenchmark.ThroughputLogger<>(200, throughput));
 
 
 

diff --git a/...cotty/flinkBenchmark/BenchmarkRunner.java → ...cotty/flinkBenchmark/BenchmarkRunner.java b/...cotty/flinkBenchmark/BenchmarkRunner.java → ...cotty/flinkBenchmark/BenchmarkRunner.java
@@ -1,9 +1,9 @@
-package de.tub.dima.scotty.flinkBenchmark;
+package stream.scotty.flinkBenchmark;
 
 import com.google.gson.*;
-import de.tub.dima.scotty.core.*;
-import de.tub.dima.scotty.core.windowType.*;
-import de.tub.dima.scotty.core.*;
+import stream.scotty.core.*;
+import stream.scotty.core.windowType.*;
+import stream.scotty.core.*;
 import org.apache.flink.api.java.tuple.*;
 import org.apache.flink.configuration.*;
 import org.apache.flink.streaming.api.environment.*;

diff --git a/...tty/flinkBenchmark/FlinkBenchmarkJob.java → ...tty/flinkBenchmark/FlinkBenchmarkJob.java b/...tty/flinkBenchmark/FlinkBenchmarkJob.java → ...tty/flinkBenchmark/FlinkBenchmarkJob.java
@@ -1,7 +1,7 @@
-package de.tub.dima.scotty.flinkBenchmark;
+package stream.scotty.flinkBenchmark;
 
-import de.tub.dima.scotty.core.windowType.*;
-import de.tub.dima.scotty.core.windowType.Window;
+import stream.scotty.core.windowType.*;
+import stream.scotty.core.windowType.Window;
 import org.apache.flink.api.java.tuple.*;
 import org.apache.flink.api.java.utils.*;
 import org.apache.flink.streaming.api.*;

diff --git a/...y/flinkBenchmark/LoadGeneratorSource.java → ...y/flinkBenchmark/LoadGeneratorSource.java b/...y/flinkBenchmark/LoadGeneratorSource.java → ...y/flinkBenchmark/LoadGeneratorSource.java
@@ -1,4 +1,4 @@
-package de.tub.dima.scotty.flinkBenchmark;
+package stream.scotty.flinkBenchmark;
 
 import org.apache.flink.api.java.tuple.*;
 import org.apache.flink.streaming.api.functions.source.*;

diff --git a/...otty/flinkBenchmark/ThroughputLogger.java → ...otty/flinkBenchmark/ThroughputLogger.java b/...otty/flinkBenchmark/ThroughputLogger.java → ...otty/flinkBenchmark/ThroughputLogger.java
@@ -1,4 +1,4 @@
-package de.tub.dima.scotty.flinkBenchmark;
+package stream.scotty.flinkBenchmark;
 
 import org.apache.flink.api.common.functions.FlatMapFunction;
 import org.apache.flink.util.Collector;

diff --git a/.../flinkBenchmark/ThroughputStatistics.java → .../flinkBenchmark/ThroughputStatistics.java b/.../flinkBenchmark/ThroughputStatistics.java → .../flinkBenchmark/ThroughputStatistics.java
@@ -1,4 +1,4 @@
-package de.tub.dima.scotty.flinkBenchmark;
+package stream.scotty.flinkBenchmark;
 
 public class ThroughputStatistics {
 

diff --git a/...enchmark/aggregations/SumAggregation.java → ...enchmark/aggregations/SumAggregation.java b/...enchmark/aggregations/SumAggregation.java → ...enchmark/aggregations/SumAggregation.java
@@ -1,6 +1,6 @@
-package de.tub.dima.scotty.flinkBenchmark.aggregations;
+package stream.scotty.flinkBenchmark.aggregations;
 
-import de.tub.dima.scotty.core.windowFunction.*;
+import stream.scotty.core.windowFunction.*;
 import org.apache.flink.api.java.tuple.*;
 
 import java.io.*;

diff --git a/...icrobenchmark/AggregationStateInline.java → ...icrobenchmark/AggregationStateInline.java b/...icrobenchmark/AggregationStateInline.java → ...icrobenchmark/AggregationStateInline.java
@@ -1,7 +1,7 @@
-package de.tub.dima.scotty.microbenchmark;
+package stream.scotty.microbenchmark;
 
-import de.tub.dima.scotty.state.StateFactory;
-import de.tub.dima.scotty.state.ValueState;
+import stream.scotty.state.StateFactory;
+import stream.scotty.state.ValueState;
 
 import java.util.ArrayList;
 

diff --git a/...obenchmark/AggregationStoreBenchmark.java → ...obenchmark/AggregationStoreBenchmark.java b/...obenchmark/AggregationStoreBenchmark.java → ...obenchmark/AggregationStoreBenchmark.java
@@ -1,8 +1,8 @@
-package de.tub.dima.scotty.microbenchmark;
+package stream.scotty.microbenchmark;
 
-import de.tub.dima.scotty.slicing.state.AggregateState;
-import de.tub.dima.scotty.state.memory.MemoryStateFactory;
-import de.tub.dima.scotty.core.windowFunction.ReduceAggregateFunction;
+import stream.scotty.slicing.state.AggregateState;
+import stream.scotty.state.memory.MemoryStateFactory;
+import stream.scotty.core.windowFunction.ReduceAggregateFunction;
 import org.openjdk.jmh.annotations.*;
 import org.openjdk.jmh.runner.Runner;
 import org.openjdk.jmh.runner.RunnerException;

diff --git a/...hmark/SlicingWindowOperatorBenchmark.java → ...hmark/SlicingWindowOperatorBenchmark.java b/...hmark/SlicingWindowOperatorBenchmark.java → ...hmark/SlicingWindowOperatorBenchmark.java
@@ -1,10 +1,10 @@
-package de.tub.dima.scotty.microbenchmark;
+package stream.scotty.microbenchmark;
 
-import de.tub.dima.scotty.slicing.SlicingWindowOperator;
-import de.tub.dima.scotty.state.memory.MemoryStateFactory;
-import de.tub.dima.scotty.core.windowType.TumblingWindow;
-import de.tub.dima.scotty.core.windowType.WindowMeasure;
-import de.tub.dima.scotty.core.windowFunction.ReduceAggregateFunction;
+import stream.scotty.slicing.SlicingWindowOperator;
+import stream.scotty.state.memory.MemoryStateFactory;
+import stream.scotty.core.windowType.TumblingWindow;
+import stream.scotty.core.windowType.WindowMeasure;
+import stream.scotty.core.windowFunction.ReduceAggregateFunction;
 import org.openjdk.jmh.annotations.*;
 import org.openjdk.jmh.runner.Runner;
 import org.openjdk.jmh.runner.RunnerException;

diff --git a/core/pom.xml b/core/pom.xml
@@ -3,8 +3,8 @@
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <parent>
-        <artifactId>parent</artifactId>
-        <groupId>de.tub.dima.scotty</groupId>
+        <artifactId>scotty</artifactId>
+        <groupId>stream.scotty</groupId>
         <version>0.4</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
@@ -18,11 +18,6 @@
             <version>1.9.2</version>
             <scope>compile</scope>
         </dependency>
-        <dependency>
-            <groupId>org.apache.flink</groupId>
-            <artifactId>flink-core</artifactId>
-            <version>1.9.2</version>
-        </dependency>
     </dependencies>
 
 </project>
diff --git a/core/src/main/java/de/tub/dima/scotty/core/windowType/ForwardContextAware.java b/core/src/main/java/de/tub/dima/scotty/core/windowType/ForwardContextAware.java
diff --git a/core/src/main/java/de/tub/dima/scotty/core/windowType/ForwardContextFree.java b/core/src/main/java/de/tub/dima/scotty/core/windowType/ForwardContextFree.java
diff --git a/core/src/main/java/de/tub/dima/scotty/core/windowType/windowContext/WindowModifications.java b/core/src/main/java/de/tub/dima/scotty/core/windowType/windowContext/WindowModifications.java
diff --git a/...tub/dima/scotty/core/AggregateWindow.java → ...a/stream/scotty/core/AggregateWindow.java b/...tub/dima/scotty/core/AggregateWindow.java → ...a/stream/scotty/core/AggregateWindow.java
@@ -1,6 +1,6 @@
-package de.tub.dima.scotty.core;
+package stream.scotty.core;
 
-import de.tub.dima.scotty.core.windowType.*;
+import stream.scotty.core.windowType.*;
 
 import java.io.*;
 import java.util.List;

diff --git a/.../de/tub/dima/scotty/core/TimeMeasure.java → .../java/stream/scotty/core/TimeMeasure.java b/.../de/tub/dima/scotty/core/TimeMeasure.java → .../java/stream/scotty/core/TimeMeasure.java
@@ -15,7 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package de.tub.dima.scotty.core;
+package stream.scotty.core;
 
 import java.util.concurrent.TimeUnit;
 /**

diff --git a/...tub/dima/scotty/core/WindowCollector.java → ...a/stream/scotty/core/WindowCollector.java b/...tub/dima/scotty/core/WindowCollector.java → ...a/stream/scotty/core/WindowCollector.java
@@ -1,6 +1,6 @@
-package de.tub.dima.scotty.core;
+package stream.scotty.core;
 
-import de.tub.dima.scotty.core.windowType.*;
+import stream.scotty.core.windowType.*;
 
 public interface WindowCollector {
 

diff --git a/.../tub/dima/scotty/core/WindowOperator.java → ...va/stream/scotty/core/WindowOperator.java b/.../tub/dima/scotty/core/WindowOperator.java → ...va/stream/scotty/core/WindowOperator.java
@@ -1,7 +1,7 @@
-package de.tub.dima.scotty.core;
+package stream.scotty.core;
 
-import de.tub.dima.scotty.core.windowType.*;
-import de.tub.dima.scotty.core.windowFunction.AggregateFunction;
+import stream.scotty.core.windowType.*;
+import stream.scotty.core.windowFunction.AggregateFunction;
 
 import java.io.*;
 import java.util.List;

diff --git a/...ore/windowFunction/AggregateFunction.java → ...ore/windowFunction/AggregateFunction.java b/...ore/windowFunction/AggregateFunction.java → ...ore/windowFunction/AggregateFunction.java
@@ -1,4 +1,4 @@
-package de.tub.dima.scotty.core.windowFunction;
+package stream.scotty.core.windowFunction;
 
 
 import java.io.*;

diff --git a/...nction/CloneablePartialStateFunction.java → ...nction/CloneablePartialStateFunction.java b/...nction/CloneablePartialStateFunction.java → ...nction/CloneablePartialStateFunction.java
@@ -1,4 +1,4 @@
-package de.tub.dima.scotty.core.windowFunction;
+package stream.scotty.core.windowFunction;
 
 public interface CloneablePartialStateFunction<PartialAggregateType> {
 

diff --git a/...unction/CommutativeAggregateFunction.java → ...unction/CommutativeAggregateFunction.java b/...unction/CommutativeAggregateFunction.java → ...unction/CommutativeAggregateFunction.java
@@ -1,4 +1,4 @@
-package de.tub.dima.scotty.core.windowFunction;
+package stream.scotty.core.windowFunction;
 
 public interface CommutativeAggregateFunction<InputType, PartialAggregateType, FinalAggregateType> extends AggregateFunction<InputType, PartialAggregateType, FinalAggregateType> {
 }
diff --git a/...Function/InvertibleAggregateFunction.java → ...Function/InvertibleAggregateFunction.java b/...Function/InvertibleAggregateFunction.java → ...Function/InvertibleAggregateFunction.java
@@ -1,4 +1,4 @@
-package de.tub.dima.scotty.core.windowFunction;
+package stream.scotty.core.windowFunction;
 
 public interface InvertibleAggregateFunction<InputType, PartialAggregateType, FinalAggregateType> extends AggregateFunction<InputType, PartialAggregateType, FinalAggregateType> {
     /**

diff --git a/...on/InvertibleReduceAggregateFunction.java → ...on/InvertibleReduceAggregateFunction.java b/...on/InvertibleReduceAggregateFunction.java → ...on/InvertibleReduceAggregateFunction.java
@@ -1,4 +1,4 @@
-package de.tub.dima.scotty.core.windowFunction;
+package stream.scotty.core.windowFunction;
 
 public interface InvertibleReduceAggregateFunction<Input> extends ReduceAggregateFunction<Input>, InvertibleAggregateFunction<Input, Input, Input> {
 

diff --git a/...ndowFunction/ReduceAggregateFunction.java → ...ndowFunction/ReduceAggregateFunction.java b/...ndowFunction/ReduceAggregateFunction.java → ...ndowFunction/ReduceAggregateFunction.java
@@ -1,4 +1,4 @@
-package de.tub.dima.scotty.core.windowFunction;
+package stream.scotty.core.windowFunction;
 
 
 @FunctionalInterface

diff --git a/...ty/core/windowType/ContextFreeWindow.java → ...ty/core/windowType/ContextFreeWindow.java b/...ty/core/windowType/ContextFreeWindow.java → ...ty/core/windowType/ContextFreeWindow.java
@@ -1,7 +1,7 @@
-package de.tub.dima.scotty.core.windowType;
+package stream.scotty.core.windowType;
 
-import de.tub.dima.scotty.core.*;
-import de.tub.dima.scotty.core.*;
+import stream.scotty.core.*;
+import stream.scotty.core.*;
 
 public interface ContextFreeWindow extends Window {
 

diff --git a/...otty/core/windowType/FixedBandWindow.java → ...otty/core/windowType/FixedBandWindow.java b/...otty/core/windowType/FixedBandWindow.java → ...otty/core/windowType/FixedBandWindow.java
@@ -1,6 +1,6 @@
-package de.tub.dima.scotty.core.windowType;
+package stream.scotty.core.windowType;
 
-import de.tub.dima.scotty.core.WindowCollector;
+import stream.scotty.core.WindowCollector;
 
 public class FixedBandWindow implements ContextFreeWindow {
     /**

diff --git a/core/src/main/java/stream/scotty/core/windowType/ForwardContextAware.java b/core/src/main/java/stream/scotty/core/windowType/ForwardContextAware.java
@@ -0,0 +1,9 @@
+package stream.scotty.core.windowType;
+
+import stream.scotty.core.windowType.windowContext.*;
+import stream.scotty.core.windowType.windowContext.*;
+
+public interface ForwardContextAware extends Window {
+
+    WindowContext createContext();
+}
diff --git a/core/src/main/java/stream/scotty/core/windowType/ForwardContextFree.java b/core/src/main/java/stream/scotty/core/windowType/ForwardContextFree.java
@@ -0,0 +1,8 @@
+package stream.scotty.core.windowType;
+
+import stream.scotty.core.windowType.windowContext.*;
+
+public interface ForwardContextFree extends Window {
+
+    WindowContext createContext();
+}