public class VectorizedParquetInputFormat extends org.apache.hadoop.mapred.FileInputFormat<org.apache.hadoop.io.NullWritable,VectorizedRowBatch> implements VectorizedInputFormatInterface
Constructor and Description |
---|
VectorizedParquetInputFormat(org.apache.parquet.hadoop.ParquetInputFormat<org.apache.hadoop.io.ArrayWritable> realInput) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,VectorizedRowBatch> |
getRecordReader(org.apache.hadoop.mapred.InputSplit split,
org.apache.hadoop.mapred.JobConf conf,
org.apache.hadoop.mapred.Reporter reporter) |
addInputPath, addInputPathRecursively, addInputPaths, computeSplitSize, getBlockIndex, getInputPathFilter, getInputPaths, getSplitHosts, getSplits, isSplitable, listStatus, makeSplit, makeSplit, setInputPathFilter, setInputPaths, setInputPaths, setMinSplitSize
public VectorizedParquetInputFormat(org.apache.parquet.hadoop.ParquetInputFormat<org.apache.hadoop.io.ArrayWritable> realInput)
public org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,VectorizedRowBatch> getRecordReader(org.apache.hadoop.mapred.InputSplit split, org.apache.hadoop.mapred.JobConf conf, org.apache.hadoop.mapred.Reporter reporter) throws IOException
getRecordReader
in interface org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.NullWritable,VectorizedRowBatch>
getRecordReader
in class org.apache.hadoop.mapred.FileInputFormat<org.apache.hadoop.io.NullWritable,VectorizedRowBatch>
IOException
Copyright © 2016 The Apache Software Foundation. All rights reserved.