Modifier and Type | Method and Description |
---|---|
protected SliceAssigner |
StreamExecWindowAggregateBase.createSliceAssigner(WindowingStrategy windowingStrategy,
java.time.ZoneId shiftTimeZone) |
protected SliceAssigner |
StreamExecWindowAggregateBase.createSliceAssigner(WindowSpec windowSpec,
int timeAttributeIndex,
java.time.ZoneId shiftTimeZone) |
Modifier and Type | Method and Description |
---|---|
SlicingWindowAggOperatorBuilder |
SlicingWindowAggOperatorBuilder.assigner(SliceAssigner assigner) |
Constructor and Description |
---|
LocalSlicingWindowAggOperator(RowDataKeySelector keySelector,
SliceAssigner sliceAssigner,
WindowBuffer.LocalFactory windowBufferFactory,
java.time.ZoneId shiftTimezone) |
Modifier and Type | Field and Description |
---|---|
protected SliceAssigner |
AbstractWindowAggProcessor.sliceAssigner |
Constructor and Description |
---|
AbstractWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler,
WindowBuffer.Factory bufferFactory,
SliceAssigner sliceAssigner,
TypeSerializer<RowData> accSerializer,
java.time.ZoneId shiftTimeZone) |
Modifier and Type | Interface and Description |
---|---|
interface |
SliceSharedAssigner
A
SliceAssigner which shares slices for windows, which means a window is divided into
multiple slices and need to merge the slices into windows when emitting windows. |
interface |
SliceUnsharedAssigner
A
SliceAssigner which doesn't share slices for windows, which means a window is divided
into only one slice and doesn't need to merge the slices when emitting windows. |
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. |
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. |
Modifier and Type | Method and Description |
---|---|
static SliceAssigner |
SliceAssigners.sliced(int sliceEndIndex,
SliceAssigner innerAssigner)
Creates a
SliceAssigner that assigns elements which has been attached slice end
timestamp. |
Modifier and Type | Method and Description |
---|---|
static SliceAssigner |
SliceAssigners.sliced(int sliceEndIndex,
SliceAssigner innerAssigner)
Creates a
SliceAssigner that assigns elements which has been attached slice end
timestamp. |
static SliceAssigners.WindowedSliceAssigner |
SliceAssigners.windowed(int windowEndIndex,
SliceAssigner innerAssigner)
Creates a
SliceAssigner that assigns elements which has been attached window start
and window end timestamp to slices. |
Constructor and Description |
---|
SlicedUnsharedSliceAssigner(int sliceEndIndex,
SliceAssigner innerAssigner) |
WindowedSliceAssigner(int windowEndIndex,
SliceAssigner innerAssigner) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.