Home

Welcome to the flink-operator-library wiki!

Here you will find several information on how to use the operator library most efficiently. Therefore we provide next to detailed documentation a set of tutorials that showcase the integration.

If any questions are left open feel free to get in contact with the authors referenced inside the pom file

Tutorials

Documentation

• [Describing references into JSON documents](JSON content references)
• [JSON processing utilities](JSON processing utilities)
• [JSON Content Matcher to integrate with Flink Spector for operator and pipeline testing](JSON Content Matcher to integrate with Flink Spector for operator and pipeline testing)
• [Base runtime for streaming applications](Base runtime for streaming applications)
• [JSON Content Filter operator](JSON Content Filter operator)
• [JSON document backed key selector](JSON document backed key selector)
• [JSON to CSV conversion operator](JSON to CSV conversion operator)
• [Static content insertion into existing JSON documents](Static content insertion into existing JSON documents)
• [Window-based JSON content aggregation](Window-based JSON content aggregation)
• [Content mappers](JSON Content Mappers)