flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Till Rohrmann <trohrm...@apache.org>
Subject Re: Apache Flink transactions
Date Thu, 04 Jun 2015 07:29:57 GMT
But what you can do to simulate an insert is to read the new data in a
separate DataSet and then apply an union operator on the new and old DataSet
.

Cheers,
Till
‚Äč

On Thu, Jun 4, 2015 at 9:00 AM, Chiwan Park <chiwanpark@icloud.com> wrote:

> 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