Package | Description |
---|---|
org.apache.flink.table.runtime.operators.window | |
org.apache.flink.table.runtime.operators.window.assigners |
Modifier and Type | Method and Description |
---|---|
CountWindow |
CountWindow.Serializer.copy(CountWindow from) |
CountWindow |
CountWindow.Serializer.copy(CountWindow from,
CountWindow reuse) |
CountWindow |
CountWindow.Serializer.createInstance() |
CountWindow |
CountWindow.Serializer.deserialize(CountWindow reuse,
DataInputView source) |
CountWindow |
CountWindow.Serializer.deserialize(DataInputView source) |
Modifier and Type | Method and Description |
---|---|
TypeSerializerSnapshot<CountWindow> |
CountWindow.Serializer.snapshotConfiguration() |
Modifier and Type | Method and Description |
---|---|
CountWindow |
CountWindow.Serializer.copy(CountWindow from) |
CountWindow |
CountWindow.Serializer.copy(CountWindow from,
CountWindow reuse) |
CountWindow |
CountWindow.Serializer.deserialize(CountWindow reuse,
DataInputView source) |
void |
CountWindow.Serializer.serialize(CountWindow record,
DataOutputView target) |
Modifier and Type | Method and Description |
---|---|
Collection<CountWindow> |
CountSlidingWindowAssigner.assignWindows(BaseRow element,
long timestamp) |
Collection<CountWindow> |
CountTumblingWindowAssigner.assignWindows(BaseRow element,
long timestamp) |
TypeSerializer<CountWindow> |
CountSlidingWindowAssigner.getWindowSerializer(ExecutionConfig executionConfig) |
TypeSerializer<CountWindow> |
CountTumblingWindowAssigner.getWindowSerializer(ExecutionConfig executionConfig) |
Modifier and Type | Method and Description |
---|---|
void |
CountSlidingWindowAssigner.open(InternalWindowProcessFunction.Context<?,CountWindow> ctx) |
void |
CountTumblingWindowAssigner.open(InternalWindowProcessFunction.Context<?,CountWindow> ctx) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.