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
- Added CLI option
-l --loom-fileto take an AlgeMapLoom plan as input. - Added websocket support
- Updated RML test cases
- Put dependency to FnOio in small case. See #1
- Update dependency on MappingLoom to 0.6.6
- Use base IRI given as program argument when generating relative IRIs
- 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
- Updated pom.xml to directly pull dataio instead of pulling this through algebraic mapping operators
- 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
0.1.0 - 2025-10-08
- Initial source code