Class WordsSocketStreamerServer
- java.lang.Object
-
- org.apache.ignite.examples.streaming.wordcount.socket.WordsSocketStreamerServer
-
public class WordsSocketStreamerServer extends java.lang.ObjectExample demonstrates streaming of data from external components into Ignite cache.WordsSocketStreamerServeris simple socket streaming server implementation that receives words from socket usingSocketStreamerand message delimiter based protocol and streams them into Ignite cache. Example illustrates usage of TCP socket streamer in case of non-Java clients. In this example words are zero-terminated strings.To start the example, you should:
- Start a few nodes using
ExampleNodeStartup. - Start socket server using
WordsSocketStreamerServer. - Start a few socket clients using
WordsSocketStreamerClient. - Start querying popular words using
QueryWords.
- Start a few nodes using
-
-
Constructor Summary
Constructors Constructor Description WordsSocketStreamerServer()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static voidmain(java.lang.String[] args)Starts socket streaming server.
-