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 and Description
FileWriterBucketState(String bucketId, Path bucketPath, long inProgressFileCreationTime, InProgressFileWriter.InProgressFileRecoverable inProgressFileRecoverable)
FileWriterBucketState(String bucketId, Path bucketPath, long inProgressFileCreationTime, InProgressFileWriter.InProgressFileRecoverable inProgressFileRecoverable, Map<Long,List<InProgressFileWriter.PendingFileRecoverable>> pendingFileRecoverablesPerCheckpoint)

Method Summary

Modifier and Type	Method and Description
String	getBucketId()
Path	getBucketPath()
long	getInProgressFileCreationTime()
Map<Long,List<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,
                             Path bucketPath,
                             long inProgressFileCreationTime,
                             @Nullable
                             InProgressFileWriter.InProgressFileRecoverable inProgressFileRecoverable)

FileWriterBucketState

public FileWriterBucketState(String bucketId,
                             Path bucketPath,
                             long inProgressFileCreationTime,
                             @Nullable
                             InProgressFileWriter.InProgressFileRecoverable inProgressFileRecoverable,
                             Map<Long,List<InProgressFileWriter.PendingFileRecoverable>> pendingFileRecoverablesPerCheckpoint)

Method Detail

getBucketId

public String getBucketId()

getBucketPath

public Path getBucketPath()

getInProgressFileCreationTime

public long getInProgressFileCreationTime()

getPendingFileRecoverablesPerCheckpoint

public Map<Long,List<InProgressFileWriter.PendingFileRecoverable>> getPendingFileRecoverablesPerCheckpoint()

toString

public String toString()

Overrides:

toString in class Object