Constructor and Description |
---|
BatchExecWindowTableFunction(ReadableConfig tableConfig,
TimeAttributeWindowingStrategy windowingStrategy,
InputProperty inputProperty,
RowType outputType,
String description) |
Modifier and Type | Field and Description |
---|---|
protected TimeAttributeWindowingStrategy |
CommonExecWindowTableFunction.windowingStrategy |
Constructor and Description |
---|
CommonExecWindowTableFunction(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
TimeAttributeWindowingStrategy windowingStrategy,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
Constructor and Description |
---|
StreamExecWindowTableFunction(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
TimeAttributeWindowingStrategy windowingStrategy,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
StreamExecWindowTableFunction(ReadableConfig tableConfig,
TimeAttributeWindowingStrategy windowingStrategy,
InputProperty inputProperty,
RowType outputType,
String description) |
Modifier and Type | Method and Description |
---|---|
static GroupWindowAssigner<TimeWindow> |
WindowTableFunctionUtil.createWindowAssigner(TimeAttributeWindowingStrategy windowingStrategy)
Creates window assigner based on input window strategy.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.