public class KafkaETLJob
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
HADOOP_PREFIX |
Constructor and Description |
---|
KafkaETLJob() |
Modifier and Type | Method and Description |
---|---|
static org.apache.hadoop.mapred.JobConf |
createJobConf(java.lang.String name,
java.lang.String topic,
Props props,
java.lang.Class classobj)
Create a job configuration
|
static org.apache.hadoop.mapred.JobConf |
getJobConf(java.lang.String name,
Props props,
java.lang.Class classobj)
Helper function to initialize a job configuration
|
static void |
info(java.lang.String message) |
static void |
setClassLoaderAndJar(org.apache.hadoop.mapred.JobConf conf,
java.lang.Class jobClass) |
public static final java.lang.String HADOOP_PREFIX
public static org.apache.hadoop.mapred.JobConf createJobConf(java.lang.String name, java.lang.String topic, Props props, java.lang.Class classobj) throws java.lang.Exception
java.lang.Exception
public static org.apache.hadoop.mapred.JobConf getJobConf(java.lang.String name, Props props, java.lang.Class classobj) throws java.lang.Exception
java.lang.Exception
public static void info(java.lang.String message)
public static void setClassLoaderAndJar(org.apache.hadoop.mapred.JobConf conf, java.lang.Class jobClass)