Package org.apache.beam.sdk.io.delta

Class DeltaCDCReadTask

java.lang.Object

org.apache.beam.sdk.io.delta.DeltaCDCReadTask

All Implemented Interfaces:

Serializable

public class DeltaCDCReadTask
extends Object
implements Serializable

A serializable task containing the necessary metadata to read a CDF (Change Data Feed) file. This can be either a CDC parquet file or a regular data file (representing inserts) from a commit.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
DeltaCDCReadTask(String path, long size, Map<String,String> partitionValues, long version, long timestamp, boolean isCDC, List<Long> rowGroupSizes, SerializableRow scanStateRow)

Method Summary

Modifier and Type	Method	Description
boolean	equals(@Nullable Object o)
Map<String,String>	getPartitionValues()
String	getPath()
List<Long>	getRowGroupSizes()
SerializableRow	getScanStateRow()
long	getSize()
long	getTimestamp()
long	getVersion()
int	hashCode()
boolean	isCDC()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

DeltaCDCReadTask

public DeltaCDCReadTask(String path,
 long size,
 Map<String,String> partitionValues,
 long version,
 long timestamp,
 boolean isCDC,
 List<Long> rowGroupSizes,
 SerializableRow scanStateRow)

Method Details

getPath

public String getPath()

getSize

public long getSize()

getPartitionValues

public Map<String,String> getPartitionValues()

getVersion

public long getVersion()

getTimestamp

public long getTimestamp()

isCDC

public boolean isCDC()

getRowGroupSizes

public List<Long> getRowGroupSizes()

getScanStateRow

public SerializableRow getScanStateRow()

equals

public boolean equals(@Nullable Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object