Package | Description |
---|---|
org.apache.flink.streaming.connectors.fs |
Modifier and Type | Method and Description |
---|---|
RollingSink<T> |
RollingSink.disableCleanupOnOpen()
Deprecated.
This option is deprecated and remains only for backwards compatibility.
We do not clean up lingering files anymore.
|
RollingSink<T> |
RollingSink.setAsyncTimeout(long timeout)
Deprecated.
Sets the default timeout for asynchronous operations such as recoverLease and truncate.
|
RollingSink<T> |
RollingSink.setBatchSize(long batchSize)
Deprecated.
Sets the maximum bucket size in bytes.
|
RollingSink<T> |
RollingSink.setBucketer(Bucketer bucketer)
Deprecated.
Sets the
Bucketer to use for determining the bucket files to write to. |
RollingSink<T> |
RollingSink.setFSConfig(Configuration config)
Deprecated.
Specify a custom
Configuration that will be used when creating
the FileSystem for writing. |
RollingSink<T> |
RollingSink.setFSConfig(Configuration config)
Deprecated.
Specify a custom
Configuration that will be used when creating
the FileSystem for writing. |
RollingSink<T> |
RollingSink.setInProgressPrefix(String inProgressPrefix)
Deprecated.
Sets the prefix of in-progress part files.
|
RollingSink<T> |
RollingSink.setInProgressSuffix(String inProgressSuffix)
Deprecated.
Sets the suffix of in-progress part files.
|
RollingSink<T> |
RollingSink.setPartPrefix(String partPrefix)
Deprecated.
Sets the prefix of part files.
|
RollingSink<T> |
RollingSink.setPendingPrefix(String pendingPrefix)
Deprecated.
Sets the prefix of pending part files.
|
RollingSink<T> |
RollingSink.setPendingSuffix(String pendingSuffix)
Deprecated.
Sets the suffix of pending part files.
|
RollingSink<T> |
RollingSink.setValidLengthPrefix(String validLengthPrefix)
Deprecated.
Sets the prefix of valid-length files.
|
RollingSink<T> |
RollingSink.setValidLengthSuffix(String validLengthSuffix)
Deprecated.
Sets the suffix of valid-length files.
|
RollingSink<T> |
RollingSink.setWriter(Writer<T> writer)
Deprecated.
Sets the
Writer to be used for writing the incoming elements to bucket files. |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.