public class AccumuloIndexedOutputFormat
extends org.apache.accumulo.core.client.mapred.AccumuloOutputFormat
Modifier and Type | Class and Description |
---|---|
protected static class |
AccumuloIndexedOutputFormat.AccumuloRecordWriter |
Constructor and Description |
---|
AccumuloIndexedOutputFormat() |
Modifier and Type | Method and Description |
---|---|
protected static String |
getIndexColumns(org.apache.hadoop.mapred.JobConf job) |
protected static String |
getIndexTableName(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 static Boolean |
getStringEncoding(org.apache.hadoop.mapred.JobConf job) |
static void |
setIndexColumns(org.apache.hadoop.mapred.JobConf job,
String fields) |
static void |
setIndexTableName(org.apache.hadoop.mapred.JobConf job,
String tableName) |
static void |
setStringEncoding(org.apache.hadoop.mapred.JobConf job,
Boolean isStringEncoding) |
canCreateTables, checkOutputSpecs, getAuthenticationToken, getBatchWriterOptions, getDefaultTableName, getInstance, getLogLevel, getPrincipal, getSimulationMode, getToken, getTokenClass, isConnectorInfoSet, setBatchWriterOptions, setConnectorInfo, setConnectorInfo, setCreateTables, setDefaultTableName, setLogLevel, setMockInstance, setSimulationMode, setZooKeeperInstance, setZooKeeperInstance
public static void setIndexTableName(org.apache.hadoop.mapred.JobConf job, String tableName)
protected static String getIndexTableName(org.apache.hadoop.mapred.JobConf job)
public static void setIndexColumns(org.apache.hadoop.mapred.JobConf job, String fields)
protected static String getIndexColumns(org.apache.hadoop.mapred.JobConf job)
public static void setStringEncoding(org.apache.hadoop.mapred.JobConf job, Boolean isStringEncoding)
protected static Boolean getStringEncoding(org.apache.hadoop.mapred.JobConf job)
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 org.apache.accumulo.core.client.mapred.AccumuloOutputFormat
IOException
Copyright © 2022 The Apache Software Foundation. All rights reserved.