Flink4K

This library provides an API for Kotlin users of Flink

The main pain point of using usual Java-based API of Flink is the constant need of passing TypeInformation

Scala API solves it with implicits, but you have to create them anyway

This library leverages reified type ability to preserve type information

So instead of

stream.map(TypeInformation.of(String::class.java)){ it.toString() }

You could just write

stream.mapK{ it.toString() } // TypeInformation will be passed implicitly!

Build