| 构造器和说明 |
|---|
BatchExecWindowTableFunction(org.apache.flink.configuration.ReadableConfig tableConfig,
TimeAttributeWindowingStrategy windowingStrategy,
InputProperty inputProperty,
org.apache.flink.table.types.logical.RowType outputType,
String description) |
| 限定符和类型 | 字段和说明 |
|---|---|
protected TimeAttributeWindowingStrategy |
CommonExecWindowTableFunction.windowingStrategy |
| 构造器和说明 |
|---|
CommonExecWindowTableFunction(int id,
ExecNodeContext context,
org.apache.flink.configuration.ReadableConfig persistedConfig,
TimeAttributeWindowingStrategy windowingStrategy,
List<InputProperty> inputProperties,
org.apache.flink.table.types.logical.RowType outputType,
String description) |
| 构造器和说明 |
|---|
StreamExecWindowTableFunction(int id,
ExecNodeContext context,
org.apache.flink.configuration.ReadableConfig persistedConfig,
TimeAttributeWindowingStrategy windowingStrategy,
List<InputProperty> inputProperties,
org.apache.flink.table.types.logical.RowType outputType,
String description) |
StreamExecWindowTableFunction(org.apache.flink.configuration.ReadableConfig tableConfig,
TimeAttributeWindowingStrategy windowingStrategy,
InputProperty inputProperty,
org.apache.flink.table.types.logical.RowType outputType,
String description) |
| 限定符和类型 | 方法和说明 |
|---|---|
static org.apache.flink.table.runtime.operators.window.assigners.WindowAssigner<org.apache.flink.table.runtime.operators.window.TimeWindow> |
WindowTableFunctionUtil.createWindowAssigner(TimeAttributeWindowingStrategy windowingStrategy)
Creates window assigner based on input window strategy.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.