Package org.apache.iceberg.mr
Class InputFormatConfig.ConfigBuilder
- java.lang.Object
-
- org.apache.iceberg.mr.InputFormatConfig.ConfigBuilder
-
- Enclosing class:
- InputFormatConfig
public static class InputFormatConfig.ConfigBuilder extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description ConfigBuilder(org.apache.hadoop.conf.Configuration conf)
-
Method Summary
-
-
-
Method Detail
-
conf
public org.apache.hadoop.conf.Configuration conf()
-
filter
public InputFormatConfig.ConfigBuilder filter(Expression expression)
-
project
public InputFormatConfig.ConfigBuilder project(Schema schema)
-
schema
public InputFormatConfig.ConfigBuilder schema(Schema schema)
-
select
public InputFormatConfig.ConfigBuilder select(java.util.List<java.lang.String> columns)
-
select
public InputFormatConfig.ConfigBuilder select(java.lang.String... columns)
-
readFrom
public InputFormatConfig.ConfigBuilder readFrom(TableIdentifier identifier)
-
readFrom
public InputFormatConfig.ConfigBuilder readFrom(java.lang.String location)
-
reuseContainers
public InputFormatConfig.ConfigBuilder reuseContainers(boolean reuse)
-
caseSensitive
public InputFormatConfig.ConfigBuilder caseSensitive(boolean caseSensitive)
-
snapshotId
public InputFormatConfig.ConfigBuilder snapshotId(long snapshotId)
-
asOfTime
public InputFormatConfig.ConfigBuilder asOfTime(long asOfTime)
-
splitSize
public InputFormatConfig.ConfigBuilder splitSize(long splitSize)
-
preferLocality
public InputFormatConfig.ConfigBuilder preferLocality()
If this API is called. The input splits constructed will have host location information
-
useHiveRows
public InputFormatConfig.ConfigBuilder useHiveRows()
-
usePigTuples
public InputFormatConfig.ConfigBuilder usePigTuples()
-
skipResidualFiltering
public InputFormatConfig.ConfigBuilder skipResidualFiltering()
Compute platforms pass down filters to data sources. If the data source cannot apply some filters, or only partially applies the filter, it will return the residual filter back. If the platform can correctly apply the residual filters, then it should call this api. Otherwise the current api will throw an exception if the passed in filter is not completely satisfied.
-
-