public class GoraRecordWriter<K,T>
extends org.apache.hadoop.mapreduce.RecordWriter<K,T>
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
LOG |
Constructor and Description |
---|
GoraRecordWriter(DataStore<K,Persistent> store,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
public GoraRecordWriter(DataStore<K,Persistent> store, org.apache.hadoop.mapreduce.TaskAttemptContext context)
public void close(org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException, InterruptedException
close
in class org.apache.hadoop.mapreduce.RecordWriter<K,T>
IOException
InterruptedException
public void write(K key, T value) throws IOException, InterruptedException
write
in class org.apache.hadoop.mapreduce.RecordWriter<K,T>
IOException
InterruptedException
Copyright © 2010-2014 The Apache Software Foundation. All Rights Reserved.