public class BatchMultipleInputStreamOperatorFactory extends AbstractStreamOperatorFactory<RowData>
BatchMultipleInputStreamOperator
.chainingStrategy, processingTimeService
Constructor and Description |
---|
BatchMultipleInputStreamOperatorFactory(List<InputSpec> inputSpecs,
List<TableOperatorWrapper<?>> headWrappers,
TableOperatorWrapper<?> tailWrapper) |
Modifier and Type | Method and Description |
---|---|
<T extends StreamOperator<RowData>> |
createStreamOperator(StreamOperatorParameters<RowData> parameters)
Create the operator.
|
Class<? extends StreamOperator> |
getStreamOperatorClass(ClassLoader classLoader)
Returns the runtime class of the stream operator.
|
getChainingStrategy, getMailboxExecutor, setChainingStrategy, setMailboxExecutor, setProcessingTimeService
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isInputTypeConfigurable, isLegacySource, isOutputTypeConfigurable, isStreamSource, setInputType, setOutputType
public BatchMultipleInputStreamOperatorFactory(List<InputSpec> inputSpecs, List<TableOperatorWrapper<?>> headWrappers, TableOperatorWrapper<?> tailWrapper)
public <T extends StreamOperator<RowData>> T createStreamOperator(StreamOperatorParameters<RowData> parameters)
StreamOperatorFactory
public Class<? extends StreamOperator> getStreamOperatorClass(ClassLoader classLoader)
StreamOperatorFactory
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.