Modifier and Type | Interface and Description |
---|---|
interface |
NamespaceAggsHandleFunction<N>
The base class for handling aggregate functions with namespace.
|
interface |
NamespaceTableAggsHandleFunction<N>
The base class for handling table aggregate functions with namespace.
|
Modifier and Type | Field and Description |
---|---|
protected NamespaceAggsHandleFunctionBase<W> |
WindowOperator.windowAggregator |
Modifier and Type | Field and Description |
---|---|
protected NamespaceAggsHandleFunctionBase<W> |
InternalWindowProcessFunction.windowAggregator |
Constructor and Description |
---|
GeneralWindowProcessFunction(WindowAssigner<W> windowAssigner,
NamespaceAggsHandleFunctionBase<W> windowAggregator,
long allowedLateness) |
InternalWindowProcessFunction(WindowAssigner<W> windowAssigner,
NamespaceAggsHandleFunctionBase<W> windowAggregator,
long allowedLateness) |
MergingWindowProcessFunction(MergingWindowAssigner<W> windowAssigner,
NamespaceAggsHandleFunctionBase<W> windowAggregator,
TypeSerializer<W> windowSerializer,
long allowedLateness) |
PanedWindowProcessFunction(PanedWindowAssigner<W> windowAssigner,
NamespaceAggsHandleFunctionBase<W> windowAggregator,
long allowedLateness) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.