Package | Description |
---|---|
org.apache.flink.streaming.connectors.fs |
Modifier and Type | Method and Description |
---|---|
RollingSink<T> |
RollingSink.disableCleanupOnOpen()
Disable cleanup of leftover in-progress/pending files when the sink is opened.
|
RollingSink<T> |
RollingSink.setAsyncTimeout(long timeout)
Sets the default timeout for asynchronous operations such as recoverLease and truncate.
|
RollingSink<T> |
RollingSink.setBatchSize(long batchSize)
Sets the maximum bucket size in bytes.
|
RollingSink<T> |
RollingSink.setBucketer(Bucketer bucketer)
Sets the
Bucketer to use for determining the bucket files to write to. |
RollingSink<T> |
RollingSink.setInProgressPrefix(String inProgressPrefix)
Sets the prefix of in-progress part files.
|
RollingSink<T> |
RollingSink.setInProgressSuffix(String inProgressSuffix)
Sets the suffix of in-progress part files.
|
RollingSink<T> |
RollingSink.setPartPrefix(String partPrefix)
Sets the prefix of part files.
|
RollingSink<T> |
RollingSink.setPendingPrefix(String pendingPrefix)
Sets the prefix of pending part files.
|
RollingSink<T> |
RollingSink.setPendingSuffix(String pendingSuffix)
Sets the suffix of pending part files.
|
RollingSink<T> |
RollingSink.setValidLengthPrefix(String validLengthPrefix)
Sets the prefix of valid-length files.
|
RollingSink<T> |
RollingSink.setValidLengthSuffix(String validLengthSuffix)
Sets the suffix of valid-length files.
|
RollingSink<T> |
RollingSink.setWriter(Writer<T> writer)
Sets the
Writer to be used for writing the incoming elements to bucket files. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.