org.apache.flink.connector.file.sink

Class FileSinkCommittable

java.lang.Object

org.apache.flink.connector.file.sink.FileSinkCommittable

All Implemented Interfaces:

Serializable

@Internal
public class FileSinkCommittable
extends Object
implements Serializable

Wrapper class for both type of committables in FileSink. One committable might be either one pending files to commit, or one in-progress file to cleanup.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
FileSinkCommittable(String bucketId, InProgressFileWriter.InProgressFileRecoverable inProgressFileToCleanup)
FileSinkCommittable(String bucketId, InProgressFileWriter.PendingFileRecoverable pendingFile)
FileSinkCommittable(String bucketId, Path compactedFileToCleanup)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
String	getBucketId()
Path	getCompactedFileToCleanup()
InProgressFileWriter.InProgressFileRecoverable	getInProgressFileToCleanup()
InProgressFileWriter.PendingFileRecoverable	getPendingFile()
boolean	hasCompactedFileToCleanup()
int	hashCode()
boolean	hasInProgressFileToCleanup()
boolean	hasPendingFile()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

FileSinkCommittable

public FileSinkCommittable(String bucketId,
                           InProgressFileWriter.PendingFileRecoverable pendingFile)

FileSinkCommittable

public FileSinkCommittable(String bucketId,
                           InProgressFileWriter.InProgressFileRecoverable inProgressFileToCleanup)

FileSinkCommittable

public FileSinkCommittable(String bucketId,
                           Path compactedFileToCleanup)

Method Detail

getBucketId

public String getBucketId()

hasPendingFile

public boolean hasPendingFile()

getPendingFile

@Nullable
public InProgressFileWriter.PendingFileRecoverable getPendingFile()

hasInProgressFileToCleanup

public boolean hasInProgressFileToCleanup()

getInProgressFileToCleanup

@Nullable
public InProgressFileWriter.InProgressFileRecoverable getInProgressFileToCleanup()

hasCompactedFileToCleanup

public boolean hasCompactedFileToCleanup()

getCompactedFileToCleanup

@Nullable
public Path getCompactedFileToCleanup()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object