Class WordsSocketStreamerClient
- java.lang.Object
-
- org.apache.ignite.examples.streaming.wordcount.socket.WordsSocketStreamerClient
-
public class WordsSocketStreamerClient extends java.lang.ObjectExample demonstrates streaming of data from external components into Ignite cache.WordsSocketStreamerClientis simple socket streaming client implementation that sends words to socket server based onSocketStreamerusing message delimiter based protocol. 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 WordsSocketStreamerClient()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static voidmain(java.lang.String[] args)
-