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. >>>> >>>>
