Package org.apache.flink.connector.file.sink.writer

Class FileWriterBucketState

java.lang.Object

org.apache.flink.connector.file.sink.writer.FileWriterBucketState

@Internal
public class FileWriterBucketState
extends Object

States for FileWriterBucket.

Constructor Summary

Constructors

Constructor	Description
FileWriterBucketState(String bucketId, org.apache.flink.core.fs.Path bucketPath, long inProgressFileCreationTime, org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter.InProgressFileRecoverable inProgressFileRecoverable)
FileWriterBucketState(String bucketId, org.apache.flink.core.fs.Path bucketPath, long inProgressFileCreationTime, org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter.InProgressFileRecoverable inProgressFileRecoverable, Map<Long,List<org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter.PendingFileRecoverable>> pendingFileRecoverablesPerCheckpoint)

Method Summary

Modifier and Type	Method	Description
String	getBucketId()
org.apache.flink.core.fs.Path	getBucketPath()
long	getInProgressFileCreationTime()
Map<Long,List<org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter.PendingFileRecoverable>>	getPendingFileRecoverablesPerCheckpoint()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

FileWriterBucketState

public FileWriterBucketState(String bucketId,
                             org.apache.flink.core.fs.Path bucketPath,
                             long inProgressFileCreationTime,
                             @Nullable
                             org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter.InProgressFileRecoverable inProgressFileRecoverable)

FileWriterBucketState

public FileWriterBucketState(String bucketId,
                             org.apache.flink.core.fs.Path bucketPath,
                             long inProgressFileCreationTime,
                             @Nullable
                             org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter.InProgressFileRecoverable inProgressFileRecoverable,
                             Map<Long,List<org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter.PendingFileRecoverable>> pendingFileRecoverablesPerCheckpoint)

Method Detail

getBucketId

public String getBucketId()

getBucketPath

public org.apache.flink.core.fs.Path getBucketPath()

getInProgressFileCreationTime

public long getInProgressFileCreationTime()

getPendingFileRecoverablesPerCheckpoint

public Map<Long,List<org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter.PendingFileRecoverable>> getPendingFileRecoverablesPerCheckpoint()

toString

public String toString()

Overrides:

toString in class Object