Package org.apache.beam.sdk.io.iceberg.cdc

Class SerializableChangelogTask

java.lang.Object

org.apache.beam.sdk.io.iceberg.cdc.SerializableChangelogTask

@DefaultSchema(AutoValueSchema.class)
public abstract class SerializableChangelogTask
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SerializableChangelogTask.Builder
static enum	SerializableChangelogTask.Type

Constructor Summary

Constructors

Constructor	Description
SerializableChangelogTask()

Method Summary

Modifier and Type	Method	Description
static SerializableChangelogTask.Builder	builder()
static SchemaCoder<SerializableChangelogTask>	coder()
static SerializableChangelogTask	from(org.apache.iceberg.ChangelogScanTask task, Map<Integer,org.apache.iceberg.PartitionSpec> specs)
static SerializableChangelogTask	from(org.apache.iceberg.ChangelogScanTask task, Map<Integer,org.apache.iceberg.PartitionSpec> specs, boolean includeMetrics)
abstract List<SerializableDeleteFile>	getAddedDeletes()
abstract long	getCommitSnapshotId()
abstract SerializableDataFile	getDataFile()
abstract List<SerializableDeleteFile>	getExistingDeletes()
org.apache.iceberg.expressions.Expression	getExpression(org.apache.iceberg.Schema schema)
abstract String	getJsonExpression()
abstract long	getLength()
abstract org.apache.iceberg.ChangelogOperation	getOperation()
abstract int	getOrdinal()
abstract int	getSpecId()
abstract long	getStart()
abstract SerializableChangelogTask.Type	getType()
abstract SerializableChangelogTask.Builder	toBuilder()

Methods inherited from class java.lang.Object

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

Constructor Details

SerializableChangelogTask

public SerializableChangelogTask()

Method Details

coder

public static SchemaCoder<SerializableChangelogTask> coder()

builder

public static SerializableChangelogTask.Builder builder()

getType

@SchemaFieldNumber("0")
public abstract SerializableChangelogTask.Type getType()

getDataFile

@SchemaFieldNumber("1")
public abstract SerializableDataFile getDataFile()

getExistingDeletes

@SchemaFieldNumber("2")
public abstract List<SerializableDeleteFile> getExistingDeletes()

getAddedDeletes

@SchemaFieldNumber("3")
public abstract List<SerializableDeleteFile> getAddedDeletes()

getSpecId

@SchemaFieldNumber("4")
public abstract int getSpecId()

getOperation

@SchemaFieldNumber("5")
public abstract org.apache.iceberg.ChangelogOperation getOperation()

getOrdinal

@SchemaFieldNumber("6")
public abstract int getOrdinal()

getCommitSnapshotId

@SchemaFieldNumber("7")
public abstract long getCommitSnapshotId()

getStart

@SchemaFieldNumber("8")
public abstract long getStart()

getLength

@SchemaFieldNumber("9")
public abstract long getLength()

getJsonExpression

@SchemaFieldNumber("10")
public abstract String getJsonExpression()

getExpression

@SchemaIgnore
public org.apache.iceberg.expressions.Expression getExpression(org.apache.iceberg.Schema schema)

toBuilder

public abstract SerializableChangelogTask.Builder toBuilder()

from

public static SerializableChangelogTask from(org.apache.iceberg.ChangelogScanTask task,
 Map<Integer,org.apache.iceberg.PartitionSpec> specs)

from

public static SerializableChangelogTask from(org.apache.iceberg.ChangelogScanTask task,
 Map<Integer,org.apache.iceberg.PartitionSpec> specs,
 boolean includeMetrics)