Package org.apache.storm.starter
Class BlobStoreAPIWordCountTopology
- java.lang.Object
-
- org.apache.storm.starter.BlobStoreAPIWordCountTopology
-
public class BlobStoreAPIWordCountTopology extends Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classBlobStoreAPIWordCountTopology.FilterWordsstatic classBlobStoreAPIWordCountTopology.RandomSentenceSpoutstatic classBlobStoreAPIWordCountTopology.SplitSentence
-
Constructor Summary
Constructors Constructor Description BlobStoreAPIWordCountTopology()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description voidbuildAndLaunchWordCountTopology(String[] args)static FilecreateFile(String fileName)static voidmain(String[] args)static voidprepare()static FileupdateFile(File file)static voidwriteToFile(File file, Set<String> content)
-
-
-
Method Detail
-
prepare
public static void prepare()
-
createFile
public static File createFile(String fileName) throws IOException
- Throws:
IOException
-
updateFile
public static File updateFile(File file) throws IOException
- Throws:
IOException
-
writeToFile
public static void writeToFile(File file, Set<String> content) throws IOException
- Throws:
IOException
-
main
public static void main(String[] args)
-
buildAndLaunchWordCountTopology
public void buildAndLaunchWordCountTopology(String[] args)
-
-