Package | Description |
---|---|
org.apache.flink.table.runtime.operators.multipleinput | |
org.apache.flink.table.runtime.operators.multipleinput.input |
Modifier and Type | Field and Description |
---|---|
protected Deque<TableOperatorWrapper<?>> |
MultipleInputStreamOperatorBase.topologicalOrderingOperators
all operator as topological ordering in this multiple input operator.
|
Modifier and Type | Method and Description |
---|---|
TableOperatorWrapper<?> |
TableOperatorWrapper.Edge.getSource() |
TableOperatorWrapper<?> |
TableOperatorWrapperGenerator.getTailWrapper() |
TableOperatorWrapper<?> |
TableOperatorWrapper.Edge.getTarget() |
Modifier and Type | Method and Description |
---|---|
List<TableOperatorWrapper<?>> |
TableOperatorWrapperGenerator.getHeadWrappers() |
List<TableOperatorWrapper<?>> |
TableOperatorWrapper.getInputWrappers() |
List<TableOperatorWrapper<?>> |
TableOperatorWrapper.getOutputWrappers() |
Modifier and Type | Method and Description |
---|---|
void |
TableOperatorWrapper.addInput(TableOperatorWrapper<?> input,
int inputId) |
protected StreamConfig |
MultipleInputStreamOperatorBase.createStreamConfig(StreamOperatorParameters<RowData> multipleInputOperatorParameters,
TableOperatorWrapper<?> wrapper) |
protected StreamConfig |
BatchMultipleInputStreamOperator.createStreamConfig(StreamOperatorParameters<RowData> multipleInputOperatorParameters,
TableOperatorWrapper<?> wrapper) |
Constructor and Description |
---|
BatchMultipleInputStreamOperator(StreamOperatorParameters<RowData> parameters,
List<InputSpec> inputSpecs,
List<TableOperatorWrapper<?>> headWrapper,
TableOperatorWrapper<?> tailWrapper) |
BatchMultipleInputStreamOperatorFactory(List<InputSpec> inputSpecs,
List<TableOperatorWrapper<?>> headWrappers,
TableOperatorWrapper<?> tailWrapper) |
Edge(TableOperatorWrapper<?> source,
TableOperatorWrapper<?> target,
int inputId) |
Edge(TableOperatorWrapper<?> source,
TableOperatorWrapper<?> target,
int inputId) |
MultipleInputStreamOperatorBase(StreamOperatorParameters<RowData> parameters,
List<InputSpec> inputSpecs,
List<TableOperatorWrapper<?>> headWrappers,
TableOperatorWrapper<?> tailWrapper) |
Constructor and Description |
---|
BatchMultipleInputStreamOperator(StreamOperatorParameters<RowData> parameters,
List<InputSpec> inputSpecs,
List<TableOperatorWrapper<?>> headWrapper,
TableOperatorWrapper<?> tailWrapper) |
BatchMultipleInputStreamOperatorFactory(List<InputSpec> inputSpecs,
List<TableOperatorWrapper<?>> headWrappers,
TableOperatorWrapper<?> tailWrapper) |
MultipleInputStreamOperatorBase(StreamOperatorParameters<RowData> parameters,
List<InputSpec> inputSpecs,
List<TableOperatorWrapper<?>> headWrappers,
TableOperatorWrapper<?> tailWrapper) |
Modifier and Type | Method and Description |
---|---|
TableOperatorWrapper<?> |
InputSpec.getOutput() |
Constructor and Description |
---|
InputSpec(int multipleInputId,
int readOrder,
TableOperatorWrapper<?> output,
int outputOpInputId) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.