To run operations like Insert, Update, Delete on persistent files, you have
to have support from the storage engine.
The Apache ORC data format recently added support for transactional
inserts, updates, deletes. http://orc.apache.org/
ORC has a Hadoop input format, and you can use that one with F
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:
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:
