public static class NullRowsInputFormat.NullRowsRecordReader extends Object implements org.apache.hadoop.mapred.RecordReader
Modifier and Type | Field and Description |
---|---|
protected VectorizedRowBatchCtx |
rbCtx |
Constructor and Description |
---|
NullRowsRecordReader(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.mapred.InputSplit split) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
org.apache.hadoop.io.NullWritable |
createKey() |
Object |
createValue() |
long |
getPos() |
float |
getProgress() |
protected void |
makeNullVrb(Object value,
int size) |
boolean |
next(Object arg0,
Object value) |
protected final VectorizedRowBatchCtx rbCtx
public NullRowsRecordReader(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.mapred.InputSplit split) throws IOException
IOException
public void close() throws IOException
close
in interface org.apache.hadoop.mapred.RecordReader
IOException
public org.apache.hadoop.io.NullWritable createKey()
createKey
in interface org.apache.hadoop.mapred.RecordReader
public Object createValue()
createValue
in interface org.apache.hadoop.mapred.RecordReader
public long getPos() throws IOException
getPos
in interface org.apache.hadoop.mapred.RecordReader
IOException
public float getProgress() throws IOException
getProgress
in interface org.apache.hadoop.mapred.RecordReader
IOException
public boolean next(Object arg0, Object value) throws IOException
next
in interface org.apache.hadoop.mapred.RecordReader
IOException
protected void makeNullVrb(Object value, int size)
Copyright © 2016 The Apache Software Foundation. All rights reserved.