Package | Description |
---|---|
org.apache.flink.streaming.api.datastream | |
org.apache.flink.streaming.api.windowing.assigners | |
org.apache.flink.streaming.api.windowing.windows |
Modifier and Type | Method and Description |
---|---|
WindowedStream<T,KEY,GlobalWindow> |
KeyedStream.countWindow(long size)
Windows this
KeyedStream into tumbling count windows. |
WindowedStream<T,KEY,GlobalWindow> |
KeyedStream.countWindow(long size,
long slide)
Windows this
KeyedStream into sliding count windows. |
AllWindowedStream<T,GlobalWindow> |
DataStream.countWindowAll(long size)
Windows this
DataStream into tumbling count windows. |
AllWindowedStream<T,GlobalWindow> |
DataStream.countWindowAll(long size,
long slide)
Windows this
DataStream into sliding count windows. |
Modifier and Type | Method and Description |
---|---|
Collection<GlobalWindow> |
GlobalWindows.assignWindows(Object element,
long timestamp,
WindowAssigner.WindowAssignerContext context) |
Trigger<Object,GlobalWindow> |
GlobalWindows.getDefaultTrigger(StreamExecutionEnvironment env) |
TypeSerializer<GlobalWindow> |
GlobalWindows.getWindowSerializer(ExecutionConfig executionConfig) |
Modifier and Type | Method and Description |
---|---|
void |
GlobalWindows.NeverTrigger.clear(GlobalWindow window,
Trigger.TriggerContext ctx) |
TriggerResult |
GlobalWindows.NeverTrigger.onElement(Object element,
long timestamp,
GlobalWindow window,
Trigger.TriggerContext ctx) |
TriggerResult |
GlobalWindows.NeverTrigger.onEventTime(long time,
GlobalWindow window,
Trigger.TriggerContext ctx) |
void |
GlobalWindows.NeverTrigger.onMerge(GlobalWindow window,
Trigger.OnMergeContext ctx) |
TriggerResult |
GlobalWindows.NeverTrigger.onProcessingTime(long time,
GlobalWindow window,
Trigger.TriggerContext ctx) |
Modifier and Type | Method and Description |
---|---|
GlobalWindow |
GlobalWindow.Serializer.copy(GlobalWindow from) |
GlobalWindow |
GlobalWindow.Serializer.copy(GlobalWindow from,
GlobalWindow reuse) |
GlobalWindow |
GlobalWindow.Serializer.createInstance() |
GlobalWindow |
GlobalWindow.Serializer.deserialize(DataInputView source) |
GlobalWindow |
GlobalWindow.Serializer.deserialize(GlobalWindow reuse,
DataInputView source) |
static GlobalWindow |
GlobalWindow.get() |
Modifier and Type | Method and Description |
---|---|
TypeSerializerSnapshot<GlobalWindow> |
GlobalWindow.Serializer.snapshotConfiguration() |
Modifier and Type | Method and Description |
---|---|
GlobalWindow |
GlobalWindow.Serializer.copy(GlobalWindow from) |
GlobalWindow |
GlobalWindow.Serializer.copy(GlobalWindow from,
GlobalWindow reuse) |
GlobalWindow |
GlobalWindow.Serializer.deserialize(GlobalWindow reuse,
DataInputView source) |
void |
GlobalWindow.Serializer.serialize(GlobalWindow record,
DataOutputView target) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.