public class CountTumblingWindowAssigner extends GroupWindowAssigner<CountWindow>
GroupWindowAssigner
that windows elements into fixed-size windows based on the count
number of the elements. Windows cannot overlap.Modifier and Type | Method and Description |
---|---|
Collection<CountWindow> |
assignWindows(RowData element,
long timestamp)
Given the timestamp and element, returns the set of windows into which it should be placed.
|
TypeSerializer<CountWindow> |
getWindowSerializer(ExecutionConfig executionConfig)
Returns a
TypeSerializer for serializing windows that are assigned by this WindowAssigner . |
boolean |
isEventTime()
Returns
true if elements are assigned to windows based on event time, false
otherwise. |
static CountTumblingWindowAssigner |
of(long size) |
void |
open(InternalWindowProcessFunction.Context<?,CountWindow> ctx)
Initialization method for the function.
|
String |
toString() |
public void open(InternalWindowProcessFunction.Context<?,CountWindow> ctx) throws Exception
GroupWindowAssigner
open
in class GroupWindowAssigner<CountWindow>
Exception
public Collection<CountWindow> assignWindows(RowData element, long timestamp) throws IOException
GroupWindowAssigner
assignWindows
in class GroupWindowAssigner<CountWindow>
element
- The element to which windows should be assigned.timestamp
- The timestamp of the element when GroupWindowAssigner.isEventTime()
returns true, or
the current system time when GroupWindowAssigner.isEventTime()
returns false. The timestamp value is
mapping to UTC milliseconds for splitting windows simply.IOException
public TypeSerializer<CountWindow> getWindowSerializer(ExecutionConfig executionConfig)
GroupWindowAssigner
TypeSerializer
for serializing windows that are assigned by this WindowAssigner
.getWindowSerializer
in class GroupWindowAssigner<CountWindow>
public boolean isEventTime()
GroupWindowAssigner
true
if elements are assigned to windows based on event time, false
otherwise.isEventTime
in class GroupWindowAssigner<CountWindow>
public String toString()
toString
in class GroupWindowAssigner<CountWindow>
public static CountTumblingWindowAssigner of(long size)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.