Package org.apache.drill.exec.store.iceberg

Class IcebergSubScan.IcebergSubScanBuilder

java.lang.Object

org.apache.drill.exec.store.iceberg.IcebergSubScan.IcebergSubScanBuilder

Enclosing class:

IcebergSubScan

public static class IcebergSubScan.IcebergSubScanBuilder
extends Object

Constructor Summary

Constructors

Constructor	Description
IcebergSubScanBuilder()

Method Summary

Modifier and Type	Method	Description
IcebergSubScan	build()
IcebergSubScan.IcebergSubScanBuilder	columns(List<SchemaPath> columns)
IcebergSubScan.IcebergSubScanBuilder	condition(LogicalExpression condition)
IcebergSubScan.IcebergSubScanBuilder	formatPlugin(IcebergFormatPlugin formatPlugin)
IcebergSubScan.IcebergSubScanBuilder	maxRecords(int maxRecords)
IcebergSubScan.IcebergSubScanBuilder	path(String path)
IcebergSubScan.IcebergSubScanBuilder	schema(TupleMetadata schema)
IcebergSubScan.IcebergSubScanBuilder	tableScan(org.apache.iceberg.TableScan tableScan)
IcebergSubScan.IcebergSubScanBuilder	userName(String userName)
IcebergSubScan.IcebergSubScanBuilder	workList(List<IcebergWork> workList)

Methods inherited from class java.lang.Object

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

Constructor Details

IcebergSubScanBuilder

public IcebergSubScanBuilder()

Method Details

userName

public IcebergSubScan.IcebergSubScanBuilder userName(String userName)

formatPlugin

public IcebergSubScan.IcebergSubScanBuilder formatPlugin(IcebergFormatPlugin formatPlugin)

columns

public IcebergSubScan.IcebergSubScanBuilder columns(List<SchemaPath> columns)

condition

public IcebergSubScan.IcebergSubScanBuilder condition(LogicalExpression condition)

schema

public IcebergSubScan.IcebergSubScanBuilder schema(TupleMetadata schema)

workList

public IcebergSubScan.IcebergSubScanBuilder workList(List<IcebergWork> workList)

tableScan

public IcebergSubScan.IcebergSubScanBuilder tableScan(org.apache.iceberg.TableScan tableScan)

path

public IcebergSubScan.IcebergSubScanBuilder path(String path)

maxRecords

public IcebergSubScan.IcebergSubScanBuilder maxRecords(int maxRecords)

build

public IcebergSubScan build()