org.apache.beam.sdk.io.iceberg

Class ReadUtils

java.lang.Object

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

public class ReadUtils
extends java.lang.Object

Helper class for source operations.

Constructor Summary

Constructors

Constructor and Description
ReadUtils()

Method Summary

Modifier and Type	Method and 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 Detail

ReadUtils

public ReadUtils()

Method Detail

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)