org.apache.flink.streaming.scala.examples.socket

Class SocketTextStreamWordCount$

java.lang.Object

org.apache.flink.streaming.scala.examples.socket.SocketTextStreamWordCount$

public class SocketTextStreamWordCount$
extends Object

This example shows an implementation of WordCount with data from a text socket. To run the example make sure that the service providing the text data is already up and running.

To start an example socket text stream on your local machine run netcat from a command line, where the parameter specifies the port number:

   nc -lk 9999
 

Usage:

   SocketTextStreamWordCount --hostname <name> --port <n> [--output <path>]
 

This example shows how to:

- use StreamExecutionEnvironment.socketTextStream - write a simple Flink Streaming program in scala. - write and use user-defined functions.

Field Summary

Fields

Modifier and Type	Field and Description
static SocketTextStreamWordCount$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
SocketTextStreamWordCount$()

Method Summary

Modifier and Type	Method and Description
void	main(String[] args)

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final SocketTextStreamWordCount$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

SocketTextStreamWordCount$

public SocketTextStreamWordCount$()

Method Detail

main

public void main(String[] args)