All notable changes to this project will be documented in this file.
The format is based on Keep a Changelog and this project adheres to Semantic Versioning.
- Upgraded Flink to v2.2.0
- Implemented stdout sink using Flink 2.2's Sink API
- Added a FlinkTargetOperator to handle the creation of sinks using a Factory pattern
- Added an extra Flink operator step to extract the serialized RDF output from solution mappings before written the records into the sinks
- Updated Algemaploom-rs version to 0.6.5
- (Re-)use Flink 2.2's mini-cluster for testing and reduce test start-up time
- Moved all CLI related parameters parsing and specification to a separate module
- Put dependency to FnOio in small case. See #1
- Old TargetSinkFunction which implements the deprecated legacy Flink's SinkFunction API
- OperatorTests.java which doesn't test anything meaningful is removed
- All existing implementations of a generic DataIO-based sink operators using legacy Flink's Source API
- Initial source code [0.1.0]: https://github.com/RMLio/MappingWeaver-java/releases/tag/v0.1.0
- Added websocket support
- Updated pom.xml to directly pull dataio instead of pulling this through algebraic mapping operators