protected static class AccumuloIndexedOutputFormat.AccumuloRecordWriter extends Object implements org.apache.hadoop.mapred.RecordWriter<org.apache.hadoop.io.Text,org.apache.accumulo.core.data.Mutation>
Modifier | Constructor and Description |
---|---|
protected |
AccumuloRecordWriter(org.apache.hadoop.mapred.JobConf job) |
Modifier and Type | Method and Description |
---|---|
void |
addTable(org.apache.hadoop.io.Text tableName) |
void |
close(org.apache.hadoop.mapred.Reporter reporter) |
void |
write(org.apache.hadoop.io.Text table,
org.apache.accumulo.core.data.Mutation mutation) |
protected AccumuloRecordWriter(org.apache.hadoop.mapred.JobConf job) throws org.apache.accumulo.core.client.AccumuloException, org.apache.accumulo.core.client.AccumuloSecurityException, IOException
org.apache.accumulo.core.client.AccumuloException
org.apache.accumulo.core.client.AccumuloSecurityException
IOException
public void write(org.apache.hadoop.io.Text table, org.apache.accumulo.core.data.Mutation mutation) throws IOException
write
in interface org.apache.hadoop.mapred.RecordWriter<org.apache.hadoop.io.Text,org.apache.accumulo.core.data.Mutation>
IOException
public void addTable(org.apache.hadoop.io.Text tableName) throws org.apache.accumulo.core.client.AccumuloException, org.apache.accumulo.core.client.AccumuloSecurityException
org.apache.accumulo.core.client.AccumuloException
org.apache.accumulo.core.client.AccumuloSecurityException
public void close(org.apache.hadoop.mapred.Reporter reporter) throws IOException
close
in interface org.apache.hadoop.mapred.RecordWriter<org.apache.hadoop.io.Text,org.apache.accumulo.core.data.Mutation>
IOException
Copyright © 2022 The Apache Software Foundation. All rights reserved.