public class PendingSplitsCheckpoint extends Object
Constructor and Description |
---|
PendingSplitsCheckpoint(Collection<FileStoreSourceSplit> splits,
Long currentSnapshotId) |
Modifier and Type | Method and Description |
---|---|
Long |
currentSnapshotId() |
Collection<FileStoreSourceSplit> |
splits() |
public PendingSplitsCheckpoint(Collection<FileStoreSourceSplit> splits, @Nullable Long currentSnapshotId)
public Collection<FileStoreSourceSplit> splits()
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.