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
KeyedTriggerWindowDataStream , which evaluates windows
over a key grouped stream. |
Modifier and Type | Interface and Description |
---|---|
interface |
AllWindowFunction<IN,OUT,W extends Window>
Base interface for functions that are evaluated over non-keyed windows.
|
class |
FoldApplyAllWindowFunction<W extends Window,T,ACC,R> |
class |
FoldApplyWindowFunction<K,W extends Window,T,ACC,R> |
class |
PassThroughAllWindowFunction<W extends Window,T> |
class |
PassThroughWindowFunction<K,W extends Window,T> |
class |
ReduceApplyAllWindowFunction<W extends Window,T,R> |
class |
ReduceApplyWindowFunction<K,W extends Window,T,R> |
class |
ReduceIterableAllWindowFunction<W extends Window,T> |
class |
ReduceIterableWindowFunction<K,W extends Window,T> |
class |
RichAllWindowFunction<IN,OUT,W extends Window> |
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 |
AllWindowedStream<T,W extends Window>
A
AllWindowedStream represents a data stream where the stream of
elements is split into windows based on a
WindowAssigner . |
class |
CoGroupedStreams.Where.EqualTo.WithWindow<W extends Window>
A co-group operation that has
KeySelector s defined for both inputs as
well as a WindowAssigner . |
class |
JoinedStreams.Where.EqualTo.WithWindow<W extends Window>
A join operation that has
KeySelector s 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> |
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> |
JoinedStreams.Where.EqualTo.window(WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1,T2>,W> assigner)
Specifies the window on which the join 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 key grouped stream. |
Modifier and Type | Class and Description |
---|---|
class |
OnJoinedStream<L,R,K,W extends Window>
Wraps a joined data stream, allowing to use anonymous partial functions to
perform extraction of items in a tuple, case class instance or collection
|
class |
OnWindowedStream<T,K,W extends Window>
Wraps a joined data stream, allowing to use anonymous partial functions to
perform extraction of items in a tuple, case class instance or collection
|
Modifier and Type | Interface and Description |
---|---|
interface |
AllWindowFunction<IN,OUT,W extends Window>
Base interface for functions that are evaluated over non-grouped windows,
i.e., windows over all stream partitions.
|
class |
RichAllWindowFunction<IN,OUT,W extends Window>
Rich variant of the
AllWindowFunction . |
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 |
ScalaAllWindowFunction<IN,OUT,W extends Window>
A wrapper function that exposes a Scala Function3 as a Java AllWindowFunction.
|
class |
ScalaAllWindowFunctionWrapper<IN,OUT,W extends Window>
A wrapper function that exposes a Scala WindowFunction as a JavaWindow function.
|
class |
ScalaWindowFunction<IN,OUT,KEY,W extends Window>
A wrapper function that exposes a Scala Function4 as a Java WindowFunction.
|
class |
ScalaWindowFunctionWrapper<IN,OUT,KEY,W extends Window>
A wrapper function that exposes a Scala WindowFunction as a JavaWindow function.
|
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 |
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> |
ContinuousProcessingTimeTrigger.of(Time interval)
Creates a trigger that continuously fires based on the given interval.
|
static <W extends Window> |
ContinuousEventTimeTrigger.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 . |
Modifier and Type | Class and Description |
---|---|
class |
GlobalWindow |
class |
TimeWindow
|
Modifier and Type | Method and Description |
---|---|
void |
GroupedProcessingTimeWindowExample.SummingWindowFunction.apply(Long key,
Window window,
Iterable<Tuple2<Long,Long>> values,
Collector<Tuple2<Long,Long>> out) |
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.
|
Modifier and Type | Field and Description |
---|---|
protected W |
WindowOperator.Context.window |
protected W |
WindowOperator.Timer.window |
Constructor and Description |
---|
AccumulatingKeyedTimePanes(KeySelector<Type,Key> keySelector,
WindowFunction<Type,Result,Key,Window> function) |
Modifier and Type | Class and Description |
---|---|
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 |
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 |
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 |
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.
|
Modifier and Type | Class and Description |
---|---|
class |
AggregateAllWindowFunction<W extends Window> |
class |
AggregateWindowFunction<W extends Window> |
class |
IncrementalAggregateAllWindowFunction<W extends Window>
Computes the final aggregate value from incrementally computed aggreagtes.
|
class |
IncrementalAggregateWindowFunction<W extends Window>
Computes the final aggregate value from incrementally computed aggreagtes.
|
Modifier and Type | Method and Description |
---|---|
static AllWindowFunction<Row,Row,Window> |
AggregateUtil.createAllWindowAggregationFunction(LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties)
Create an
AllWindowFunction to compute non-partitioned group window aggregates. |
AllWindowFunction<Row,Row,Window> |
AggregateUtil$.createAllWindowAggregationFunction(LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties)
Create an
AllWindowFunction to compute non-partitioned group window aggregates. |
static AllWindowFunction<Row,Row,Window> |
AggregateUtil.createAllWindowIncrementalAggregationFunction(LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties)
Create an
AllWindowFunction to finalize incrementally pre-computed non-partitioned
window aggreagtes. |
AllWindowFunction<Row,Row,Window> |
AggregateUtil$.createAllWindowIncrementalAggregationFunction(LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties)
Create an
AllWindowFunction to finalize incrementally pre-computed non-partitioned
window aggreagtes. |
static WindowFunction<Row,Row,Tuple,Window> |
AggregateUtil.createWindowAggregationFunction(LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties)
Create a
WindowFunction to compute partitioned group window aggregates. |
WindowFunction<Row,Row,Tuple,Window> |
AggregateUtil$.createWindowAggregationFunction(LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties)
Create a
WindowFunction to compute partitioned group window aggregates. |
static WindowFunction<Row,Row,Tuple,Window> |
AggregateUtil.createWindowIncrementalAggregationFunction(LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties)
Create a
WindowFunction to finalize incrementally pre-computed window aggregates. |
WindowFunction<Row,Row,Tuple,Window> |
AggregateUtil$.createWindowIncrementalAggregationFunction(LogicalWindow window,
scala.collection.Seq<org.apache.calcite.util.Pair<org.apache.calcite.rel.core.AggregateCall,String>> namedAggregates,
org.apache.calcite.rel.type.RelDataType inputType,
org.apache.calcite.rel.type.RelDataType outputType,
int[] groupings,
scala.collection.Seq<FlinkRelBuilder.NamedWindowProperty> properties)
Create a
WindowFunction to finalize incrementally pre-computed window aggregates. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.