public class SimpleKafkaETLJob
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected java.lang.String |
_input |
protected java.lang.String |
_name |
protected java.lang.String |
_output |
protected Props |
_props |
protected java.lang.String |
_topic |
Constructor and Description |
---|
SimpleKafkaETLJob(java.lang.String name,
Props props) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.hadoop.mapred.JobConf |
createJobConf() |
void |
execute() |
static void |
main(java.lang.String[] args)
for testing only
|
protected java.lang.String _name
protected Props _props
protected java.lang.String _input
protected java.lang.String _output
protected java.lang.String _topic
public SimpleKafkaETLJob(java.lang.String name, Props props) throws java.lang.Exception
java.lang.Exception
protected org.apache.hadoop.mapred.JobConf createJobConf() throws java.lang.Exception
java.lang.Exception
public void execute() throws java.lang.Exception
java.lang.Exception
public static void main(java.lang.String[] args) throws java.lang.Exception
args
- java.lang.Exception