Constructor and Description |
---|
Options() |
Options(Configuration conf) |
Modifier and Type | Method and Description |
---|---|
Reader.Options |
clone() |
Reader.Options |
dataReader(DataReader value) |
String[] |
getColumnNames() |
DataReader |
getDataReader() |
boolean[] |
getInclude() |
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 |
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 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 Reader.Options clone()
public boolean getTolerateMissingSchema()
Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.