Class SocketWindowWordCount
- java.lang.Object
-
- org.apache.flink.streaming.examples.socket.SocketWindowWordCount
-
public class SocketWindowWordCount extends Object
Implements a streaming windowed version of the "WordCount" program.This program connects to a server socket and reads strings from the socket. The easiest way to try this out is to open a text server (at port 12345) using the netcat tool via
nc -l 12345 on Linux or nc -l -p 12345 on Windows
and run this example with the hostname and the port as arguments.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classSocketWindowWordCount.WordWithCountData type for words with count.
-
Constructor Summary
Constructors Constructor Description SocketWindowWordCount()
-