public class ContinuousFromSnapshotStartingScanner extends Object implements StartingScanner
StartingScanner
for the CoreOptions.StartupMode.FROM_SNAPSHOT
startup mode of a streaming
read.Constructor and Description |
---|
ContinuousFromSnapshotStartingScanner(long snapshotId) |
Modifier and Type | Method and Description |
---|---|
DataTableScan.DataFilePlan |
getPlan(SnapshotManager snapshotManager,
DataTableScan scan) |
public ContinuousFromSnapshotStartingScanner(long snapshotId)
public DataTableScan.DataFilePlan getPlan(SnapshotManager snapshotManager, DataTableScan scan)
getPlan
in interface StartingScanner
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.