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> |
InternalWindowProcessFunction.windowAggregator |
Constructor and Description |
---|
DefaultAccMergingConsumer(InternalWindowProcessFunction.Context<?,W> ctx,
NamespaceAggsHandleFunctionBase<W> windowAggregator) |
GeneralWindowProcessFunction(GroupWindowAssigner<W> windowAssigner,
NamespaceAggsHandleFunctionBase<W> windowAggregator,
long allowedLateness) |
InternalWindowProcessFunction(GroupWindowAssigner<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) |
Modifier and Type | Field and Description |
---|---|
protected NamespaceAggsHandleFunctionBase<W> |
WindowOperator.windowAggregator |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.