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.
|
class |
GroupTableAggFunction
Aggregate Function used for the groupby (without window) table aggregate.
|
Modifier and Type | Class and Description |
---|---|
class |
ProcTimeDeduplicateKeepFirstRowFunction
This function is used to deduplicate on keys and keeps only first row.
|
class |
ProcTimeDeduplicateKeepLastRowFunction
This function is used to deduplicate on keys and keeps only last row.
|
class |
RowTimeDeduplicateFunction
This function is used to deduplicate on keys and keeps only first or last row on row time.
|
Modifier and Type | Class and Description |
---|---|
class |
KeyedLookupJoinWrapper
The lookup join handler which holds a
LookupJoinRunner to process lookup for insert or
update_after record and directly process delete and update_before record via local state. |
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 |
AppendOnlyFirstNFunction
A variant of
AppendOnlyTopNFunction to handle first-n case. |
class |
AppendOnlyTopNFunction
A TopN function could handle insert-only stream.
|
class |
FastTop1Function
A more concise implementation for
AppendOnlyTopNFunction and UpdatableTopNFunction when only Top-1 is desired. |
class |
RetractableTopNFunction
A TopN function could handle updating stream.
|
class |
UpdatableTopNFunction
A TopN function could handle updating stream.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.