public class EndOfStreamWindows extends org.apache.flink.streaming.api.windowing.assigners.WindowAssigner<Object,org.apache.flink.streaming.api.windowing.windows.TimeWindow>
WindowAssigner
that assigns all elements of a bounded input stream into one window
pane. The results are emitted once the input stream has ended.Modifier and Type | Method and Description |
---|---|
Collection<org.apache.flink.streaming.api.windowing.windows.TimeWindow> |
assignWindows(Object element,
long timestamp,
org.apache.flink.streaming.api.windowing.assigners.WindowAssigner.WindowAssignerContext context) |
static EndOfStreamWindows |
get() |
org.apache.flink.streaming.api.windowing.triggers.Trigger<Object,org.apache.flink.streaming.api.windowing.windows.TimeWindow> |
getDefaultTrigger(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env) |
org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.streaming.api.windowing.windows.TimeWindow> |
getWindowSerializer(org.apache.flink.api.common.ExecutionConfig executionConfig) |
boolean |
isEventTime() |
String |
toString() |
public static EndOfStreamWindows get()
public Collection<org.apache.flink.streaming.api.windowing.windows.TimeWindow> assignWindows(Object element, long timestamp, org.apache.flink.streaming.api.windowing.assigners.WindowAssigner.WindowAssignerContext context)
assignWindows
in class org.apache.flink.streaming.api.windowing.assigners.WindowAssigner<Object,org.apache.flink.streaming.api.windowing.windows.TimeWindow>
public org.apache.flink.streaming.api.windowing.triggers.Trigger<Object,org.apache.flink.streaming.api.windowing.windows.TimeWindow> getDefaultTrigger(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)
getDefaultTrigger
in class org.apache.flink.streaming.api.windowing.assigners.WindowAssigner<Object,org.apache.flink.streaming.api.windowing.windows.TimeWindow>
public org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.streaming.api.windowing.windows.TimeWindow> getWindowSerializer(org.apache.flink.api.common.ExecutionConfig executionConfig)
getWindowSerializer
in class org.apache.flink.streaming.api.windowing.assigners.WindowAssigner<Object,org.apache.flink.streaming.api.windowing.windows.TimeWindow>
public boolean isEventTime()
isEventTime
in class org.apache.flink.streaming.api.windowing.assigners.WindowAssigner<Object,org.apache.flink.streaming.api.windowing.windows.TimeWindow>
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.