Package org.apache.storm.starter
Class BlobStoreAPIWordCountTopology
java.lang.Object
org.apache.storm.starter.BlobStoreAPIWordCountTopology
-
Nested Class Summary
Modifier and TypeClassDescriptionstatic class
static class
static class
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
static File
createFile
(String fileName) static void
static void
prepare()
static File
updateFile
(File file) static void
writeToFile
(File file, Set<String> content)
-
Constructor Details
-
BlobStoreAPIWordCountTopology
public BlobStoreAPIWordCountTopology()
-
-
Method Details
-
prepare
public static void prepare() -
createFile
- Throws:
IOException
-
updateFile
- Throws:
IOException
-
writeToFile
- Throws:
IOException
-
main
-
buildAndLaunchWordCountTopology
-