Constructor and Description |
---|
StreamArrowPythonGroupWindowAggregateFunctionOperator(Configuration config,
PythonFunctionInfo[] pandasAggFunctions,
RowType inputType,
RowType udfInputType,
RowType udfOutputType,
int inputTimeFieldIndex,
WindowAssigner<W> windowAssigner,
Trigger<W> trigger,
long allowedLateness,
NamedWindowProperty[] namedProperties,
java.time.ZoneId shiftTimeZone,
GeneratedProjection generatedProjection) |
Modifier and Type | Field and Description |
---|---|
protected Trigger<?> |
WindowOperatorBuilder.trigger |
Modifier and Type | Method and Description |
---|---|
WindowOperatorBuilder |
WindowOperatorBuilder.triggering(Trigger<?> trigger) |
Modifier and Type | Class and Description |
---|---|
static class |
ElementTriggers.CountElement<W extends Window>
A
Trigger that fires at some point after a specified number of input elements have
arrived. |
static class |
ElementTriggers.EveryElement<W extends Window>
A
Trigger that triggers on every element. |
static class |
EventTimeTriggers.AfterEndOfWindow<W extends Window>
A
Trigger that fires once the watermark passes the end of the window to which a pane
belongs. |
static class |
EventTimeTriggers.AfterEndOfWindowEarlyAndLate<W extends Window>
A composite
Trigger that consist of AfterEndOfWindow and a early trigger and late
trigger. |
static class |
EventTimeTriggers.AfterEndOfWindowNoLate<W extends Window>
A composite
Trigger that consist of AfterEndOfWindow and a late trigger. |
static class |
ProcessingTimeTriggers.AfterEndOfWindow<W extends Window>
A
Trigger that fires once the current system time passes the end of the window to
which a pane belongs. |
static class |
ProcessingTimeTriggers.AfterEndOfWindowNoLate<W extends Window>
A composite
Trigger that consist of AfterEndOfWindow and a early trigger. |
static class |
ProcessingTimeTriggers.AfterFirstElementPeriodic<W extends Window>
Trigger every a given interval, the first trigger time is interval after the first element in
the pane.
|
class |
WindowTrigger<W extends Window>
A
WindowTrigger determines when a window should be evaluated to emit the results. |
Modifier and Type | Method and Description |
---|---|
Trigger<W> |
EventTimeTriggers.AfterEndOfWindow.withLateFirings(Trigger<W> lateFirings)
Creates a new
Trigger like the this, except that it fires repeatedly whenever the
given Trigger fires after the watermark has passed the end of the window. |
Trigger<W> |
EventTimeTriggers.AfterEndOfWindowNoLate.withLateFirings(Trigger<W> lateFirings)
Creates a new
Trigger like the this, except that it fires repeatedly whenever the
given Trigger fires after the watermark has passed the end of the window. |
Modifier and Type | Method and Description |
---|---|
EventTimeTriggers.AfterEndOfWindowNoLate<W> |
EventTimeTriggers.AfterEndOfWindow.withEarlyFirings(Trigger<W> earlyFirings)
Creates a new
Trigger like the this, except that it fires repeatedly whenever the
given Trigger fires before the watermark has passed the end of the window. |
ProcessingTimeTriggers.AfterEndOfWindowNoLate<W> |
ProcessingTimeTriggers.AfterEndOfWindow.withEarlyFirings(Trigger<W> earlyFirings)
Creates a new
Trigger like the this, except that it fires repeatedly whenever the
given Trigger fires before the processing time has passed the end of the window. |
Trigger<W> |
EventTimeTriggers.AfterEndOfWindow.withLateFirings(Trigger<W> lateFirings)
Creates a new
Trigger like the this, except that it fires repeatedly whenever the
given Trigger fires after the watermark has passed the end of the window. |
Trigger<W> |
EventTimeTriggers.AfterEndOfWindowNoLate.withLateFirings(Trigger<W> lateFirings)
Creates a new
Trigger like the this, except that it fires repeatedly whenever the
given Trigger fires after the watermark has passed the end of the window. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.