flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chiwan Park <chiwanp...@icloud.com>
Subject Re: Apache Flink transactions
Date Thu, 04 Jun 2015 07:00:58 GMT
Hi.

Flink is not DBMS. There is no equivalent operation of insert, update, remove.
But you can use map[1] or filter[2] operation to create modified dataset.

I recommend you some sildes[3][4] to understand Flink concepts.

Regards,
Chiwan Park

[1] http://ci.apache.org/projects/flink/flink-docs-master/apis/dataset_transformations.html#map
[2] http://ci.apache.org/projects/flink/flink-docs-master/apis/dataset_transformations.html#filter
[3] http://www.slideshare.net/robertmetzger1/introduction-to-apache-flink-palo-alto-meetup
[4] http://www.slideshare.net/dataArtisans/flink-training-dataset-api-basics


> On Jun 4, 2015, at 2:48 PM, Hawin Jiang <hawin.jiang@gmail.com> wrote:
> 
> Hi  Admin
> 
> 
> 
> Do we have insert, update and remove operations on Apache Flink?
> 
> For example:  I have 10 million records in my test file.  I want to add one
> record, update one record and remove one record from this test file. 
> 
> How to implement it by Flink?
> 
> Thanks.
> 
> 
> 
> 
> 
> 
> 
> 
> 
> Best regards
> 
> Email: hawin.jiang@gmail.com
> 





Mime
View raw message