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 >
