Package | Description |
---|---|
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 |
WindowOperator.WindowContext
A utility class for handling
ProcessWindowFunction invocations. |
Modifier and Type | Method and Description |
---|---|
void |
InternalIterableProcessAllWindowFunction.clear(W window,
InternalWindowFunction.InternalWindowContext context) |
void |
InternalAggregateProcessWindowFunction.clear(W window,
InternalWindowFunction.InternalWindowContext context) |
void |
InternalIterableProcessWindowFunction.clear(W window,
InternalWindowFunction.InternalWindowContext context) |
void |
InternalAggregateProcessAllWindowFunction.clear(W window,
InternalWindowFunction.InternalWindowContext context) |
void |
InternalWindowFunction.clear(W window,
InternalWindowFunction.InternalWindowContext context)
Deletes any state in the
Context when the Window is purged. |
void |
InternalSingleValueProcessAllWindowFunction.clear(W window,
InternalWindowFunction.InternalWindowContext context) |
void |
InternalSingleValueWindowFunction.clear(W window,
InternalWindowFunction.InternalWindowContext context) |
void |
InternalSingleValueAllWindowFunction.clear(W window,
InternalWindowFunction.InternalWindowContext context) |
void |
InternalSingleValueProcessWindowFunction.clear(W window,
InternalWindowFunction.InternalWindowContext context) |
void |
InternalIterableWindowFunction.clear(W window,
InternalWindowFunction.InternalWindowContext context) |
void |
InternalIterableAllWindowFunction.clear(W window,
InternalWindowFunction.InternalWindowContext context) |
void |
InternalSingleValueProcessAllWindowFunction.process(Byte key,
W window,
InternalWindowFunction.InternalWindowContext context,
IN input,
Collector<OUT> out) |
void |
InternalSingleValueAllWindowFunction.process(Byte key,
W window,
InternalWindowFunction.InternalWindowContext context,
IN input,
Collector<OUT> out) |
void |
InternalIterableProcessAllWindowFunction.process(Byte key,
W window,
InternalWindowFunction.InternalWindowContext context,
Iterable<IN> input,
Collector<OUT> out) |
void |
InternalIterableAllWindowFunction.process(Byte key,
W window,
InternalWindowFunction.InternalWindowContext context,
Iterable<IN> input,
Collector<OUT> out) |
void |
InternalAggregateProcessAllWindowFunction.process(Byte key,
W window,
InternalWindowFunction.InternalWindowContext context,
Iterable<T> input,
Collector<R> out) |
void |
InternalWindowFunction.process(KEY key,
W window,
InternalWindowFunction.InternalWindowContext context,
IN input,
Collector<OUT> out)
Evaluates the window and outputs none or several elements.
|
void |
InternalSingleValueWindowFunction.process(KEY key,
W window,
InternalWindowFunction.InternalWindowContext context,
IN input,
Collector<OUT> out) |
void |
InternalSingleValueProcessWindowFunction.process(KEY key,
W window,
InternalWindowFunction.InternalWindowContext context,
IN input,
Collector<OUT> out) |
void |
InternalIterableProcessWindowFunction.process(KEY key,
W window,
InternalWindowFunction.InternalWindowContext context,
Iterable<IN> input,
Collector<OUT> out) |
void |
InternalIterableWindowFunction.process(KEY key,
W window,
InternalWindowFunction.InternalWindowContext context,
Iterable<IN> input,
Collector<OUT> out) |
void |
InternalAggregateProcessWindowFunction.process(K key,
W window,
InternalWindowFunction.InternalWindowContext context,
Iterable<T> input,
Collector<R> out) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.