Constructor and Description |
---|
Options() |
Options(Configuration conf) |
Modifier and Type | Method and Description |
---|---|
Reader.Options |
clone() |
Reader.Options |
dataReader(DataReader value) |
Reader.Options |
forcePositionalEvolution(boolean value)
Set whether to force schema evolution to be positional instead of
based on the column names.
|
String[] |
getColumnNames() |
DataReader |
getDataReader() |
boolean |
getForcePositionalEvolution() |
boolean[] |
getInclude() |
boolean |
getIsSchemaEvolutionCaseAware() |
long |
getLength() |
long |
getMaxOffset() |
long |
getOffset() |
TypeDescription |
getSchema() |
SearchArgument |
getSearchArgument() |
Boolean |
getSkipCorruptRecords() |
boolean |
getTolerateMissingSchema() |
Boolean |
getUseZeroCopy() |
Reader.Options |
include(boolean[] include)
Set the list of columns to read.
|
Reader.Options |
isSchemaEvolutionCaseAware(boolean value)
Set boolean flag to determine if the comparision of field names in schema
evolution is case sensitive
|
Reader.Options |
range(long offset,
long length)
Set the range of bytes to read
|
Reader.Options |
schema(TypeDescription schema)
Set the schema on read type description.
|
Reader.Options |
searchArgument(SearchArgument sarg,
String[] columnNames)
Set search argument for predicate push down.
|
Reader.Options |
skipCorruptRecords(boolean value)
Set whether to skip corrupt records.
|
Reader.Options |
tolerateMissingSchema(boolean value)
Set whether to make a best effort to tolerate schema evolution for files
which do not have an embedded schema because they were written with a'
pre-HIVE-4243 writer.
|
String |
toString() |
Reader.Options |
useZeroCopy(boolean value)
Set whether to use zero copy from HDFS.
|
public Options()
public Options(Configuration conf)
public Reader.Options include(boolean[] include)
include
- a list of columns to readpublic Reader.Options range(long offset, long length)
offset
- the starting byte offsetlength
- the number of bytes to readpublic Reader.Options schema(TypeDescription schema)
public Reader.Options searchArgument(SearchArgument sarg, String[] columnNames)
sarg
- the search argumentcolumnNames
- the column names forpublic Reader.Options useZeroCopy(boolean value)
value
- the new zero copy flagpublic Reader.Options dataReader(DataReader value)
public Reader.Options skipCorruptRecords(boolean value)
value
- the new skip corrupt records flagpublic Reader.Options tolerateMissingSchema(boolean value)
value
- the new tolerance flagpublic Reader.Options forcePositionalEvolution(boolean value)
value
- force positional evolutionpublic Reader.Options isSchemaEvolutionCaseAware(boolean value)
value
- the flag for schema evolution is case sensitive or not.public boolean[] getInclude()
public long getOffset()
public long getLength()
public TypeDescription getSchema()
public SearchArgument getSearchArgument()
public String[] getColumnNames()
public long getMaxOffset()
public Boolean getUseZeroCopy()
public Boolean getSkipCorruptRecords()
public DataReader getDataReader()
public boolean getForcePositionalEvolution()
public boolean getIsSchemaEvolutionCaseAware()
public Reader.Options clone()
public boolean getTolerateMissingSchema()
Copyright © 2013–2018 The Apache Software Foundation. All rights reserved.