A modern programming language that makes developers happier.

kotlinlang

set the channel description: All about using Beam with Kotlin

set the channel topic: <https://code.chermenin.ru/kio>

Hello everyone, :wave:

I would like to present my little project called *Kio*. :male_mage:
It’s a set of Kotlin extensions and some additional stuff for Apache Beam.

Here is the first public release: <https://github.com/chermenin/kio/releases/tag/0.1.0> :tada:
Here is the documentation: <https://code.chermenin.ru/kio/documentation/>
And some `WordCount` examples ported from the Beam repository: <https://github.com/chermenin/kio/tree/master/examples/src/main/kotlin/ru/chermenin/kio/examples>

That’s it for now. I’ll be glad to receive any feedback, comments, issues, or pull requests. And I will keep improving the code. :hugging_face:

<@U017G370546> Thanks for link, super interesting! I'm curious about your experience and perception: how seamless is it to use vanilla Kotlin with Beam? We currently use Beam at work and I'm trying to analyze if using Kotlin instead of strictly Java would be an adequate use case.  

In general, using vanilla Beam Java SDK in Kotlin has to be very similar to using it in Java. There are some problems with Kotlin’s native classes (for example, `Iterable`: <https://stackoverflow.com/questions/55908999/kotlin-iterable-not-supported-in-apache-beam>, usually it’s connected with Kotlin wildcards in generics).

As for me, I rarely use just Beam Java SDK without some additional methods that cover it. We have several streaming and batch pipelines in Kotlin using methods from Kio that running in Google Dataflow now, and it looks quite workable.

Does kio have any extensions/mechanisms for using kotlinx serialization as a `CustomCoder`?

Hi all! I’m using kotlin + apache beam on google cloud dataflow for some BI data streams. I’ve an issue with kotlin 1.4.30 and apache beam, While i was waiting for slack invitation I’ve asked on stackoverflow <https://stackoverflow.com/questions/66170900/kotlin-1-4-30-apache-beam-compilation-error>
Has anyone had the same problem? How can be fixed?

There is a bug in the issue tracker for that <https://youtrack.jetbrains.com/issue/KT-45067>, but seems no workarounds yet other than downgrading to version 1.4.21.

FYI: I’ve answered on stackoverflow. It caused by the Kotlin compiler, by the part of the type use annotations reading from class files. Unfortunately, it’s true there aren’t any normal workarounds in 1.4.30. The fix will be available in 1.5-M1.