public abstract class IcebergScanConfig
extends java.lang.Object
implements java.io.Serializable
Modifier and Type | Class and Description |
---|---|
static class |
IcebergScanConfig.Builder |
static class |
IcebergScanConfig.ScanType |
Constructor and Description |
---|
IcebergScanConfig() |
Modifier and Type | Method and Description |
---|---|
static IcebergScanConfig.Builder |
builder() |
abstract @Nullable java.lang.String |
getBranch() |
abstract @Nullable java.lang.Boolean |
getCaseSensitive() |
abstract IcebergCatalogConfig |
getCatalogConfig() |
abstract @Nullable org.apache.iceberg.expressions.Expression |
getFilter() |
abstract @Nullable java.lang.Long |
getFromSnapshotExclusive() |
abstract @Nullable java.lang.Long |
getFromSnapshotInclusive() |
abstract @Nullable java.lang.String |
getFromSnapshotRefExclusive() |
abstract @Nullable java.lang.String |
getFromSnapshotRefInclusive() |
abstract org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.ImmutableMap<java.lang.String,java.lang.String> |
getOptions() |
abstract IcebergScanConfig.ScanType |
getScanType() |
abstract Schema |
getSchema() |
abstract @Nullable java.lang.Long |
getSnapshot() |
org.apache.iceberg.Table |
getTable() |
abstract java.lang.String |
getTableIdentifier() |
abstract @Nullable java.lang.String |
getTag() |
abstract @Nullable java.lang.Long |
getTimestamp() |
abstract @Nullable java.lang.Long |
getToSnapshot() |
abstract @Nullable java.lang.String |
getToSnapshotRef() |
@Pure public abstract IcebergScanConfig.ScanType getScanType()
@Pure public abstract IcebergCatalogConfig getCatalogConfig()
@Pure public abstract java.lang.String getTableIdentifier()
@Pure public org.apache.iceberg.Table getTable()
@Pure public abstract Schema getSchema()
@Pure public abstract @Nullable org.apache.iceberg.expressions.Expression getFilter()
@Pure public abstract @Nullable java.lang.Boolean getCaseSensitive()
@Pure public abstract org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.ImmutableMap<java.lang.String,java.lang.String> getOptions()
@Pure public abstract @Nullable java.lang.Long getSnapshot()
@Pure public abstract @Nullable java.lang.Long getTimestamp()
@Pure public abstract @Nullable java.lang.Long getFromSnapshotInclusive()
@Pure public abstract @Nullable java.lang.String getFromSnapshotRefInclusive()
@Pure public abstract @Nullable java.lang.Long getFromSnapshotExclusive()
@Pure public abstract @Nullable java.lang.String getFromSnapshotRefExclusive()
@Pure public abstract @Nullable java.lang.Long getToSnapshot()
@Pure public abstract @Nullable java.lang.String getToSnapshotRef()
@Pure public abstract @Nullable java.lang.String getTag()
@Pure public abstract @Nullable java.lang.String getBranch()
@Pure public static IcebergScanConfig.Builder builder()