@Internal public class FileSinkCommittable extends Object implements Serializable
FileSink
. One committable might be either
one pending files to commit, or one in-progress file to cleanup.Constructor and Description |
---|
FileSinkCommittable(InProgressFileWriter.InProgressFileRecoverable inProgressFileToCleanup) |
FileSinkCommittable(InProgressFileWriter.PendingFileRecoverable pendingFile) |
Modifier and Type | Method and Description |
---|---|
InProgressFileWriter.InProgressFileRecoverable |
getInProgressFileToCleanup() |
InProgressFileWriter.PendingFileRecoverable |
getPendingFile() |
boolean |
hasInProgressFileToCleanup() |
boolean |
hasPendingFile() |
public FileSinkCommittable(InProgressFileWriter.PendingFileRecoverable pendingFile)
public FileSinkCommittable(InProgressFileWriter.InProgressFileRecoverable inProgressFileToCleanup)
public boolean hasPendingFile()
@Nullable public InProgressFileWriter.PendingFileRecoverable getPendingFile()
public boolean hasInProgressFileToCleanup()
@Nullable public InProgressFileWriter.InProgressFileRecoverable getInProgressFileToCleanup()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.