org.apache.beam.runners.spark.structuredstreaming.translation.helpers

Class KVHelpers

java.lang.Object

org.apache.beam.runners.spark.structuredstreaming.translation.helpers.KVHelpers

public final class KVHelpers
extends java.lang.Object

Helper functions for working with KV.

Constructor Summary

Constructors

Constructor and Description
KVHelpers()

Method Summary

Modifier and Type	Method and Description
static <K,V> org.apache.spark.api.java.function.MapFunction<org.apache.beam.sdk.util.WindowedValue<KV<K,V>>,K>	extractKey() A Spark MapFunction for extracting the key out of a KV for GBK for example.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KVHelpers

public KVHelpers()

Method Detail

extractKey

public static <K,V> org.apache.spark.api.java.function.MapFunction<org.apache.beam.sdk.util.WindowedValue<KV<K,V>>,K> extractKey()

A Spark MapFunction for extracting the key out of a KV for GBK for example.