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 void buildAndLaunchWordCountTopology(String[] args)
public static File createFile(String fileName) throws IOException
IOException
public static File updateFile(File file) throws IOException
IOException
public static void writeToFile(File file, Set<String> content) throws IOException
IOException
public static void main(String[] args)
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.