public class SequentialParquetStarTable extends ParquetStarTable
CREATEDBY_INFO
Constructor and Description |
---|
SequentialParquetStarTable(IOSupplier<org.apache.parquet.hadoop.ParquetFileReader> pfrSupplier)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
RowSequence |
getRowSequence()
Returns an object which can iterate over all the rows in the table
sequentially.
|
RowSplittable |
getRowSplittable()
Returns a default splittable which relies on table random access
if available, or otherwise provides only sequential access (no splits).
|
boolean |
isRandom()
The AbstractStarTable implementation of this method
returns false.
|
getColumnCount, getColumnInfo, getColumnReadStore, getInputColumn, getParquetFileReader, getRowCount, getSchema
checkedLongToInt, close, getCell, getColumnAuxDataInfos, getName, getParameters, getRow, getRowAccess, getURL, setName, setParameters, setURL
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getParameterByName, setParameter
public SequentialParquetStarTable(IOSupplier<org.apache.parquet.hadoop.ParquetFileReader> pfrSupplier) throws IOException
pfrSupplier
- access to parquet data fileIOException
public boolean isRandom()
AbstractStarTable
isRandom
in interface StarTable
isRandom
in class AbstractStarTable
public RowSequence getRowSequence() throws IOException
StarTable
getRowSequence
in interface StarTable
getRowSequence
in class AbstractStarTable
IOException
- if there is an error providing accesspublic RowSplittable getRowSplittable() throws IOException
AbstractStarTable
It is often possible to provide a better implementation than this.
getRowSplittable
in interface StarTable
getRowSplittable
in class AbstractStarTable
Tables.getDefaultRowSplittable(this)
IOException
RowRunner
Copyright © 2023 Central Laboratory of the Research Councils. All Rights Reserved.