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| 构造器和说明 |
|---|
SinkOperatorFactory(org.apache.flink.api.connector.sink.Sink<InputT,CommT,WriterStateT,?> sink,
boolean batch,
boolean shouldEmit) |
| 限定符和类型 | 方法和说明 |
|---|---|
<T extends StreamOperator<byte[]>> |
createStreamOperator(StreamOperatorParameters<byte[]> parameters)
Create the operator.
|
org.apache.flink.api.connector.sink.Sink<InputT,CommT,WriterStateT,?> |
getSink() |
Class<? extends StreamOperator> |
getStreamOperatorClass(ClassLoader classLoader)
Returns the runtime class of the stream operator.
|
getChainingStrategy, getMailboxExecutor, setChainingStrategy, setMailboxExecutor, setProcessingTimeServiceclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitsetMailboxExecutorgetChainingStrategy, isInputTypeConfigurable, isLegacySource, isOutputTypeConfigurable, isStreamSource, setChainingStrategy, setInputType, setOutputTypepublic SinkOperatorFactory(org.apache.flink.api.connector.sink.Sink<InputT,CommT,WriterStateT,?> sink, boolean batch, boolean shouldEmit)
public <T extends StreamOperator<byte[]>> T createStreamOperator(StreamOperatorParameters<byte[]> parameters)
StreamOperatorFactorycreateStreamOperator 在接口中 StreamOperatorFactory<byte[]>public Class<? extends StreamOperator> getStreamOperatorClass(ClassLoader classLoader)
StreamOperatorFactorygetStreamOperatorClass 在接口中 StreamOperatorFactory<byte[]>@VisibleForTesting public org.apache.flink.api.connector.sink.Sink<InputT,CommT,WriterStateT,?> getSink()
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.