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

Class CdcReadUtils.GenericDeleteReader

java.lang.Object

org.apache.beam.sdk.io.iceberg.cdc.DeleteReader<org.apache.iceberg.data.Record>

org.apache.beam.sdk.io.iceberg.cdc.CdcReadUtils.GenericDeleteReader

Enclosing class:

CdcReadUtils

public static class CdcReadUtils.GenericDeleteReader
extends DeleteReader<org.apache.iceberg.data.Record>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.beam.sdk.io.iceberg.cdc.DeleteReader

DeleteReader.PreloadedDeletes

Constructor Summary

Constructors

Constructor	Description
GenericDeleteReader(org.apache.iceberg.io.FileIO io, String dataFilePath, org.apache.iceberg.Schema tableSchema, org.apache.iceberg.Schema requiredSchema, List<org.apache.iceberg.DeleteFile> deleteFiles, DeleteReader.PreloadedDeletes preloadedDeletes)

Method Summary

Modifier and Type	Method	Description
protected org.apache.iceberg.StructLike	asStructLike(org.apache.iceberg.data.Record record)
protected org.apache.iceberg.io.InputFile	getInputFile(String location)

Methods inherited from class org.apache.beam.sdk.io.iceberg.cdc.DeleteReader

deletedRowPositions, loadInputFile, newDeleteLoader, pos, read, requiredSchema

Methods inherited from class java.lang.Object

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

Constructor Details

GenericDeleteReader

public GenericDeleteReader(org.apache.iceberg.io.FileIO io,
 String dataFilePath,
 org.apache.iceberg.Schema tableSchema,
 org.apache.iceberg.Schema requiredSchema,
 List<org.apache.iceberg.DeleteFile> deleteFiles,
 DeleteReader.PreloadedDeletes preloadedDeletes)

Method Details

asStructLike

protected org.apache.iceberg.StructLike asStructLike(org.apache.iceberg.data.Record record)

Specified by:

asStructLike in class DeleteReader<org.apache.iceberg.data.Record>

getInputFile

protected org.apache.iceberg.io.InputFile getInputFile(String location)

Specified by:

getInputFile in class DeleteReader<org.apache.iceberg.data.Record>