Package | Description |
---|---|
org.apache.flink.streaming.api.datastream |
Modifier and Type | Method and Description |
---|---|
static CustomSinkOperatorUidHashes.SinkOperatorUidHashesBuilder |
CustomSinkOperatorUidHashes.builder()
Creates a builder to construct
CustomSinkOperatorUidHashes . |
CustomSinkOperatorUidHashes.SinkOperatorUidHashesBuilder |
CustomSinkOperatorUidHashes.SinkOperatorUidHashesBuilder.setCommitterUidHash(String committerUidHash)
Sets the uid hash of the committer operator used to recover state.
|
CustomSinkOperatorUidHashes.SinkOperatorUidHashesBuilder |
CustomSinkOperatorUidHashes.SinkOperatorUidHashesBuilder.setGlobalCommitterUidHash(String globalCommitterUidHash)
Sets the uid hash of the global committer operator used to recover state.
|
CustomSinkOperatorUidHashes.SinkOperatorUidHashesBuilder |
CustomSinkOperatorUidHashes.SinkOperatorUidHashesBuilder.setWriterUidHash(String writerUidHash)
Sets the uid hash of the writer operator used to recover state.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.