public class GoraRecordReader<K,T extends PersistentBase>
extends org.apache.hadoop.mapreduce.RecordReader<K,T>
Modifier and Type | Field and Description |
---|---|
static String |
BUFFER_LIMIT_READ_NAME |
static int |
BUFFER_LIMIT_READ_VALUE |
static org.slf4j.Logger |
LOG |
protected Query<K,T> |
query |
protected Result<K,T> |
result |
Constructor and Description |
---|
GoraRecordReader(Query<K,T> query,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
executeQuery() |
K |
getCurrentKey() |
T |
getCurrentValue() |
float |
getProgress() |
void |
initialize(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
boolean |
nextKeyValue() |
public static final org.slf4j.Logger LOG
public static final String BUFFER_LIMIT_READ_NAME
public static final int BUFFER_LIMIT_READ_VALUE
protected Query<K,T extends PersistentBase> query
protected Result<K,T extends PersistentBase> result
public void executeQuery() throws IOException, Exception
IOException
Exception
public K getCurrentKey() throws IOException, InterruptedException
getCurrentKey
in class org.apache.hadoop.mapreduce.RecordReader<K,T extends PersistentBase>
IOException
InterruptedException
public T getCurrentValue() throws IOException, InterruptedException
getCurrentValue
in class org.apache.hadoop.mapreduce.RecordReader<K,T extends PersistentBase>
IOException
InterruptedException
public float getProgress() throws IOException, InterruptedException
getProgress
in class org.apache.hadoop.mapreduce.RecordReader<K,T extends PersistentBase>
IOException
InterruptedException
public void initialize(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException, InterruptedException
initialize
in class org.apache.hadoop.mapreduce.RecordReader<K,T extends PersistentBase>
IOException
InterruptedException
public boolean nextKeyValue() throws IOException, InterruptedException
nextKeyValue
in class org.apache.hadoop.mapreduce.RecordReader<K,T extends PersistentBase>
IOException
InterruptedException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class org.apache.hadoop.mapreduce.RecordReader<K,T extends PersistentBase>
IOException
Copyright © 2010-2014 The Apache Software Foundation. All Rights Reserved.