You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2017/04/26 10:07:28 UTC
[06/23] flink git commit: [FLINK-6107] Enable import order check in
streaming checkstyle
[FLINK-6107] Enable import order check in streaming checkstyle
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/922352ac
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/922352ac
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/922352ac
Branch: refs/heads/master
Commit: 922352ac35f3753334e834632e3e361fbd36336e
Parents: 5aa93a2
Author: Aljoscha Krettek <al...@gmail.com>
Authored: Sun Mar 19 12:23:22 2017 +0100
Committer: Aljoscha Krettek <al...@gmail.com>
Committed: Wed Apr 26 10:36:50 2017 +0200
----------------------------------------------------------------------
.../api/graph/StreamGraphHasherV1.java | 25 ++++++++++----------
.../MultiplexingStreamRecordSerializer.java | 7 +++---
.../streamrecord/StreamRecordSerializer.java | 3 +--
.../streaming/api/checkpoint/Checkpointed.java | 3 +--
.../checkpoint/CheckpointedAsynchronously.java | 3 +--
.../api/checkpoint/CheckpointedRestoring.java | 3 +--
.../api/checkpoint/ListCheckpointed.java | 5 ++--
.../selector/CopyingDirectedOutput.java | 7 +++---
.../api/datastream/AllWindowedStream.java | 10 ++++----
.../api/datastream/AsyncDataStream.java | 3 +--
.../api/datastream/CoGroupedStreams.java | 13 +++++-----
.../api/datastream/ConnectedStreams.java | 6 ++---
.../streaming/api/datastream/DataStream.java | 17 +++++++------
.../api/datastream/DataStreamSink.java | 2 +-
.../api/datastream/IterativeStream.java | 5 ++--
.../streaming/api/datastream/JoinedStreams.java | 6 ++---
.../streaming/api/datastream/KeyedStream.java | 11 ++++-----
.../datastream/SingleOutputStreamOperator.java | 11 ++++-----
.../api/datastream/WindowedStream.java | 10 ++++----
.../api/environment/CheckpointConfig.java | 6 ++---
.../environment/StreamExecutionEnvironment.java | 19 +++++++--------
.../AssignerWithPeriodicWatermarks.java | 3 +--
.../AssignerWithPunctuatedWatermarks.java | 3 +--
.../functions/aggregation/SumAggregator.java | 2 +-
.../api/functions/aggregation/SumFunction.java | 3 +--
.../api/functions/async/AsyncFunction.java | 3 +--
.../api/functions/async/RichAsyncFunction.java | 7 +++---
.../async/collector/AsyncCollector.java | 3 +--
.../api/functions/sink/SocketClientSink.java | 8 +++----
.../api/functions/sink/WriteFormat.java | 3 +--
.../api/functions/sink/WriteFormatAsCsv.java | 3 +--
.../api/functions/sink/WriteFormatAsText.java | 3 +--
.../api/functions/sink/WriteSinkFunction.java | 3 +--
.../ContinuousFileMonitoringFunction.java | 17 +++++++------
.../source/ContinuousFileReaderOperator.java | 23 +++++++++---------
.../source/FileMonitoringFunction.java | 13 +++++-----
.../functions/source/FromElementsFunction.java | 15 ++++++------
.../functions/source/FromIteratorFunction.java | 3 +--
.../source/FromSplittableIteratorFunction.java | 3 +--
.../source/InputFormatSourceFunction.java | 5 ++--
...ltipleIdsMessageAcknowledgingSourceBase.java | 11 ++++-----
.../source/SocketTextStreamFunction.java | 14 +++++------
.../api/functions/source/SourceFunction.java | 5 ++--
.../source/StatefulSequenceSource.java | 5 ++--
.../source/TimestampedFileInputSplit.java | 3 +--
.../timestamps/AscendingTimestampExtractor.java | 5 ++--
.../AggregateApplyAllWindowFunction.java | 3 +--
.../windowing/AggregateApplyWindowFunction.java | 3 +--
.../functions/windowing/AllWindowFunction.java | 3 +--
.../windowing/FoldApplyAllWindowFunction.java | 9 ++++---
.../FoldApplyProcessAllWindowFunction.java | 9 ++++---
.../FoldApplyProcessWindowFunction.java | 9 ++++---
.../windowing/FoldApplyWindowFunction.java | 9 ++++---
.../windowing/ReduceApplyAllWindowFunction.java | 3 +--
.../ReduceApplyProcessAllWindowFunction.java | 3 +--
.../ReduceApplyProcessWindowFunction.java | 3 +--
.../windowing/ReduceApplyWindowFunction.java | 3 +--
.../api/functions/windowing/WindowFunction.java | 3 +--
.../windowing/delta/DeltaFunction.java | 3 +--
.../windowing/delta/extractor/Extractor.java | 3 +--
.../delta/extractor/FieldFromArray.java | 3 +--
.../delta/extractor/FieldsFromArray.java | 3 +--
.../flink/streaming/api/graph/StreamConfig.java | 3 +--
.../flink/streaming/api/graph/StreamEdge.java | 3 +--
.../flink/streaming/api/graph/StreamGraph.java | 3 +--
.../api/graph/StreamGraphGenerator.java | 13 +++++-----
.../streaming/api/graph/StreamGraphHasher.java | 3 +--
.../api/graph/StreamGraphHasherV2.java | 21 ++++++++--------
.../api/graph/StreamGraphUserHashHasher.java | 3 +--
.../flink/streaming/api/graph/StreamNode.java | 7 +++---
.../api/graph/StreamingJobGraphGenerator.java | 19 +++++++--------
.../api/operators/AbstractStreamOperator.java | 17 +++++++------
.../operators/AbstractUdfStreamOperator.java | 9 ++++---
.../api/operators/HeapInternalTimerService.java | 17 +++++++------
.../operators/InternalTimeServiceManager.java | 7 +++---
.../streaming/api/operators/InternalTimer.java | 3 +--
.../InternalWatermarkCallbackService.java | 13 +++++-----
.../api/operators/KeyedProcessOperator.java | 6 ++---
.../api/operators/OnWatermarkCallback.java | 3 +--
.../api/operators/OperatorSnapshotResult.java | 3 +--
.../api/operators/ProcessOperator.java | 4 ++--
.../streaming/api/operators/StreamOperator.java | 3 +--
.../streaming/api/operators/StreamSource.java | 3 +--
.../api/operators/StreamSourceContexts.java | 5 ++--
.../api/operators/StreamingRuntimeContext.java | 5 ++--
.../api/operators/async/AsyncWaitOperator.java | 17 +++++++------
.../streaming/api/operators/async/Emitter.java | 5 ++--
.../async/queue/AsyncCollectionResult.java | 3 +--
.../async/queue/OrderedStreamElementQueue.java | 13 +++++-----
.../async/queue/StreamElementQueue.java | 3 +--
.../async/queue/StreamElementQueueEntry.java | 3 +--
.../async/queue/StreamRecordQueueEntry.java | 3 +--
.../queue/UnorderedStreamElementQueue.java | 13 +++++-----
.../api/operators/co/CoProcessOperator.java | 6 ++---
.../api/operators/co/CoStreamFlatMap.java | 2 +-
.../operators/co/KeyedCoProcessOperator.java | 6 ++---
.../CoFeedbackTransformation.java | 7 +++---
.../transformations/FeedbackTransformation.java | 5 ++--
.../transformations/OneInputTransformation.java | 5 ++--
.../PartitionTransformation.java | 6 ++---
.../transformations/SelectTransformation.java | 5 ++--
.../SideOutputTransformation.java | 5 ++--
.../api/transformations/SinkTransformation.java | 5 ++--
.../transformations/SourceTransformation.java | 5 ++--
.../transformations/SplitTransformation.java | 5 ++--
.../transformations/StreamTransformation.java | 7 +++---
.../transformations/TwoInputTransformation.java | 5 ++--
.../transformations/UnionTransformation.java | 5 ++--
.../assigners/BaseAlignedWindowAssigner.java | 3 +--
.../assigners/EventTimeSessionWindows.java | 5 ++--
.../api/windowing/assigners/GlobalWindows.java | 5 ++--
.../assigners/MergingWindowAssigner.java | 3 +--
.../assigners/ProcessingTimeSessionWindows.java | 5 ++--
.../assigners/SlidingEventTimeWindows.java | 9 ++++---
.../assigners/SlidingProcessingTimeWindows.java | 7 +++---
.../assigners/TumblingEventTimeWindows.java | 7 +++---
.../TumblingProcessingTimeWindows.java | 5 ++--
.../api/windowing/assigners/WindowAssigner.java | 6 ++---
.../api/windowing/evictors/CountEvictor.java | 3 +--
.../api/windowing/evictors/DeltaEvictor.java | 3 +--
.../api/windowing/evictors/Evictor.java | 3 +--
.../api/windowing/evictors/TimeEvictor.java | 3 +--
.../streaming/api/windowing/time/Time.java | 3 ++-
.../api/windowing/triggers/Trigger.java | 3 +--
.../api/windowing/windows/GlobalWindow.java | 3 +--
.../api/windowing/windows/TimeWindow.java | 15 ++++++------
.../streaming/runtime/io/BarrierBuffer.java | 12 ++++------
.../streaming/runtime/io/BarrierTracker.java | 6 ++---
.../runtime/io/CheckpointBarrierHandler.java | 3 +--
.../runtime/io/RecordWriterOutput.java | 9 ++++---
.../runtime/io/StreamInputProcessor.java | 17 +++++++------
.../runtime/io/StreamRecordWriter.java | 5 ++--
.../runtime/io/StreamTwoInputProcessor.java | 19 +++++++--------
.../runtime/operators/CheckpointCommitter.java | 3 +--
.../operators/GenericWriteAheadSink.java | 13 +++++-----
...ractAlignedProcessingTimeWindowOperator.java | 11 ++++-----
.../windowing/AbstractKeyedTimePanes.java | 7 +++---
.../windowing/AccumulatingKeyedTimePanes.java | 7 +++---
...ccumulatingProcessingTimeWindowOperator.java | 3 +--
.../windowing/EvictingWindowOperator.java | 10 ++++----
.../runtime/operators/windowing/KeyMap.java | 7 +++---
.../operators/windowing/MergingWindowSet.java | 11 ++++-----
.../operators/windowing/WindowOperator.java | 24 +++++++++----------
...ternalAggregateProcessAllWindowFunction.java | 3 +--
.../InternalAggregateProcessWindowFunction.java | 3 +--
.../InternalSingleValueAllWindowFunction.java | 3 +--
...rnalSingleValueProcessAllWindowFunction.java | 3 +--
...nternalSingleValueProcessWindowFunction.java | 3 +--
.../InternalSingleValueWindowFunction.java | 3 +--
.../streamrecord/StreamElementSerializer.java | 7 +++---
.../streamstatus/StatusWatermarkValve.java | 6 ++---
.../ExceptionInChainedOperatorException.java | 4 ++--
.../streaming/runtime/tasks/OperatorChain.java | 21 ++++++++--------
.../runtime/tasks/OperatorStateHandles.java | 5 ++--
.../runtime/tasks/StreamIterationHead.java | 3 +--
.../streaming/runtime/tasks/StreamTask.java | 23 +++++++++---------
.../tasks/SystemProcessingTimeService.java | 9 ++++---
.../tasks/TestProcessingTimeService.java | 5 ++--
.../flink/streaming/util/HDFSCopyFromLocal.java | 5 ++--
.../flink/streaming/util/HDFSCopyToLocal.java | 5 ++--
.../util/functions/StreamingFunctionUtils.java | 7 +++---
.../streaming/util/keys/KeySelectorUtil.java | 7 +++---
.../AbstractDeserializationSchema.java | 3 +--
.../util/serialization/SerializationSchema.java | 3 +--
.../util/serialization/SimpleStringSchema.java | 9 ++++---
.../TypeInformationSerializationSchema.java | 3 +--
.../streaming/util/typeutils/FieldAccessor.java | 17 +++++++------
.../util/typeutils/FieldAccessorFactory.java | 7 +++---
tools/maven/strict-checkstyle.xml | 20 ++++++++--------
169 files changed, 505 insertions(+), 665 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/migration/streaming/api/graph/StreamGraphHasherV1.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/migration/streaming/api/graph/StreamGraphHasherV1.java b/flink-streaming-java/src/main/java/org/apache/flink/migration/streaming/api/graph/StreamGraphHasherV1.java
index a80ff7d..2fbfe1c 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/migration/streaming/api/graph/StreamGraphHasherV1.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/migration/streaming/api/graph/StreamGraphHasherV1.java
@@ -18,20 +18,11 @@
package org.apache.flink.migration.streaming.api.graph;
+import static org.apache.flink.util.StringUtils.byteToHexString;
+
import com.google.common.hash.HashFunction;
import com.google.common.hash.Hasher;
import com.google.common.hash.Hashing;
-import org.apache.flink.streaming.api.graph.StreamEdge;
-import org.apache.flink.streaming.api.graph.StreamGraph;
-import org.apache.flink.streaming.api.graph.StreamGraphHasher;
-import org.apache.flink.streaming.api.graph.StreamNode;
-import org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator;
-import org.apache.flink.streaming.api.operators.ChainingStrategy;
-import org.apache.flink.streaming.api.operators.StreamOperator;
-import org.apache.flink.streaming.runtime.partitioner.ForwardPartitioner;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
import java.nio.charset.Charset;
import java.util.ArrayDeque;
import java.util.ArrayList;
@@ -43,8 +34,16 @@ import java.util.List;
import java.util.Map;
import java.util.Queue;
import java.util.Set;
-
-import static org.apache.flink.util.StringUtils.byteToHexString;
+import org.apache.flink.streaming.api.graph.StreamEdge;
+import org.apache.flink.streaming.api.graph.StreamGraph;
+import org.apache.flink.streaming.api.graph.StreamGraphHasher;
+import org.apache.flink.streaming.api.graph.StreamNode;
+import org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator;
+import org.apache.flink.streaming.api.operators.ChainingStrategy;
+import org.apache.flink.streaming.api.operators.StreamOperator;
+import org.apache.flink.streaming.runtime.partitioner.ForwardPartitioner;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* StreamGraphHasher from Flink 1.1. This contains duplicated code to ensure that the algorithm does not change with
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/migration/streaming/runtime/streamrecord/MultiplexingStreamRecordSerializer.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/migration/streaming/runtime/streamrecord/MultiplexingStreamRecordSerializer.java b/flink-streaming-java/src/main/java/org/apache/flink/migration/streaming/runtime/streamrecord/MultiplexingStreamRecordSerializer.java
index db9977b..fdcd5b8 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/migration/streaming/runtime/streamrecord/MultiplexingStreamRecordSerializer.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/migration/streaming/runtime/streamrecord/MultiplexingStreamRecordSerializer.java
@@ -18,6 +18,9 @@
package org.apache.flink.migration.streaming.runtime.streamrecord;
+import static java.util.Objects.requireNonNull;
+
+import java.io.IOException;
import org.apache.flink.api.common.typeutils.TypeSerializer;
import org.apache.flink.core.memory.DataInputView;
import org.apache.flink.core.memory.DataOutputView;
@@ -25,10 +28,6 @@ import org.apache.flink.streaming.api.watermark.Watermark;
import org.apache.flink.streaming.runtime.streamrecord.StreamElement;
import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;
-import java.io.IOException;
-
-import static java.util.Objects.requireNonNull;
-
/**
* Legacy multiplexing {@link TypeSerializer} for stream records, watermarks and other stream
* elements.
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/migration/streaming/runtime/streamrecord/StreamRecordSerializer.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/migration/streaming/runtime/streamrecord/StreamRecordSerializer.java b/flink-streaming-java/src/main/java/org/apache/flink/migration/streaming/runtime/streamrecord/StreamRecordSerializer.java
index 0e9e809..2c8dc4a 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/migration/streaming/runtime/streamrecord/StreamRecordSerializer.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/migration/streaming/runtime/streamrecord/StreamRecordSerializer.java
@@ -18,6 +18,7 @@
package org.apache.flink.migration.streaming.runtime.streamrecord;
+import java.io.IOException;
import org.apache.flink.annotation.Internal;
import org.apache.flink.api.common.typeutils.TypeSerializer;
import org.apache.flink.core.memory.DataInputView;
@@ -25,8 +26,6 @@ import org.apache.flink.core.memory.DataOutputView;
import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;
import org.apache.flink.util.Preconditions;
-import java.io.IOException;
-
/**
* Serializer for {@link StreamRecord}. This version ignores timestamps and only deals with
* the element.
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/Checkpointed.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/Checkpointed.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/Checkpointed.java
index 7dedfbf..6de7329 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/Checkpointed.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/Checkpointed.java
@@ -18,9 +18,8 @@
package org.apache.flink.streaming.api.checkpoint;
-import org.apache.flink.annotation.PublicEvolving;
-
import java.io.Serializable;
+import org.apache.flink.annotation.PublicEvolving;
/**
* This method must be implemented by functions that have state that needs to be
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedAsynchronously.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedAsynchronously.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedAsynchronously.java
index 2230f59..b96c242 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedAsynchronously.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedAsynchronously.java
@@ -18,9 +18,8 @@
package org.apache.flink.streaming.api.checkpoint;
-import org.apache.flink.annotation.PublicEvolving;
-
import java.io.Serializable;
+import org.apache.flink.annotation.PublicEvolving;
/**
* This interface marks a function/operator as checkpointed similar to the
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedRestoring.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedRestoring.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedRestoring.java
index cfaa505..f695418 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedRestoring.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedRestoring.java
@@ -18,9 +18,8 @@
package org.apache.flink.streaming.api.checkpoint;
-import org.apache.flink.annotation.PublicEvolving;
-
import java.io.Serializable;
+import org.apache.flink.annotation.PublicEvolving;
/**
* This deprecated interface contains the methods for restoring from the legacy checkpointing mechanism of state.
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/ListCheckpointed.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/ListCheckpointed.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/ListCheckpointed.java
index 0b8b1b6..49ce3e3 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/ListCheckpointed.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/ListCheckpointed.java
@@ -18,14 +18,13 @@
package org.apache.flink.streaming.api.checkpoint;
+import java.io.Serializable;
+import java.util.List;
import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.api.common.functions.RichFunction;
import org.apache.flink.api.common.state.OperatorStateStore;
import org.apache.flink.configuration.Configuration;
-import java.io.Serializable;
-import java.util.List;
-
/**
* This interface can be implemented by functions that want to store state in checkpoints.
* It can be used in a similar way as the deprecated {@link Checkpointed} interface, but
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/collector/selector/CopyingDirectedOutput.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/collector/selector/CopyingDirectedOutput.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/collector/selector/CopyingDirectedOutput.java
index 5f7e278..f74d652 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/collector/selector/CopyingDirectedOutput.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/collector/selector/CopyingDirectedOutput.java
@@ -17,15 +17,14 @@
package org.apache.flink.streaming.api.collector.selector;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Set;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.streaming.api.graph.StreamEdge;
import org.apache.flink.streaming.api.operators.Output;
import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;
-import java.util.Iterator;
-import java.util.List;
-import java.util.Set;
-
/**
* Special version of {@link DirectedOutput} that performs a shallow copy of the
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AllWindowedStream.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AllWindowedStream.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AllWindowedStream.java
index 5aabf28..2400330 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AllWindowedStream.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AllWindowedStream.java
@@ -18,8 +18,11 @@
package org.apache.flink.streaming.api.datastream;
-import org.apache.flink.annotation.PublicEvolving;
+import static org.apache.flink.util.Preconditions.checkArgument;
+import static org.apache.flink.util.Preconditions.checkNotNull;
+
import org.apache.flink.annotation.Public;
+import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.api.common.functions.AggregateFunction;
import org.apache.flink.api.common.functions.FoldFunction;
import org.apache.flink.api.common.functions.ReduceFunction;
@@ -40,9 +43,9 @@ import org.apache.flink.streaming.api.functions.aggregation.ComparableAggregator
import org.apache.flink.streaming.api.functions.aggregation.SumAggregator;
import org.apache.flink.streaming.api.functions.windowing.AggregateApplyAllWindowFunction;
import org.apache.flink.streaming.api.functions.windowing.AllWindowFunction;
+import org.apache.flink.streaming.api.functions.windowing.FoldApplyAllWindowFunction;
import org.apache.flink.streaming.api.functions.windowing.FoldApplyProcessAllWindowFunction;
import org.apache.flink.streaming.api.functions.windowing.PassThroughAllWindowFunction;
-import org.apache.flink.streaming.api.functions.windowing.FoldApplyAllWindowFunction;
import org.apache.flink.streaming.api.functions.windowing.ProcessAllWindowFunction;
import org.apache.flink.streaming.api.functions.windowing.ReduceApplyAllWindowFunction;
import org.apache.flink.streaming.api.functions.windowing.ReduceApplyProcessAllWindowFunction;
@@ -66,9 +69,6 @@ import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;
import org.apache.flink.util.OutputTag;
import org.apache.flink.util.Preconditions;
-import static org.apache.flink.util.Preconditions.checkArgument;
-import static org.apache.flink.util.Preconditions.checkNotNull;
-
/**
* A {@code AllWindowedStream} represents a data stream where the stream of
* elements is split into windows based on a
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AsyncDataStream.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AsyncDataStream.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AsyncDataStream.java
index 8461d2c..759e32a 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AsyncDataStream.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AsyncDataStream.java
@@ -17,6 +17,7 @@
package org.apache.flink.streaming.api.datastream;
+import java.util.concurrent.TimeUnit;
import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.api.common.typeinfo.TypeInformation;
import org.apache.flink.api.java.Utils;
@@ -24,8 +25,6 @@ import org.apache.flink.api.java.typeutils.TypeExtractor;
import org.apache.flink.streaming.api.functions.async.AsyncFunction;
import org.apache.flink.streaming.api.operators.async.AsyncWaitOperator;
-import java.util.concurrent.TimeUnit;
-
/**
* A helper class to apply {@link AsyncFunction} to a data stream.
*
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/CoGroupedStreams.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/CoGroupedStreams.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/CoGroupedStreams.java
index 98c57f1..13a8a24 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/CoGroupedStreams.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/CoGroupedStreams.java
@@ -17,9 +17,14 @@
package org.apache.flink.streaming.api.datastream;
-import org.apache.flink.annotation.PublicEvolving;
+import static java.util.Objects.requireNonNull;
+
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.List;
import org.apache.flink.annotation.Internal;
import org.apache.flink.annotation.Public;
+import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.api.common.ExecutionConfig;
import org.apache.flink.api.common.functions.CoGroupFunction;
import org.apache.flink.api.common.functions.MapFunction;
@@ -37,12 +42,6 @@ import org.apache.flink.streaming.api.windowing.triggers.Trigger;
import org.apache.flink.streaming.api.windowing.windows.Window;
import org.apache.flink.util.Collector;
-import java.io.IOException;
-import java.util.ArrayList;
-import java.util.List;
-
-import static java.util.Objects.requireNonNull;
-
/**
*{@code CoGroupedStreams} represents two {@link DataStream DataStreams} that have been co-grouped.
* A streaming co-group operation is evaluated over elements in a window.
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/ConnectedStreams.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/ConnectedStreams.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/ConnectedStreams.java
index b45881a..0a2b4e1 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/ConnectedStreams.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/ConnectedStreams.java
@@ -17,9 +17,11 @@
package org.apache.flink.streaming.api.datastream;
+import static java.util.Objects.requireNonNull;
+
import org.apache.flink.annotation.Internal;
-import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.annotation.Public;
+import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.api.common.typeinfo.TypeInformation;
import org.apache.flink.api.java.Utils;
import org.apache.flink.api.java.functions.KeySelector;
@@ -35,8 +37,6 @@ import org.apache.flink.streaming.api.operators.co.CoStreamMap;
import org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperator;
import org.apache.flink.streaming.api.transformations.TwoInputTransformation;
-import static java.util.Objects.requireNonNull;
-
/**
* ConnectedStreams represent two connected streams of (possibly) different data types.
* Connected streams are useful for cases where operations on one stream directly
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
index e73e4e7..c531987 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
@@ -19,10 +19,9 @@ package org.apache.flink.streaming.api.datastream;
import java.util.ArrayList;
import java.util.List;
-
-import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.annotation.Internal;
import org.apache.flink.annotation.Public;
+import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.api.common.ExecutionConfig;
import org.apache.flink.api.common.functions.FilterFunction;
import org.apache.flink.api.common.functions.FlatMapFunction;
@@ -32,6 +31,7 @@ import org.apache.flink.api.common.functions.RichFilterFunction;
import org.apache.flink.api.common.functions.RichFlatMapFunction;
import org.apache.flink.api.common.functions.RichMapFunction;
import org.apache.flink.api.common.io.OutputFormat;
+import org.apache.flink.api.common.operators.Keys;
import org.apache.flink.api.common.operators.ResourceSpec;
import org.apache.flink.api.common.typeinfo.BasicArrayTypeInfo;
import org.apache.flink.api.common.typeinfo.PrimitiveArrayTypeInfo;
@@ -40,7 +40,6 @@ import org.apache.flink.api.java.Utils;
import org.apache.flink.api.java.functions.KeySelector;
import org.apache.flink.api.java.io.CsvOutputFormat;
import org.apache.flink.api.java.io.TextOutputFormat;
-import org.apache.flink.api.common.operators.Keys;
import org.apache.flink.api.java.tuple.Tuple;
import org.apache.flink.api.java.typeutils.InputTypeConfigurable;
import org.apache.flink.api.java.typeutils.TypeExtractor;
@@ -52,13 +51,13 @@ import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.api.functions.AssignerWithPeriodicWatermarks;
import org.apache.flink.streaming.api.functions.AssignerWithPunctuatedWatermarks;
import org.apache.flink.streaming.api.functions.ProcessFunction;
-import org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor;
-import org.apache.flink.streaming.api.functions.timestamps.BoundedOutOfOrdernessTimestampExtractor;
import org.apache.flink.streaming.api.functions.TimestampExtractor;
import org.apache.flink.streaming.api.functions.sink.OutputFormatSinkFunction;
import org.apache.flink.streaming.api.functions.sink.PrintSinkFunction;
import org.apache.flink.streaming.api.functions.sink.SinkFunction;
import org.apache.flink.streaming.api.functions.sink.SocketClientSink;
+import org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor;
+import org.apache.flink.streaming.api.functions.timestamps.BoundedOutOfOrdernessTimestampExtractor;
import org.apache.flink.streaming.api.operators.OneInputStreamOperator;
import org.apache.flink.streaming.api.operators.ProcessOperator;
import org.apache.flink.streaming.api.operators.StreamFilter;
@@ -70,10 +69,10 @@ import org.apache.flink.streaming.api.transformations.PartitionTransformation;
import org.apache.flink.streaming.api.transformations.StreamTransformation;
import org.apache.flink.streaming.api.transformations.UnionTransformation;
import org.apache.flink.streaming.api.windowing.assigners.GlobalWindows;
-import org.apache.flink.streaming.api.windowing.assigners.SlidingProcessingTimeWindows;
import org.apache.flink.streaming.api.windowing.assigners.SlidingEventTimeWindows;
-import org.apache.flink.streaming.api.windowing.assigners.TumblingProcessingTimeWindows;
+import org.apache.flink.streaming.api.windowing.assigners.SlidingProcessingTimeWindows;
import org.apache.flink.streaming.api.windowing.assigners.TumblingEventTimeWindows;
+import org.apache.flink.streaming.api.windowing.assigners.TumblingProcessingTimeWindows;
import org.apache.flink.streaming.api.windowing.assigners.WindowAssigner;
import org.apache.flink.streaming.api.windowing.evictors.CountEvictor;
import org.apache.flink.streaming.api.windowing.time.Time;
@@ -88,9 +87,9 @@ import org.apache.flink.streaming.runtime.operators.TimestampsAndPunctuatedWater
import org.apache.flink.streaming.runtime.partitioner.BroadcastPartitioner;
import org.apache.flink.streaming.runtime.partitioner.CustomPartitionerWrapper;
import org.apache.flink.streaming.runtime.partitioner.ForwardPartitioner;
-import org.apache.flink.streaming.runtime.partitioner.RescalePartitioner;
-import org.apache.flink.streaming.runtime.partitioner.RebalancePartitioner;
import org.apache.flink.streaming.runtime.partitioner.GlobalPartitioner;
+import org.apache.flink.streaming.runtime.partitioner.RebalancePartitioner;
+import org.apache.flink.streaming.runtime.partitioner.RescalePartitioner;
import org.apache.flink.streaming.runtime.partitioner.ShufflePartitioner;
import org.apache.flink.streaming.runtime.partitioner.StreamPartitioner;
import org.apache.flink.streaming.util.keys.KeySelectorUtil;
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamSink.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamSink.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamSink.java
index d098c98..074d481 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamSink.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamSink.java
@@ -17,9 +17,9 @@
package org.apache.flink.streaming.api.datastream;
-import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.annotation.Internal;
import org.apache.flink.annotation.Public;
+import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.api.common.operators.ResourceSpec;
import org.apache.flink.streaming.api.operators.ChainingStrategy;
import org.apache.flink.streaming.api.operators.StreamSink;
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/IterativeStream.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/IterativeStream.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/IterativeStream.java
index ed87b1b..75699ae 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/IterativeStream.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/IterativeStream.java
@@ -17,8 +17,9 @@
package org.apache.flink.streaming.api.datastream;
-import org.apache.flink.annotation.PublicEvolving;
+import java.util.Collection;
import org.apache.flink.annotation.Public;
+import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.api.common.typeinfo.TypeInformation;
import org.apache.flink.api.java.functions.KeySelector;
import org.apache.flink.api.java.typeutils.TypeExtractor;
@@ -27,8 +28,6 @@ import org.apache.flink.streaming.api.transformations.CoFeedbackTransformation;
import org.apache.flink.streaming.api.transformations.FeedbackTransformation;
import org.apache.flink.streaming.api.transformations.StreamTransformation;
-import java.util.Collection;
-
/**
* The iterative data stream represents the start of an iteration in a {@link DataStream}.
*
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/JoinedStreams.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/JoinedStreams.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/JoinedStreams.java
index d02a2e2..77a252e 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/JoinedStreams.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/JoinedStreams.java
@@ -17,8 +17,10 @@
package org.apache.flink.streaming.api.datastream;
-import org.apache.flink.annotation.PublicEvolving;
+import static java.util.Objects.requireNonNull;
+
import org.apache.flink.annotation.Public;
+import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.api.common.functions.CoGroupFunction;
import org.apache.flink.api.common.functions.FlatJoinFunction;
import org.apache.flink.api.common.functions.JoinFunction;
@@ -33,8 +35,6 @@ import org.apache.flink.streaming.api.windowing.triggers.Trigger;
import org.apache.flink.streaming.api.windowing.windows.Window;
import org.apache.flink.util.Collector;
-import static java.util.Objects.requireNonNull;
-
/**
*{@code JoinedStreams} represents two {@link DataStream DataStreams} that have been joined.
* A streaming join operation is evaluated over elements in a window.
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java
index 6f8fd07..c042f2f 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java
@@ -17,6 +17,10 @@
package org.apache.flink.streaming.api.datastream;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Stack;
+import java.util.UUID;
import org.apache.commons.lang3.StringUtils;
import org.apache.flink.annotation.Internal;
import org.apache.flink.annotation.Public;
@@ -46,8 +50,8 @@ import org.apache.flink.streaming.api.functions.query.QueryableAppendingStateOpe
import org.apache.flink.streaming.api.functions.query.QueryableValueStateOperator;
import org.apache.flink.streaming.api.functions.sink.SinkFunction;
import org.apache.flink.streaming.api.graph.StreamGraphGenerator;
-import org.apache.flink.streaming.api.operators.OneInputStreamOperator;
import org.apache.flink.streaming.api.operators.KeyedProcessOperator;
+import org.apache.flink.streaming.api.operators.OneInputStreamOperator;
import org.apache.flink.streaming.api.operators.StreamGroupedFold;
import org.apache.flink.streaming.api.operators.StreamGroupedReduce;
import org.apache.flink.streaming.api.transformations.OneInputTransformation;
@@ -68,11 +72,6 @@ import org.apache.flink.streaming.api.windowing.windows.Window;
import org.apache.flink.streaming.runtime.partitioner.KeyGroupStreamPartitioner;
import org.apache.flink.streaming.runtime.partitioner.StreamPartitioner;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Stack;
-import java.util.UUID;
-
/**
* A {@code KeyedStream} represents a {@link DataStream} on which operator state is
* partitioned by key using a provided {@link KeySelector}. Typical operations supported by a
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/SingleOutputStreamOperator.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/SingleOutputStreamOperator.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/SingleOutputStreamOperator.java
index d540a9f..d033e98 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/SingleOutputStreamOperator.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/SingleOutputStreamOperator.java
@@ -17,10 +17,13 @@
package org.apache.flink.streaming.api.datastream;
+import static java.util.Objects.requireNonNull;
+
+import java.util.HashMap;
+import java.util.Map;
import org.apache.flink.annotation.Public;
import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.api.common.functions.InvalidTypesException;
-import org.apache.flink.util.OutputTag;
import org.apache.flink.api.common.operators.ResourceSpec;
import org.apache.flink.api.common.typeinfo.TypeHint;
import org.apache.flink.api.common.typeinfo.TypeInformation;
@@ -31,13 +34,9 @@ import org.apache.flink.streaming.api.transformations.PartitionTransformation;
import org.apache.flink.streaming.api.transformations.SideOutputTransformation;
import org.apache.flink.streaming.api.transformations.StreamTransformation;
import org.apache.flink.streaming.runtime.partitioner.StreamPartitioner;
+import org.apache.flink.util.OutputTag;
import org.apache.flink.util.Preconditions;
-import java.util.HashMap;
-import java.util.Map;
-
-import static java.util.Objects.requireNonNull;
-
/**
* {@code SingleOutputStreamOperator} represents a user defined transformation
* applied on a {@link DataStream} with one predefined output type.
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java
index 6104b35..688e9b6 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java
@@ -18,9 +18,12 @@
package org.apache.flink.streaming.api.datastream;
+import static org.apache.flink.util.Preconditions.checkArgument;
+import static org.apache.flink.util.Preconditions.checkNotNull;
+
import org.apache.flink.annotation.Internal;
-import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.annotation.Public;
+import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.api.common.functions.AggregateFunction;
import org.apache.flink.api.common.functions.FoldFunction;
import org.apache.flink.api.common.functions.Function;
@@ -64,21 +67,18 @@ import org.apache.flink.streaming.api.windowing.windows.Window;
import org.apache.flink.streaming.runtime.operators.windowing.AccumulatingProcessingTimeWindowOperator;
import org.apache.flink.streaming.runtime.operators.windowing.AggregatingProcessingTimeWindowOperator;
import org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperator;
+import org.apache.flink.streaming.runtime.operators.windowing.WindowOperator;
import org.apache.flink.streaming.runtime.operators.windowing.functions.InternalAggregateProcessWindowFunction;
import org.apache.flink.streaming.runtime.operators.windowing.functions.InternalIterableProcessWindowFunction;
import org.apache.flink.streaming.runtime.operators.windowing.functions.InternalIterableWindowFunction;
import org.apache.flink.streaming.runtime.operators.windowing.functions.InternalSingleValueProcessWindowFunction;
import org.apache.flink.streaming.runtime.operators.windowing.functions.InternalSingleValueWindowFunction;
-import org.apache.flink.streaming.runtime.operators.windowing.WindowOperator;
import org.apache.flink.streaming.runtime.operators.windowing.functions.InternalWindowFunction;
import org.apache.flink.streaming.runtime.streamrecord.StreamElementSerializer;
import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;
import org.apache.flink.util.OutputTag;
import org.apache.flink.util.Preconditions;
-import static org.apache.flink.util.Preconditions.checkArgument;
-import static org.apache.flink.util.Preconditions.checkNotNull;
-
/**
* A {@code WindowedStream} represents a data stream where elements are grouped by
* key, and for each key, the stream of elements is split into windows based on a
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java
index da65147..8d8abfb 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java
@@ -18,15 +18,15 @@
package org.apache.flink.streaming.api.environment;
+import static java.util.Objects.requireNonNull;
+import static org.apache.flink.util.Preconditions.checkNotNull;
+
import org.apache.flink.annotation.Public;
import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.configuration.ConfigConstants;
import org.apache.flink.runtime.jobgraph.JobStatus;
import org.apache.flink.streaming.api.CheckpointingMode;
-import static java.util.Objects.requireNonNull;
-import static org.apache.flink.util.Preconditions.checkNotNull;
-
/**
* Configuration that captures all checkpointing related settings.
*/
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
index 3f73eb2..7a6c7d6 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
@@ -17,7 +17,16 @@
package org.apache.flink.streaming.api.environment;
+import static org.apache.flink.util.Preconditions.checkNotNull;
+
import com.esotericsoftware.kryo.Serializer;
+import java.io.IOException;
+import java.io.Serializable;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Collection;
+import java.util.Iterator;
+import java.util.List;
import org.apache.flink.annotation.Internal;
import org.apache.flink.annotation.Public;
import org.apache.flink.annotation.PublicEvolving;
@@ -76,16 +85,6 @@ import org.apache.flink.streaming.api.transformations.StreamTransformation;
import org.apache.flink.util.Preconditions;
import org.apache.flink.util.SplittableIterator;
-import java.io.IOException;
-import java.io.Serializable;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.Collection;
-import java.util.Iterator;
-import java.util.List;
-
-import static org.apache.flink.util.Preconditions.checkNotNull;
-
/**
* The StreamExecutionEnvironment is the context in which a streaming program is executed. A
* {@link LocalStreamEnvironment} will cause execution in the current JVM, a
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/AssignerWithPeriodicWatermarks.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/AssignerWithPeriodicWatermarks.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/AssignerWithPeriodicWatermarks.java
index 823a5c3..4621988 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/AssignerWithPeriodicWatermarks.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/AssignerWithPeriodicWatermarks.java
@@ -18,11 +18,10 @@
package org.apache.flink.streaming.api.functions;
+import javax.annotation.Nullable;
import org.apache.flink.api.common.ExecutionConfig;
import org.apache.flink.streaming.api.watermark.Watermark;
-import javax.annotation.Nullable;
-
/**
* The {@code AssignerWithPeriodicWatermarks} assigns event time timestamps to elements,
* and generates low watermarks that signal event time progress within the stream.
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/AssignerWithPunctuatedWatermarks.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/AssignerWithPunctuatedWatermarks.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/AssignerWithPunctuatedWatermarks.java
index a69a839..2040e77 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/AssignerWithPunctuatedWatermarks.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/AssignerWithPunctuatedWatermarks.java
@@ -18,9 +18,8 @@
package org.apache.flink.streaming.api.functions;
-import org.apache.flink.streaming.api.watermark.Watermark;
-
import javax.annotation.Nullable;
+import org.apache.flink.streaming.api.watermark.Watermark;
/**
* The {@code AssignerWithPunctuatedWatermarks} assigns event time timestamps to elements,
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/aggregation/SumAggregator.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/aggregation/SumAggregator.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/aggregation/SumAggregator.java
index 58b5981..86d91d0 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/aggregation/SumAggregator.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/aggregation/SumAggregator.java
@@ -22,9 +22,9 @@ import org.apache.flink.api.common.ExecutionConfig;
import org.apache.flink.api.common.typeinfo.TypeInformation;
import org.apache.flink.api.common.typeutils.TypeSerializer;
import org.apache.flink.api.java.tuple.Tuple;
-import org.apache.flink.streaming.util.typeutils.FieldAccessorFactory;
import org.apache.flink.api.java.typeutils.TupleTypeInfo;
import org.apache.flink.streaming.util.typeutils.FieldAccessor;
+import org.apache.flink.streaming.util.typeutils.FieldAccessorFactory;
/**
* An {@link AggregationFunction} that sums up fields.
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/aggregation/SumFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/aggregation/SumFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/aggregation/SumFunction.java
index a177c58..9bbac3d 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/aggregation/SumFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/aggregation/SumFunction.java
@@ -17,9 +17,8 @@
package org.apache.flink.streaming.api.functions.aggregation;
-import org.apache.flink.annotation.Internal;
-
import java.io.Serializable;
+import org.apache.flink.annotation.Internal;
/**
* Internal function for summing up contents of fields. This is used with {@link SumAggregator}.
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/AsyncFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/AsyncFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/AsyncFunction.java
index 5bb4459..c0cde30 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/AsyncFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/AsyncFunction.java
@@ -18,12 +18,11 @@
package org.apache.flink.streaming.api.functions.async;
+import java.io.Serializable;
import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.api.common.functions.Function;
import org.apache.flink.streaming.api.functions.async.collector.AsyncCollector;
-import java.io.Serializable;
-
/**
* A function to trigger Async I/O operation.
*
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/RichAsyncFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/RichAsyncFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/RichAsyncFunction.java
index 552f009..3885b1c 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/RichAsyncFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/RichAsyncFunction.java
@@ -18,6 +18,9 @@
package org.apache.flink.streaming.api.functions.async;
+import java.io.Serializable;
+import java.util.List;
+import java.util.Map;
import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.api.common.ExecutionConfig;
import org.apache.flink.api.common.accumulators.Accumulator;
@@ -47,10 +50,6 @@ import org.apache.flink.streaming.api.functions.async.collector.AsyncCollector;
import org.apache.flink.types.Value;
import org.apache.flink.util.Preconditions;
-import java.io.Serializable;
-import java.util.List;
-import java.util.Map;
-
/**
* Rich variant of the {@link AsyncFunction}. As a {@link RichFunction}, it gives access to the
* {@link RuntimeContext} and provides setup and teardown methods:
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/collector/AsyncCollector.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/collector/AsyncCollector.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/collector/AsyncCollector.java
index 964c13a..9c07d1a 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/collector/AsyncCollector.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/collector/AsyncCollector.java
@@ -18,9 +18,8 @@
package org.apache.flink.streaming.api.functions.async.collector;
-import org.apache.flink.annotation.PublicEvolving;
-
import java.util.Collection;
+import org.apache.flink.annotation.PublicEvolving;
/**
* {@link AsyncCollector} collects data / error in user codes while processing async i/o.
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/SocketClientSink.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/SocketClientSink.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/SocketClientSink.java
index 21c35a3..44a9677 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/SocketClientSink.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/SocketClientSink.java
@@ -17,21 +17,19 @@
package org.apache.flink.streaming.api.functions.sink;
+import static org.apache.flink.util.Preconditions.checkArgument;
+import static org.apache.flink.util.Preconditions.checkNotNull;
+
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
-
import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.runtime.util.SerializableObject;
import org.apache.flink.streaming.util.serialization.SerializationSchema;
-
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import static org.apache.flink.util.Preconditions.checkArgument;
-import static org.apache.flink.util.Preconditions.checkNotNull;
-
/**
* Socket client that acts as a streaming sink. The data is sent to a Socket as a byte array.
*
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteFormat.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteFormat.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteFormat.java
index 65915af..270b7b5 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteFormat.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteFormat.java
@@ -17,10 +17,9 @@
package org.apache.flink.streaming.api.functions.sink;
-import org.apache.flink.annotation.PublicEvolving;
-
import java.io.Serializable;
import java.util.ArrayList;
+import org.apache.flink.annotation.PublicEvolving;
/**
* Abstract class for formatting the output of the writeAsText and writeAsCsv
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteFormatAsCsv.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteFormatAsCsv.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteFormatAsCsv.java
index 234dd39..ed1451b 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteFormatAsCsv.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteFormatAsCsv.java
@@ -17,13 +17,12 @@
package org.apache.flink.streaming.api.functions.sink;
-import org.apache.flink.annotation.PublicEvolving;
-
import java.io.BufferedWriter;
import java.io.FileWriter;
import java.io.IOException;
import java.io.PrintWriter;
import java.util.ArrayList;
+import org.apache.flink.annotation.PublicEvolving;
/**
* Writes tuples in csv format.
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteFormatAsText.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteFormatAsText.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteFormatAsText.java
index e331ed9..eb9ddcd 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteFormatAsText.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteFormatAsText.java
@@ -17,13 +17,12 @@
package org.apache.flink.streaming.api.functions.sink;
-import org.apache.flink.annotation.PublicEvolving;
-
import java.io.BufferedWriter;
import java.io.FileWriter;
import java.io.IOException;
import java.io.PrintWriter;
import java.util.ArrayList;
+import org.apache.flink.annotation.PublicEvolving;
/**
* Writes tuples in text format.
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteSinkFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteSinkFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteSinkFunction.java
index fa2bd8d..9c8f5bd 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteSinkFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteSinkFunction.java
@@ -17,11 +17,10 @@
package org.apache.flink.streaming.api.functions.sink;
-import org.apache.flink.annotation.PublicEvolving;
-
import java.io.FileNotFoundException;
import java.io.PrintWriter;
import java.util.ArrayList;
+import org.apache.flink.annotation.PublicEvolving;
/**
* Simple implementation of the SinkFunction writing tuples as simple text to
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java
index 8694135..1b76733 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java
@@ -16,6 +16,14 @@
*/
package org.apache.flink.streaming.api.functions.source;
+import java.io.FileNotFoundException;
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.TreeMap;
import org.apache.flink.annotation.Internal;
import org.apache.flink.annotation.VisibleForTesting;
import org.apache.flink.api.common.io.FileInputFormat;
@@ -36,15 +44,6 @@ import org.apache.flink.util.Preconditions;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import java.io.FileNotFoundException;
-import java.io.IOException;
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.TreeMap;
-
/**
* This is the single (non-parallel) monitoring task which takes a {@link FileInputFormat}
* and, depending on the {@link FileProcessingMode} and the {@link FilePathFilter}, it is responsible for:
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java
index 6e8d01d..54b6a03 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java
@@ -16,6 +16,17 @@
*/
package org.apache.flink.streaming.api.functions.source;
+import static org.apache.flink.util.Preconditions.checkNotNull;
+import static org.apache.flink.util.Preconditions.checkState;
+
+import java.io.IOException;
+import java.io.ObjectInputStream;
+import java.io.Serializable;
+import java.util.ArrayList;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.PriorityQueue;
+import java.util.Queue;
import org.apache.flink.annotation.Internal;
import org.apache.flink.api.common.ExecutionConfig;
import org.apache.flink.api.common.io.CheckpointableInputFormat;
@@ -42,18 +53,6 @@ import org.apache.flink.util.Preconditions;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import java.io.IOException;
-import java.io.ObjectInputStream;
-import java.io.Serializable;
-import java.util.ArrayList;
-import java.util.LinkedList;
-import java.util.List;
-import java.util.PriorityQueue;
-import java.util.Queue;
-
-import static org.apache.flink.util.Preconditions.checkState;
-import static org.apache.flink.util.Preconditions.checkNotNull;
-
/**
* The operator that reads the {@link TimestampedFileInputSplit splits} received from the preceding
* {@link ContinuousFileMonitoringFunction}. Contrary to the {@link ContinuousFileMonitoringFunction}
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FileMonitoringFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FileMonitoringFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FileMonitoringFunction.java
index 8cee0bc..2f91227 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FileMonitoringFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FileMonitoringFunction.java
@@ -17,6 +17,12 @@
package org.apache.flink.streaming.api.functions.source;
+import java.io.IOException;
+import java.net.URI;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
import org.apache.flink.annotation.Internal;
import org.apache.flink.api.java.tuple.Tuple3;
import org.apache.flink.core.fs.FileStatus;
@@ -25,13 +31,6 @@ import org.apache.flink.core.fs.Path;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import java.io.IOException;
-import java.net.URI;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
/**
* A {@link SourceFunction} that monitors a directory and sends events downstream when it detects
* new files. Used together with {@link FileReadFunction}.
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FromElementsFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FromElementsFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FromElementsFunction.java
index 691d3d6..745a26b 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FromElementsFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FromElementsFunction.java
@@ -17,6 +17,13 @@
package org.apache.flink.streaming.api.functions.source;
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Collection;
+import java.util.List;
import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.api.common.state.ListState;
import org.apache.flink.api.common.state.ListStateDescriptor;
@@ -30,14 +37,6 @@ import org.apache.flink.runtime.state.FunctionSnapshotContext;
import org.apache.flink.streaming.api.checkpoint.CheckpointedFunction;
import org.apache.flink.util.Preconditions;
-import java.io.ByteArrayInputStream;
-import java.io.ByteArrayOutputStream;
-import java.io.IOException;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.Collection;
-import java.util.List;
-
/**
* A stream source function that returns a sequence of elements.
*
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FromIteratorFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FromIteratorFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FromIteratorFunction.java
index a8b527f..b844a0a 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FromIteratorFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FromIteratorFunction.java
@@ -17,9 +17,8 @@
package org.apache.flink.streaming.api.functions.source;
-import org.apache.flink.annotation.PublicEvolving;
-
import java.util.Iterator;
+import org.apache.flink.annotation.PublicEvolving;
/**
* A {@link SourceFunction} that reads elements from an {@link Iterator} and emits them.
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FromSplittableIteratorFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FromSplittableIteratorFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FromSplittableIteratorFunction.java
index db6c8a2..68e18bb 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FromSplittableIteratorFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FromSplittableIteratorFunction.java
@@ -17,12 +17,11 @@
package org.apache.flink.streaming.api.functions.source;
+import java.util.Iterator;
import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.util.SplittableIterator;
-import java.util.Iterator;
-
/**
* A {@link SourceFunction} that reads elements from an {@link SplittableIterator} and emits them.
*/
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/InputFormatSourceFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/InputFormatSourceFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/InputFormatSourceFunction.java
index 3fdedf1..e6e6ea3 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/InputFormatSourceFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/InputFormatSourceFunction.java
@@ -17,6 +17,8 @@
package org.apache.flink.streaming.api.functions.source;
+import java.util.Iterator;
+import java.util.NoSuchElementException;
import org.apache.flink.annotation.Internal;
import org.apache.flink.api.common.io.InputFormat;
import org.apache.flink.api.common.io.RichInputFormat;
@@ -29,9 +31,6 @@ import org.apache.flink.runtime.jobgraph.tasks.InputSplitProvider;
import org.apache.flink.runtime.jobgraph.tasks.InputSplitProviderException;
import org.apache.flink.streaming.api.operators.StreamingRuntimeContext;
-import java.util.Iterator;
-import java.util.NoSuchElementException;
-
/**
* A {@link SourceFunction} that reads data using an {@link InputFormat}.
*/
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/MultipleIdsMessageAcknowledgingSourceBase.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/MultipleIdsMessageAcknowledgingSourceBase.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/MultipleIdsMessageAcknowledgingSourceBase.java
index 965dc02..ceef4e0 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/MultipleIdsMessageAcknowledgingSourceBase.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/MultipleIdsMessageAcknowledgingSourceBase.java
@@ -18,6 +18,11 @@
package org.apache.flink.streaming.api.functions.source;
+import java.util.ArrayDeque;
+import java.util.ArrayList;
+import java.util.Deque;
+import java.util.Iterator;
+import java.util.List;
import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.api.common.typeinfo.TypeInformation;
import org.apache.flink.api.java.tuple.Tuple2;
@@ -26,12 +31,6 @@ import org.apache.flink.runtime.state.FunctionSnapshotContext;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import java.util.ArrayDeque;
-import java.util.ArrayList;
-import java.util.Deque;
-import java.util.Iterator;
-import java.util.List;
-
/**
* Abstract base class for data sources that receive elements from a message queue and
* acknowledge them back by IDs. In contrast to {@link MessageAcknowledgingSourceBase}, this source
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunction.java
index dd852a4..e7d1673 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunction.java
@@ -17,19 +17,17 @@
package org.apache.flink.streaming.api.functions.source;
-import org.apache.flink.annotation.PublicEvolving;
-import org.apache.flink.util.IOUtils;
-
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
+import static org.apache.flink.util.Preconditions.checkArgument;
+import static org.apache.flink.util.Preconditions.checkNotNull;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.InetSocketAddress;
import java.net.Socket;
-
-import static org.apache.flink.util.Preconditions.checkArgument;
-import static org.apache.flink.util.Preconditions.checkNotNull;
+import org.apache.flink.annotation.PublicEvolving;
+import org.apache.flink.util.IOUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* A source function that reads strings from a socket. The source will read bytes from the socket
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java
index df5f9b6..0db8984 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java
@@ -18,15 +18,14 @@
package org.apache.flink.streaming.api.functions.source;
-import org.apache.flink.annotation.PublicEvolving;
+import java.io.Serializable;
import org.apache.flink.annotation.Public;
+import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.api.common.functions.Function;
import org.apache.flink.streaming.api.TimeCharacteristic;
import org.apache.flink.streaming.api.functions.TimestampAssigner;
import org.apache.flink.streaming.api.watermark.Watermark;
-import java.io.Serializable;
-
/**
* Base interface for all stream data sources in Flink. The contract of a stream source
* is the following: When the source should start emitting elements, the {@link #run} method
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/StatefulSequenceSource.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/StatefulSequenceSource.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/StatefulSequenceSource.java
index b6a0c3b..598ccb3 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/StatefulSequenceSource.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/StatefulSequenceSource.java
@@ -17,6 +17,8 @@
*/
package org.apache.flink.streaming.api.functions.source;
+import java.util.ArrayDeque;
+import java.util.Deque;
import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.api.common.state.ListState;
import org.apache.flink.api.common.state.ListStateDescriptor;
@@ -26,9 +28,6 @@ import org.apache.flink.runtime.state.FunctionSnapshotContext;
import org.apache.flink.streaming.api.checkpoint.CheckpointedFunction;
import org.apache.flink.util.Preconditions;
-import java.util.ArrayDeque;
-import java.util.Deque;
-
/**
* A stateful streaming source that emits each number from a given interval exactly once,
* possibly in parallel.
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/TimestampedFileInputSplit.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/TimestampedFileInputSplit.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/TimestampedFileInputSplit.java
index 07eb1d9..9a679b9 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/TimestampedFileInputSplit.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/TimestampedFileInputSplit.java
@@ -17,12 +17,11 @@
package org.apache.flink.streaming.api.functions.source;
+import java.io.Serializable;
import org.apache.flink.core.fs.FileInputSplit;
import org.apache.flink.core.fs.Path;
import org.apache.flink.util.Preconditions;
-import java.io.Serializable;
-
/**
* An extended {@link FileInputSplit} that also includes information about:
* <ul>
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/timestamps/AscendingTimestampExtractor.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/timestamps/AscendingTimestampExtractor.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/timestamps/AscendingTimestampExtractor.java
index ceed996..500348a 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/timestamps/AscendingTimestampExtractor.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/timestamps/AscendingTimestampExtractor.java
@@ -18,15 +18,14 @@
package org.apache.flink.streaming.api.functions.timestamps;
-import org.apache.flink.annotation.PublicEvolving;
+import static java.util.Objects.requireNonNull;
+import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.streaming.api.functions.AssignerWithPeriodicWatermarks;
import org.apache.flink.streaming.api.watermark.Watermark;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import static java.util.Objects.requireNonNull;
-
/**
* A timestamp assigner and watermark generator for streams where timestamps are monotonously
* ascending. In this case, the local watermarks for the streams are easy to generate, because
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AggregateApplyAllWindowFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AggregateApplyAllWindowFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AggregateApplyAllWindowFunction.java
index e20b878..3d6c1e1 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AggregateApplyAllWindowFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AggregateApplyAllWindowFunction.java
@@ -18,14 +18,13 @@
package org.apache.flink.streaming.api.functions.windowing;
+import java.util.Collections;
import org.apache.flink.annotation.Internal;
import org.apache.flink.api.common.functions.AggregateFunction;
import org.apache.flink.api.java.operators.translation.WrappingFunction;
import org.apache.flink.streaming.api.windowing.windows.Window;
import org.apache.flink.util.Collector;
-import java.util.Collections;
-
/**
* A {@link AllWindowFunction} that composes an {@link AggregateFunction} and {@link AllWindowFunction}.
* Upon invocation, this first applies {@code AggregateFunction} to the input, and then
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AggregateApplyWindowFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AggregateApplyWindowFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AggregateApplyWindowFunction.java
index 0341084..ce5363f 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AggregateApplyWindowFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AggregateApplyWindowFunction.java
@@ -17,14 +17,13 @@
*/
package org.apache.flink.streaming.api.functions.windowing;
+import java.util.Collections;
import org.apache.flink.annotation.Internal;
import org.apache.flink.api.common.functions.AggregateFunction;
import org.apache.flink.api.java.operators.translation.WrappingFunction;
import org.apache.flink.streaming.api.windowing.windows.Window;
import org.apache.flink.util.Collector;
-import java.util.Collections;
-
/**
* A {@link WindowFunction} that composes an {@link AggregateFunction} and {@link WindowFunction}.
* Upon invocation, this first applies {@code AggregateFunction} to the input, and then
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AllWindowFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AllWindowFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AllWindowFunction.java
index c497b4a..04817b4 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AllWindowFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AllWindowFunction.java
@@ -18,13 +18,12 @@
package org.apache.flink.streaming.api.functions.windowing;
+import java.io.Serializable;
import org.apache.flink.annotation.Public;
import org.apache.flink.api.common.functions.Function;
import org.apache.flink.streaming.api.windowing.windows.Window;
import org.apache.flink.util.Collector;
-import java.io.Serializable;
-
/**
* Base interface for functions that are evaluated over non-keyed windows.
*
http://git-wip-us.apache.org/repos/asf/flink/blob/922352ac/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyAllWindowFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyAllWindowFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyAllWindowFunction.java
index 2514355..30662f0 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyAllWindowFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyAllWindowFunction.java
@@ -17,6 +17,10 @@
*/
package org.apache.flink.streaming.api.functions.windowing;
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.util.Collections;
import org.apache.flink.annotation.Internal;
import org.apache.flink.api.common.ExecutionConfig;
import org.apache.flink.api.common.functions.FoldFunction;
@@ -30,11 +34,6 @@ import org.apache.flink.streaming.api.operators.OutputTypeConfigurable;
import org.apache.flink.streaming.api.windowing.windows.Window;
import org.apache.flink.util.Collector;
-import java.io.ByteArrayInputStream;
-import java.io.ByteArrayOutputStream;
-import java.io.IOException;
-import java.util.Collections;
-
/**
* Internal {@link AllWindowFunction} that is used for implementing a fold on a window configuration
* that only allows {@link AllWindowFunction} and cannot directly execute a {@link FoldFunction}.