Package org.apache.storm.perf
Class KafkaClientHdfsTopo
- java.lang.Object
-
- org.apache.storm.perf.KafkaClientHdfsTopo
-
public class KafkaClientHdfsTopo extends Object
This topo helps measure speed of reading from Kafka and writing to Hdfs.Spout Reads from Kafka.
Bolt writes to Hdfs.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classKafkaClientHdfsTopo.LineWriter
-
Field Summary
Fields Modifier and Type Field Description static StringBOLT_IDstatic StringBOLT_NUMstatic intDEFAULT_BOLT_NUMstatic intDEFAULT_HDFS_BATCHstatic intDEFAULT_SPOUT_NUMstatic StringHDFS_BATCHstatic StringHDFS_PATHstatic StringHDFS_URIstatic StringKAFKA_BOOTSTRAP_HOSTSstatic StringKAFKA_TOPICstatic StringSPOUT_IDstatic StringSPOUT_NUMstatic StringTOPOLOGY_NAME
-
Constructor Summary
Constructors Constructor Description KafkaClientHdfsTopo()
-
-
-
Field Detail
-
SPOUT_NUM
public static final String SPOUT_NUM
- See Also:
- Constant Field Values
-
BOLT_NUM
public static final String BOLT_NUM
- See Also:
- Constant Field Values
-
KAFKA_TOPIC
public static final String KAFKA_TOPIC
- See Also:
- Constant Field Values
-
KAFKA_BOOTSTRAP_HOSTS
public static final String KAFKA_BOOTSTRAP_HOSTS
- See Also:
- Constant Field Values
-
HDFS_URI
public static final String HDFS_URI
- See Also:
- Constant Field Values
-
HDFS_PATH
public static final String HDFS_PATH
- See Also:
- Constant Field Values
-
HDFS_BATCH
public static final String HDFS_BATCH
- See Also:
- Constant Field Values
-
DEFAULT_SPOUT_NUM
public static final int DEFAULT_SPOUT_NUM
- See Also:
- Constant Field Values
-
DEFAULT_BOLT_NUM
public static final int DEFAULT_BOLT_NUM
- See Also:
- Constant Field Values
-
DEFAULT_HDFS_BATCH
public static final int DEFAULT_HDFS_BATCH
- See Also:
- Constant Field Values
-
TOPOLOGY_NAME
public static final String TOPOLOGY_NAME
- See Also:
- Constant Field Values
-
SPOUT_ID
public static final String SPOUT_ID
- See Also:
- Constant Field Values
-
BOLT_ID
public static final String BOLT_ID
- See Also:
- Constant Field Values
-
-