Skip to content

Instantly share code, notes, and snippets.

@sanderploegsma

sanderploegsma/PCollectionUtils.kt

Last active January 31, 2018 19:24
Show Gist options
  • Save sanderploegsma/20cc8c73aacd3935df2158ff81da50ec to your computer and use it in GitHub Desktop.
Save sanderploegsma/20cc8c73aacd3935df2158ff81da50ec to your computer and use it in GitHub Desktop.
Download ZIP
Raw
PCollectionUtils.kt
inline fun <T> PCollection<T>.filter(name: String = "Filter", crossinline predicate: (T) -> Boolean): PCollection<T>
= this.apply(name, Filter.by(SerializableFunction<T, Boolean> { predicate(it) }))
inline fun <T, R> PCollection<T>.map(name: String = "Map", crossinline apply: (T) -> R): PCollection<R>
= this.apply(name, MapElements.into(object : TypeDescriptor<R>(){}).via({ apply(it) }))
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment