public class JdbcRecordReader extends Object implements org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.MapWritable>
Constructor and Description |
---|
JdbcRecordReader(org.apache.hadoop.mapred.JobConf conf,
JdbcInputSplit split) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
org.apache.hadoop.io.LongWritable |
createKey() |
org.apache.hadoop.io.MapWritable |
createValue() |
long |
getPos() |
float |
getProgress() |
boolean |
next(org.apache.hadoop.io.LongWritable key,
org.apache.hadoop.io.MapWritable value) |
void |
setDbAccessor(DatabaseAccessor dbAccessor) |
void |
setIterator(JdbcRecordIterator iterator) |
public JdbcRecordReader(org.apache.hadoop.mapred.JobConf conf, JdbcInputSplit split)
public boolean next(org.apache.hadoop.io.LongWritable key, org.apache.hadoop.io.MapWritable value) throws IOException
next
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.MapWritable>
IOException
public org.apache.hadoop.io.LongWritable createKey()
createKey
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.MapWritable>
public org.apache.hadoop.io.MapWritable createValue()
createValue
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.MapWritable>
public long getPos() throws IOException
getPos
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.MapWritable>
IOException
public void close() throws IOException
close
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.MapWritable>
IOException
public float getProgress() throws IOException
getProgress
in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.MapWritable>
IOException
public void setDbAccessor(DatabaseAccessor dbAccessor)
public void setIterator(JdbcRecordIterator iterator)
Copyright © 2021 The Apache Software Foundation. All rights reserved.