InputT
- The input type of the SinkWriter
.CommT
- The committable type of the SinkWriter
.WriterStateT
- The type of the Writer's
state.@Internal public final class SinkOperatorFactory<InputT,CommT,WriterStateT> extends AbstractStreamOperatorFactory<byte[]> implements OneInputStreamOperatorFactory<InputT,byte[]>, YieldingOperatorFactory<byte[]>
StreamOperatorFactory
for SinkOperator
.chainingStrategy, processingTimeService
Constructor and Description |
---|
SinkOperatorFactory(Sink<InputT,CommT,WriterStateT,?> sink,
boolean batch,
boolean shouldEmit) |
Modifier and Type | Method and Description |
---|---|
<T extends StreamOperator<byte[]>> |
createStreamOperator(StreamOperatorParameters<byte[]> parameters)
Create the operator.
|
Sink<InputT,CommT,WriterStateT,?> |
getSink() |
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
setMailboxExecutor
getChainingStrategy, isInputTypeConfigurable, isLegacySource, isOutputTypeConfigurable, isStreamSource, setChainingStrategy, setInputType, setOutputType
public SinkOperatorFactory(Sink<InputT,CommT,WriterStateT,?> sink, boolean batch, boolean shouldEmit)
public <T extends StreamOperator<byte[]>> T createStreamOperator(StreamOperatorParameters<byte[]> parameters)
StreamOperatorFactory
createStreamOperator
in interface StreamOperatorFactory<byte[]>
public Class<? extends StreamOperator> getStreamOperatorClass(ClassLoader classLoader)
StreamOperatorFactory
getStreamOperatorClass
in interface StreamOperatorFactory<byte[]>
@VisibleForTesting public Sink<InputT,CommT,WriterStateT,?> getSink()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.