public class HiveAccumuloTableOutputFormat extends AccumuloIndexedOutputFormat
AccumuloIndexedOutputFormat.AccumuloRecordWriter
Modifier and Type | Field and Description |
---|---|
protected HiveAccumuloHelper |
helper |
Constructor and Description |
---|
HiveAccumuloTableOutputFormat() |
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 |
setAccumuloIndexColumns(org.apache.hadoop.mapred.JobConf conf,
String indexColumns) |
protected void |
setAccumuloIndexTableName(org.apache.hadoop.mapred.JobConf conf,
String indexTableName) |
protected void |
setAccumuloStringEncoding(org.apache.hadoop.mapred.JobConf conf,
Boolean isStringEncoded) |
protected void |
setDefaultAccumuloTableName(org.apache.hadoop.mapred.JobConf conf,
String tableName) |
getIndexColumns, getIndexTableName, getStringEncoding, setIndexColumns, setIndexTableName, setStringEncoding
canCreateTables, getAuthenticationToken, getBatchWriterOptions, getDefaultTableName, getInstance, getLogLevel, getPrincipal, getSimulationMode, getToken, getTokenClass, isConnectorInfoSet, setBatchWriterOptions, setConnectorInfo, setConnectorInfo, setCreateTables, setDefaultTableName, setLogLevel, setMockInstance, setSimulationMode, setZooKeeperInstance, setZooKeeperInstance
protected final HiveAccumuloHelper helper
public void checkOutputSpecs(org.apache.hadoop.fs.FileSystem ignored, org.apache.hadoop.mapred.JobConf job) throws IOException
checkOutputSpecs
in interface org.apache.hadoop.mapred.OutputFormat<org.apache.hadoop.io.Text,org.apache.accumulo.core.data.Mutation>
checkOutputSpecs
in class org.apache.accumulo.core.client.mapred.AccumuloOutputFormat
IOException
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
getRecordWriter
in interface org.apache.hadoop.mapred.OutputFormat<org.apache.hadoop.io.Text,org.apache.accumulo.core.data.Mutation>
getRecordWriter
in class AccumuloIndexedOutputFormat
IOException
protected void configureAccumuloOutputFormat(org.apache.hadoop.mapred.JobConf job) throws IOException
IOException
protected void setDefaultAccumuloTableName(org.apache.hadoop.mapred.JobConf conf, String tableName)
protected void setAccumuloIndexTableName(org.apache.hadoop.mapred.JobConf conf, String indexTableName)
protected void setAccumuloIndexColumns(org.apache.hadoop.mapred.JobConf conf, String indexColumns)
protected void setAccumuloStringEncoding(org.apache.hadoop.mapred.JobConf conf, Boolean isStringEncoded)
Copyright © 2022 The Apache Software Foundation. All rights reserved.