org.apache.hadoop.hive.accumulo.mr

Class HiveAccumuloTableOutputFormat

java.lang.Object

org.apache.accumulo.core.client.mapred.AccumuloOutputFormat

org.apache.hadoop.hive.accumulo.mr.HiveAccumuloTableOutputFormat

All Implemented Interfaces:

org.apache.hadoop.mapred.OutputFormat<org.apache.hadoop.io.Text,org.apache.accumulo.core.data.Mutation>

public class HiveAccumuloTableOutputFormat
extends org.apache.accumulo.core.client.mapred.AccumuloOutputFormat

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.accumulo.core.client.mapred.AccumuloOutputFormat

org.apache.accumulo.core.client.mapred.AccumuloOutputFormat.AccumuloRecordWriter

Field Summary

Fields

Modifier and Type	Field and Description
protected HiveAccumuloHelper	helper

Fields inherited from class org.apache.accumulo.core.client.mapred.AccumuloOutputFormat

log

Constructor Summary

Constructors

Constructor and Description
HiveAccumuloTableOutputFormat()

Method Summary

Methods

Modifier and Type	Method and Description
void	checkOutputSpecs(org.apache.hadoop.fs.FileSystem ignored, org.apache.hadoop.mapred.JobConf job)
protected void	configureAccumuloOutputFormat(org.apache.hadoop.mapred.JobConf job)
org.apache.hadoop.mapred.RecordWriter<org.apache.hadoop.io.Text,org.apache.accumulo.core.data.Mutation>	getRecordWriter(org.apache.hadoop.fs.FileSystem ignored, org.apache.hadoop.mapred.JobConf job, String name, org.apache.hadoop.util.Progressable progress)
protected void	setAccumuloConnectorInfo(org.apache.hadoop.mapred.JobConf conf, String username, org.apache.accumulo.core.client.security.tokens.AuthenticationToken token)
protected void	setAccumuloMockInstance(org.apache.hadoop.mapred.JobConf conf, String instanceName)
protected void	setAccumuloZooKeeperInstance(org.apache.hadoop.mapred.JobConf conf, String instanceName, String zookeepers, boolean isSasl)
protected void	setDefaultAccumuloTableName(org.apache.hadoop.mapred.JobConf conf, String tableName)

Methods inherited from class org.apache.accumulo.core.client.mapred.AccumuloOutputFormat

canCreateTables, getAuthenticationToken, getBatchWriterOptions, getDefaultTableName, getInstance, getLogLevel, getPrincipal, getSimulationMode, getToken, getTokenClass, isConnectorInfoSet, setBatchWriterOptions, setConnectorInfo, setConnectorInfo, setCreateTables, setDefaultTableName, setLogLevel, setMockInstance, setSimulationMode, setZooKeeperInstance, setZooKeeperInstance

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

helper

protected final HiveAccumuloHelper helper

Constructor Detail

HiveAccumuloTableOutputFormat

public HiveAccumuloTableOutputFormat()

Method Detail

checkOutputSpecs

public void checkOutputSpecs(org.apache.hadoop.fs.FileSystem ignored,
                    org.apache.hadoop.mapred.JobConf job)
                      throws IOException

Specified by:

checkOutputSpecs in interface org.apache.hadoop.mapred.OutputFormat<org.apache.hadoop.io.Text,org.apache.accumulo.core.data.Mutation>

Overrides:

checkOutputSpecs in class org.apache.accumulo.core.client.mapred.AccumuloOutputFormat

Throws:

IOException

getRecordWriter

public org.apache.hadoop.mapred.RecordWriter<org.apache.hadoop.io.Text,org.apache.accumulo.core.data.Mutation> getRecordWriter(org.apache.hadoop.fs.FileSystem ignored,
                                                                                                                      org.apache.hadoop.mapred.JobConf job,
                                                                                                                      String name,
                                                                                                                      org.apache.hadoop.util.Progressable progress)
                                                                                                                        throws IOException

Specified by:

getRecordWriter in interface org.apache.hadoop.mapred.OutputFormat<org.apache.hadoop.io.Text,org.apache.accumulo.core.data.Mutation>

Overrides:

getRecordWriter in class org.apache.accumulo.core.client.mapred.AccumuloOutputFormat

Throws:

IOException

configureAccumuloOutputFormat

protected void configureAccumuloOutputFormat(org.apache.hadoop.mapred.JobConf job)
                                      throws IOException

Throws:

IOException

setAccumuloConnectorInfo

protected void setAccumuloConnectorInfo(org.apache.hadoop.mapred.JobConf conf,
                            String username,
                            org.apache.accumulo.core.client.security.tokens.AuthenticationToken token)
                                 throws org.apache.accumulo.core.client.AccumuloSecurityException

Throws:

org.apache.accumulo.core.client.AccumuloSecurityException

setAccumuloZooKeeperInstance

protected void setAccumuloZooKeeperInstance(org.apache.hadoop.mapred.JobConf conf,
                                String instanceName,
                                String zookeepers,
                                boolean isSasl)
                                     throws IOException

Throws:

IOException

setAccumuloMockInstance

protected void setAccumuloMockInstance(org.apache.hadoop.mapred.JobConf conf,
                           String instanceName)

setDefaultAccumuloTableName

protected void setDefaultAccumuloTableName(org.apache.hadoop.mapred.JobConf conf,
                               String tableName)