InputT
- The input type of the SinkWriter
.CommT
- The committable type of the SinkWriter
.public final class StatelessSinkWriterOperatorFactory<InputT,CommT> extends AbstractStreamOperatorFactory<CommT>
StreamOperatorFactory
for StatelessSinkWriterOperator
.chainingStrategy, processingTimeService
Constructor and Description |
---|
StatelessSinkWriterOperatorFactory(Sink<InputT,CommT,?,?> sink) |
Modifier and Type | Method and Description |
---|---|
<T extends StreamOperator<CommT>> |
createStreamOperator(StreamOperatorParameters<CommT> parameters)
Create the operator.
|
Class<? extends StreamOperator> |
getStreamOperatorClass(ClassLoader classLoader)
Returns the runtime class of the stream operator.
|
getChainingStrategy, setChainingStrategy, setProcessingTimeService
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getChainingStrategy, isInputTypeConfigurable, isLegacySource, isOutputTypeConfigurable, isStreamSource, setChainingStrategy, setInputType, setOutputType
public Class<? extends StreamOperator> getStreamOperatorClass(ClassLoader classLoader)
StreamOperatorFactory
public <T extends StreamOperator<CommT>> T createStreamOperator(StreamOperatorParameters<CommT> parameters)
StreamOperatorFactory
createStreamOperator
in interface StreamOperatorFactory<CommT>
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.