Thanks Saikat for the reply. 1) Rest API: how does the streamer listen to the REST requests? Is there an example? Or do I just enable streaming an option (e.g., the way you do it with JDBC/SQL)? Sorry if this is a trivial question. Another question(unrelated to the topic of data load via streamers): is it possible to use Ignite's rest API to call an ignite service method (via a service proxy? If yes, is there an example? 2) I started anywhere from 2 to 4 ExampleNodeStartup nodes (different tries), but still got the "ignite node stopped" message.
On Sun, Jan 5, 2020 at 12:04 PM Saikat Maitra <[email protected]> wrote: > Hi, > > Thank you for your email and using DataStreamer. > > 1. Yes, there are rest endpoints available to send data in Ignite cache. > Here is the docs for the same https://apacheignite.readme.io/docs/rest-api > 2. As per the docs as mentioned below, can you please confirm if you have > few nodes running using ExampleNodeStartup? > > * To start the example, you should: > * <ul> > * <li>Start a few nodes using {@link ExampleNodeStartup}.</li> > * <li>Start socket server using {@link WordsSocketStreamerServer}.</li> > * <li>Start a few socket clients using {@link > WordsSocketStreamerClient}.</li> > * <li>Start querying popular words using {@link QueryWords}.</li> > * </ul> > Regards, > Saikat > > On Sat, Jan 4, 2020 at 2:33 PM narges saleh <[email protected]> wrote: > >> Hi All, >> >> I have two questions regarding loading data with the streamer, with non >> ignite client. >> >> 1) Is there a REST/HTTP counterpart for the TCP socket streamer, meaning >> the client sending the data to the streamer via HTTP POST? >> 2) I am trying to play with ignite's TCP socket streamer example, but the >> client node stops with the message "Ignite node stopped" -- It hits the >> finally clause after the socket streamer is started. Any idea what could be >> wrong? >> >> >> https://github.com/apache/ignite/blob/master/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/socket/WordsSocketStreamerServer.java >> >> thanks. >> >>
