Package | Description |
---|---|
org.apache.flink.table.runtime.operators.aggregate.window.processors | |
org.apache.flink.table.runtime.operators.window.slicing |
Constructor and Description |
---|
SliceUnsharedWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler,
WindowBuffer.Factory windowBufferFactory,
SliceUnsharedAssigner sliceAssigner,
TypeSerializer<RowData> accSerializer,
java.time.ZoneId shiftTimeZone) |
Modifier and Type | Class and Description |
---|---|
static class |
SliceAssigners.SlicedUnsharedSliceAssigner
The
SliceAssigner for elements have been attached slice end timestamp, but the slices
are not shared, i.e. |
static class |
SliceAssigners.TumblingSliceAssigner
The
SliceAssigner for tumbling windows. |
static class |
SliceAssigners.WindowedSliceAssigner
The
SliceAssigner for elements have been attached window start and end timestamps. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.