Package | Description |
---|---|
org.apache.flink.streaming.api.datastream |
Modifier and Type | Class and Description |
---|---|
class |
DataStreamSource<T>
The DataStreamSource represents the starting point of a DataStream.
|
class |
IterativeStream<T>
The iterative data stream represents the start of an iteration in a
DataStream . |
Modifier and Type | Method and Description |
---|---|
protected SingleOutputStreamOperator<T> |
KeyedStream.aggregate(AggregationFunction<T> aggregate) |
<R> SingleOutputStreamOperator<R> |
AllWindowedStream.apply(AllWindowFunction<T,R,W> function)
Applies a window function to the window.
|
<R> SingleOutputStreamOperator<R> |
AllWindowedStream.apply(AllWindowFunction<T,R,W> function,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
<R> SingleOutputStreamOperator<R> |
AllWindowedStream.apply(ReduceFunction<T> preAggregator,
AllWindowFunction<T,R,W> function)
Applies the given window function to each window.
|
<R> SingleOutputStreamOperator<R> |
AllWindowedStream.apply(ReduceFunction<T> preAggregator,
AllWindowFunction<T,R,W> function,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
<R> SingleOutputStreamOperator<R> |
WindowedStream.apply(ReduceFunction<T> reduceFunction,
WindowFunction<T,R,K,W> function)
Applies the given window function to each window.
|
<R> SingleOutputStreamOperator<R> |
WindowedStream.apply(ReduceFunction<T> reduceFunction,
WindowFunction<T,R,K,W> function,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
<R> SingleOutputStreamOperator<R> |
AllWindowedStream.apply(R initialValue,
FoldFunction<T,R> foldFunction,
AllWindowFunction<R,R,W> function)
Applies the given window function to each window.
|
<R> SingleOutputStreamOperator<R> |
AllWindowedStream.apply(R initialValue,
FoldFunction<T,R> foldFunction,
AllWindowFunction<R,R,W> function,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
<R> SingleOutputStreamOperator<R> |
WindowedStream.apply(R initialValue,
FoldFunction<T,R> foldFunction,
WindowFunction<R,R,K,W> function)
Applies the given window function to each window.
|
<R> SingleOutputStreamOperator<R> |
WindowedStream.apply(R initialValue,
FoldFunction<T,R> foldFunction,
WindowFunction<R,R,K,W> function,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
<R> SingleOutputStreamOperator<R> |
WindowedStream.apply(WindowFunction<T,R,K,W> function)
Applies the given window function to each window.
|
<R> SingleOutputStreamOperator<R> |
WindowedStream.apply(WindowFunction<T,R,K,W> function,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
SingleOutputStreamOperator<T> |
DataStream.assignTimestamps(TimestampExtractor<T> extractor)
Deprecated.
|
SingleOutputStreamOperator<T> |
DataStream.assignTimestampsAndWatermarks(AssignerWithPeriodicWatermarks<T> timestampAndWatermarkAssigner)
Assigns timestamps to the elements in the data stream and periodically creates
watermarks to signal event time progress.
|
SingleOutputStreamOperator<T> |
DataStream.assignTimestampsAndWatermarks(AssignerWithPunctuatedWatermarks<T> timestampAndWatermarkAssigner)
Assigns timestamps to the elements in the data stream and periodically creates
watermarks to signal event time progress.
|
SingleOutputStreamOperator<T> |
SingleOutputStreamOperator.disableChaining()
Turns off chaining for this operator so thread co-location will not be
used as an optimization.
|
SingleOutputStreamOperator<T> |
DataStream.filter(FilterFunction<T> filter)
Applies a Filter transformation on a
DataStream . |
<R> SingleOutputStreamOperator<R> |
ConnectedStreams.flatMap(CoFlatMapFunction<IN1,IN2,R> coFlatMapper)
Applies a CoFlatMap transformation on a
ConnectedStreams and
maps the output to a common type. |
<R> SingleOutputStreamOperator<R> |
DataStream.flatMap(FlatMapFunction<T,R> flatMapper)
Applies a FlatMap transformation on a
DataStream . |
<R> SingleOutputStreamOperator<R> |
WindowedStream.fold(R initialValue,
FoldFunction<T,R> function)
Applies the given fold function to each window.
|
<R> SingleOutputStreamOperator<R> |
KeyedStream.fold(R initialValue,
FoldFunction<T,R> folder)
Applies a fold transformation on the grouped data stream grouped on by
the given key position.
|
<R> SingleOutputStreamOperator<R> |
AllWindowedStream.fold(R initialValue,
FoldFunction<T,R> function)
Applies the given fold function to each window.
|
<R> SingleOutputStreamOperator<R> |
WindowedStream.fold(R initialValue,
FoldFunction<T,R> function,
TypeInformation<R> resultType)
Applies the given fold function to each window.
|
<R> SingleOutputStreamOperator<R> |
AllWindowedStream.fold(R initialValue,
FoldFunction<T,R> function,
TypeInformation<R> resultType)
Applies the given fold function to each window.
|
<R> SingleOutputStreamOperator<R> |
ConnectedStreams.map(CoMapFunction<IN1,IN2,R> coMapper)
Applies a CoMap transformation on a
ConnectedStreams and maps
the output to a common type. |
<R> SingleOutputStreamOperator<R> |
DataStream.map(MapFunction<T,R> mapper)
Applies a Map transformation on a
DataStream . |
SingleOutputStreamOperator<T> |
WindowedStream.max(int positionToMax)
Applies an aggregation that gives the maximum value of every window of
the data stream at the given position.
|
SingleOutputStreamOperator<T> |
KeyedStream.max(int positionToMax)
Applies an aggregation that gives the current maximum of the data stream
at the given position by the given key.
|
SingleOutputStreamOperator<T> |
AllWindowedStream.max(int positionToMax)
Applies an aggregation that gives the maximum value of every window of
the data stream at the given position.
|
SingleOutputStreamOperator<T> |
WindowedStream.max(String field)
Applies an aggregation that that gives the maximum value of the pojo data
stream at the given field expression for every window.
|
SingleOutputStreamOperator<T> |
KeyedStream.max(String field)
Applies an aggregation that that gives the current maximum of the pojo
data stream at the given field expression by the given key.
|
SingleOutputStreamOperator<T> |
AllWindowedStream.max(String field)
Applies an aggregation that that gives the maximum value of the pojo data
stream at the given field expression for every window.
|
SingleOutputStreamOperator<T> |
WindowedStream.maxBy(int positionToMaxBy)
Applies an aggregation that gives the maximum element of every window of
the data stream by the given position.
|
SingleOutputStreamOperator<T> |
KeyedStream.maxBy(int positionToMaxBy)
Applies an aggregation that that gives the current element with the
maximum value at the given position by the given key.
|
SingleOutputStreamOperator<T> |
AllWindowedStream.maxBy(int positionToMaxBy)
Applies an aggregation that gives the maximum element of every window of
the data stream by the given position.
|
SingleOutputStreamOperator<T> |
WindowedStream.maxBy(int positionToMaxBy,
boolean first)
Applies an aggregation that gives the maximum element of every window of
the data stream by the given position.
|
SingleOutputStreamOperator<T> |
KeyedStream.maxBy(int positionToMaxBy,
boolean first)
Applies an aggregation that that gives the current element with the
maximum value at the given position by the given key.
|
SingleOutputStreamOperator<T> |
AllWindowedStream.maxBy(int positionToMaxBy,
boolean first)
Applies an aggregation that gives the maximum element of every window of
the data stream by the given position.
|
SingleOutputStreamOperator<T> |
WindowedStream.maxBy(String positionToMaxBy)
Applies an aggregation that gives the maximum element of every window of
the data stream by the given position.
|
SingleOutputStreamOperator<T> |
KeyedStream.maxBy(String positionToMaxBy)
Applies an aggregation that that gives the current element with the
maximum value at the given position by the given key.
|
SingleOutputStreamOperator<T> |
AllWindowedStream.maxBy(String positionToMaxBy)
Applies an aggregation that gives the maximum element of every window of
the data stream by the given position.
|
SingleOutputStreamOperator<T> |
WindowedStream.maxBy(String field,
boolean first)
Applies an aggregation that that gives the maximum element of the pojo
data stream by the given field expression for every window.
|
SingleOutputStreamOperator<T> |
KeyedStream.maxBy(String field,
boolean first)
Applies an aggregation that that gives the current maximum element of the
pojo data stream by the given field expression by the given key.
|
SingleOutputStreamOperator<T> |
AllWindowedStream.maxBy(String field,
boolean first)
Applies an aggregation that that gives the maximum element of the pojo
data stream by the given field expression for every window.
|
SingleOutputStreamOperator<T> |
WindowedStream.min(int positionToMin)
Applies an aggregation that that gives the minimum value of every window
of the data stream at the given position.
|
SingleOutputStreamOperator<T> |
KeyedStream.min(int positionToMin)
Applies an aggregation that that gives the current minimum of the data
stream at the given position by the given key.
|
SingleOutputStreamOperator<T> |
AllWindowedStream.min(int positionToMin)
Applies an aggregation that that gives the minimum value of every window
of the data stream at the given position.
|
SingleOutputStreamOperator<T> |
WindowedStream.min(String field)
Applies an aggregation that that gives the minimum value of the pojo data
stream at the given field expression for every window.
|
SingleOutputStreamOperator<T> |
KeyedStream.min(String field)
Applies an aggregation that that gives the current minimum of the pojo
data stream at the given field expression by the given key.
|
SingleOutputStreamOperator<T> |
AllWindowedStream.min(String field)
Applies an aggregation that that gives the minimum value of the pojo data
stream at the given field expression for every window.
|
SingleOutputStreamOperator<T> |
WindowedStream.minBy(int positionToMinBy)
Applies an aggregation that gives the minimum element of every window of
the data stream by the given position.
|
SingleOutputStreamOperator<T> |
KeyedStream.minBy(int positionToMinBy)
Applies an aggregation that that gives the current element with the
minimum value at the given position by the given key.
|
SingleOutputStreamOperator<T> |
AllWindowedStream.minBy(int positionToMinBy)
Applies an aggregation that gives the minimum element of every window of
the data stream by the given position.
|
SingleOutputStreamOperator<T> |
WindowedStream.minBy(int positionToMinBy,
boolean first)
Applies an aggregation that gives the minimum element of every window of
the data stream by the given position.
|
SingleOutputStreamOperator<T> |
KeyedStream.minBy(int positionToMinBy,
boolean first)
Applies an aggregation that that gives the current element with the
minimum value at the given position by the given key.
|
SingleOutputStreamOperator<T> |
AllWindowedStream.minBy(int positionToMinBy,
boolean first)
Applies an aggregation that gives the minimum element of every window of
the data stream by the given position.
|
SingleOutputStreamOperator<T> |
WindowedStream.minBy(String positionToMinBy)
Applies an aggregation that gives the minimum element of every window of
the data stream by the given position.
|
SingleOutputStreamOperator<T> |
KeyedStream.minBy(String positionToMinBy)
Applies an aggregation that that gives the current element with the
minimum value at the given position by the given key.
|
SingleOutputStreamOperator<T> |
AllWindowedStream.minBy(String positionToMinBy)
Applies an aggregation that gives the minimum element of every window of
the data stream by the given position.
|
SingleOutputStreamOperator<T> |
WindowedStream.minBy(String field,
boolean first)
Applies an aggregation that that gives the minimum element of the pojo
data stream by the given field expression for every window.
|
SingleOutputStreamOperator<T> |
KeyedStream.minBy(String field,
boolean first)
Applies an aggregation that that gives the current minimum element of the
pojo data stream by the given field expression by the given key.
|
SingleOutputStreamOperator<T> |
AllWindowedStream.minBy(String field,
boolean first)
Applies an aggregation that that gives the minimum element of the pojo
data stream by the given field expression for every window.
|
SingleOutputStreamOperator<T> |
SingleOutputStreamOperator.name(String name)
Sets the name of the current data stream.
|
<R extends Tuple> |
DataStream.project(int... fieldIndexes)
Initiates a Project transformation on a
Tuple DataStream .Note: Only Tuple DataStreams can be projected. |
<T0> SingleOutputStreamOperator<Tuple1<T0>> |
StreamProjection.projectTuple1()
Projects a
Tuple DataStream to the previously selected fields. |
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9> |
StreamProjection.projectTuple10()
Projects a
Tuple DataStream to the previously selected fields. |
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10> |
StreamProjection.projectTuple11()
Projects a
Tuple DataStream to the previously selected fields. |
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11> |
StreamProjection.projectTuple12()
Projects a
Tuple DataStream to the previously selected fields. |
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12> |
StreamProjection.projectTuple13()
Projects a
Tuple DataStream to the previously selected fields. |
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13> |
StreamProjection.projectTuple14()
Projects a
Tuple DataStream to the previously selected fields. |
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14> |
StreamProjection.projectTuple15()
Projects a
Tuple DataStream to the previously selected fields. |
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15> |
StreamProjection.projectTuple16()
Projects a
Tuple DataStream to the previously selected fields. |
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16> |
StreamProjection.projectTuple17()
Projects a
Tuple DataStream to the previously selected fields. |
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17> |
StreamProjection.projectTuple18()
Projects a
Tuple DataStream to the previously selected fields. |
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18> |
StreamProjection.projectTuple19()
Projects a
Tuple DataStream to the previously selected fields. |
<T0,T1> SingleOutputStreamOperator<Tuple2<T0,T1>> |
StreamProjection.projectTuple2()
Projects a
Tuple DataStream to the previously selected fields. |
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19> |
StreamProjection.projectTuple20()
Projects a
Tuple DataStream to the previously selected fields. |
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20> |
StreamProjection.projectTuple21()
Projects a
Tuple DataStream to the previously selected fields. |
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21> |
StreamProjection.projectTuple22()
Projects a
Tuple DataStream to the previously selected fields. |
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22> |
StreamProjection.projectTuple23()
Projects a
Tuple DataStream to the previously selected fields. |
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,T23> |
StreamProjection.projectTuple24()
Projects a
Tuple DataStream to the previously selected fields. |
<T0,T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,T19,T20,T21,T22,T23,T24> |
StreamProjection.projectTuple25()
Projects a
Tuple DataStream to the previously selected fields. |
<T0,T1,T2> SingleOutputStreamOperator<Tuple3<T0,T1,T2>> |
StreamProjection.projectTuple3()
Projects a
Tuple DataStream to the previously selected fields. |
<T0,T1,T2,T3> |
StreamProjection.projectTuple4()
Projects a
Tuple DataStream to the previously selected fields. |
<T0,T1,T2,T3,T4> |
StreamProjection.projectTuple5()
Projects a
Tuple DataStream to the previously selected fields. |
<T0,T1,T2,T3,T4,T5> |
StreamProjection.projectTuple6()
Projects a
Tuple DataStream to the previously selected fields. |
<T0,T1,T2,T3,T4,T5,T6> |
StreamProjection.projectTuple7()
Projects a
Tuple DataStream to the previously selected fields. |
<T0,T1,T2,T3,T4,T5,T6,T7> |
StreamProjection.projectTuple8()
Projects a
Tuple DataStream to the previously selected fields. |
<T0,T1,T2,T3,T4,T5,T6,T7,T8> |
StreamProjection.projectTuple9()
Projects a
Tuple DataStream to the previously selected fields. |
<OUT extends Tuple> |
StreamProjection.projectTupleX()
Chooses a projectTupleX according to the length of
StreamProjection.fieldIndexes |
SingleOutputStreamOperator<T> |
WindowedStream.reduce(ReduceFunction<T> function)
Applies a reduce function to the window.
|
SingleOutputStreamOperator<T> |
KeyedStream.reduce(ReduceFunction<T> reducer)
Applies a reduce transformation on the grouped data stream grouped on by
the given key position.
|
SingleOutputStreamOperator<T> |
AllWindowedStream.reduce(ReduceFunction<T> function)
Applies a reduce function to the window.
|
SingleOutputStreamOperator<T> |
SingleOutputStreamOperator.returns(Class<T> typeClass)
Adds a type information hint about the return type of this operator.
|
SingleOutputStreamOperator<T> |
SingleOutputStreamOperator.returns(String typeInfoString)
Deprecated.
Please use
returns(Class) or returns(TypeHint) instead. |
SingleOutputStreamOperator<T> |
SingleOutputStreamOperator.returns(TypeHint<T> typeHint)
Adds a type information hint about the return type of this operator.
|
SingleOutputStreamOperator<T> |
SingleOutputStreamOperator.returns(TypeInformation<T> typeInfo)
Adds a type information hint about the return type of this operator.
|
SingleOutputStreamOperator<T> |
SingleOutputStreamOperator.setBufferTimeout(long timeoutMillis)
Sets the maximum time frequency (ms) for the flushing of the output
buffer.
|
SingleOutputStreamOperator<T> |
SingleOutputStreamOperator.setParallelism(int parallelism)
Sets the parallelism for this operator.
|
SingleOutputStreamOperator<T> |
SingleOutputStreamOperator.slotSharingGroup(String slotSharingGroup)
Sets the slot sharing group of this operation.
|
SingleOutputStreamOperator<T> |
SingleOutputStreamOperator.startNewChain()
Starts a new task chain beginning at this operator.
|
SingleOutputStreamOperator<T> |
WindowedStream.sum(int positionToSum)
Applies an aggregation that sums every window of the data stream at the
given position.
|
SingleOutputStreamOperator<T> |
KeyedStream.sum(int positionToSum)
Applies an aggregation that gives a rolling sum of the data stream at the
given position grouped by the given key.
|
SingleOutputStreamOperator<T> |
AllWindowedStream.sum(int positionToSum)
Applies an aggregation that sums every window of the data stream at the
given position.
|
SingleOutputStreamOperator<T> |
WindowedStream.sum(String field)
Applies an aggregation that sums every window of the pojo data stream at
the given field for every window.
|
SingleOutputStreamOperator<T> |
KeyedStream.sum(String field)
Applies an aggregation that that gives the current sum of the pojo data
stream at the given field expressionby the given key.
|
SingleOutputStreamOperator<T> |
AllWindowedStream.sum(String field)
Applies an aggregation that sums every window of the pojo data stream at
the given field for every window.
|
<R> SingleOutputStreamOperator<R> |
KeyedStream.transform(String operatorName,
TypeInformation<R> outTypeInfo,
OneInputStreamOperator<T,R> operator) |
<R> SingleOutputStreamOperator<R> |
DataStream.transform(String operatorName,
TypeInformation<R> outTypeInfo,
OneInputStreamOperator<T,R> operator)
Method for passing user defined operators along with the type
information that will transform the DataStream.
|
<R> SingleOutputStreamOperator<R> |
ConnectedStreams.transform(String functionName,
TypeInformation<R> outTypeInfo,
TwoInputStreamOperator<IN1,IN2,R> operator) |
SingleOutputStreamOperator<T> |
SingleOutputStreamOperator.uid(String uid)
Sets an ID for this operator.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.