Package | Description |
---|---|
org.apache.flink.table.runtime.operators.aggregate.window.processors | |
org.apache.flink.table.runtime.operators.window.slicing |
Constructor and Description |
---|
SliceSharedWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler,
WindowBuffer.Factory bufferFactory,
SliceSharedAssigner sliceAssigner,
TypeSerializer<RowData> accSerializer,
int indexOfCountStar,
java.time.ZoneId shiftTimeZone) |
Modifier and Type | Class and Description |
---|---|
static class |
SliceAssigners.CumulativeSliceAssigner
The
SliceAssigner for cumulative windows. |
static class |
SliceAssigners.HoppingSliceAssigner
The
SliceAssigner for hopping windows. |
static class |
SliceAssigners.SlicedSharedSliceAssigner
The
SliceAssigner for elements have been attached slice end timestamp, and the slices
are shared. |
Constructor and Description |
---|
SlicedSharedSliceAssigner(int sliceEndIndex,
SliceSharedAssigner innerAssigner) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.