Marshall Pierce created FLINK-18280: ---------------------------------------
Summary: Kotlin adapters for Flink types? Key: FLINK-18280 URL: https://issues.apache.org/jira/browse/FLINK-18280 Project: Flink Issue Type: Wish Affects Versions: 1.10.1 Reporter: Marshall Pierce Currently, using a Kotlin lambda for, say, a {{KeySelector}} doesn't work – it needs to be an {{object}} expression for the runtime type detection to work. At my day job we have started building up a handful of wrappers, like this one for {{KeySelector}}: {code:kotlin} inline fun <T, K> keySelector(crossinline block: (T) -> K): KeySelector<T, K> { return object : KeySelector<T, K> { override fun getKey(value: T): K { return block(value) } } } {code} Usage looks like: {{keySelector { it.fooId }}}. Surely not the only way to solve that problem, but it's been working smoothly for us so far. Is there any interested in shipping these sorts of extensions as part of the Flink project so users don't need to write them? It could be a wholly separate artifact (or rather multiple artifacts, as there would probably be one for flink core, one for flink streaming, etc). -- This message was sent by Atlassian Jira (v8.3.4#803005)