Package org.apache.nemo.examples.beam
Class WordCountTimeOut1Sec
- java.lang.Object
-
- org.apache.nemo.examples.beam.WordCountTimeOut1Sec
-
public final class WordCountTimeOut1Sec extends java.lang.Object
WordCount application, but with a timeout of 1 second.
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static void
main(java.lang.String[] args)
Main function for the MR BEAM program.
-