You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by mb...@apache.org on 2015/05/29 15:46:10 UTC
[6/6] flink git commit: [streaming] Build warnings eliminated from
streaming-core
[streaming] Build warnings eliminated from streaming-core
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0930179f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0930179f
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0930179f
Branch: refs/heads/master
Commit: 0930179f41dec179cb60882f699ee4ce8ba34d61
Parents: 0fd6023
Author: mbalassi <mb...@apache.org>
Authored: Thu May 28 16:32:37 2015 +0200
Committer: mbalassi <mb...@apache.org>
Committed: Fri May 29 15:08:33 2015 +0200
----------------------------------------------------------------------
.../api/datastream/ConnectedDataStream.java | 15 ++------
.../streaming/api/datastream/DataStream.java | 37 ++++++++++----------
.../api/datastream/DiscretizedStream.java | 7 ++--
.../api/datastream/GroupedDataStream.java | 11 ++----
.../api/datastream/IterativeDataStream.java | 6 ++--
.../api/datastream/WindowedDataStream.java | 4 +--
.../datastream/temporal/TemporalOperator.java | 4 +--
.../environment/StreamExecutionEnvironment.java | 35 ++++++++----------
.../functions/source/FileSourceFunction.java | 1 +
.../api/operators/windowing/WindowMerger.java | 1 +
.../ExtractionAwareDeltaFunction.java | 6 ++--
.../streaming/api/windowing/helper/Delta.java | 1 +
.../streaming/api/windowing/helper/Time.java | 2 +-
.../policy/CloneableMultiEvictionPolicy.java | 4 +--
.../windowing/policy/CountEvictionPolicy.java | 2 +-
.../api/windowing/policy/DeltaPolicy.java | 1 +
.../api/windowing/policy/TimeTriggerPolicy.java | 14 +++-----
.../streaming/runtime/tasks/OutputHandler.java | 2 +-
.../api/StreamExecutionEnvironmentTest.java | 1 +
.../SlidingTimeGroupedPreReducerTest.java | 1 +
.../windowbuffer/SlidingTimePreReducerTest.java | 1 +
21 files changed, 69 insertions(+), 87 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/0930179f/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/ConnectedDataStream.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/ConnectedDataStream.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/ConnectedDataStream.java
index 7362802..02db538 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/ConnectedDataStream.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/ConnectedDataStream.java
@@ -17,7 +17,6 @@
package org.apache.flink.streaming.api.datastream;
-import org.apache.flink.api.common.functions.RichFlatMapFunction;
import org.apache.flink.api.common.typeinfo.TypeInformation;
import org.apache.flink.api.java.ClosureCleaner;
import org.apache.flink.api.java.Utils;
@@ -28,8 +27,6 @@ import org.apache.flink.streaming.api.functions.co.CoFlatMapFunction;
import org.apache.flink.streaming.api.functions.co.CoMapFunction;
import org.apache.flink.streaming.api.functions.co.CoReduceFunction;
import org.apache.flink.streaming.api.functions.co.CoWindowFunction;
-import org.apache.flink.streaming.api.functions.co.RichCoMapFunction;
-import org.apache.flink.streaming.api.functions.co.RichCoReduceFunction;
import org.apache.flink.streaming.api.graph.StreamGraph;
import org.apache.flink.streaming.api.operators.TwoInputStreamOperator;
import org.apache.flink.streaming.api.operators.co.CoStreamFlatMap;
@@ -232,9 +229,7 @@ public class ConnectedDataStream<IN1, IN2> {
* the output to a common type. The transformation calls a
* {@link CoMapFunction#map1} for each element of the first input and
* {@link CoMapFunction#map2} for each element of the second input. Each
- * CoMapFunction call returns exactly one element. The user can also extend
- * {@link RichCoMapFunction} to gain access to other features provided by
- * the {@link RichFuntion} interface.
+ * CoMapFunction call returns exactly one element.
*
* @param coMapper
* The CoMapFunction used to jointly transform the two input
@@ -258,9 +253,7 @@ public class ConnectedDataStream<IN1, IN2> {
* {@link CoFlatMapFunction#flatMap1} for each element of the first input
* and {@link CoFlatMapFunction#flatMap2} for each element of the second
* input. Each CoFlatMapFunction call returns any number of elements
- * including none. The user can also extend {@link RichFlatMapFunction} to
- * gain access to other features provided by the {@link RichFuntion}
- * interface.
+ * including none.
*
* @param coFlatMapper
* The CoFlatMapFunction used to jointly transform the two input
@@ -285,9 +278,7 @@ public class ConnectedDataStream<IN1, IN2> {
* sliding batch/window of the data stream. If the connected data stream is
* grouped then the reducer is applied on every group of elements sharing
* the same key. This type of reduce is much faster than reduceGroup since
- * the reduce function can be applied incrementally. The user can also
- * extend the {@link RichCoReduceFunction} to gain access to other features
- * provided by the {@link RichFuntion} interface.
+ * the reduce function can be applied incrementally.
*
* @param coReducer
* The {@link CoReduceFunction} that will be called for every
http://git-wip-us.apache.org/repos/asf/flink/blob/0930179f/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
index 5165ec7..7edbec5 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
@@ -378,7 +378,7 @@ public class DataStream<OUT> {
* instances of the next processing operator.
*
* @param keySelector
- * @return
+ * @return The partitioned DataStream
*/
protected DataStream<OUT> partitionBy(KeySelector<OUT, ?> keySelector) {
return setConnectionType(new FieldsPartitioner<OUT>(clean(keySelector)));
@@ -607,17 +607,13 @@ public class DataStream<OUT> {
* Initiates a Project transformation on a {@link Tuple} {@link DataStream}.<br/>
* <b>Note: Only Tuple DataStreams can be projected.</b></br> The
* transformation projects each Tuple of the DataSet onto a (sub)set of
- * fields.</br> This method returns a {@link StreamProjection} on which
- * {@link StreamProjection#types(Class)} needs to be called to completed the
- * transformation.
+ * fields.
*
* @param fieldIndexes
* The field indexes of the input tuples that are retained. The
* order of fields in the output tuple corresponds to the order
* of field indexes.
- * @return A StreamProjection that needs to be converted into a DataStream
- * to complete the project transformation by calling
- * {@link StreamProjection#types(Class)}.
+ * @return The projected DataStream
*
* @see Tuple
* @see DataStream
@@ -639,8 +635,8 @@ public class DataStream<OUT> {
* {@link StreamCrossOperator#onWindow} should be called to define the
* window.
* <p>
- * Call {@link StreamCrossOperator.CrossWindow#with(crossFunction)} to
- * define a custom cross function.
+ * Call {@link StreamCrossOperator.CrossWindow#with(org.apache.flink.api.common.functions.CrossFunction)}
+ * to define a custom cross function.
*
* @param dataStreamToCross
* The other DataStream with which this DataStream is crossed.
@@ -658,14 +654,17 @@ public class DataStream<OUT> {
* {@link DataStream}s on key equality over a specified time window.</br>
*
* This method returns a {@link StreamJoinOperator} on which the
- * {@link StreamJoinOperator#onWindow} should be called to define the
- * window, and then the {@link StreamJoinOperator.JoinWindow#where} and
- * {@link StreamJoinOperator.JoinPredicate#equalTo} can be used to define
- * the join keys.</p> The user can also use the
- * {@link StreamJoinOperator.JoinedStream#with(joinFunction)} to apply
- * custom join function.
- *
- * @param other
+ * {@link StreamJoinOperator#onWindow(long, java.util.concurrent.TimeUnit)}
+ * should be called to define the window, and then the
+ * {@link StreamJoinOperator.JoinWindow#where(int...)} and
+ * {@link StreamJoinOperator.JoinPredicate#equalTo(int...)} can be used to define
+ * the join keys.
+ * <p>
+ * The user can also use the
+ * {@link StreamJoinOperator.JoinedStream#with(org.apache.flink.api.common.functions.JoinFunction)}
+ * to apply a custom join function.
+ *
+ * @param dataStreamToJoin
* The other DataStream with which this DataStream is joined.
* @return A {@link StreamJoinOperator} to continue the definition of the
* Join transformation.
@@ -923,11 +922,11 @@ public class DataStream<OUT> {
* to a grouped data stream, the windows (evictions) and slide sizes
* (triggers) will be computed on a per group basis. </br></br> For more
* advanced control over the trigger and eviction policies please refer to
- * {@link #window(trigger, eviction)} </br> </br> For example to create a
+ * {@link #window(TriggerPolicy, EvictionPolicy)} </br> </br> For example to create a
* sum every 5 seconds in a tumbling fashion:</br>
* {@code ds.window(Time.of(5, TimeUnit.SECONDS)).sum(field)} </br></br> To
* create sliding windows use the
- * {@link WindowedDataStream#every(WindowingHelper...)} </br></br> The same
+ * {@link WindowedDataStream#every(WindowingHelper)} </br></br> The same
* example with 3 second slides:</br>
*
* {@code ds.window(Time.of(5, TimeUnit.SECONDS)).every(Time.of(3,
http://git-wip-us.apache.org/repos/asf/flink/blob/0930179f/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DiscretizedStream.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DiscretizedStream.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DiscretizedStream.java
index d70c4b8..4083bb8 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DiscretizedStream.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DiscretizedStream.java
@@ -53,9 +53,8 @@ import org.apache.flink.streaming.api.windowing.WindowUtils.WindowTransformation
/**
* A {@link DiscretizedStream} represents a data stream that has been divided
* into windows (predefined chunks). User defined function such as
- * {@link #reduceWindow(ReduceFunction)}, {@link #mapWindow()},
- * {@link #foldWindow(FoldFunction, initialValue)} or aggregations can be
- * applied to the windows.
+ * {@link #reduceWindow(ReduceFunction)}, {@link #mapWindow(WindowMapFunction)},
+ * or aggregations can be applied to the windows.
*
* @param <OUT>
* The output type of the {@link DiscretizedStream}
@@ -127,7 +126,7 @@ public class DiscretizedStream<OUT> extends WindowedDataStream<OUT> {
*
* @param reduceFunction
* The reduce function to be applied on the windows
- * @return
+ * @return The reduced DataStream
*/
protected DiscretizedStream<OUT> timeReduce(ReduceFunction<OUT> reduceFunction) {
http://git-wip-us.apache.org/repos/asf/flink/blob/0930179f/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/GroupedDataStream.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/GroupedDataStream.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/GroupedDataStream.java
index aed02dc..62e7781 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/GroupedDataStream.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/GroupedDataStream.java
@@ -19,7 +19,6 @@ package org.apache.flink.streaming.api.datastream;
import org.apache.flink.api.common.functions.FoldFunction;
import org.apache.flink.api.common.functions.ReduceFunction;
-import org.apache.flink.api.common.functions.RichReduceFunction;
import org.apache.flink.api.common.typeinfo.TypeInformation;
import org.apache.flink.api.java.Utils;
import org.apache.flink.api.java.functions.KeySelector;
@@ -32,7 +31,7 @@ import org.apache.flink.streaming.runtime.partitioner.StreamPartitioner;
/**
* A GroupedDataStream represents a {@link DataStream} which has been
* partitioned by the given {@link KeySelector}. Operators like {@link #reduce},
- * {@link #batchReduce} etc. can be applied on the {@link GroupedDataStream} to
+ * {@link #fold} etc. can be applied on the {@link GroupedDataStream} to
* get additional functionality by the grouping.
*
* @param <OUT>
@@ -67,9 +66,7 @@ public class GroupedDataStream<OUT> extends DataStream<OUT> {
* Applies a reduce transformation on the grouped data stream grouped on by
* the given key position. The {@link ReduceFunction} will receive input
* values based on the key value. Only input values with the same key will
- * go to the same reducer.The user can also extend
- * {@link RichReduceFunction} to gain access to other features provided by
- * the {@link RichFuntion} interface.
+ * go to the same reducer.
*
* @param reducer
* The {@link ReduceFunction} that will be called for every
@@ -86,9 +83,7 @@ public class GroupedDataStream<OUT> extends DataStream<OUT> {
* Applies a fold transformation on the grouped data stream grouped on by
* the given key position. The {@link FoldFunction} will receive input
* values based on the key value. Only input values with the same key will
- * go to the same folder.The user can also extend {@link RichFoldFunction}
- * to gain access to other features provided by the {@link RichFuntion}
- * interface.
+ * go to the same folder.
*
* @param folder
* The {@link FoldFunction} that will be called for every element
http://git-wip-us.apache.org/repos/asf/flink/blob/0930179f/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/IterativeDataStream.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/IterativeDataStream.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/IterativeDataStream.java
index 178f2eb..581087d 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/IterativeDataStream.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/IterativeDataStream.java
@@ -42,11 +42,11 @@ public class IterativeDataStream<IN> extends
* program part that will be fed back to the start of the iteration. </br>
* </br>A common usage pattern for streaming iterations is to use output
* splitting to send a part of the closing data stream to the head. Refer to
- * {@link SingleOutputStreamOperator#split(OutputSelector)} for more
- * information.
+ * {@link DataStream#split(org.apache.flink.streaming.api.collector.selector.OutputSelector)}
+ * for more information.
*
*
- * @param iterationResult
+ * @param iterationTail
* The data stream that is fed back to the next iteration head.
* @return Returns the stream that was fed back to the iteration. In most
* cases no further transformation are applied on this stream.
http://git-wip-us.apache.org/repos/asf/flink/blob/0930179f/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/WindowedDataStream.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/WindowedDataStream.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/WindowedDataStream.java
index a10c79e..5d769ca 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/WindowedDataStream.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/WindowedDataStream.java
@@ -76,7 +76,7 @@ import org.apache.flink.streaming.util.keys.KeySelectorUtil;
/**
* A {@link WindowedDataStream} represents a data stream that has been
* discretised into windows. User defined function such as
- * {@link #reduceWindow(ReduceFunction)}, {@link #mapWindow()} or aggregations
+ * {@link #reduceWindow(ReduceFunction)}, {@link #mapWindow(WindowMapFunction)} or aggregations
* can be applied to the windows. The results of these transformations are also
* WindowedDataStreams of the same discretisation unit.
*
@@ -610,7 +610,7 @@ public class WindowedDataStream<OUT> {
* stream's underlying type. A dot can be used to drill down into objects,
* as in {@code "field1.getInnerField2()" }.
*
- * @param positionToSum
+ * @param field
* The field to sum
* @return The transformed DataStream.
*/
http://git-wip-us.apache.org/repos/asf/flink/blob/0930179f/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/temporal/TemporalOperator.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/temporal/TemporalOperator.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/temporal/TemporalOperator.java
index 75332d1..3fe7eb7 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/temporal/TemporalOperator.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/temporal/TemporalOperator.java
@@ -69,7 +69,7 @@ public abstract class TemporalOperator<I1, I2, OP extends TemporalWindow<OP>> {
* transformed.To define sliding windows call {@link TemporalWindow#every}
* on the resulting operator.
*
- * @param windowSize
+ * @param length
* The size of the window in milliseconds.
* @param timeStamp1
* The timestamp used to extract time from the elements of the
@@ -89,7 +89,7 @@ public abstract class TemporalOperator<I1, I2, OP extends TemporalWindow<OP>> {
* transformed.To define sliding windows call {@link TemporalWindow#every}
* on the resulting operator.
*
- * @param windowSize
+ * @param length
* The size of the window in milliseconds.
* @param timeStamp1
* The timestamp used to extract time from the elements of the
http://git-wip-us.apache.org/repos/asf/flink/blob/0930179f/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
index 651da63..da1ba73 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
@@ -251,7 +251,7 @@ public abstract class StreamExecutionEnvironment {
* Sets the {@link StateHandleProvider} used for storing operator state
* checkpoints when checkpointing is enabled.
* <p>
- * An example would be using a {@link FileStateHandle#createProvider(Path)}
+ * An example would be using a {@link FileStateHandle#createProvider(String)}
* to use any Flink supported file system as a state backend
*
*/
@@ -857,16 +857,14 @@ public abstract class StreamExecutionEnvironment {
}
/**
- * Generic method to create an input data stream with {@link org.apache.flink.api.common.io.InputFormat}. The data stream will not be immediately
- * created - instead, this method returns a data stream that will be lazily created from the input format once the
- * program is executed.
+ * Generic method to create an input data stream with {@link org.apache.flink.api.common.io.InputFormat}.
* <p/>
* Since all data streams need specific information about their types, this method needs to determine the type of
* the data produced by the input format. It will attempt to determine the data type by reflection, unless the
* input
- * format implements the {@link org.apache.flink.api.java.typeutils .ResultTypeQueryable} interface. In the latter
- * case, this method will invoke the {@link org.apache.flink.api.java.typeutils
- * .ResultTypeQueryable#getProducedType()} method to determine data type produced by the input format.
+ * format implements the {@link org.apache.flink.api.java.typeutils.ResultTypeQueryable} interface. In the latter
+ * case, this method will invoke the {@link org.apache.flink.api.java.typeutils.ResultTypeQueryable#getProducedType()}
+ * method to determine data type produced by the input format.
*
* @param inputFormat
* The input format used to create the data stream
@@ -879,14 +877,12 @@ public abstract class StreamExecutionEnvironment {
}
/**
- * Generic method to create an input data stream with {@link org.apache.flink.api.common.io.InputFormat}. The data stream will not be immediately
- * created - instead, this method returns a data stream that will be lazily created from the input format once the
- * program is executed.
- * <p/>
+ * Generic method to create an input data stream with {@link org.apache.flink.api.common.io.InputFormat}.
+ * <p>
* The data stream is typed to the given TypeInformation. This method is intended for input formats where the
* return
- * type cannot be determined by reflection analysis, and that do not implement the {@link
- * org.apache.flink.api.java.typeutils.ResultTypeQueryable} interface.
+ * type cannot be determined by reflection analysis, and that do not implement the
+ * {@link org.apache.flink.api.java.typeutils.ResultTypeQueryable} interface.
*
* @param inputFormat
* The input format used to create the data stream
@@ -908,14 +904,13 @@ public abstract class StreamExecutionEnvironment {
}
/**
- * Ads a data source with a custom type information thus opening a {@link org.apache.flink.streaming.api
- * .datastream.DataStream}. Only in very special cases does the user need to support type information. Otherwise
- * use
- * {@link #addSource(org.apache.flink.streaming.api.function.source.SourceFunction)}
- * <p/>
+ * Adds a data source with a custom type information thus opening a
+ * {@link org.apache.flink.streaming.api.datastream.DataStream}. Only in very special cases does the user need
+ * to support type information. Otherwise use {@link #addSource(org.apache.flink.streaming.api.functions.source.SourceFunction)}
+ * <p>
* By default sources have a parallelism of 1. To enable parallel execution, the user defined source should
- * implement {@link org.apache.flink.streaming.api.function.source.ParallelSourceFunction} or extend {@link
- * org.apache.flink.streaming.api.function.source.RichParallelSourceFunction}. In these cases the resulting source
+ * implement {@link org.apache.flink.streaming.api.functions.source.ParallelSourceFunction} or extend {@link
+ * org.apache.flink.streaming.api.functions.source.RichParallelSourceFunction}. In these cases the resulting source
* will have the parallelism of the environment. To change this afterwards call {@link
* org.apache.flink.streaming.api.datastream.DataStreamSource#setParallelism(int)}
*
http://git-wip-us.apache.org/repos/asf/flink/blob/0930179f/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/source/FileSourceFunction.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/source/FileSourceFunction.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/source/FileSourceFunction.java
index af00d4d..c6f4421 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/source/FileSourceFunction.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/source/FileSourceFunction.java
@@ -40,6 +40,7 @@ public class FileSourceFunction<OUT> extends RichParallelSourceFunction<OUT> {
private Iterator<InputSplit> splitIterator;
private transient OUT nextElement;
+ @SuppressWarnings("unchecked")
public FileSourceFunction(InputFormat<OUT, ?> format, TypeInformation<OUT> typeInfo) {
this.format = (InputFormat<OUT, InputSplit>) format;
this.typeInfo = typeInfo;
http://git-wip-us.apache.org/repos/asf/flink/blob/0930179f/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/operators/windowing/WindowMerger.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/operators/windowing/WindowMerger.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/operators/windowing/WindowMerger.java
index 9b33474..bb8cfaa 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/operators/windowing/WindowMerger.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/operators/windowing/WindowMerger.java
@@ -43,6 +43,7 @@ public class WindowMerger<T> extends AbstractStreamOperator<StreamWindow<T>>
}
@Override
+ @SuppressWarnings("unchecked")
public void processElement(StreamWindow<T> nextWindow) throws Exception {
StreamWindow<T> current = windows.get(nextWindow.windowID);
http://git-wip-us.apache.org/repos/asf/flink/blob/0930179f/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/deltafunction/ExtractionAwareDeltaFunction.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/deltafunction/ExtractionAwareDeltaFunction.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/deltafunction/ExtractionAwareDeltaFunction.java
index 81d01a4..3e9f2ca 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/deltafunction/ExtractionAwareDeltaFunction.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/deltafunction/ExtractionAwareDeltaFunction.java
@@ -47,10 +47,10 @@ public abstract class ExtractionAwareDeltaFunction<DATA, TO> implements DeltaFun
/**
* This method takes the two data point and runs the set extractor on it.
- * The delta function implemented at {@link getNestedDelta} is then called
+ * The delta function implemented at {@link #getNestedDelta} is then called
* with the extracted data. In case no extractor is set the input data gets
- * passes to {@link getNestedDelta} as-is. The return value is just
- * forwarded from {@link getNestedDelta}.
+ * passes to {@link #getNestedDelta} as-is. The return value is just
+ * forwarded from {@link #getNestedDelta}.
*
* @param oldDataPoint
* the older data point as raw data (before extraction).
http://git-wip-us.apache.org/repos/asf/flink/blob/0930179f/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/helper/Delta.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/helper/Delta.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/helper/Delta.java
index bcb548f..255049d 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/helper/Delta.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/helper/Delta.java
@@ -94,6 +94,7 @@ public class Delta<DATA> extends WindowingHelper<DATA> {
return new Delta<DATA>(deltaFunction, initVal, threshold);
}
+ @SuppressWarnings("unchecked")
private void instantiateTypeSerializer(){
if (executionConfig == null){
throw new UnsupportedOperationException("ExecutionConfig has to be set to instantiate TypeSerializer.");
http://git-wip-us.apache.org/repos/asf/flink/blob/0930179f/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/helper/Time.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/helper/Time.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/helper/Time.java
index 0089d26..022f975 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/helper/Time.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/helper/Time.java
@@ -27,7 +27,7 @@ import org.apache.flink.streaming.api.windowing.policy.TriggerPolicy;
/**
* This helper represents a time based count or eviction policy. By default the
* time is measured with {@link System#currentTimeMillis()} in
- * {@link DefaultTimeStamp}.
+ * {@link SystemTimestamp}.
*
* @param <DATA>
* The data type which is handled by the time stamp used in the
http://git-wip-us.apache.org/repos/asf/flink/blob/0930179f/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/CloneableMultiEvictionPolicy.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/CloneableMultiEvictionPolicy.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/CloneableMultiEvictionPolicy.java
index d86b174..5adddc4 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/CloneableMultiEvictionPolicy.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/CloneableMultiEvictionPolicy.java
@@ -44,7 +44,7 @@ public class CloneableMultiEvictionPolicy<DATA> extends MultiEvictionPolicy<DATA
*
* When using this constructor the MAX strategy is used by default. You can
* select other strategies using
- * {@link CloneableMultiEvictionPolicy#CloneableMultiEvictionPolicy(org.apache.flink.streaming.api.windowing.policy.MultiEvictionPolicy.EvictionStrategy, CloneableEvictionPolicy...)}
+ * {@link CloneableMultiEvictionPolicy#CloneableMultiEvictionPolicy(EvictionStrategy, CloneableEvictionPolicy...)}
* .
*
* @param evictionPolicies
@@ -60,7 +60,7 @@ public class CloneableMultiEvictionPolicy<DATA> extends MultiEvictionPolicy<DATA
* constructor.
*
* @param strategy
- * the strategy to be used. See {@link EvictionStrategy} for a
+ * the strategy to be used. See {@link MultiEvictionPolicy.EvictionStrategy} for a
* list of possible options.
* @param evictionPolicies
* some cloneable policies to be tied together.
http://git-wip-us.apache.org/repos/asf/flink/blob/0930179f/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/CountEvictionPolicy.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/CountEvictionPolicy.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/CountEvictionPolicy.java
index 5e0c862..9be25d3 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/CountEvictionPolicy.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/CountEvictionPolicy.java
@@ -89,7 +89,7 @@ public class CountEvictionPolicy<IN> implements CloneableEvictionPolicy<IN> {
* will be adjusted respectively but never below zero.
* @param startValue
* A custom start value for the counter of arriving elements.
- * @see CountEvictionPolicy#NextGenCountEvictionPolicy(int, int)
+ * @see CountEvictionPolicy#CountEvictionPolicy(int, int)
*/
public CountEvictionPolicy(int maxElements, int deleteOnEviction, int startValue) {
this.counter = startValue;
http://git-wip-us.apache.org/repos/asf/flink/blob/0930179f/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/DeltaPolicy.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/DeltaPolicy.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/DeltaPolicy.java
index 69dd66f..0583176 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/DeltaPolicy.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/DeltaPolicy.java
@@ -86,6 +86,7 @@ public class DeltaPolicy<DATA> implements CloneableTriggerPolicy<DATA>,
* TypeSerializer to properly forward the initial value to
* the cluster
*/
+ @SuppressWarnings("unchecked")
public DeltaPolicy(DeltaFunction<DATA> deltaFuntion, DATA init, double threshold, TypeSerializer typeSerializer) {
this.deltaFuntion = deltaFuntion;
this.triggerDataPoint = init;
http://git-wip-us.apache.org/repos/asf/flink/blob/0930179f/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/TimeTriggerPolicy.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/TimeTriggerPolicy.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/TimeTriggerPolicy.java
index ef701cf..03984a9 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/TimeTriggerPolicy.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/policy/TimeTriggerPolicy.java
@@ -19,6 +19,7 @@ package org.apache.flink.streaming.api.windowing.policy;
import java.util.LinkedList;
+import org.apache.flink.streaming.api.windowing.helper.SystemTimestamp;
import org.apache.flink.streaming.api.windowing.helper.Timestamp;
import org.apache.flink.streaming.api.windowing.helper.TimestampWrapper;
@@ -46,7 +47,7 @@ public class TimeTriggerPolicy<DATA> implements ActiveTriggerPolicy<DATA>,
/**
* This is mostly the same as
- * {@link TimeTriggerPolicy#TimeTriggerPolicy(long, Timestamp)}. In addition
+ * {@link TimeTriggerPolicy#TimeTriggerPolicy(long, TimestampWrapper)}. In addition
* to granularity and timestamp a delay can be specified for the first
* trigger. If the start time given by the timestamp is x, the delay is y,
* and the granularity is z, the first trigger will happen at x+y+z.
@@ -57,11 +58,6 @@ public class TimeTriggerPolicy<DATA> implements ActiveTriggerPolicy<DATA>,
* @param timestampWrapper
* The {@link TimestampWrapper} to measure the time with. This
* can be either user defined of provided by the API.
- * @param timeWrapper
- * This policy creates fake elements to not miss windows in case
- * no element arrived within the duration of the window. This
- * extractor should wrap a long into such an element of type
- * DATA.
*/
public TimeTriggerPolicy(long granularity, TimestampWrapper<DATA> timestampWrapper) {
this.startTime = timestampWrapper.getStartTime();
@@ -86,9 +82,9 @@ public class TimeTriggerPolicy<DATA> implements ActiveTriggerPolicy<DATA>,
}
/**
- * In case {@link DefaultTimeStamp} is used, a runnable is returned which
+ * In case {@link SystemTimestamp} is used, a runnable is returned which
* triggers based on the current system time. If any other time measure is
- * used the method return null.
+ * used the method returns null.
*
* @param callback
* The object which is takes the callbacks for adding fake
@@ -107,7 +103,7 @@ public class TimeTriggerPolicy<DATA> implements ActiveTriggerPolicy<DATA>,
/**
* This method is only called in case the runnable triggers a window end
- * according to the {@link DefaultTimeStamp}.
+ * according to the {@link SystemTimestamp}.
*
* @param callback
* The callback object.
http://git-wip-us.apache.org/repos/asf/flink/blob/0930179f/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/tasks/OutputHandler.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/tasks/OutputHandler.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/tasks/OutputHandler.java
index 38f1231..20aeb89 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/tasks/OutputHandler.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/tasks/OutputHandler.java
@@ -226,8 +226,8 @@ public class OutputHandler<OUT> {
}
@Override
+ @SuppressWarnings("unchecked")
public void collect(T record) {
-
try {
operator.processElement(record);
} catch (Exception e) {
http://git-wip-us.apache.org/repos/asf/flink/blob/0930179f/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/StreamExecutionEnvironmentTest.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/StreamExecutionEnvironmentTest.java b/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/StreamExecutionEnvironmentTest.java
index c70c1df..5ca4883 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/StreamExecutionEnvironmentTest.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/StreamExecutionEnvironmentTest.java
@@ -41,6 +41,7 @@ public class StreamExecutionEnvironmentTest {
private static int PARALLELISM = 4;
@Test
+ @SuppressWarnings("unchecked")
public void testFromCollectionParallelism() {
TypeInformation<Object> typeInfo = TypeExtractor.getForClass(Object.class);
StreamExecutionEnvironment env = new TestStreamEnvironment(PARALLELISM, MEMORYSIZE);
http://git-wip-us.apache.org/repos/asf/flink/blob/0930179f/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/windowing/windowbuffer/SlidingTimeGroupedPreReducerTest.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/windowing/windowbuffer/SlidingTimeGroupedPreReducerTest.java b/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/windowing/windowbuffer/SlidingTimeGroupedPreReducerTest.java
index 18a4748..3f1cba1 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/windowing/windowbuffer/SlidingTimeGroupedPreReducerTest.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/windowing/windowbuffer/SlidingTimeGroupedPreReducerTest.java
@@ -52,6 +52,7 @@ public class SlidingTimeGroupedPreReducerTest {
KeySelector<Tuple2<Integer, Integer>, ?> tupleKey = new TupleModKey(2);
@Test
+ @SuppressWarnings("unchecked")
public void testPreReduce1() throws Exception {
// This ensures that the buffer is properly cleared after a burst of elements by
// replaying the same sequence of elements with a later timestamp and expecting the same
http://git-wip-us.apache.org/repos/asf/flink/blob/0930179f/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/windowing/windowbuffer/SlidingTimePreReducerTest.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/windowing/windowbuffer/SlidingTimePreReducerTest.java b/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/windowing/windowbuffer/SlidingTimePreReducerTest.java
index a48bc0c..0519da7 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/windowing/windowbuffer/SlidingTimePreReducerTest.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/windowing/windowbuffer/SlidingTimePreReducerTest.java
@@ -44,6 +44,7 @@ public class SlidingTimePreReducerTest {
ReduceFunction<Tuple2<Integer, Integer>> tupleReducer = new TupleSumReducer();
@Test
+ @SuppressWarnings("unchecked")
public void testPreReduce1() throws Exception {
// This ensures that the buffer is properly cleared after a burst of elements by
// replaying the same sequence of elements with a later timestamp and expecting the same