Modifier and Type | Method and Description |
---|---|
<R> SingleOutputStreamOperator<R> |
KeyedStream.process(KeyedProcessFunction<KEY,T,R> keyedProcessFunction)
Applies the given
KeyedProcessFunction on the input stream, thereby creating a transformed output stream. |
<R> SingleOutputStreamOperator<R> |
KeyedStream.process(KeyedProcessFunction<KEY,T,R> keyedProcessFunction,
TypeInformation<R> outputType)
Applies the given
KeyedProcessFunction on the input stream, thereby creating a transformed output stream. |
Constructor and Description |
---|
KeyedProcessOperator(KeyedProcessFunction<K,IN,OUT> function) |
Modifier and Type | Class and Description |
---|---|
class |
KeyedProcessFunctionWithCleanupState<K,IN,OUT>
A function that processes elements of a stream, and could cleanup state.
|
Modifier and Type | Class and Description |
---|---|
class |
GroupAggFunction
Aggregate Function used for the groupby (without window) aggregate.
|
Modifier and Type | Class and Description |
---|---|
class |
DeduplicateKeepFirstRowFunction
This function is used to deduplicate on keys and keeps only first row.
|
class |
DeduplicateKeepLastRowFunction
This function is used to deduplicate on keys and keeps only last row.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractRowTimeUnboundedPrecedingOver<K>
A basic implementation to support unbounded event-time over-window.
|
class |
ProcTimeRangeBoundedPrecedingFunction<K>
Process Function used for the aggregate in bounded proc-time OVER window.
|
class |
ProcTimeRowsBoundedPrecedingFunction<K>
Process Function for ROW clause processing-time bounded OVER window.
|
class |
ProcTimeUnboundedPrecedingFunction<K>
Process Function for processing-time unbounded OVER window.
|
class |
RowTimeRangeBoundedPrecedingFunction<K>
Process Function for RANGE clause event-time bounded OVER window.
|
class |
RowTimeRangeUnboundedPrecedingFunction<K>
A ProcessFunction to support unbounded RANGE window.
|
class |
RowTimeRowsBoundedPrecedingFunction<K>
Process Function for ROWS clause event-time bounded OVER window.
|
class |
RowTimeRowsUnboundedPrecedingFunction<K>
A ProcessFunction to support unbounded ROWS window.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractTopNFunction
Base class for TopN Function.
|
class |
AppendOnlyTopNFunction
The function could and only could handle append input stream.
|
class |
RetractableTopNFunction
The function could handle retract stream.
|
class |
UpdatableTopNFunction
The function could handle update input stream.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.