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.

Constructor Summary

Constructors

Constructor and Description
SocketTextStreamWordCount()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

SocketTextStreamWordCount

public SocketTextStreamWordCount()

Method Detail

main

public static void main(String[] args)