Thanks Saikat for the reply. 1) I will check out the webinar. thanks. 2) The socket streamer server code goes to the finally clause right after the socket streamer is starts. The screen snapshot with 2 servers and one client is here.
[image: image.png] On Mon, Jan 6, 2020 at 7:59 PM Saikat Maitra <saikat.mai...@gmail.com> wrote: > Hi, > > 1. If you define schema for your dataset then you should be able to > execute qry to get the desired resultset. Please take a look into Valentin > Kulichenko's webinar related to using jdbc thin client and getting > resultset. You can execute similar qry using rest api. Alternatively, you > can also use rest api to Execute command to perform any task in the Ignite > grid. > > https://www.youtube.com/watch?v=eMs_2vEsbBk&t=3103s > > 2. If I understand correctly the topology for the grid, we have 4 ignite > servers and 1 Data streamer client which is pushing the data to Ignite > cluster. If the Ignite Data Streamer client is stopped in finally clause > then where do you receive the "Ignite node stopped message". > > Also, can you please share if this is a INFO message or ERROR message? > > Regards, > Saikat > > > > On Sun, Jan 5, 2020 at 8:23 PM narges saleh <snarges...@gmail.com> wrote: > >> Hello Saikat, >> 1) Any service method; say I have an affinity based deployed service with >> a method that aggregates the balances for each customer based on their >> location. >> Also, I take it that it is not possible to have rest API/streamer >> producer/consumer arrangement as you would have in tcp socket connection >> between the client data producer and streamer data consumer, right? >> 2)Yes the nodes report number of servers=4 and clients=1 and but then the >> number of clients goes to 0 when the streamer node stops (but the number of >> servers stays at 4). >> thanks. >> >> On Sun, Jan 5, 2020 at 6:56 PM Saikat Maitra <saikat.mai...@gmail.com> >> wrote: >> >>> Hi, >>> >>> 1. The rest api is separate interface to load data in cache. I do not >>> think we have rest endpoint to call ignite service method, can you share an >>> example of which service method you want to call using rest api. You can >>> check the rest api docs to learn more about rest apis supported >>> functionality. >>> >>> https://apacheignite.readme.io/docs/rest-api >>> >>> 2. Can you see if any active node running, all the nodes will log >>> cluster health information and number of servers running etc >>> >>> Regards, >>> Saikat >>> >>> On Sun, Jan 5, 2020 at 3:21 PM narges saleh <snarges...@gmail.com> >>> wrote: >>> >>>> 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 <saikat.mai...@gmail.com> >>>> 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 <snarges...@gmail.com> >>>>> 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. >>>>>> >>>>>>
