public static final class RollingSink.BucketState extends Object implements Serializable
Modifier and Type | Field and Description |
---|---|
String |
currentFile
The file that was in-progress when the last checkpoint occurred.
|
long |
currentFileValidLength
The valid length of the in-progress file at the time of the last checkpoint.
|
List<String> |
pendingFiles
Pending files that accumulated since the last checkpoint.
|
Map<Long,List<String>> |
pendingFilesPerCheckpoint
When doing a checkpoint we move the pending files since the last checkpoint to this map
with the id of the checkpoint.
|
Constructor and Description |
---|
BucketState() |
public String currentFile
public long currentFileValidLength
public List<String> pendingFiles
public final Map<Long,List<String>> pendingFilesPerCheckpoint
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.