Package | Description |
---|---|
org.apache.flink.streaming.api.datastream | |
org.apache.flink.streaming.runtime.operators.windowing |
This package contains the operators that implement the various window operations
on data streams.
|
Modifier and Type | Method and Description |
---|---|
static LegacyWindowOperatorType |
LegacyWindowOperatorType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static LegacyWindowOperatorType[] |
LegacyWindowOperatorType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Constructor and Description |
---|
WindowOperator(WindowAssigner<? super IN,W> windowAssigner,
TypeSerializer<W> windowSerializer,
KeySelector<IN,K> keySelector,
TypeSerializer<K> keySerializer,
StateDescriptor<? extends AppendingState<IN,ACC>,?> windowStateDescriptor,
InternalWindowFunction<ACC,OUT,K,W> windowFunction,
Trigger<? super IN,? super W> trigger,
long allowedLateness,
LegacyWindowOperatorType legacyWindowOperatorType)
Creates a new
WindowOperator based on the given policies and user functions. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.