Kio is a set of Kotlin extensions for Apache Beam to implement fluent-like API for Java SDK.
Word Count example
// Create Kio context
val kio = Kio.fromArguments(args)
// Configure a pipeline
kio.read().text("~/input.txt")
.map { it.toLowerCase() }
.flatMap { it.split("\\W+".toRegex()) }
.filter { it.isNotEmpty() }
.countByValue()
.forEach { println(it) }
// And execute it
kio.execute().waitUntilDone()
Documentation
For more information about Kio, please see the documentation here: https://code.chermenin.ru/kio.