org.apache.beam.sdk.io.iceberg

Class IcebergScanConfig

java.lang.Object

org.apache.beam.sdk.io.iceberg.IcebergScanConfig

All Implemented Interfaces:

java.io.Serializable

public abstract class IcebergScanConfig
extends java.lang.Object
implements java.io.Serializable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	IcebergScanConfig.Builder
static class	IcebergScanConfig.ScanType

Constructor Summary

Constructors

Constructor and Description
IcebergScanConfig()

Method Summary

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IcebergScanConfig

public IcebergScanConfig()

Method Detail

getScanType

@Pure
public abstract IcebergScanConfig.ScanType getScanType()

getCatalogConfig

@Pure
public abstract IcebergCatalogConfig getCatalogConfig()

getTableIdentifier

@Pure
public abstract java.lang.String getTableIdentifier()

getTable

@Pure
public org.apache.iceberg.Table getTable()

getSchema

@Pure
public abstract Schema getSchema()

getFilter

@Pure
public abstract @Nullable org.apache.iceberg.expressions.Expression getFilter()

getCaseSensitive

@Pure
public abstract @Nullable java.lang.Boolean getCaseSensitive()

getOptions

@Pure
public abstract org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.ImmutableMap<java.lang.String,java.lang.String> getOptions()

getSnapshot

@Pure
public abstract @Nullable java.lang.Long getSnapshot()

getTimestamp

@Pure
public abstract @Nullable java.lang.Long getTimestamp()

getFromSnapshotInclusive

@Pure
public abstract @Nullable java.lang.Long getFromSnapshotInclusive()

getFromSnapshotRefInclusive

@Pure
public abstract @Nullable java.lang.String getFromSnapshotRefInclusive()

getFromSnapshotExclusive

@Pure
public abstract @Nullable java.lang.Long getFromSnapshotExclusive()

getFromSnapshotRefExclusive

@Pure
public abstract @Nullable java.lang.String getFromSnapshotRefExclusive()

getToSnapshot

@Pure
public abstract @Nullable java.lang.Long getToSnapshot()

getToSnapshotRef

@Pure
public abstract @Nullable java.lang.String getToSnapshotRef()

getTag

@Pure
public abstract @Nullable java.lang.String getTag()

getBranch

@Pure
public abstract @Nullable java.lang.String getBranch()

builder

@Pure
public static IcebergScanConfig.Builder builder()