public class StrGenSpoutHdfsBoltTopo extends Object
This topo helps measure speed of writing to Hdfs Spout generates fixed length random strings. Bolt writes to Hdfs
| Modifier and Type | Class and Description | 
|---|---|
| static class  | StrGenSpoutHdfsBoltTopo.LineWriter | 
| Modifier and Type | Field and Description | 
|---|---|
| static String | BOLT_ID | 
| static String | BOLT_NUM | 
| static int | DEFAULT_BOLT_NUM | 
| static int | DEFAULT_HDFS_BATCH | 
| static int | DEFAULT_SPOUT_NUM | 
| static String | HDFS_BATCH | 
| static String | HDFS_PATH | 
| static String | HDFS_URI | 
| static String | SPOUT_ID | 
| static String | SPOUT_NUM | 
| static String | TOPOLOGY_NAME | 
| Constructor and Description | 
|---|
| StrGenSpoutHdfsBoltTopo() | 
| Modifier and Type | Method and Description | 
|---|---|
| static StormTopology | getTopology(Map topoConf) | 
| static void | main(String[] args)Spout generates random strings and HDFS bolt writes them to a text file | 
public static final String SPOUT_NUM
public static final String BOLT_NUM
public static final String HDFS_URI
public static final String HDFS_PATH
public static final String HDFS_BATCH
public static final int DEFAULT_SPOUT_NUM
public static final int DEFAULT_BOLT_NUM
public static final int DEFAULT_HDFS_BATCH
public static final String TOPOLOGY_NAME
public static final String SPOUT_ID
public static final String BOLT_ID
public static StormTopology getTopology(Map topoConf)
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.