public interface NamespaceAggsHandleFunction<N> extends NamespaceAggsHandleFunctionBase<N>
Modifier and Type | Method and Description |
---|---|
RowData |
getValue(N namespace)
Gets the result of the aggregation from the current accumulators and namespace properties
(like window start).
|
accumulate, cleanup, close, createAccumulators, getAccumulators, merge, open, retract, setAccumulators
RowData getValue(N namespace) throws Exception
namespace
- the namespace properties which should be calculated, such window startException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.