public class BlobStoreAPIWordCountTopology extends Object
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
BlobStoreAPIWordCountTopology.FilterWords  | 
static class  | 
BlobStoreAPIWordCountTopology.RandomSentenceSpout  | 
static class  | 
BlobStoreAPIWordCountTopology.SplitSentence  | 
| Constructor and Description | 
|---|
BlobStoreAPIWordCountTopology()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
buildAndLaunchWordCountTopology(String[] args)  | 
static File | 
createFile(String fileName)  | 
static void | 
main(String[] args)  | 
static void | 
prepare()  | 
static File | 
updateFile(File file)  | 
static void | 
writeToFile(File file,
           Set<String> content)  | 
public static void prepare()
public static File createFile(String fileName) throws IOException
IOExceptionpublic static File updateFile(File file) throws IOException
IOExceptionpublic static void writeToFile(File file, Set<String> content) throws IOException
IOExceptionpublic static void main(String[] args)
public void buildAndLaunchWordCountTopology(String[] args)
Copyright © 2020 The Apache Software Foundation. All rights reserved.