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 <[email protected]> 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 <[email protected]>
> 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 <[email protected]> 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 <[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.
>>>>>
>>>>>

Reply via email to