[FLINK-1452] Rename 'flink-addons' to 'flink-staging'

apache · Feb 2, 2015 · f94112f · f94112f
1 parent 563e546
commit f94112f
Show file tree

Hide file tree

Showing 389 changed files with 18 additions and 17 deletions.
diff --git a/docs/internal_add_operator.md b/docs/internal_add_operator.md
@@ -100,7 +100,7 @@ void setInput(DataSet<IN> inputData);
 DataSet<OUT> createResult();
 ~~~
 
-The {% gh_link /flink-addons/flink-spargel/src/main/java/org/apache/flink/spargel/java/VertexCentricIteration.java "VertexCentricIteration" %} operator is implemented that way. Below is an example how to implement the *count()* operator that way.
+The {% gh_link /flink-staging/flink-spargel/src/main/java/org/apache/flink/spargel/java/VertexCentricIteration.java "VertexCentricIteration" %} operator is implemented that way. Below is an example how to implement the *count()* operator that way.
 
 ~~~ java
 public class Counter<T> implements CustomUnaryOperation<T, Long> {

diff --git a/docs/internal_general_arch.md b/docs/internal_general_arch.md
@@ -75,12 +75,13 @@ In addition to the projects listed in the figure above, Flink currently contains
 - `flink-dist`: The *distribution* project. It defines how to assemble the compiled code, scripts, and other resources
 into the final folder structure that is ready to use.
 
-- `flink-addons`: A series of projects that are in an early version. Currently contains
+- `flink-staging`: A series of projects that are in an early version. Currently contains
 among other things projects for YARN support, JDBC data sources and sinks, hadoop compatibility,
 graph specific operators, and HBase connectors.
 
 - `flink-quickstart`: Scripts, maven archetypes, and example programs for the quickstarts and tutorials.
 
+- `flink-contrib`: Useful tools contributed by users. The code is maintained mainly by external contributors. The requirements for code being accepted into `flink-contrib` are lower compared to the rest of the code.
 
 
 

diff --git a/docs/streaming_guide.md b/docs/streaming_guide.md
@@ -857,7 +857,7 @@ After installing Docker an image can be pulled for each connector. Containers ca
 For the easiest set up create a jar with all the dependencies of the *flink-streaming-connectors* project.
 
 ~~~batch
-cd /PATH/TO/GIT/incubator-flink/flink-addons/flink-streaming-connectors
+cd /PATH/TO/GIT/flink/flink-staging/flink-streaming-connectors
 mvn assembly:assembly
 ~~~batch
 
@@ -974,14 +974,14 @@ Now a terminal started running from the image with all the necessary configurati
 
 To have the latest version of Flink type:
 ~~~batch
-cd /git/incubator-flink/
+cd /git/flink/
 git pull
 ~~~
 
 Then build the code with:
 
 ~~~batch
-cd /git/incubator-flink/flink-addons/flink-streaming/flink-streaming-connectors/
+cd /git/flink/flink-staging/flink-streaming/flink-streaming-connectors/
 mvn install -DskipTests
 ~~~
 

diff --git a/flink-addons/flink-avro/pom.xml → flink-staging/flink-avro/pom.xml b/flink-addons/flink-avro/pom.xml → flink-staging/flink-avro/pom.xml
@@ -25,7 +25,7 @@ under the License.
 
 	<parent>
 		<groupId>org.apache.flink</groupId>
-		<artifactId>flink-addons</artifactId>
+		<artifactId>flink-staging</artifactId>
 		<version>0.9-SNAPSHOT</version>
 		<relativePath>..</relativePath>
 	</parent>

diff --git a/...ache/flink/api/avro/DataInputDecoder.java → ...ache/flink/api/avro/DataInputDecoder.java b/...ache/flink/api/avro/DataInputDecoder.java → ...ache/flink/api/avro/DataInputDecoder.java
diff --git a/...che/flink/api/avro/DataOutputEncoder.java → ...che/flink/api/avro/DataOutputEncoder.java b/...che/flink/api/avro/DataOutputEncoder.java → ...che/flink/api/avro/DataOutputEncoder.java
diff --git a/...nk/api/avro/FSDataInputStreamWrapper.java → ...nk/api/avro/FSDataInputStreamWrapper.java b/...nk/api/avro/FSDataInputStreamWrapper.java → ...nk/api/avro/FSDataInputStreamWrapper.java
diff --git a/.../api/io/avro/example/AvroTypeExample.java → .../api/io/avro/example/AvroTypeExample.java b/.../api/io/avro/example/AvroTypeExample.java → .../api/io/avro/example/AvroTypeExample.java
diff --git a/...pache/flink/api/io/avro/example/User.java → ...pache/flink/api/io/avro/example/User.java b/...pache/flink/api/io/avro/example/User.java → ...pache/flink/api/io/avro/example/User.java
diff --git a/...he/flink/api/java/io/AvroInputFormat.java → ...he/flink/api/java/io/AvroInputFormat.java b/...he/flink/api/java/io/AvroInputFormat.java → ...he/flink/api/java/io/AvroInputFormat.java
diff --git a/...e/flink/api/java/io/AvroOutputFormat.java → ...e/flink/api/java/io/AvroOutputFormat.java b/...e/flink/api/java/io/AvroOutputFormat.java → ...e/flink/api/java/io/AvroOutputFormat.java
diff --git a/...-avro/src/test/assembly/test-assembly.xml → ...-avro/src/test/assembly/test-assembly.xml b/...-avro/src/test/assembly/test-assembly.xml → ...-avro/src/test/assembly/test-assembly.xml
diff --git a/...pi/avro/AvroExternalJarProgramITCase.java → ...pi/avro/AvroExternalJarProgramITCase.java b/...pi/avro/AvroExternalJarProgramITCase.java → ...pi/avro/AvroExternalJarProgramITCase.java
diff --git a/.../flink/api/avro/AvroOutputFormatTest.java → .../flink/api/avro/AvroOutputFormatTest.java b/.../flink/api/avro/AvroOutputFormatTest.java → .../flink/api/avro/AvroOutputFormatTest.java
diff --git a/...he/flink/api/avro/EncoderDecoderTest.java → ...he/flink/api/avro/EncoderDecoderTest.java b/...he/flink/api/avro/EncoderDecoderTest.java → ...he/flink/api/avro/EncoderDecoderTest.java
diff --git a/.../avro/testjar/AvroExternalJarProgram.java → .../avro/testjar/AvroExternalJarProgram.java b/.../avro/testjar/AvroExternalJarProgram.java → .../avro/testjar/AvroExternalJarProgram.java
diff --git a/...pi/io/avro/AvroRecordInputFormatTest.java → ...pi/io/avro/AvroRecordInputFormatTest.java b/...pi/io/avro/AvroRecordInputFormatTest.java → ...pi/io/avro/AvroRecordInputFormatTest.java
diff --git a/...e/flink/api/io/avro/generated/Colors.java → ...e/flink/api/io/avro/generated/Colors.java b/...e/flink/api/io/avro/generated/Colors.java → ...e/flink/api/io/avro/generated/Colors.java
diff --git a/...che/flink/api/io/avro/generated/User.java → ...che/flink/api/io/avro/generated/User.java b/...che/flink/api/io/avro/generated/User.java → ...che/flink/api/io/avro/generated/User.java
diff --git a/...io/AvroInputFormatTypeExtractionTest.java → ...io/AvroInputFormatTypeExtractionTest.java b/...io/AvroInputFormatTypeExtractionTest.java → ...io/AvroInputFormatTypeExtractionTest.java
diff --git a/...nk-avro/src/test/resources/avro/user.avsc → ...nk-avro/src/test/resources/avro/user.avsc b/...nk-avro/src/test/resources/avro/user.avsc → ...nk-avro/src/test/resources/avro/user.avsc
diff --git a/.../src/test/resources/log4j-test.properties → .../src/test/resources/log4j-test.properties b/.../src/test/resources/log4j-test.properties → .../src/test/resources/log4j-test.properties
diff --git a/...-avro/src/test/resources/logback-test.xml → ...-avro/src/test/resources/logback-test.xml b/...-avro/src/test/resources/logback-test.xml → ...-avro/src/test/resources/logback-test.xml
diff --git a/...ink-avro/src/test/resources/testdata.avro → ...ink-avro/src/test/resources/testdata.avro b/...ink-avro/src/test/resources/testdata.avro → ...ink-avro/src/test/resources/testdata.avro
diff --git a/...addons/flink-hadoop-compatibility/pom.xml → ...taging/flink-hadoop-compatibility/pom.xml b/...addons/flink-hadoop-compatibility/pom.xml → ...taging/flink-hadoop-compatibility/pom.xml
@@ -24,7 +24,7 @@ under the License.
 
 	<parent>
 		<groupId>org.apache.flink</groupId>
-		<artifactId>flink-addons</artifactId>
+		<artifactId>flink-staging</artifactId>
 		<version>0.9-SNAPSHOT</version>
 		<relativePath>..</relativePath>
 	</parent>

diff --git a/...mpatibility/mapred/HadoopInputFormat.java → ...mpatibility/mapred/HadoopInputFormat.java b/...mpatibility/mapred/HadoopInputFormat.java → ...mpatibility/mapred/HadoopInputFormat.java
diff --git a/...mpatibility/mapred/HadoopMapFunction.java → ...mpatibility/mapred/HadoopMapFunction.java b/...mpatibility/mapred/HadoopMapFunction.java → ...mpatibility/mapred/HadoopMapFunction.java
diff --git a/...patibility/mapred/HadoopOutputFormat.java → ...patibility/mapred/HadoopOutputFormat.java b/...patibility/mapred/HadoopOutputFormat.java → ...patibility/mapred/HadoopOutputFormat.java
diff --git a/...y/mapred/HadoopReduceCombineFunction.java → ...y/mapred/HadoopReduceCombineFunction.java b/...y/mapred/HadoopReduceCombineFunction.java → ...y/mapred/HadoopReduceCombineFunction.java
diff --git a/...tibility/mapred/HadoopReduceFunction.java → ...tibility/mapred/HadoopReduceFunction.java b/...tibility/mapred/HadoopReduceFunction.java → ...tibility/mapred/HadoopReduceFunction.java
diff --git a/.../example/HadoopMapredCompatWordCount.java → .../example/HadoopMapredCompatWordCount.java b/.../example/HadoopMapredCompatWordCount.java → .../example/HadoopMapredCompatWordCount.java
diff --git a/...ibility/mapred/record/HadoopDataSink.java → ...ibility/mapred/record/HadoopDataSink.java b/...ibility/mapred/record/HadoopDataSink.java → ...ibility/mapred/record/HadoopDataSink.java
diff --git a/...ility/mapred/record/HadoopDataSource.java → ...ility/mapred/record/HadoopDataSource.java b/...ility/mapred/record/HadoopDataSource.java → ...ility/mapred/record/HadoopDataSource.java
diff --git a/...apred/record/HadoopRecordInputFormat.java → ...apred/record/HadoopRecordInputFormat.java b/...apred/record/HadoopRecordInputFormat.java → ...apred/record/HadoopRecordInputFormat.java
diff --git a/...pred/record/HadoopRecordOutputFormat.java → ...pred/record/HadoopRecordOutputFormat.java b/...pred/record/HadoopRecordOutputFormat.java → ...pred/record/HadoopRecordOutputFormat.java
diff --git a/.../datatypes/DefaultFlinkTypeConverter.java → .../datatypes/DefaultFlinkTypeConverter.java b/.../datatypes/DefaultFlinkTypeConverter.java → .../datatypes/DefaultFlinkTypeConverter.java
diff --git a/...datatypes/DefaultHadoopTypeConverter.java → ...datatypes/DefaultHadoopTypeConverter.java b/...datatypes/DefaultHadoopTypeConverter.java → ...datatypes/DefaultHadoopTypeConverter.java
diff --git a/.../record/datatypes/FlinkTypeConverter.java → .../record/datatypes/FlinkTypeConverter.java b/.../record/datatypes/FlinkTypeConverter.java → .../record/datatypes/FlinkTypeConverter.java
diff --git a/.../datatypes/HadoopFileOutputCommitter.java → .../datatypes/HadoopFileOutputCommitter.java b/.../datatypes/HadoopFileOutputCommitter.java → .../datatypes/HadoopFileOutputCommitter.java
diff --git a/...record/datatypes/HadoopTypeConverter.java → ...record/datatypes/HadoopTypeConverter.java b/...record/datatypes/HadoopTypeConverter.java → ...record/datatypes/HadoopTypeConverter.java
diff --git a/.../datatypes/WritableComparableWrapper.java → .../datatypes/WritableComparableWrapper.java b/.../datatypes/WritableComparableWrapper.java → .../datatypes/WritableComparableWrapper.java
diff --git a/...red/record/datatypes/WritableWrapper.java → ...red/record/datatypes/WritableWrapper.java b/...red/record/datatypes/WritableWrapper.java → ...red/record/datatypes/WritableWrapper.java
diff --git a/...d/datatypes/WritableWrapperConverter.java → ...d/datatypes/WritableWrapperConverter.java b/...d/datatypes/WritableWrapperConverter.java → ...d/datatypes/WritableWrapperConverter.java
diff --git a/...lity/mapred/record/example/WordCount.java → ...lity/mapred/record/example/WordCount.java b/...lity/mapred/record/example/WordCount.java → ...lity/mapred/record/example/WordCount.java
diff --git a/...rd/example/WordCountWithOutputFormat.java → ...rd/example/WordCountWithOutputFormat.java b/...rd/example/WordCountWithOutputFormat.java → ...rd/example/WordCountWithOutputFormat.java
diff --git a/...mpatibility/mapred/utils/HadoopUtils.java → ...mpatibility/mapred/utils/HadoopUtils.java b/...mpatibility/mapred/utils/HadoopUtils.java → ...mpatibility/mapred/utils/HadoopUtils.java
diff --git a/...pred/wrapper/HadoopDummyProgressable.java → ...pred/wrapper/HadoopDummyProgressable.java b/...pred/wrapper/HadoopDummyProgressable.java → ...pred/wrapper/HadoopDummyProgressable.java
diff --git a/...y/mapred/wrapper/HadoopDummyReporter.java → ...y/mapred/wrapper/HadoopDummyReporter.java b/...y/mapred/wrapper/HadoopDummyReporter.java → ...y/mapred/wrapper/HadoopDummyReporter.java
diff --git a/...lity/mapred/wrapper/HadoopInputSplit.java → ...lity/mapred/wrapper/HadoopInputSplit.java b/...lity/mapred/wrapper/HadoopInputSplit.java → ...lity/mapred/wrapper/HadoopInputSplit.java
diff --git a/...mapred/wrapper/HadoopOutputCollector.java → ...mapred/wrapper/HadoopOutputCollector.java b/...mapred/wrapper/HadoopOutputCollector.java → ...mapred/wrapper/HadoopOutputCollector.java
diff --git a/...rapper/HadoopTupleUnwrappingIterator.java → ...rapper/HadoopTupleUnwrappingIterator.java b/...rapper/HadoopTupleUnwrappingIterator.java → ...rapper/HadoopTupleUnwrappingIterator.java
diff --git a/...tibility/mapreduce/HadoopInputFormat.java → ...tibility/mapreduce/HadoopInputFormat.java b/...tibility/mapreduce/HadoopInputFormat.java → ...tibility/mapreduce/HadoopInputFormat.java
diff --git a/...ibility/mapreduce/HadoopOutputFormat.java → ...ibility/mapreduce/HadoopOutputFormat.java b/...ibility/mapreduce/HadoopOutputFormat.java → ...ibility/mapreduce/HadoopOutputFormat.java
diff --git a/...tibility/mapreduce/example/WordCount.java → ...tibility/mapreduce/example/WordCount.java b/...tibility/mapreduce/example/WordCount.java → ...tibility/mapreduce/example/WordCount.java
diff --git a/...tibility/mapreduce/utils/HadoopUtils.java → ...tibility/mapreduce/utils/HadoopUtils.java b/...tibility/mapreduce/utils/HadoopUtils.java → ...tibility/mapreduce/utils/HadoopUtils.java
diff --git a/...y/mapreduce/wrapper/HadoopInputSplit.java → ...y/mapreduce/wrapper/HadoopInputSplit.java b/...y/mapreduce/wrapper/HadoopInputSplit.java → ...y/mapreduce/wrapper/HadoopInputSplit.java
diff --git a/...ibility/mapred/HadoopIOFormatsITCase.java → ...ibility/mapred/HadoopIOFormatsITCase.java b/...ibility/mapred/HadoopIOFormatsITCase.java → ...ibility/mapred/HadoopIOFormatsITCase.java
diff --git a/...ibility/mapred/HadoopInputFormatTest.java → ...ibility/mapred/HadoopInputFormatTest.java b/...ibility/mapred/HadoopInputFormatTest.java → ...ibility/mapred/HadoopInputFormatTest.java
diff --git a/...ility/mapred/HadoopMapFunctionITCase.java → ...ility/mapred/HadoopMapFunctionITCase.java b/...ility/mapred/HadoopMapFunctionITCase.java → ...ility/mapred/HadoopMapFunctionITCase.java
diff --git a/...patibility/mapred/HadoopMapredITCase.java → ...patibility/mapred/HadoopMapredITCase.java b/...patibility/mapred/HadoopMapredITCase.java → ...patibility/mapred/HadoopMapredITCase.java
diff --git a/...ed/HadoopReduceCombineFunctionITCase.java → ...ed/HadoopReduceCombineFunctionITCase.java b/...ed/HadoopReduceCombineFunctionITCase.java → ...ed/HadoopReduceCombineFunctionITCase.java
diff --git a/...ty/mapred/HadoopReduceFunctionITCase.java → ...ty/mapred/HadoopReduceFunctionITCase.java b/...ty/mapred/HadoopReduceFunctionITCase.java → ...ty/mapred/HadoopReduceFunctionITCase.java
diff --git a/...pcompatibility/mapred/HadoopTestData.java → ...pcompatibility/mapred/HadoopTestData.java b/...pcompatibility/mapred/HadoopTestData.java → ...pcompatibility/mapred/HadoopTestData.java
diff --git a/...record/HadoopRecordInputOutputITCase.java → ...record/HadoopRecordInputOutputITCase.java b/...record/HadoopRecordInputOutputITCase.java → ...record/HadoopRecordInputOutputITCase.java
diff --git a/...er/HadoopTupleUnwrappingIteratorTest.java → ...er/HadoopTupleUnwrappingIteratorTest.java b/...er/HadoopTupleUnwrappingIteratorTest.java → ...er/HadoopTupleUnwrappingIteratorTest.java
diff --git a/...lity/mapreduce/HadoopInputFormatTest.java → ...lity/mapreduce/HadoopInputFormatTest.java b/...lity/mapreduce/HadoopInputFormatTest.java → ...lity/mapreduce/HadoopInputFormatTest.java
diff --git a/...ty/mapreduce/HadoopInputOutputITCase.java → ...ty/mapreduce/HadoopInputOutputITCase.java b/...ty/mapreduce/HadoopInputOutputITCase.java → ...ty/mapreduce/HadoopInputOutputITCase.java
diff --git a/.../src/test/resources/log4j-test.properties → .../src/test/resources/log4j-test.properties b/.../src/test/resources/log4j-test.properties → .../src/test/resources/log4j-test.properties
diff --git a/...ility/src/test/resources/logback-test.xml → ...ility/src/test/resources/logback-test.xml b/...ility/src/test/resources/logback-test.xml → ...ility/src/test/resources/logback-test.xml
diff --git a/flink-addons/flink-hbase/pom.xml → flink-staging/flink-hbase/pom.xml b/flink-addons/flink-hbase/pom.xml → flink-staging/flink-hbase/pom.xml
@@ -24,7 +24,7 @@ under the License.
 
 	<parent>
 		<groupId>org.apache.flink</groupId>
-		<artifactId>flink-addons</artifactId>
+		<artifactId>flink-staging</artifactId>
 		<version>0.9-SNAPSHOT</version>
 		<relativePath>..</relativePath>
 	</parent>

diff --git a/.../flink/addons/hbase/TableInputFormat.java → .../flink/addons/hbase/TableInputFormat.java b/.../flink/addons/hbase/TableInputFormat.java → .../flink/addons/hbase/TableInputFormat.java
diff --git a/...e/flink/addons/hbase/TableInputSplit.java → ...e/flink/addons/hbase/TableInputSplit.java b/...e/flink/addons/hbase/TableInputSplit.java → ...e/flink/addons/hbase/TableInputSplit.java
diff --git a/...ddons/hbase/example/HBaseReadExample.java → ...ddons/hbase/example/HBaseReadExample.java b/...ddons/hbase/example/HBaseReadExample.java → ...ddons/hbase/example/HBaseReadExample.java
diff --git a/...k-hbase/src/test/resources/hbase-site.xml → ...k-hbase/src/test/resources/hbase-site.xml b/...k-hbase/src/test/resources/hbase-site.xml → ...k-hbase/src/test/resources/hbase-site.xml
diff --git a/...hbase/src/test/resources/log4j.properties → ...hbase/src/test/resources/log4j.properties b/...hbase/src/test/resources/log4j.properties → ...hbase/src/test/resources/log4j.properties
diff --git a/flink-addons/flink-jdbc/pom.xml → flink-staging/flink-jdbc/pom.xml b/flink-addons/flink-jdbc/pom.xml → flink-staging/flink-jdbc/pom.xml
@@ -25,7 +25,7 @@ under the License.
 
 	<parent>
 		<groupId>org.apache.flink</groupId>
-		<artifactId>flink-addons</artifactId>
+		<artifactId>flink-staging</artifactId>
 		<version>0.9-SNAPSHOT</version>
 		<relativePath>..</relativePath>
 	</parent>

diff --git a/...ink/api/java/io/jdbc/JDBCInputFormat.java → ...ink/api/java/io/jdbc/JDBCInputFormat.java b/...ink/api/java/io/jdbc/JDBCInputFormat.java → ...ink/api/java/io/jdbc/JDBCInputFormat.java
diff --git a/...nk/api/java/io/jdbc/JDBCOutputFormat.java → ...nk/api/java/io/jdbc/JDBCOutputFormat.java b/...nk/api/java/io/jdbc/JDBCOutputFormat.java → ...nk/api/java/io/jdbc/JDBCOutputFormat.java
diff --git a/...api/java/io/jdbc/example/JDBCExample.java → ...api/java/io/jdbc/example/JDBCExample.java b/...api/java/io/jdbc/example/JDBCExample.java → ...api/java/io/jdbc/example/JDBCExample.java
diff --git a/.../java/record/io/jdbc/JDBCInputFormat.java → .../java/record/io/jdbc/JDBCInputFormat.java b/.../java/record/io/jdbc/JDBCInputFormat.java → .../java/record/io/jdbc/JDBCInputFormat.java
diff --git a/...java/record/io/jdbc/JDBCOutputFormat.java → ...java/record/io/jdbc/JDBCOutputFormat.java b/...java/record/io/jdbc/JDBCOutputFormat.java → ...java/record/io/jdbc/JDBCOutputFormat.java
diff --git a/...a/record/io/jdbc/example/JDBCExample.java → ...a/record/io/jdbc/example/JDBCExample.java b/...a/record/io/jdbc/example/JDBCExample.java → ...a/record/io/jdbc/example/JDBCExample.java
diff --git a/...api/java/io/jdbc/JDBCInputFormatTest.java → ...api/java/io/jdbc/JDBCInputFormatTest.java b/...api/java/io/jdbc/JDBCInputFormatTest.java → ...api/java/io/jdbc/JDBCInputFormatTest.java
diff --git a/...pi/java/io/jdbc/JDBCOutputFormatTest.java → ...pi/java/io/jdbc/JDBCOutputFormatTest.java b/...pi/java/io/jdbc/JDBCOutputFormatTest.java → ...pi/java/io/jdbc/JDBCOutputFormatTest.java
diff --git a/...java/record/io/jdbc/DevNullLogStream.java → ...java/record/io/jdbc/DevNullLogStream.java b/...java/record/io/jdbc/DevNullLogStream.java → ...java/record/io/jdbc/DevNullLogStream.java
diff --git a/...a/record/io/jdbc/JDBCInputFormatTest.java → ...a/record/io/jdbc/JDBCInputFormatTest.java b/...a/record/io/jdbc/JDBCInputFormatTest.java → ...a/record/io/jdbc/JDBCInputFormatTest.java
diff --git a/.../record/io/jdbc/JDBCOutputFormatTest.java → .../record/io/jdbc/JDBCOutputFormatTest.java b/.../record/io/jdbc/JDBCOutputFormatTest.java → .../record/io/jdbc/JDBCOutputFormatTest.java
diff --git a/.../src/test/resources/log4j-test.properties → .../src/test/resources/log4j-test.properties b/.../src/test/resources/log4j-test.properties → .../src/test/resources/log4j-test.properties
diff --git a/...-jdbc/src/test/resources/logback-test.xml → ...-jdbc/src/test/resources/logback-test.xml b/...-jdbc/src/test/resources/logback-test.xml → ...-jdbc/src/test/resources/logback-test.xml
diff --git a/flink-addons/flink-spargel/pom.xml → flink-staging/flink-spargel/pom.xml b/flink-addons/flink-spargel/pom.xml → flink-staging/flink-spargel/pom.xml
@@ -24,7 +24,7 @@ under the License.
 
 	<parent>
 		<groupId>org.apache.flink</groupId>
-		<artifactId>flink-addons</artifactId>
+		<artifactId>flink-staging</artifactId>
 		<version>0.9-SNAPSHOT</version>
 		<relativePath>..</relativePath>
 	</parent>

diff --git a/...e/flink/spargel/java/MessageIterator.java → ...e/flink/spargel/java/MessageIterator.java b/...e/flink/spargel/java/MessageIterator.java → ...e/flink/spargel/java/MessageIterator.java
diff --git a/...flink/spargel/java/MessagingFunction.java → ...flink/spargel/java/MessagingFunction.java b/...flink/spargel/java/MessagingFunction.java → ...flink/spargel/java/MessagingFunction.java
diff --git a/...ache/flink/spargel/java/OutgoingEdge.java → ...ache/flink/spargel/java/OutgoingEdge.java b/...ache/flink/spargel/java/OutgoingEdge.java → ...ache/flink/spargel/java/OutgoingEdge.java
diff --git a/.../spargel/java/VertexCentricIteration.java → .../spargel/java/VertexCentricIteration.java b/.../spargel/java/VertexCentricIteration.java → .../spargel/java/VertexCentricIteration.java
diff --git a/...nk/spargel/java/VertexUpdateFunction.java → ...nk/spargel/java/VertexUpdateFunction.java b/...nk/spargel/java/VertexUpdateFunction.java → ...nk/spargel/java/VertexUpdateFunction.java
diff --git a/.../examples/SpargelConnectedComponents.java → .../examples/SpargelConnectedComponents.java b/.../examples/SpargelConnectedComponents.java → .../examples/SpargelConnectedComponents.java
diff --git a/...pargel/java/examples/SpargelPageRank.java → ...pargel/java/examples/SpargelPageRank.java b/...pargel/java/examples/SpargelPageRank.java → ...pargel/java/examples/SpargelPageRank.java
diff --git a/...ples/SpargelPageRankCountingVertices.java → ...ples/SpargelPageRankCountingVertices.java b/...ples/SpargelPageRankCountingVertices.java → ...ples/SpargelPageRankCountingVertices.java
diff --git a/...pache/flink/spargel/java/record/Edge.java → ...pache/flink/spargel/java/record/Edge.java b/...pache/flink/spargel/java/record/Edge.java → ...pache/flink/spargel/java/record/Edge.java
diff --git a/.../spargel/java/record/MessageIterator.java → .../spargel/java/record/MessageIterator.java b/.../spargel/java/record/MessageIterator.java → .../spargel/java/record/MessageIterator.java
diff --git a/...pargel/java/record/MessagingFunction.java → ...pargel/java/record/MessagingFunction.java b/...pargel/java/record/MessagingFunction.java → ...pargel/java/record/MessagingFunction.java
diff --git a/...spargel/java/record/SpargelIteration.java → ...spargel/java/record/SpargelIteration.java b/...spargel/java/record/SpargelIteration.java → ...spargel/java/record/SpargelIteration.java
diff --git a/...gel/java/record/VertexUpdateFunction.java → ...gel/java/record/VertexUpdateFunction.java b/...gel/java/record/VertexUpdateFunction.java → ...gel/java/record/VertexUpdateFunction.java
diff --git a/...ink/spargel/java/SpargelCompilerTest.java → ...ink/spargel/java/SpargelCompilerTest.java b/...ink/spargel/java/SpargelCompilerTest.java → ...ink/spargel/java/SpargelCompilerTest.java
diff --git a/.../spargel/java/SpargelTranslationTest.java → .../spargel/java/SpargelTranslationTest.java b/.../spargel/java/SpargelTranslationTest.java → .../spargel/java/SpargelTranslationTest.java
diff --git a/...gel/SpargelConnectedComponentsITCase.java → ...gel/SpargelConnectedComponentsITCase.java b/...gel/SpargelConnectedComponentsITCase.java → ...gel/SpargelConnectedComponentsITCase.java
diff --git a/.../src/test/resources/log4j-test.properties → .../src/test/resources/log4j-test.properties b/.../src/test/resources/log4j-test.properties → .../src/test/resources/log4j-test.properties
diff --git a/...argel/src/test/resources/logback-test.xml → ...argel/src/test/resources/logback-test.xml b/...argel/src/test/resources/logback-test.xml → ...argel/src/test/resources/logback-test.xml
diff --git a/...eaming/flink-streaming-connectors/pom.xml → ...eaming/flink-streaming-connectors/pom.xml b/...eaming/flink-streaming-connectors/pom.xml → ...eaming/flink-streaming-connectors/pom.xml
diff --git a/...streaming/connectors/ConnectorSource.java → ...streaming/connectors/ConnectorSource.java b/...streaming/connectors/ConnectorSource.java → ...streaming/connectors/ConnectorSource.java
diff --git a/...ectors/db/CustomSerializationDBState.java → ...ectors/db/CustomSerializationDBState.java b/...ectors/db/CustomSerializationDBState.java → ...ectors/db/CustomSerializationDBState.java
diff --git a/...streaming/connectors/db/DBSerializer.java → ...streaming/connectors/db/DBSerializer.java b/...streaming/connectors/db/DBSerializer.java → ...streaming/connectors/db/DBSerializer.java
diff --git a/...link/streaming/connectors/db/DBState.java → ...link/streaming/connectors/db/DBState.java b/...link/streaming/connectors/db/DBState.java → ...link/streaming/connectors/db/DBState.java
diff --git a/...eaming/connectors/db/DBStateIterator.java → ...eaming/connectors/db/DBStateIterator.java b/...eaming/connectors/db/DBStateIterator.java → ...eaming/connectors/db/DBStateIterator.java
diff --git a/...ng/connectors/db/DBStateWithIterator.java → ...ng/connectors/db/DBStateWithIterator.java b/...ng/connectors/db/DBStateWithIterator.java → ...ng/connectors/db/DBStateWithIterator.java
diff --git a/...ng/connectors/db/DefaultDBSerializer.java → ...ng/connectors/db/DefaultDBSerializer.java b/...ng/connectors/db/DefaultDBSerializer.java → ...ng/connectors/db/DefaultDBSerializer.java
diff --git a/...streaming/connectors/db/LevelDBState.java → ...streaming/connectors/db/LevelDBState.java b/...streaming/connectors/db/LevelDBState.java → ...streaming/connectors/db/LevelDBState.java
diff --git a/...reaming/connectors/db/MemcachedState.java → ...reaming/connectors/db/MemcachedState.java b/...reaming/connectors/db/MemcachedState.java → ...reaming/connectors/db/MemcachedState.java
diff --git a/...k/streaming/connectors/db/RedisState.java → ...k/streaming/connectors/db/RedisState.java b/...k/streaming/connectors/db/RedisState.java → ...k/streaming/connectors/db/RedisState.java
diff --git a/...streaming/connectors/flume/FlumeSink.java → ...streaming/connectors/flume/FlumeSink.java b/...streaming/connectors/flume/FlumeSink.java → ...streaming/connectors/flume/FlumeSink.java
diff --git a/...reaming/connectors/flume/FlumeSource.java → ...reaming/connectors/flume/FlumeSource.java b/...reaming/connectors/flume/FlumeSource.java → ...reaming/connectors/flume/FlumeSource.java
diff --git a/...aming/connectors/flume/FlumeTopology.java → ...aming/connectors/flume/FlumeTopology.java b/...aming/connectors/flume/FlumeTopology.java → ...aming/connectors/flume/FlumeTopology.java
diff --git a/...ing/connectors/json/JSONParseFlatMap.java → ...ing/connectors/json/JSONParseFlatMap.java b/...ing/connectors/json/JSONParseFlatMap.java → ...ing/connectors/json/JSONParseFlatMap.java
diff --git a/...streaming/connectors/json/JSONParser.java → ...streaming/connectors/json/JSONParser.java b/...streaming/connectors/json/JSONParser.java → ...streaming/connectors/json/JSONParser.java
diff --git a/...streaming/connectors/kafka/KafkaSink.java → ...streaming/connectors/kafka/KafkaSink.java b/...streaming/connectors/kafka/KafkaSink.java → ...streaming/connectors/kafka/KafkaSink.java
diff --git a/...reaming/connectors/kafka/KafkaSource.java → ...reaming/connectors/kafka/KafkaSource.java b/...reaming/connectors/kafka/KafkaSource.java → ...reaming/connectors/kafka/KafkaSource.java
diff --git a/...aming/connectors/kafka/KafkaTopology.java → ...aming/connectors/kafka/KafkaTopology.java b/...aming/connectors/kafka/KafkaTopology.java → ...aming/connectors/kafka/KafkaTopology.java
diff --git a/...treaming/connectors/rabbitmq/RMQSink.java → ...treaming/connectors/rabbitmq/RMQSink.java b/...treaming/connectors/rabbitmq/RMQSink.java → ...treaming/connectors/rabbitmq/RMQSink.java
diff --git a/...eaming/connectors/rabbitmq/RMQSource.java → ...eaming/connectors/rabbitmq/RMQSource.java b/...eaming/connectors/rabbitmq/RMQSource.java → ...eaming/connectors/rabbitmq/RMQSource.java
diff --git a/...ming/connectors/rabbitmq/RMQTopology.java → ...ming/connectors/rabbitmq/RMQTopology.java b/...ming/connectors/rabbitmq/RMQTopology.java → ...ming/connectors/rabbitmq/RMQTopology.java
diff --git a/...ing/connectors/twitter/TwitterSource.java → ...ing/connectors/twitter/TwitterSource.java b/...ing/connectors/twitter/TwitterSource.java → ...ing/connectors/twitter/TwitterSource.java
diff --git a/.../connectors/twitter/TwitterStreaming.java → .../connectors/twitter/TwitterStreaming.java b/.../connectors/twitter/TwitterStreaming.java → .../connectors/twitter/TwitterStreaming.java
diff --git a/...g/connectors/twitter/TwitterTopology.java → ...g/connectors/twitter/TwitterTopology.java b/...g/connectors/twitter/TwitterTopology.java → ...g/connectors/twitter/TwitterTopology.java
diff --git a/...onnectors/util/DeserializationSchema.java → ...onnectors/util/DeserializationSchema.java b/...onnectors/util/DeserializationSchema.java → ...onnectors/util/DeserializationSchema.java
diff --git a/.../streaming/connectors/util/RawSchema.java → .../streaming/connectors/util/RawSchema.java b/.../streaming/connectors/util/RawSchema.java → .../streaming/connectors/util/RawSchema.java
diff --git a/.../connectors/util/SerializationSchema.java → .../connectors/util/SerializationSchema.java b/.../connectors/util/SerializationSchema.java → .../connectors/util/SerializationSchema.java
diff --git a/...g/connectors/util/SimpleStringSchema.java → ...g/connectors/util/SimpleStringSchema.java b/...g/connectors/util/SimpleStringSchema.java → ...g/connectors/util/SimpleStringSchema.java
diff --git a/.../streaming/connectors/db/DBStateTest.java → .../streaming/connectors/db/DBStateTest.java b/.../streaming/connectors/db/DBStateTest.java → .../streaming/connectors/db/DBStateTest.java
diff --git a/...aming/connectors/json/JSONParserTest.java → ...aming/connectors/json/JSONParserTest.java b/...aming/connectors/json/JSONParserTest.java → ...aming/connectors/json/JSONParserTest.java
diff --git a/...ming/connectors/json/JSONParserTest2.java → ...ming/connectors/json/JSONParserTest2.java b/...ming/connectors/json/JSONParserTest2.java → ...ming/connectors/json/JSONParserTest2.java
diff --git a/.../src/test/resources/log4j-test.properties → .../src/test/resources/log4j-test.properties b/.../src/test/resources/log4j-test.properties → .../src/test/resources/log4j-test.properties
diff --git a/...ctors/src/test/resources/logback-test.xml → ...ctors/src/test/resources/logback-test.xml b/...ctors/src/test/resources/logback-test.xml → ...ctors/src/test/resources/logback-test.xml
diff --git a/...nk-streaming/flink-streaming-core/pom.xml → ...nk-streaming/flink-streaming-core/pom.xml b/...nk-streaming/flink-streaming-core/pom.xml → ...nk-streaming/flink-streaming-core/pom.xml
diff --git a/...che/flink/streaming/api/StreamConfig.java → ...che/flink/streaming/api/StreamConfig.java b/...che/flink/streaming/api/StreamConfig.java → ...che/flink/streaming/api/StreamConfig.java
diff --git a/...ache/flink/streaming/api/StreamGraph.java → ...ache/flink/streaming/api/StreamGraph.java b/...ache/flink/streaming/api/StreamGraph.java → ...ache/flink/streaming/api/StreamGraph.java
diff --git a/...aming/api/StreamingJobGraphGenerator.java → ...aming/api/StreamingJobGraphGenerator.java b/...aming/api/StreamingJobGraphGenerator.java → ...aming/api/StreamingJobGraphGenerator.java
diff --git a/...aming/api/collector/CollectorWrapper.java → ...aming/api/collector/CollectorWrapper.java b/...aming/api/collector/CollectorWrapper.java → ...aming/api/collector/CollectorWrapper.java
diff --git a/...i/collector/DirectedCollectorWrapper.java → ...i/collector/DirectedCollectorWrapper.java b/...i/collector/DirectedCollectorWrapper.java → ...i/collector/DirectedCollectorWrapper.java
diff --git a/...reaming/api/collector/OutputSelector.java → ...reaming/api/collector/OutputSelector.java b/...reaming/api/collector/OutputSelector.java → ...reaming/api/collector/OutputSelector.java
diff --git a/...streaming/api/collector/StreamOutput.java → ...streaming/api/collector/StreamOutput.java b/...streaming/api/collector/StreamOutput.java → ...streaming/api/collector/StreamOutput.java
diff --git a/...g/api/datastream/ConnectedDataStream.java → ...g/api/datastream/ConnectedDataStream.java b/...g/api/datastream/ConnectedDataStream.java → ...g/api/datastream/ConnectedDataStream.java
diff --git a/.../streaming/api/datastream/DataStream.java → .../streaming/api/datastream/DataStream.java b/.../streaming/api/datastream/DataStream.java → .../streaming/api/datastream/DataStream.java
diff --git a/...eaming/api/datastream/DataStreamSink.java → ...eaming/api/datastream/DataStreamSink.java b/...eaming/api/datastream/DataStreamSink.java → ...eaming/api/datastream/DataStreamSink.java
diff --git a/...ming/api/datastream/DataStreamSource.java → ...ming/api/datastream/DataStreamSource.java b/...ming/api/datastream/DataStreamSource.java → ...ming/api/datastream/DataStreamSource.java
diff --git a/...ing/api/datastream/GroupedDataStream.java → ...ing/api/datastream/GroupedDataStream.java b/...ing/api/datastream/GroupedDataStream.java → ...ing/api/datastream/GroupedDataStream.java
diff --git a/...g/api/datastream/IterativeDataStream.java → ...g/api/datastream/IterativeDataStream.java b/...g/api/datastream/IterativeDataStream.java → ...g/api/datastream/IterativeDataStream.java
diff --git a/...atastream/SingleOutputStreamOperator.java → ...atastream/SingleOutputStreamOperator.java b/...atastream/SingleOutputStreamOperator.java → ...atastream/SingleOutputStreamOperator.java
diff --git a/...aming/api/datastream/SplitDataStream.java → ...aming/api/datastream/SplitDataStream.java b/...aming/api/datastream/SplitDataStream.java → ...aming/api/datastream/SplitDataStream.java
diff --git a/...ming/api/datastream/StreamProjection.java → ...ming/api/datastream/StreamProjection.java b/...ming/api/datastream/StreamProjection.java → ...ming/api/datastream/StreamProjection.java
diff --git a/...ng/api/datastream/WindowedDataStream.java → ...ng/api/datastream/WindowedDataStream.java b/...ng/api/datastream/WindowedDataStream.java → ...ng/api/datastream/WindowedDataStream.java
diff --git a/...temporaloperator/StreamCrossOperator.java → ...temporaloperator/StreamCrossOperator.java b/...temporaloperator/StreamCrossOperator.java → ...temporaloperator/StreamCrossOperator.java
diff --git a/.../temporaloperator/StreamJoinOperator.java → .../temporaloperator/StreamJoinOperator.java b/.../temporaloperator/StreamJoinOperator.java → .../temporaloperator/StreamJoinOperator.java
diff --git a/...am/temporaloperator/TemporalOperator.java → ...am/temporaloperator/TemporalOperator.java b/...am/temporaloperator/TemporalOperator.java → ...am/temporaloperator/TemporalOperator.java
diff --git a/...ream/temporaloperator/TemporalWindow.java → ...ream/temporaloperator/TemporalWindow.java b/...ream/temporaloperator/TemporalWindow.java → ...ream/temporaloperator/TemporalWindow.java
diff --git a/...i/environment/LocalStreamEnvironment.java → ...i/environment/LocalStreamEnvironment.java b/...i/environment/LocalStreamEnvironment.java → ...i/environment/LocalStreamEnvironment.java
diff --git a/.../environment/RemoteStreamEnvironment.java → .../environment/RemoteStreamEnvironment.java b/.../environment/RemoteStreamEnvironment.java → .../environment/RemoteStreamEnvironment.java
diff --git a/...environment/StreamContextEnvironment.java → ...environment/StreamContextEnvironment.java b/...environment/StreamContextEnvironment.java → ...environment/StreamContextEnvironment.java
diff --git a/...vironment/StreamExecutionEnvironment.java → ...vironment/StreamExecutionEnvironment.java b/...vironment/StreamExecutionEnvironment.java → ...vironment/StreamExecutionEnvironment.java
diff --git a/...pi/environment/StreamPlanEnvironment.java → ...pi/environment/StreamPlanEnvironment.java b/...pi/environment/StreamPlanEnvironment.java → ...pi/environment/StreamPlanEnvironment.java
diff --git a/...tion/aggregation/AggregationFunction.java → ...tion/aggregation/AggregationFunction.java b/...tion/aggregation/AggregationFunction.java → ...tion/aggregation/AggregationFunction.java
diff --git a/...ion/aggregation/ComparableAggregator.java → ...ion/aggregation/ComparableAggregator.java b/...ion/aggregation/ComparableAggregator.java → ...ion/aggregation/ComparableAggregator.java
diff --git a/.../api/function/aggregation/Comparator.java → .../api/function/aggregation/Comparator.java b/.../api/function/aggregation/Comparator.java → .../api/function/aggregation/Comparator.java
diff --git a/...i/function/aggregation/SumAggregator.java → ...i/function/aggregation/SumAggregator.java b/...i/function/aggregation/SumAggregator.java → ...i/function/aggregation/SumAggregator.java
diff --git a/...api/function/aggregation/SumFunction.java → ...api/function/aggregation/SumFunction.java b/...api/function/aggregation/SumFunction.java → ...api/function/aggregation/SumFunction.java
diff --git a/...ng/api/function/co/CoFlatMapFunction.java → ...ng/api/function/co/CoFlatMapFunction.java b/...ng/api/function/co/CoFlatMapFunction.java → ...ng/api/function/co/CoFlatMapFunction.java
diff --git a/...eaming/api/function/co/CoMapFunction.java → ...eaming/api/function/co/CoMapFunction.java b/...eaming/api/function/co/CoMapFunction.java → ...eaming/api/function/co/CoMapFunction.java
diff --git a/...ing/api/function/co/CoReduceFunction.java → ...ing/api/function/co/CoReduceFunction.java b/...ing/api/function/co/CoReduceFunction.java → ...ing/api/function/co/CoReduceFunction.java
diff --git a/...ing/api/function/co/CoWindowFunction.java → ...ing/api/function/co/CoWindowFunction.java b/...ing/api/function/co/CoWindowFunction.java → ...ing/api/function/co/CoWindowFunction.java
diff --git a/.../api/function/co/CrossWindowFunction.java → .../api/function/co/CrossWindowFunction.java b/.../api/function/co/CrossWindowFunction.java → .../api/function/co/CrossWindowFunction.java
diff --git a/...g/api/function/co/JoinWindowFunction.java → ...g/api/function/co/JoinWindowFunction.java b/...g/api/function/co/JoinWindowFunction.java → ...g/api/function/co/JoinWindowFunction.java
diff --git a/...pi/function/co/RichCoFlatMapFunction.java → ...pi/function/co/RichCoFlatMapFunction.java b/...pi/function/co/RichCoFlatMapFunction.java → ...pi/function/co/RichCoFlatMapFunction.java
diff --git a/...ng/api/function/co/RichCoMapFunction.java → ...ng/api/function/co/RichCoMapFunction.java b/...ng/api/function/co/RichCoMapFunction.java → ...ng/api/function/co/RichCoMapFunction.java
diff --git a/...api/function/co/RichCoReduceFunction.java → ...api/function/co/RichCoReduceFunction.java b/...api/function/co/RichCoReduceFunction.java → ...api/function/co/RichCoReduceFunction.java
diff --git a/...api/function/co/RichCoWindowFunction.java → ...api/function/co/RichCoWindowFunction.java b/...api/function/co/RichCoWindowFunction.java → ...api/function/co/RichCoWindowFunction.java
diff --git a/...g/api/function/sink/FileSinkFunction.java → ...g/api/function/sink/FileSinkFunction.java b/...g/api/function/sink/FileSinkFunction.java → ...g/api/function/sink/FileSinkFunction.java
diff --git a/...nction/sink/FileSinkFunctionByMillis.java → ...nction/sink/FileSinkFunctionByMillis.java b/...nction/sink/FileSinkFunctionByMillis.java → ...nction/sink/FileSinkFunctionByMillis.java
diff --git a/.../api/function/sink/PrintSinkFunction.java → .../api/function/sink/PrintSinkFunction.java b/.../api/function/sink/PrintSinkFunction.java → .../api/function/sink/PrintSinkFunction.java
diff --git a/...g/api/function/sink/RichSinkFunction.java → ...g/api/function/sink/RichSinkFunction.java b/...g/api/function/sink/RichSinkFunction.java → ...g/api/function/sink/RichSinkFunction.java
diff --git a/...aming/api/function/sink/SinkFunction.java → ...aming/api/function/sink/SinkFunction.java b/...aming/api/function/sink/SinkFunction.java → ...aming/api/function/sink/SinkFunction.java
diff --git a/...eaming/api/function/sink/WriteFormat.java → ...eaming/api/function/sink/WriteFormat.java b/...eaming/api/function/sink/WriteFormat.java → ...eaming/api/function/sink/WriteFormat.java
diff --git a/...g/api/function/sink/WriteFormatAsCsv.java → ...g/api/function/sink/WriteFormatAsCsv.java b/...g/api/function/sink/WriteFormatAsCsv.java → ...g/api/function/sink/WriteFormatAsCsv.java
diff --git a/.../api/function/sink/WriteFormatAsText.java → .../api/function/sink/WriteFormatAsText.java b/.../api/function/sink/WriteFormatAsText.java → .../api/function/sink/WriteFormatAsText.java
diff --git a/.../api/function/sink/WriteSinkFunction.java → .../api/function/sink/WriteSinkFunction.java b/.../api/function/sink/WriteSinkFunction.java → .../api/function/sink/WriteSinkFunction.java
diff --git a/...ction/sink/WriteSinkFunctionByMillis.java → ...ction/sink/WriteSinkFunctionByMillis.java b/...ction/sink/WriteSinkFunctionByMillis.java → ...ction/sink/WriteSinkFunctionByMillis.java
diff --git a/...nction/source/FileMonitoringFunction.java → ...nction/source/FileMonitoringFunction.java b/...nction/source/FileMonitoringFunction.java → ...nction/source/FileMonitoringFunction.java
diff --git a/...api/function/source/FileReadFunction.java → ...api/function/source/FileReadFunction.java b/...api/function/source/FileReadFunction.java → ...api/function/source/FileReadFunction.java
diff --git a/...i/function/source/FileSourceFunction.java → ...i/function/source/FileSourceFunction.java b/...i/function/source/FileSourceFunction.java → ...i/function/source/FileSourceFunction.java
diff --git a/...function/source/FromElementsFunction.java → ...function/source/FromElementsFunction.java b/...function/source/FromElementsFunction.java → ...function/source/FromElementsFunction.java
diff --git a/.../function/source/GenSequenceFunction.java → .../function/source/GenSequenceFunction.java b/.../function/source/GenSequenceFunction.java → .../function/source/GenSequenceFunction.java
diff --git a/...unction/source/GenericSourceFunction.java → ...unction/source/GenericSourceFunction.java b/...unction/source/GenericSourceFunction.java → ...unction/source/GenericSourceFunction.java
diff --git a/...nction/source/ParallelSourceFunction.java → ...nction/source/ParallelSourceFunction.java b/...nction/source/ParallelSourceFunction.java → ...nction/source/ParallelSourceFunction.java
diff --git a/...on/source/RichParallelSourceFunction.java → ...on/source/RichParallelSourceFunction.java b/...on/source/RichParallelSourceFunction.java → ...on/source/RichParallelSourceFunction.java
diff --git a/...i/function/source/RichSourceFunction.java → ...i/function/source/RichSourceFunction.java b/...i/function/source/RichSourceFunction.java → ...i/function/source/RichSourceFunction.java
diff --git a/...tion/source/SocketTextStreamFunction.java → ...tion/source/SocketTextStreamFunction.java b/...tion/source/SocketTextStreamFunction.java → ...tion/source/SocketTextStreamFunction.java
diff --git a/...g/api/function/source/SourceFunction.java → ...g/api/function/source/SourceFunction.java b/...g/api/function/source/SourceFunction.java → ...g/api/function/source/SourceFunction.java
diff --git a/...ing/api/invokable/ChainableInvokable.java → ...ing/api/invokable/ChainableInvokable.java b/...ing/api/invokable/ChainableInvokable.java → ...ing/api/invokable/ChainableInvokable.java
diff --git a/...treaming/api/invokable/SinkInvokable.java → ...treaming/api/invokable/SinkInvokable.java b/...treaming/api/invokable/SinkInvokable.java → ...treaming/api/invokable/SinkInvokable.java
diff --git a/...eaming/api/invokable/SourceInvokable.java → ...eaming/api/invokable/SourceInvokable.java b/...eaming/api/invokable/SourceInvokable.java → ...eaming/api/invokable/SourceInvokable.java
diff --git a/...eaming/api/invokable/StreamInvokable.java → ...eaming/api/invokable/StreamInvokable.java b/...eaming/api/invokable/StreamInvokable.java → ...eaming/api/invokable/StreamInvokable.java
diff --git a/...api/invokable/operator/BatchIterator.java → ...api/invokable/operator/BatchIterator.java b/...api/invokable/operator/BatchIterator.java → ...api/invokable/operator/BatchIterator.java
diff --git a/.../invokable/operator/CounterInvokable.java → .../invokable/operator/CounterInvokable.java b/.../invokable/operator/CounterInvokable.java → .../invokable/operator/CounterInvokable.java
diff --git a/...i/invokable/operator/FilterInvokable.java → ...i/invokable/operator/FilterInvokable.java b/...i/invokable/operator/FilterInvokable.java → ...i/invokable/operator/FilterInvokable.java
diff --git a/.../invokable/operator/FlatMapInvokable.java → .../invokable/operator/FlatMapInvokable.java b/.../invokable/operator/FlatMapInvokable.java → .../invokable/operator/FlatMapInvokable.java
diff --git a/...able/operator/GroupedReduceInvokable.java → ...able/operator/GroupedReduceInvokable.java b/...able/operator/GroupedReduceInvokable.java → ...able/operator/GroupedReduceInvokable.java
diff --git a/...able/operator/GroupedWindowInvokable.java → ...able/operator/GroupedWindowInvokable.java b/...able/operator/GroupedWindowInvokable.java → ...able/operator/GroupedWindowInvokable.java
diff --git a/.../api/invokable/operator/MapInvokable.java → .../api/invokable/operator/MapInvokable.java b/.../api/invokable/operator/MapInvokable.java → .../api/invokable/operator/MapInvokable.java
diff --git a/.../invokable/operator/ProjectInvokable.java → .../invokable/operator/ProjectInvokable.java b/.../invokable/operator/ProjectInvokable.java → .../invokable/operator/ProjectInvokable.java
diff --git a/...kable/operator/StreamReduceInvokable.java → ...kable/operator/StreamReduceInvokable.java b/...kable/operator/StreamReduceInvokable.java → ...kable/operator/StreamReduceInvokable.java
diff --git a/.../operator/WindowGroupReduceInvokable.java → .../operator/WindowGroupReduceInvokable.java b/.../operator/WindowGroupReduceInvokable.java → .../operator/WindowGroupReduceInvokable.java
diff --git a/...i/invokable/operator/WindowInvokable.java → ...i/invokable/operator/WindowInvokable.java b/...i/invokable/operator/WindowInvokable.java → ...i/invokable/operator/WindowInvokable.java
diff --git a/...kable/operator/WindowReduceInvokable.java → ...kable/operator/WindowReduceInvokable.java b/...kable/operator/WindowReduceInvokable.java → ...kable/operator/WindowReduceInvokable.java
diff --git a/...kable/operator/co/CoFlatMapInvokable.java → ...kable/operator/co/CoFlatMapInvokable.java b/...kable/operator/co/CoFlatMapInvokable.java → ...kable/operator/co/CoFlatMapInvokable.java
diff --git a/...operator/co/CoGroupedReduceInvokable.java → ...operator/co/CoGroupedReduceInvokable.java b/...operator/co/CoGroupedReduceInvokable.java → ...operator/co/CoGroupedReduceInvokable.java
diff --git a/...pi/invokable/operator/co/CoInvokable.java → ...pi/invokable/operator/co/CoInvokable.java b/...pi/invokable/operator/co/CoInvokable.java → ...pi/invokable/operator/co/CoInvokable.java
diff --git a/...invokable/operator/co/CoMapInvokable.java → ...invokable/operator/co/CoMapInvokable.java b/...invokable/operator/co/CoMapInvokable.java → ...invokable/operator/co/CoMapInvokable.java
diff --git a/...okable/operator/co/CoReduceInvokable.java → ...okable/operator/co/CoReduceInvokable.java b/...okable/operator/co/CoReduceInvokable.java → ...okable/operator/co/CoReduceInvokable.java
diff --git a/...okable/operator/co/CoWindowInvokable.java → ...okable/operator/co/CoWindowInvokable.java b/...okable/operator/co/CoWindowInvokable.java → ...okable/operator/co/CoWindowInvokable.java
diff --git a/...eaming/api/streamrecord/StreamRecord.java → ...eaming/api/streamrecord/StreamRecord.java b/...eaming/api/streamrecord/StreamRecord.java → ...eaming/api/streamrecord/StreamRecord.java
diff --git a/.../streamrecord/StreamRecordSerializer.java → .../streamrecord/StreamRecordSerializer.java b/.../streamrecord/StreamRecordSerializer.java → .../streamrecord/StreamRecordSerializer.java
diff --git a/...flink/streaming/api/streamrecord/UID.java → ...flink/streaming/api/streamrecord/UID.java b/...flink/streaming/api/streamrecord/UID.java → ...flink/streaming/api/streamrecord/UID.java
diff --git a/...ming/api/streamvertex/CoStreamVertex.java → ...ming/api/streamvertex/CoStreamVertex.java b/...ming/api/streamvertex/CoStreamVertex.java → ...ming/api/streamvertex/CoStreamVertex.java
diff --git a/...eaming/api/streamvertex/InputHandler.java → ...eaming/api/streamvertex/InputHandler.java b/...eaming/api/streamvertex/InputHandler.java → ...eaming/api/streamvertex/InputHandler.java
diff --git a/...aming/api/streamvertex/OutputHandler.java → ...aming/api/streamvertex/OutputHandler.java b/...aming/api/streamvertex/OutputHandler.java → ...aming/api/streamvertex/OutputHandler.java
diff --git a/...api/streamvertex/StreamIterationHead.java → ...api/streamvertex/StreamIterationHead.java b/...api/streamvertex/StreamIterationHead.java → ...api/streamvertex/StreamIterationHead.java
diff --git a/...api/streamvertex/StreamIterationTail.java → ...api/streamvertex/StreamIterationTail.java b/...api/streamvertex/StreamIterationTail.java → ...api/streamvertex/StreamIterationTail.java
diff --git a/...g/api/streamvertex/StreamTaskContext.java → ...g/api/streamvertex/StreamTaskContext.java b/...g/api/streamvertex/StreamTaskContext.java → ...g/api/streamvertex/StreamTaskContext.java
diff --git a/...eaming/api/streamvertex/StreamVertex.java → ...eaming/api/streamvertex/StreamVertex.java b/...eaming/api/streamvertex/StreamVertex.java → ...eaming/api/streamvertex/StreamVertex.java
diff --git a/...i/streamvertex/StreamVertexException.java → ...i/streamvertex/StreamVertexException.java b/...i/streamvertex/StreamVertexException.java → ...i/streamvertex/StreamVertexException.java
diff --git a/...streamvertex/StreamingRuntimeContext.java → ...streamvertex/StreamingRuntimeContext.java b/...streamvertex/StreamingRuntimeContext.java → ...streamvertex/StreamingRuntimeContext.java
diff --git a/...ndowing/deltafunction/CosineDistance.java → ...ndowing/deltafunction/CosineDistance.java b/...ndowing/deltafunction/CosineDistance.java → ...ndowing/deltafunction/CosineDistance.java
diff --git a/...indowing/deltafunction/DeltaFunction.java → ...indowing/deltafunction/DeltaFunction.java b/...indowing/deltafunction/DeltaFunction.java → ...indowing/deltafunction/DeltaFunction.java
diff --git a/...wing/deltafunction/EuclideanDistance.java → ...wing/deltafunction/EuclideanDistance.java b/...wing/deltafunction/EuclideanDistance.java → ...wing/deltafunction/EuclideanDistance.java
diff --git a/...unction/ExtractionAwareDeltaFunction.java → ...unction/ExtractionAwareDeltaFunction.java b/...unction/ExtractionAwareDeltaFunction.java → ...unction/ExtractionAwareDeltaFunction.java
diff --git a/...i/windowing/extractor/ArrayFromTuple.java → ...i/windowing/extractor/ArrayFromTuple.java b/...i/windowing/extractor/ArrayFromTuple.java → ...i/windowing/extractor/ArrayFromTuple.java
diff --git a/...dowing/extractor/ConcatinatedExtract.java → ...dowing/extractor/ConcatinatedExtract.java b/...dowing/extractor/ConcatinatedExtract.java → ...dowing/extractor/ConcatinatedExtract.java
diff --git a/...ng/api/windowing/extractor/Extractor.java → ...ng/api/windowing/extractor/Extractor.java b/...ng/api/windowing/extractor/Extractor.java → ...ng/api/windowing/extractor/Extractor.java
diff --git a/...i/windowing/extractor/FieldFromArray.java → ...i/windowing/extractor/FieldFromArray.java b/...i/windowing/extractor/FieldFromArray.java → ...i/windowing/extractor/FieldFromArray.java
diff --git a/...i/windowing/extractor/FieldFromTuple.java → ...i/windowing/extractor/FieldFromTuple.java b/...i/windowing/extractor/FieldFromTuple.java → ...i/windowing/extractor/FieldFromTuple.java
diff --git a/.../windowing/extractor/FieldsFromArray.java → .../windowing/extractor/FieldsFromArray.java b/.../windowing/extractor/FieldsFromArray.java → .../windowing/extractor/FieldsFromArray.java
diff --git a/.../windowing/extractor/FieldsFromTuple.java → .../windowing/extractor/FieldsFromTuple.java b/.../windowing/extractor/FieldsFromTuple.java → .../windowing/extractor/FieldsFromTuple.java
diff --git a/...streaming/api/windowing/helper/Count.java → ...streaming/api/windowing/helper/Count.java b/...streaming/api/windowing/helper/Count.java → ...streaming/api/windowing/helper/Count.java
diff --git a/...streaming/api/windowing/helper/Delta.java → ...streaming/api/windowing/helper/Delta.java b/...streaming/api/windowing/helper/Delta.java → ...streaming/api/windowing/helper/Delta.java
diff --git a/...api/windowing/helper/SystemTimestamp.java → ...api/windowing/helper/SystemTimestamp.java b/...api/windowing/helper/SystemTimestamp.java → ...api/windowing/helper/SystemTimestamp.java
diff --git a/.../streaming/api/windowing/helper/Time.java → .../streaming/api/windowing/helper/Time.java b/.../streaming/api/windowing/helper/Time.java → .../streaming/api/windowing/helper/Time.java
diff --git a/...aming/api/windowing/helper/Timestamp.java → ...aming/api/windowing/helper/Timestamp.java b/...aming/api/windowing/helper/Timestamp.java → ...aming/api/windowing/helper/Timestamp.java
diff --git a/...pi/windowing/helper/TimestampWrapper.java → ...pi/windowing/helper/TimestampWrapper.java b/...pi/windowing/helper/TimestampWrapper.java → ...pi/windowing/helper/TimestampWrapper.java
diff --git a/...api/windowing/helper/WindowingHelper.java → ...api/windowing/helper/WindowingHelper.java b/...api/windowing/helper/WindowingHelper.java → ...api/windowing/helper/WindowingHelper.java
diff --git a/...ActiveCloneableEvictionPolicyWrapper.java → ...ActiveCloneableEvictionPolicyWrapper.java b/...ActiveCloneableEvictionPolicyWrapper.java → ...ActiveCloneableEvictionPolicyWrapper.java
diff --git a/...indowing/policy/ActiveEvictionPolicy.java → ...indowing/policy/ActiveEvictionPolicy.java b/...indowing/policy/ActiveEvictionPolicy.java → ...indowing/policy/ActiveEvictionPolicy.java
diff --git a/...g/policy/ActiveEvictionPolicyWrapper.java → ...g/policy/ActiveEvictionPolicyWrapper.java b/...g/policy/ActiveEvictionPolicyWrapper.java → ...g/policy/ActiveEvictionPolicyWrapper.java
diff --git a/...ndowing/policy/ActiveTriggerCallback.java → ...ndowing/policy/ActiveTriggerCallback.java b/...ndowing/policy/ActiveTriggerCallback.java → ...ndowing/policy/ActiveTriggerCallback.java
diff --git a/...windowing/policy/ActiveTriggerPolicy.java → ...windowing/policy/ActiveTriggerPolicy.java b/...windowing/policy/ActiveTriggerPolicy.java → ...windowing/policy/ActiveTriggerPolicy.java
diff --git a/...owing/policy/CloneableEvictionPolicy.java → ...owing/policy/CloneableEvictionPolicy.java b/...owing/policy/CloneableEvictionPolicy.java → ...owing/policy/CloneableEvictionPolicy.java
diff --git a/...dowing/policy/CloneableTriggerPolicy.java → ...dowing/policy/CloneableTriggerPolicy.java b/...dowing/policy/CloneableTriggerPolicy.java → ...dowing/policy/CloneableTriggerPolicy.java
diff --git a/...windowing/policy/CountEvictionPolicy.java → ...windowing/policy/CountEvictionPolicy.java b/...windowing/policy/CountEvictionPolicy.java → ...windowing/policy/CountEvictionPolicy.java
diff --git a/.../windowing/policy/CountTriggerPolicy.java → .../windowing/policy/CountTriggerPolicy.java b/.../windowing/policy/CountTriggerPolicy.java → .../windowing/policy/CountTriggerPolicy.java
diff --git a/...ing/api/windowing/policy/DeltaPolicy.java → ...ing/api/windowing/policy/DeltaPolicy.java b/...ing/api/windowing/policy/DeltaPolicy.java → ...ing/api/windowing/policy/DeltaPolicy.java
diff --git a/.../api/windowing/policy/EvictionPolicy.java → .../api/windowing/policy/EvictionPolicy.java b/.../api/windowing/policy/EvictionPolicy.java → .../api/windowing/policy/EvictionPolicy.java
diff --git a/...i/windowing/policy/PunctuationPolicy.java → ...i/windowing/policy/PunctuationPolicy.java b/...i/windowing/policy/PunctuationPolicy.java → ...i/windowing/policy/PunctuationPolicy.java
diff --git a/.../windowing/policy/TimeEvictionPolicy.java → .../windowing/policy/TimeEvictionPolicy.java b/.../windowing/policy/TimeEvictionPolicy.java → .../windowing/policy/TimeEvictionPolicy.java
diff --git a/...i/windowing/policy/TimeTriggerPolicy.java → ...i/windowing/policy/TimeTriggerPolicy.java b/...i/windowing/policy/TimeTriggerPolicy.java → ...i/windowing/policy/TimeTriggerPolicy.java
diff --git a/...g/api/windowing/policy/TriggerPolicy.java → ...g/api/windowing/policy/TriggerPolicy.java b/...g/api/windowing/policy/TriggerPolicy.java → ...g/api/windowing/policy/TriggerPolicy.java
diff --git a/...dowing/policy/TumblingEvictionPolicy.java → ...dowing/policy/TumblingEvictionPolicy.java b/...dowing/policy/TumblingEvictionPolicy.java → ...dowing/policy/TumblingEvictionPolicy.java
diff --git a/...ink/streaming/io/BlockingQueueBroker.java → ...ink/streaming/io/BlockingQueueBroker.java b/...ink/streaming/io/BlockingQueueBroker.java → ...ink/streaming/io/BlockingQueueBroker.java
diff --git a/.../flink/streaming/io/CoReaderIterator.java → .../flink/streaming/io/CoReaderIterator.java b/.../flink/streaming/io/CoReaderIterator.java → .../flink/streaming/io/CoReaderIterator.java
diff --git a/...he/flink/streaming/io/CoRecordReader.java → ...he/flink/streaming/io/CoRecordReader.java b/...he/flink/streaming/io/CoRecordReader.java → ...he/flink/streaming/io/CoRecordReader.java
diff --git a/...link/streaming/io/StreamRecordWriter.java → ...link/streaming/io/StreamRecordWriter.java b/...link/streaming/io/StreamRecordWriter.java → ...link/streaming/io/StreamRecordWriter.java
diff --git a/...ing/partitioner/BroadcastPartitioner.java → ...ing/partitioner/BroadcastPartitioner.java b/...ing/partitioner/BroadcastPartitioner.java → ...ing/partitioner/BroadcastPartitioner.java
diff --git a/...ng/partitioner/DistributePartitioner.java → ...ng/partitioner/DistributePartitioner.java b/...ng/partitioner/DistributePartitioner.java → ...ng/partitioner/DistributePartitioner.java
diff --git a/...eaming/partitioner/FieldsPartitioner.java → ...eaming/partitioner/FieldsPartitioner.java b/...eaming/partitioner/FieldsPartitioner.java → ...eaming/partitioner/FieldsPartitioner.java
diff --git a/...eaming/partitioner/GlobalPartitioner.java → ...eaming/partitioner/GlobalPartitioner.java b/...eaming/partitioner/GlobalPartitioner.java → ...eaming/partitioner/GlobalPartitioner.java
diff --git a/...aming/partitioner/ShufflePartitioner.java → ...aming/partitioner/ShufflePartitioner.java b/...aming/partitioner/ShufflePartitioner.java → ...aming/partitioner/ShufflePartitioner.java
diff --git a/...eaming/partitioner/StreamPartitioner.java → ...eaming/partitioner/StreamPartitioner.java b/...eaming/partitioner/StreamPartitioner.java → ...eaming/partitioner/StreamPartitioner.java
diff --git a/...ink/streaming/state/CircularFifoList.java → ...ink/streaming/state/CircularFifoList.java b/...ink/streaming/state/CircularFifoList.java → ...ink/streaming/state/CircularFifoList.java
diff --git a/...che/flink/streaming/state/GraphState.java → ...che/flink/streaming/state/GraphState.java b/...che/flink/streaming/state/GraphState.java → ...che/flink/streaming/state/GraphState.java
diff --git a/...pache/flink/streaming/state/MapState.java → ...pache/flink/streaming/state/MapState.java b/...pache/flink/streaming/state/MapState.java → ...pache/flink/streaming/state/MapState.java
diff --git a/...reaming/state/NullableCircularBuffer.java → ...reaming/state/NullableCircularBuffer.java b/...reaming/state/NullableCircularBuffer.java → ...reaming/state/NullableCircularBuffer.java
diff --git a/.../flink/streaming/state/OperatorState.java → .../flink/streaming/state/OperatorState.java b/.../flink/streaming/state/OperatorState.java → .../flink/streaming/state/OperatorState.java
diff --git a/...k/streaming/state/PartitionableState.java → ...k/streaming/state/PartitionableState.java b/...k/streaming/state/PartitionableState.java → ...k/streaming/state/PartitionableState.java
diff --git a/...he/flink/streaming/state/SimpleState.java → ...he/flink/streaming/state/SimpleState.java b/...he/flink/streaming/state/SimpleState.java → ...he/flink/streaming/state/SimpleState.java
diff --git a/...aming/state/checkpoint/MapCheckpoint.java → ...aming/state/checkpoint/MapCheckpoint.java b/...aming/state/checkpoint/MapCheckpoint.java → ...aming/state/checkpoint/MapCheckpoint.java
diff --git a/...ing/state/checkpoint/StateCheckpoint.java → ...ing/state/checkpoint/StateCheckpoint.java b/...ing/state/checkpoint/StateCheckpoint.java → ...ing/state/checkpoint/StateCheckpoint.java
diff --git a/...che/flink/streaming/util/ClusterUtil.java → ...che/flink/streaming/util/ClusterUtil.java b/...che/flink/streaming/util/ClusterUtil.java → ...che/flink/streaming/util/ClusterUtil.java
diff --git a/.../streaming/util/keys/KeySelectorUtil.java → .../streaming/util/keys/KeySelectorUtil.java b/.../streaming/util/keys/KeySelectorUtil.java → .../streaming/util/keys/KeySelectorUtil.java
diff --git a/...treaming/api/AggregationFunctionTest.java → ...treaming/api/AggregationFunctionTest.java b/...treaming/api/AggregationFunctionTest.java → ...treaming/api/AggregationFunctionTest.java
diff --git a/...ache/flink/streaming/api/IterateTest.java → ...ache/flink/streaming/api/IterateTest.java b/...ache/flink/streaming/api/IterateTest.java → ...ache/flink/streaming/api/IterateTest.java
diff --git a/...ink/streaming/api/OutputSplitterTest.java → ...ink/streaming/api/OutputSplitterTest.java b/...ink/streaming/api/OutputSplitterTest.java → ...ink/streaming/api/OutputSplitterTest.java
diff --git a/...apache/flink/streaming/api/PrintTest.java → ...apache/flink/streaming/api/PrintTest.java b/...apache/flink/streaming/api/PrintTest.java → ...apache/flink/streaming/api/PrintTest.java
diff --git a/...pache/flink/streaming/api/SourceTest.java → ...pache/flink/streaming/api/SourceTest.java b/...pache/flink/streaming/api/SourceTest.java → ...pache/flink/streaming/api/SourceTest.java
diff --git a/...nk/streaming/api/WindowCrossJoinTest.java → ...nk/streaming/api/WindowCrossJoinTest.java b/...nk/streaming/api/WindowCrossJoinTest.java → ...nk/streaming/api/WindowCrossJoinTest.java