Apache Ignite Developers - Legacy Mail Archive

Apache Flink integration

Classic

List

Threaded

6 messages Options

Saikat Maitra

Apache Flink integration

Hi,

I am looking forward to taking up this ticket
https://issues.apache.org/jira/browse/IGNITE-813 (Apache Flink Integration).

I wanted to understand which module will be suitable for integration. Any
reference to similar integration or pointers to design discussion will be
helpful.

Regards
Saikat

Roman Shtykh

Re: Apache Flink integration

Hi Saikat,
Probably [1] can give you some pointers where to start.
[1] http://apache-ignite-developers.2346864.n4.nabble.com/Apache-Flink-and-Spark-Integration-and-Acceleration-td82.html
-Roman

On Monday, February 8, 2016 2:25 AM, Saikat Maitra <[hidden email]> wrote:

Hi,

I am looking forward to taking up this ticket
https://issues.apache.org/jira/browse/IGNITE-813 (Apache Flink Integration).

I wanted to understand which module will be suitable for integration. Any
reference to similar integration or pointers to design discussion will be
helpful.

Regards
Saikat

Saikat Maitra

Re: Apache Flink integration

Thank you Roman !!!

On Mon, Feb 8, 2016 at 3:20 PM, Roman Shtykh <[hidden email]>
wrote:

> Hi Saikat,
> Probably [1] can give you some pointers where to start.
> [1]
> http://apache-ignite-developers.2346864.n4.nabble.com/Apache-Flink-and-Spark-Integration-and-Acceleration-td82.html
> -Roman
>
>
> On Monday, February 8, 2016 2:25 AM, Saikat Maitra <
> [hidden email]> wrote:
>
>
> Hi,
>
> I am looking forward to taking up this ticket
> https://issues.apache.org/jira/browse/IGNITE-813 (Apache Flink
> Integration).
>
> I wanted to understand which module will be suitable for integration. Any
> reference to similar integration or pointers to design discussion will be
> helpful.
>
> Regards
> Saikat
>
>
>
>

Saikat Maitra

Re: Apache Flink integration

Hi there !

I have implemented Apache Ignite Flink integration. The design is based on
using IgniteQueue as a sink for Flink DataStreams. The IgniteSink
implements RichSinkFunction and enable custom implementation of Data sinks.
The Data sink consumes DataStreams and forwards them to IgniteQueue.

Please review this PR https://github.com/apache/ignite/pull/550 and share
feedback.

Regards
Saikat

On Mon, Feb 8, 2016 at 10:57 PM, Saikat Maitra <[hidden email]>
wrote:

> Thank you Roman !!!
>
> On Mon, Feb 8, 2016 at 3:20 PM, Roman Shtykh <[hidden email]>
> wrote:
>
>> Hi Saikat,
>> Probably [1] can give you some pointers where to start.
>> [1]
>> http://apache-ignite-developers.2346864.n4.nabble.com/Apache-Flink-and-Spark-Integration-and-Acceleration-td82.html
>> -Roman
>>
>>
>> On Monday, February 8, 2016 2:25 AM, Saikat Maitra <
>> [hidden email]> wrote:
>>
>>
>> Hi,
>>
>> I am looking forward to taking up this ticket
>> https://issues.apache.org/jira/browse/IGNITE-813 (Apache Flink
>> Integration).
>>
>> I wanted to understand which module will be suitable for integration. Any
>> reference to similar integration or pointers to design discussion will be
>> helpful.
>>
>> Regards
>> Saikat
>>
>>
>>
>>
>
>

Roman Shtykh

Re: Apache Flink integration

Hi Saikat,
Thank you for the PR! I will review it.Please see my comments at jira.
-Roman

On Sunday, March 13, 2016 6:07 PM, Saikat Maitra <[hidden email]> wrote:

Hi there !
I have implemented Apache Ignite Flink integration. The design is based on using IgniteQueue as a sink for Flink DataStreams. The IgniteSink implements RichSinkFunction and enable custom implementation of Data sinks. The Data sink consumes DataStreams and forwards them to IgniteQueue.
Please review this PR https://github.com/apache/ignite/pull/550 and share feedback.
RegardsSaikat
On Mon, Feb 8, 2016 at 10:57 PM, Saikat Maitra <[hidden email]> wrote:

Thank you Roman !!!
On Mon, Feb 8, 2016 at 3:20 PM, Roman Shtykh <[hidden email]> wrote:

Hi Saikat,
Probably [1] can give you some pointers where to start.
[1] http://apache-ignite-developers.2346864.n4.nabble.com/Apache-Flink-and-Spark-Integration-and-Acceleration-td82.html
-Roman

On Monday, February 8, 2016 2:25 AM, Saikat Maitra <[hidden email]> wrote:

Hi,

I am looking forward to taking up this ticket
https://issues.apache.org/jira/browse/IGNITE-813 (Apache Flink Integration).

I wanted to understand which module will be suitable for integration. Any
reference to similar integration or pointers to design discussion will be
helpful.

Regards
Saikat

Saikat Maitra

Re: Apache Flink integration

Thank you Roman..

On Mon, Mar 14, 2016 at 4:21 PM, Roman Shtykh <[hidden email]>
wrote:

> Hi Saikat,
> Thank you for the PR! I will review it.Please see my comments at jira.
> -Roman
>
>
> On Sunday, March 13, 2016 6:07 PM, Saikat Maitra <
> [hidden email]> wrote:
>
>
> Hi there !
> I have implemented Apache Ignite Flink integration. The design is based on
> using IgniteQueue as a sink for Flink DataStreams. The IgniteSink
> implements RichSinkFunction and enable custom implementation of Data sinks.
> The Data sink consumes DataStreams and forwards them to IgniteQueue.
> Please review this PR https://github.com/apache/ignite/pull/550 and share
> feedback.
> RegardsSaikat
> On Mon, Feb 8, 2016 at 10:57 PM, Saikat Maitra <[hidden email]>
> wrote:
>
> Thank you Roman !!!
> On Mon, Feb 8, 2016 at 3:20 PM, Roman Shtykh <[hidden email]>
> wrote:
>
> Hi Saikat,
> Probably [1] can give you some pointers where to start.
> [1]
> http://apache-ignite-developers.2346864.n4.nabble.com/Apache-Flink-and-Spark-Integration-and-Acceleration-td82.html
> -Roman
>
>
> On Monday, February 8, 2016 2:25 AM, Saikat Maitra <
> [hidden email]> wrote:
>
>
> Hi,
>
> I am looking forward to taking up this ticket
> https://issues.apache.org/jira/browse/IGNITE-813 (Apache Flink
> Integration).
>
> I wanted to understand which module will be suitable for integration. Any
> reference to similar integration or pointers to design discussion will be
> helpful.
>
> Regards
> Saikat
>
>
>
>
>
>
>
>
>
>