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 <chiwanp...@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.ji...@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.ji...@gmail.com > > > > > > >
