Package | Description |
---|---|
org.apache.flink.state.api | |
org.apache.flink.state.api.functions | |
org.apache.flink.state.api.input.operator | |
org.apache.flink.state.api.input.operator.window | |
org.apache.flink.streaming.api.datastream | |
org.apache.flink.streaming.api.functions.windowing | |
org.apache.flink.streaming.api.windowing.assigners | |
org.apache.flink.streaming.api.windowing.evictors | |
org.apache.flink.streaming.api.windowing.triggers | |
org.apache.flink.streaming.api.windowing.windows | |
org.apache.flink.streaming.runtime.operators.windowing |
This package contains the operators that implement the various window operations on data streams.
|
org.apache.flink.streaming.runtime.operators.windowing.functions |
Modifier and Type | Class and Description |
---|---|
class |
EvictingWindowReader<W extends Window>
Deprecated.
|
class |
EvictingWindowSavepointReader<W extends Window>
This class provides entry points for reading keyed state written out using the
WindowOperator . |
class |
WindowedOperatorTransformation<T,K,W extends Window>
A
WindowedOperatorTransformation represents a OneInputOperatorTransformation for
bootstrapping window state. |
class |
WindowedStateTransformation<T,K,W extends Window>
A
WindowedStateTransformation represents a OneInputStateTransformation for
bootstrapping window state. |
class |
WindowReader<W extends Window>
Deprecated.
|
class |
WindowSavepointReader<W extends Window>
This class provides entry points for reading keyed state written out using the
WindowOperator . |
Modifier and Type | Method and Description |
---|---|
<W extends Window> |
ExistingSavepoint.window(TypeSerializer<W> windowSerializer)
Deprecated.
Read window state from an operator in a
Savepoint . |
<W extends Window> |
SavepointReader.window(TypeSerializer<W> windowSerializer)
Read window state from an operator in a
Savepoint . |
<W extends Window> |
KeyedOperatorTransformation.window(WindowAssigner<? super T,W> assigner)
Deprecated.
Windows this transformation into a
WindowedOperatorTransformation , which bootstraps
state that can be restored by a WindowOperator . |
<W extends Window> |
KeyedStateTransformation.window(WindowAssigner<? super T,W> assigner)
Windows this transformation into a
WindowedOperatorTransformation , which bootstraps
state that can be restored by a WindowOperator . |
<W extends Window> |
ExistingSavepoint.window(WindowAssigner<?,W> assigner)
Deprecated.
Read window state from an operator in a
Savepoint . |
<W extends Window> |
SavepointReader.window(WindowAssigner<?,W> assigner)
Read window state from an operator in a
Savepoint . |
Modifier and Type | Class and Description |
---|---|
class |
WindowReaderFunction<IN,OUT,KEY,W extends Window>
Base abstract class for functions that are evaluated over keyed (grouped) windows using a context
for retrieving extra information.
|
static interface |
WindowReaderFunction.Context<W extends Window>
The context holding window metadata.
|
Modifier and Type | Class and Description |
---|---|
class |
WindowReaderOperator<S extends State,KEY,IN,W extends Window,OUT>
A
StateReaderOperator for reading WindowOperator state. |
Modifier and Type | Method and Description |
---|---|
static <KEY,T,ACC,R,OUT,W extends Window> |
WindowReaderOperator.aggregate(AggregateFunction<T,ACC,R> function,
WindowReaderFunction<R,OUT,KEY,W> readerFunction,
TypeInformation<KEY> keyType,
TypeSerializer<W> windowSerializer,
TypeInformation<ACC> accumulatorType) |
static <KEY,T,W extends Window,OUT> |
WindowReaderOperator.evictingWindow(WindowReaderFunction<StreamRecord<T>,OUT,KEY,W> readerFunction,
TypeInformation<KEY> keyType,
TypeSerializer<W> windowSerializer,
TypeInformation<T> stateType,
ExecutionConfig config) |
static <KEY,T,W extends Window,OUT> |
WindowReaderOperator.process(WindowReaderFunction<T,OUT,KEY,W> readerFunction,
TypeInformation<KEY> keyType,
TypeSerializer<W> windowSerializer,
TypeInformation<T> stateType) |
static <KEY,T,W extends Window,OUT> |
WindowReaderOperator.reduce(ReduceFunction<T> function,
WindowReaderFunction<T,OUT,KEY,W> reader,
TypeInformation<KEY> keyType,
TypeSerializer<W> windowSerializer,
TypeInformation<T> inputType) |
Modifier and Type | Class and Description |
---|---|
class |
AggregateEvictingWindowReaderFunction<IN,ACC,R,OUT,KEY,W extends Window>
A wrapper for reading an evicting window operator with an aggregate function.
|
class |
EvictingWindowReaderFunction<IN,R,OUT,KEY,W extends Window>
Wrapper for reading state from an evicting window operator.
|
class |
PassThroughReader<KEY,W extends Window,IN>
A
WindowReaderFunction that just emits each input element. |
class |
ProcessEvictingWindowReader<IN,OUT,KEY,W extends Window>
A wrapper function for reading an evicting window with no pre-aggregation.
|
class |
ReduceEvictingWindowReaderFunction<IN,OUT,KEY,W extends Window>
A wrapper function for reading state from an evicting window operator with a reduce function.
|
Modifier and Type | Class and Description |
---|---|
class |
AllWindowedStream<T,W extends Window>
A
AllWindowedStream represents a data stream where the stream of elements is split into
windows based on a WindowAssigner . |
static class |
CoGroupedStreams.WithWindow<T1,T2,KEY,W extends Window>
A co-group operation that has
KeySelectors defined for both inputs as
well as a WindowAssigner . |
static class |
JoinedStreams.WithWindow<T1,T2,KEY,W extends Window>
A join operation that has
KeySelectors defined for both inputs as well as
a WindowAssigner . |
class |
WindowedStream<T,K,W extends Window>
A
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 WindowAssigner . |
Modifier and Type | Method and Description |
---|---|
<W extends Window> |
JoinedStreams.Where.EqualTo.window(WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1,T2>,W> assigner)
Specifies the window on which the join operation works.
|
<W extends Window> |
CoGroupedStreams.Where.EqualTo.window(WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1,T2>,W> assigner)
Specifies the window on which the co-group operation works.
|
<W extends Window> |
KeyedStream.window(WindowAssigner<? super T,W> assigner)
Windows this data stream to a
WindowedStream , which evaluates windows over a key
grouped stream. |
<W extends Window> |
DataStream.windowAll(WindowAssigner<? super T,W> assigner)
Windows this data stream to a
AllWindowedStream , which evaluates windows over a non
key grouped stream. |
Modifier and Type | Class and Description |
---|---|
class |
AggregateApplyAllWindowFunction<W extends Window,T,ACC,V,R>
|
class |
AggregateApplyWindowFunction<K,W extends Window,T,ACC,V,R>
|
interface |
AllWindowFunction<IN,OUT,W extends Window>
Base interface for functions that are evaluated over non-keyed windows.
|
class |
InternalProcessApplyAllWindowContext<IN,OUT,W extends Window>
Internal reusable context wrapper.
|
class |
InternalProcessApplyWindowContext<IN,OUT,KEY,W extends Window>
Internal reusable context wrapper.
|
class |
PassThroughAllWindowFunction<W extends Window,T>
A
AllWindowFunction that just emits each input element. |
class |
PassThroughWindowFunction<K,W extends Window,T>
A
WindowFunction that just emits each input element. |
class |
ProcessAllWindowFunction<IN,OUT,W extends Window>
Base abstract class for functions that are evaluated over non-keyed windows using a context for
retrieving extra information.
|
class |
ProcessWindowFunction<IN,OUT,KEY,W extends Window>
Base abstract class for functions that are evaluated over keyed (grouped) windows using a context
for retrieving extra information.
|
class |
ReduceApplyAllWindowFunction<W extends Window,T,R>
Internal
AllWindowFunction that is used for implementing a fold on a window configuration
that only allows AllWindowFunction and cannot directly execute a ReduceFunction . |
class |
ReduceApplyProcessAllWindowFunction<W extends Window,T,R>
Internal
ProcessAllWindowFunction that is used for implementing a fold on a window
configuration that only allows AllWindowFunction and cannot directly execute a ReduceFunction . |
class |
ReduceApplyProcessWindowFunction<K,W extends Window,T,R>
Internal
ProcessWindowFunction that is used for implementing a fold on a window
configuration that only allows AllWindowFunction and cannot directly execute a ReduceFunction . |
class |
ReduceApplyWindowFunction<K,W extends Window,T,R>
Internal
WindowFunction that is used for implementing a fold on a window configuration
that only allows WindowFunction and cannot directly execute a ReduceFunction . |
class |
RichAllWindowFunction<IN,OUT,W extends Window>
A
RichFunction version of AllWindowFunction . |
class |
RichProcessAllWindowFunction<IN,OUT,W extends Window>
Deprecated.
use
ProcessAllWindowFunction instead |
class |
RichProcessWindowFunction<IN,OUT,KEY,W extends Window>
Deprecated.
use
ProcessWindowFunction instead |
class |
RichWindowFunction<IN,OUT,KEY,W extends Window>
Rich variant of the
WindowFunction . |
interface |
WindowFunction<IN,OUT,KEY,W extends Window>
Base interface for functions that are evaluated over keyed (grouped) windows.
|
Modifier and Type | Class and Description |
---|---|
class |
MergingWindowAssigner<T,W extends Window>
A
WindowAssigner that can merge windows. |
class |
WindowAssigner<T,W extends Window>
A
WindowAssigner assigns zero or more Windows to an element. |
Modifier and Type | Class and Description |
---|---|
class |
CountEvictor<W extends Window>
An
Evictor that keeps up to a certain amount of elements. |
class |
DeltaEvictor<T,W extends Window>
An
Evictor that keeps elements based on a DeltaFunction and a threshold. |
interface |
Evictor<T,W extends Window>
An
Evictor can remove elements from a pane before/after the evaluation of WindowFunction
and after the window evaluation gets triggered by a Trigger |
class |
TimeEvictor<W extends Window>
An
Evictor that keeps elements for a certain amount of time. |
Modifier and Type | Method and Description |
---|---|
static <T,W extends Window> |
DeltaEvictor.of(double threshold,
DeltaFunction<T> deltaFunction)
Creates a
DeltaEvictor from the given threshold and DeltaFunction . |
static <T,W extends Window> |
DeltaEvictor.of(double threshold,
DeltaFunction<T> deltaFunction,
boolean doEvictAfter)
Creates a
DeltaEvictor from the given threshold, DeltaFunction . |
static <W extends Window> |
CountEvictor.of(long maxCount)
Creates a
CountEvictor that keeps the given number of elements. |
static <W extends Window> |
CountEvictor.of(long maxCount,
boolean doEvictAfter)
Creates a
CountEvictor that keeps the given number of elements in the pane Eviction
is done before/after the window function based on the value of doEvictAfter. |
static <W extends Window> |
TimeEvictor.of(Time windowSize)
Creates a
TimeEvictor that keeps the given number of elements. |
static <W extends Window> |
TimeEvictor.of(Time windowSize,
boolean doEvictAfter)
Creates a
TimeEvictor that keeps the given number of elements. |
Modifier and Type | Class and Description |
---|---|
class |
ContinuousEventTimeTrigger<W extends Window>
A
Trigger that continuously fires based on a given time interval. |
class |
ContinuousProcessingTimeTrigger<W extends Window>
A
Trigger that continuously fires based on a given time interval as measured by the clock
of the machine on which the job is running. |
class |
CountTrigger<W extends Window>
A
Trigger that fires once the count of elements in a pane reaches the given count. |
class |
DeltaTrigger<T,W extends Window>
A
Trigger that fires based on a DeltaFunction and a threshold. |
class |
ProcessingTimeoutTrigger<T,W extends Window>
|
class |
PurgingTrigger<T,W extends Window>
A trigger that can turn any
Trigger into a purging Trigger . |
class |
Trigger<T,W extends Window>
A
Trigger determines when a pane of a window should be evaluated to emit the results for
that part of the window. |
Modifier and Type | Method and Description |
---|---|
static <T,W extends Window> |
DeltaTrigger.of(double threshold,
DeltaFunction<T> deltaFunction,
TypeSerializer<T> stateSerializer)
Creates a delta trigger from the given threshold and
DeltaFunction . |
static <W extends Window> |
CountTrigger.of(long maxCount)
Creates a trigger that fires once the number of elements in a pane reaches the given count.
|
static <W extends Window> |
ContinuousEventTimeTrigger.of(Time interval)
Creates a trigger that continuously fires based on the given interval.
|
static <W extends Window> |
ContinuousProcessingTimeTrigger.of(Time interval)
Creates a trigger that continuously fires based on the given interval.
|
static <T,W extends Window> |
PurgingTrigger.of(Trigger<T,W> nestedTrigger)
Creates a new purging trigger from the given
Trigger . |
static <T,W extends Window> |
ProcessingTimeoutTrigger.of(Trigger<T,W> nestedTrigger,
java.time.Duration timeout)
Creates a new
ProcessingTimeoutTrigger that fires when the inner trigger is fired or
when the timeout timer fires. |
static <T,W extends Window> |
ProcessingTimeoutTrigger.of(Trigger<T,W> nestedTrigger,
java.time.Duration timeout,
boolean resetTimerOnNewRecord,
boolean shouldClearOnTimeout)
Creates a new
ProcessingTimeoutTrigger that fires when the inner trigger is fired or
when the timeout timer fires. |
Modifier and Type | Class and Description |
---|---|
class |
GlobalWindow
The default window into which all data is placed (via
GlobalWindows ). |
class |
TimeWindow
|
Modifier and Type | Class and Description |
---|---|
class |
EvictingWindowOperator<K,IN,OUT,W extends Window>
A
WindowOperator that also allows an Evictor to be used. |
class |
MergingWindowSet<W extends Window>
Utility for keeping track of merging
Windows when using a MergingWindowAssigner in a WindowOperator . |
class |
WindowOperator<K,IN,ACC,OUT,W extends Window>
An operator that implements the logic for windowing based on a
WindowAssigner and Trigger . |
protected static class |
WindowOperator.Timer<K,W extends Window>
Internal class for keeping track of in-flight timers.
|
class |
WindowOperatorBuilder<T,K,W extends Window>
A builder for creating
WindowOperators . |
Modifier and Type | Field and Description |
---|---|
protected W |
WindowOperator.AbstractPerWindowStateStore.window |
protected W |
WindowOperator.WindowContext.window |
protected W |
WindowOperator.Context.window |
protected W |
WindowOperator.Timer.window |
Modifier and Type | Class and Description |
---|---|
class |
InternalAggregateProcessAllWindowFunction<T,ACC,V,R,W extends Window>
Internal window function for wrapping a
ProcessAllWindowFunction that takes an Iterable and an AggregateFunction . |
class |
InternalAggregateProcessWindowFunction<T,ACC,V,R,K,W extends Window>
Internal window function for wrapping a
ProcessWindowFunction that takes an Iterable and an AggregateFunction . |
class |
InternalIterableAllWindowFunction<IN,OUT,W extends Window>
Internal window function for wrapping an
AllWindowFunction that takes an Iterable
when the window state also is an Iterable . |
class |
InternalIterableProcessAllWindowFunction<IN,OUT,W extends Window>
Internal window function for wrapping a
ProcessAllWindowFunction that takes an Iterable when the window state also is an Iterable . |
class |
InternalIterableProcessWindowFunction<IN,OUT,KEY,W extends Window>
Internal window function for wrapping a
ProcessWindowFunction that takes an Iterable when the window state also is an Iterable . |
class |
InternalIterableWindowFunction<IN,OUT,KEY,W extends Window>
Internal window function for wrapping a
WindowFunction that takes an Iterable
when the window state also is an Iterable . |
class |
InternalProcessAllWindowContext<IN,OUT,W extends Window>
Internal reusable context wrapper.
|
class |
InternalProcessWindowContext<IN,OUT,KEY,W extends Window>
Internal reusable context wrapper.
|
class |
InternalSingleValueAllWindowFunction<IN,OUT,W extends Window>
Internal window function for wrapping an
AllWindowFunction that takes an Iterable
when the window state is a single value. |
class |
InternalSingleValueProcessAllWindowFunction<IN,OUT,W extends Window>
Internal window function for wrapping a
ProcessAllWindowFunction that takes an Iterable when the window state is a single value. |
class |
InternalSingleValueProcessWindowFunction<IN,OUT,KEY,W extends Window>
Internal window function for wrapping a
ProcessWindowFunction that takes an Iterable when the window state is a single value. |
class |
InternalSingleValueWindowFunction<IN,OUT,KEY,W extends Window>
Internal window function for wrapping a
WindowFunction that takes an Iterable
when the window state is a single value. |
interface |
InternalWindowFunction<IN,OUT,KEY,W extends Window>
Internal interface for functions that are evaluated over keyed (grouped) windows.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.