public class HiveVectorizedParquetSplitReader extends Object implements SplitReader
SplitReader
to read files using ParquetColumnarRowSplitReader
.Constructor and Description |
---|
HiveVectorizedParquetSplitReader(String hiveVersion,
org.apache.hadoop.mapred.JobConf jobConf,
String[] fieldNames,
DataType[] fieldTypes,
int[] selectedFields,
HiveTableInputSplit split) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
RowData |
nextRecord(RowData reuse)
Reads the next record from the input.
|
boolean |
reachedEnd()
Method used to check if the end of the input is reached.
|
void |
seekToRow(long rowCount,
RowData reuse)
Seek to a particular row number.
|
public HiveVectorizedParquetSplitReader(String hiveVersion, org.apache.hadoop.mapred.JobConf jobConf, String[] fieldNames, DataType[] fieldTypes, int[] selectedFields, HiveTableInputSplit split) throws IOException
IOException
public void seekToRow(long rowCount, RowData reuse) throws IOException
SplitReader
seekToRow
in interface SplitReader
IOException
public boolean reachedEnd() throws IOException
SplitReader
reachedEnd
in interface SplitReader
IOException
- Thrown, if an I/O error occurred.public RowData nextRecord(RowData reuse)
SplitReader
nextRecord
in interface SplitReader
reuse
- Object that may be reused.public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.