Package org.apache.nemo.examples.beam

Class WindowedWordCount

java.lang.Object

org.apache.nemo.examples.beam.WindowedWordCount

public final class WindowedWordCount
extends java.lang.Object

A Windowed WordCount application.

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	INPUT_TYPE_BOUNDED
static java.lang.String	INPUT_TYPE_UNBOUNDED
static java.util.Random	RAND

Method Summary

Modifier and Type	Method	Description
static void	main(java.lang.String[] args)	Main function for the MR BEAM program.

Methods inherited from class java.lang.Object

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

Field Detail

INPUT_TYPE_BOUNDED

public static final java.lang.String INPUT_TYPE_BOUNDED

See Also:

Constant Field Values

INPUT_TYPE_UNBOUNDED

public static final java.lang.String INPUT_TYPE_UNBOUNDED

See Also:

Constant Field Values

RAND

public static final java.util.Random RAND

Method Detail

main

public static void main(java.lang.String[] args)

Main function for the MR BEAM program.

Parameters:

args - arguments.