Kotlin support for Apache Flink
MIT License
This package provides type information and
specialized type serializers
for kotlin data classes (including Pair
and Triple
), as well as for Kotlin Map
and Collection
types.
The package is available on Maven Central and Github, using Gradle:
implementation("com.lapanthere:flink-kotlin:0.1.0")
Using the createTypeInformation
that will return a Kotlin friendly TypeInformation
for data classes, collections,
maps, etc:
dataStream.process(
processFunction(),
createTypeInformation<Row>()
)
It also supports fields name in the definition of keys, i.e. you will be able to use name of fields directly:
dataStream.join(another).where("name").equalTo("personName")
You can also annotate your data classes with the @TypeInfo
annotation:
@TypeInfo(DataClassTypeInfoFactory::class)
data class Record(
val name: String,
val value: Long
)
Schema evolution for data classes follow this set of rules: