Package org.apache.wayang.apps.wordcount

Class WordCountWithJavaNativeAPI

java.lang.Object

org.apache.wayang.apps.wordcount.WordCountWithJavaNativeAPI

public class WordCountWithJavaNativeAPI
extends Object

Example Apache Wayang (incubating) App that does a word count -- the Hello World of Map/Reduce-like systems.

Constructor Summary

Constructors

Constructor	Description
WordCountWithJavaNativeAPI()

Method Summary

Modifier and Type	Method	Description
static WayangPlan	createWayangPlan(String inputFileUrl, Collection<Tuple2<String,Integer>> collector)	Creates the WayangPlan for the word count app.
static void	main(String[] args)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

WordCountWithJavaNativeAPI

public WordCountWithJavaNativeAPI()

Method Details

createWayangPlan

public static WayangPlan createWayangPlan(String inputFileUrl,
 Collection<Tuple2<String,Integer>> collector)
                                   throws URISyntaxException,
IOException

Creates the WayangPlan for the word count app.

Parameters:

inputFileUrl - the file whose words should be counted

Throws:

URISyntaxException

IOException

main

public static void main(String[] args)
                 throws IOException,
URISyntaxException

Throws:

IOException

URISyntaxException