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

Class ReadUtils

java.lang.Object

org.apache.beam.sdk.io.iceberg.ReadUtils

public class ReadUtils
extends Object

Helper class for source operations.

Constructor Summary

Constructors

Constructor	Description
ReadUtils()

Method Summary

Modifier and Type	Method	Description
static org.apache.iceberg.io.CloseableIterable<org.apache.iceberg.data.Record>	maybeApplyFilter(org.apache.iceberg.io.CloseableIterable<org.apache.iceberg.data.Record> iterable, IcebergScanConfig scanConfig)

Methods inherited from class java.lang.Object

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

Constructor Details

ReadUtils

public ReadUtils()

Method Details

maybeApplyFilter

public static org.apache.iceberg.io.CloseableIterable<org.apache.iceberg.data.Record> maybeApplyFilter(org.apache.iceberg.io.CloseableIterable<org.apache.iceberg.data.Record> iterable,
 IcebergScanConfig scanConfig)