public class AccumuloOutputFormat extends org.apache.hadoop.mapreduce.OutputFormat<org.apache.hadoop.io.Text,Mutation>
Constructor and Description |
---|
AccumuloOutputFormat() |
Modifier and Type | Method and Description |
---|---|
protected static boolean |
canCreateTables(org.apache.hadoop.conf.Configuration conf) |
protected static boolean |
canCreateTables(org.apache.hadoop.mapreduce.JobContext job)
Deprecated.
Use
canCreateTables(Configuration) instead |
void |
checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext job) |
protected static String |
getDefaultTableName(org.apache.hadoop.conf.Configuration conf) |
protected static String |
getDefaultTableName(org.apache.hadoop.mapreduce.JobContext job)
Deprecated.
Use
getDefaultTableName(Configuration) instead |
protected static Instance |
getInstance(org.apache.hadoop.conf.Configuration conf) |
protected static Instance |
getInstance(org.apache.hadoop.mapreduce.JobContext job)
Deprecated.
Use
getInstance(Configuration) instead |
protected static org.apache.log4j.Level |
getLogLevel(org.apache.hadoop.conf.Configuration conf) |
protected static org.apache.log4j.Level |
getLogLevel(org.apache.hadoop.mapreduce.JobContext job)
Deprecated.
Use
getLogLevel(Configuration) instead |
protected static int |
getMaxLatency(org.apache.hadoop.conf.Configuration conf) |
protected static int |
getMaxLatency(org.apache.hadoop.mapreduce.JobContext job)
Deprecated.
Use
getMaxLatency(Configuration) instead |
protected static long |
getMaxMutationBufferSize(org.apache.hadoop.conf.Configuration conf) |
protected static long |
getMaxMutationBufferSize(org.apache.hadoop.mapreduce.JobContext job)
Deprecated.
Use
getMaxMutationBufferSize(Configuration) instead |
protected static int |
getMaxWriteThreads(org.apache.hadoop.conf.Configuration conf) |
protected static int |
getMaxWriteThreads(org.apache.hadoop.mapreduce.JobContext job)
Deprecated.
Use
getMaxWriteThreads(Configuration) instead |
org.apache.hadoop.mapreduce.OutputCommitter |
getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext context) |
protected static byte[] |
getPassword(org.apache.hadoop.conf.Configuration conf)
WARNING: The password is stored in the Configuration and shared with all MapReduce tasks; It is BASE64 encoded to provide a charset safe conversion to a
string, and is not intended to be secure.
|
protected static byte[] |
getPassword(org.apache.hadoop.mapreduce.JobContext job)
Deprecated.
Use
getPassword(Configuration) instead |
org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.Text,Mutation> |
getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext attempt) |
protected static boolean |
getSimulationMode(org.apache.hadoop.conf.Configuration conf) |
protected static boolean |
getSimulationMode(org.apache.hadoop.mapreduce.JobContext job)
Deprecated.
Use
getSimulationMode(Configuration) instead |
protected static String |
getUsername(org.apache.hadoop.conf.Configuration conf) |
protected static String |
getUsername(org.apache.hadoop.mapreduce.JobContext job)
Deprecated.
Use
getUsername(Configuration) instead |
static void |
setLogLevel(org.apache.hadoop.conf.Configuration conf,
org.apache.log4j.Level level) |
static void |
setLogLevel(org.apache.hadoop.mapreduce.JobContext job,
org.apache.log4j.Level level)
Deprecated.
Use
setLogLevel(Configuration,Level) instead |
static void |
setMaxLatency(org.apache.hadoop.conf.Configuration conf,
int numberOfMilliseconds) |
static void |
setMaxLatency(org.apache.hadoop.mapreduce.JobContext job,
int numberOfMilliseconds)
Deprecated.
Use
setMaxLatency(Configuration,int) instead |
static void |
setMaxMutationBufferSize(org.apache.hadoop.conf.Configuration conf,
long numberOfBytes) |
static void |
setMaxMutationBufferSize(org.apache.hadoop.mapreduce.JobContext job,
long numberOfBytes)
Deprecated.
Use
setMaxMutationBufferSize(Configuration,long) instead |
static void |
setMaxWriteThreads(org.apache.hadoop.conf.Configuration conf,
int numberOfThreads) |
static void |
setMaxWriteThreads(org.apache.hadoop.mapreduce.JobContext job,
int numberOfThreads)
Deprecated.
Use
setMaxWriteThreads(Configuration,int) instead |
static void |
setMockInstance(org.apache.hadoop.conf.Configuration conf,
String instanceName) |
static void |
setMockInstance(org.apache.hadoop.mapreduce.JobContext job,
String instanceName)
Deprecated.
Use
setMockInstance(Configuration,String) instead |
static void |
setOutputInfo(org.apache.hadoop.conf.Configuration conf,
String user,
byte[] passwd,
boolean createTables,
String defaultTable)
Configure the output format.
|
static void |
setOutputInfo(org.apache.hadoop.mapreduce.JobContext job,
String user,
byte[] passwd,
boolean createTables,
String defaultTable)
Deprecated.
|
static void |
setSimulationMode(org.apache.hadoop.conf.Configuration conf) |
static void |
setSimulationMode(org.apache.hadoop.mapreduce.JobContext job)
Deprecated.
Use
setSimulationMode(Configuration) instead |
static void |
setZooKeeperInstance(org.apache.hadoop.conf.Configuration conf,
String instanceName,
String zooKeepers) |
static void |
setZooKeeperInstance(org.apache.hadoop.mapreduce.JobContext job,
String instanceName,
String zooKeepers)
Deprecated.
|
@Deprecated public static void setOutputInfo(org.apache.hadoop.mapreduce.JobContext job, String user, byte[] passwd, boolean createTables, String defaultTable)
setOutputInfo(Configuration,String,byte[],boolean,String)
insteadjob
- the Map/Reduce job objectuser
- the username, which must have the Table.CREATE permission to create tablespasswd
- the passwd for the usernamecreateTables
- the output format will create new tables as necessary. Table names can only be alpha-numeric and underscores.defaultTable
- the table to use when the tablename is null in the write callpublic static void setOutputInfo(org.apache.hadoop.conf.Configuration conf, String user, byte[] passwd, boolean createTables, String defaultTable)
conf
- the Map/Reduce job objectuser
- the username, which must have the Table.CREATE permission to create tablespasswd
- the passwd for the usernamecreateTables
- the output format will create new tables as necessary. Table names can only be alpha-numeric and underscores.defaultTable
- the table to use when the tablename is null in the write call@Deprecated public static void setZooKeeperInstance(org.apache.hadoop.mapreduce.JobContext job, String instanceName, String zooKeepers)
setZooKeeperInstance(Configuration,String,String)
insteadpublic static void setZooKeeperInstance(org.apache.hadoop.conf.Configuration conf, String instanceName, String zooKeepers)
@Deprecated public static void setMockInstance(org.apache.hadoop.mapreduce.JobContext job, String instanceName)
setMockInstance(Configuration,String)
insteadpublic static void setMockInstance(org.apache.hadoop.conf.Configuration conf, String instanceName)
@Deprecated public static void setMaxMutationBufferSize(org.apache.hadoop.mapreduce.JobContext job, long numberOfBytes)
setMaxMutationBufferSize(Configuration,long)
insteadpublic static void setMaxMutationBufferSize(org.apache.hadoop.conf.Configuration conf, long numberOfBytes)
@Deprecated public static void setMaxLatency(org.apache.hadoop.mapreduce.JobContext job, int numberOfMilliseconds)
setMaxLatency(Configuration,int)
insteadpublic static void setMaxLatency(org.apache.hadoop.conf.Configuration conf, int numberOfMilliseconds)
@Deprecated public static void setMaxWriteThreads(org.apache.hadoop.mapreduce.JobContext job, int numberOfThreads)
setMaxWriteThreads(Configuration,int)
insteadpublic static void setMaxWriteThreads(org.apache.hadoop.conf.Configuration conf, int numberOfThreads)
@Deprecated public static void setLogLevel(org.apache.hadoop.mapreduce.JobContext job, org.apache.log4j.Level level)
setLogLevel(Configuration,Level)
insteadpublic static void setLogLevel(org.apache.hadoop.conf.Configuration conf, org.apache.log4j.Level level)
@Deprecated public static void setSimulationMode(org.apache.hadoop.mapreduce.JobContext job)
setSimulationMode(Configuration)
insteadpublic static void setSimulationMode(org.apache.hadoop.conf.Configuration conf)
@Deprecated protected static String getUsername(org.apache.hadoop.mapreduce.JobContext job)
getUsername(Configuration)
insteadprotected static String getUsername(org.apache.hadoop.conf.Configuration conf)
@Deprecated protected static byte[] getPassword(org.apache.hadoop.mapreduce.JobContext job)
getPassword(Configuration)
insteadprotected static byte[] getPassword(org.apache.hadoop.conf.Configuration conf)
@Deprecated protected static boolean canCreateTables(org.apache.hadoop.mapreduce.JobContext job)
canCreateTables(Configuration)
insteadprotected static boolean canCreateTables(org.apache.hadoop.conf.Configuration conf)
@Deprecated protected static String getDefaultTableName(org.apache.hadoop.mapreduce.JobContext job)
getDefaultTableName(Configuration)
insteadprotected static String getDefaultTableName(org.apache.hadoop.conf.Configuration conf)
@Deprecated protected static Instance getInstance(org.apache.hadoop.mapreduce.JobContext job)
getInstance(Configuration)
insteadprotected static Instance getInstance(org.apache.hadoop.conf.Configuration conf)
@Deprecated protected static long getMaxMutationBufferSize(org.apache.hadoop.mapreduce.JobContext job)
getMaxMutationBufferSize(Configuration)
insteadprotected static long getMaxMutationBufferSize(org.apache.hadoop.conf.Configuration conf)
@Deprecated protected static int getMaxLatency(org.apache.hadoop.mapreduce.JobContext job)
getMaxLatency(Configuration)
insteadprotected static int getMaxLatency(org.apache.hadoop.conf.Configuration conf)
@Deprecated protected static int getMaxWriteThreads(org.apache.hadoop.mapreduce.JobContext job)
getMaxWriteThreads(Configuration)
insteadprotected static int getMaxWriteThreads(org.apache.hadoop.conf.Configuration conf)
@Deprecated protected static org.apache.log4j.Level getLogLevel(org.apache.hadoop.mapreduce.JobContext job)
getLogLevel(Configuration)
insteadprotected static org.apache.log4j.Level getLogLevel(org.apache.hadoop.conf.Configuration conf)
@Deprecated protected static boolean getSimulationMode(org.apache.hadoop.mapreduce.JobContext job)
getSimulationMode(Configuration)
insteadprotected static boolean getSimulationMode(org.apache.hadoop.conf.Configuration conf)
public void checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext job) throws IOException
checkOutputSpecs
in class org.apache.hadoop.mapreduce.OutputFormat<org.apache.hadoop.io.Text,Mutation>
IOException
public org.apache.hadoop.mapreduce.OutputCommitter getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
getOutputCommitter
in class org.apache.hadoop.mapreduce.OutputFormat<org.apache.hadoop.io.Text,Mutation>
public org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.Text,Mutation> getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext attempt) throws IOException
getRecordWriter
in class org.apache.hadoop.mapreduce.OutputFormat<org.apache.hadoop.io.Text,Mutation>
IOException
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.