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.