Package | Description |
---|---|
org.apache.flink.streaming.connectors.fs.bucketing |
Modifier and Type | Method and Description |
---|---|
BucketingSink<T> |
BucketingSink.disableCleanupOnOpen()
Deprecated.
This option is deprecated and remains only for backwards compatibility. We do not
clean up lingering files anymore.
|
BucketingSink<T> |
BucketingSink.setAsyncTimeout(long timeout)
Deprecated.
Sets the default timeout for asynchronous operations such as recoverLease and truncate.
|
BucketingSink<T> |
BucketingSink.setBatchRolloverInterval(long batchRolloverInterval)
Deprecated.
Sets the roll over interval in milliseconds.
|
BucketingSink<T> |
BucketingSink.setBatchSize(long batchSize)
Deprecated.
Sets the maximum bucket size in bytes.
|
BucketingSink<T> |
BucketingSink.setBucketer(Bucketer<T> bucketer)
Deprecated.
Sets the
Bucketer to use for determining the bucket files to write to. |
BucketingSink<T> |
BucketingSink.setFSConfig(Configuration config)
Deprecated.
Specify a custom
Configuration that will be used when creating the FileSystem
for writing. |
BucketingSink<T> |
BucketingSink.setFSConfig(Configuration config)
Deprecated.
Specify a custom
Configuration that will be used when creating the FileSystem
for writing. |
BucketingSink<T> |
BucketingSink.setInactiveBucketCheckInterval(long interval)
Deprecated.
Sets the default time between checks for inactive buckets.
|
BucketingSink<T> |
BucketingSink.setInactiveBucketThreshold(long threshold)
Deprecated.
Sets the default threshold for marking a bucket as inactive and closing its part files.
|
BucketingSink<T> |
BucketingSink.setInProgressPrefix(String inProgressPrefix)
Deprecated.
Sets the prefix of in-progress part files.
|
BucketingSink<T> |
BucketingSink.setInProgressSuffix(String inProgressSuffix)
Deprecated.
Sets the suffix of in-progress part files.
|
BucketingSink<T> |
BucketingSink.setPartPrefix(String partPrefix)
Deprecated.
Sets the prefix of part files.
|
BucketingSink<T> |
BucketingSink.setPartSuffix(String partSuffix)
Deprecated.
Sets the suffix of part files.
|
BucketingSink<T> |
BucketingSink.setPendingPrefix(String pendingPrefix)
Deprecated.
Sets the prefix of pending part files.
|
BucketingSink<T> |
BucketingSink.setPendingSuffix(String pendingSuffix)
Deprecated.
Sets the suffix of pending part files.
|
BucketingSink<T> |
BucketingSink.setUseTruncate(boolean useTruncate)
Deprecated.
Sets whether to use
FileSystem.truncate() to truncate written bucket files back to a
consistent state in case of a restore from checkpoint. |
BucketingSink<T> |
BucketingSink.setValidLengthPrefix(String validLengthPrefix)
Deprecated.
Sets the prefix of valid-length files.
|
BucketingSink<T> |
BucketingSink.setValidLengthSuffix(String validLengthSuffix)
Deprecated.
Sets the suffix of valid-length files.
|
BucketingSink<T> |
BucketingSink.setWriter(Writer<T> writer)
Deprecated.
Sets the
Writer to be used for writing the incoming elements to bucket files. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.