Package org.apache.wayang.apps.wordcount

Class WordCountWithJavaNativeAPI

java.lang.Object

org.apache.wayang.apps.wordcount.WordCountWithJavaNativeAPI

public class WordCountWithJavaNativeAPI
extends java.lang.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(java.lang.String inputFileUrl, java.util.Collection<Tuple2<java.lang.String,java.lang.Integer>> collector)	Creates the WayangPlan for the word count app.
static void	main(java.lang.String[] args)

Methods inherited from class java.lang.Object

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

Constructor Detail

WordCountWithJavaNativeAPI

public WordCountWithJavaNativeAPI()

Method Detail

createWayangPlan

public static WayangPlan createWayangPlan(java.lang.String inputFileUrl,
                                          java.util.Collection<Tuple2<java.lang.String,java.lang.Integer>> collector)
                                   throws java.net.URISyntaxException,
                                          java.io.IOException

Creates the WayangPlan for the word count app.

Parameters:

inputFileUrl - the file whose words should be counted

Throws:

java.net.URISyntaxException

java.io.IOException

main

public static void main(java.lang.String[] args)
                 throws java.io.IOException,
                        java.net.URISyntaxException

Throws:

java.io.IOException

java.net.URISyntaxException