protected static class AccumuloOutputFormat.AccumuloRecordWriter extends org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.Text,Mutation>
RecordWriter
instances that write to Accumulo.Modifier | Constructor and Description |
---|---|
protected |
AccumuloOutputFormat.AccumuloRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context) |
protected AccumuloOutputFormat.AccumuloRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context) throws AccumuloException, AccumuloSecurityException, IOException
public void write(org.apache.hadoop.io.Text table, Mutation mutation) throws IOException
AccumuloOutputFormat.canCreateTables(JobContext)
is set, the
table will be created if it does not exist. The table name must only contain alphanumerics and underscore.write
in class org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.Text,Mutation>
IOException
public void addTable(org.apache.hadoop.io.Text tableName) throws AccumuloException, AccumuloSecurityException
public void close(org.apache.hadoop.mapreduce.TaskAttemptContext attempt) throws IOException, InterruptedException
close
in class org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.Text,Mutation>
IOException
InterruptedException
Copyright © 2011–2017 The Apache Software Foundation. All rights reserved.