public static class StreamingFileCommitter.CommitMessage extends Object implements Serializable
Need to ensure that the partitions are ready to commit. That is to say, the files in the partition have become readable rather than temporary.
Modifier and Type | Field and Description |
---|---|
long |
checkpointId |
int |
numberOfTasks |
List<String> |
partitions |
int |
taskId |
Constructor and Description |
---|
CommitMessage()
Pojo need this constructor.
|
CommitMessage(long checkpointId,
int taskId,
int numberOfTasks,
List<String> partitions) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.