Package org.apache.beam.runners.spark.coders

Class CoderHelpers.FromByteFunction<K,V>

java.lang.Object
org.apache.beam.runners.spark.coders.CoderHelpers.FromByteFunction<K,V>
Type Parameters:
K - The type of the key being deserialized.
V - The type of the value being deserialized.
All Implemented Interfaces:
Serializable, Function<scala.Tuple2<ByteArray,byte[]>,scala.Tuple2<K,V>>, org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.base.Function<scala.Tuple2<ByteArray,byte[]>,scala.Tuple2<K,V>>, org.apache.spark.api.java.function.PairFunction<scala.Tuple2<ByteArray,byte[]>,K,V>
Enclosing class:
CoderHelpers
public static class CoderHelpers.FromByteFunction<K,V> extends Object implements org.apache.spark.api.java.function.PairFunction<scala.Tuple2<ByteArray,byte[]>,K,V>, org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.base.Function<scala.Tuple2<ByteArray,byte[]>,scala.Tuple2<K,V>>
A function for converting a byte array pair to a key-value pair.
See Also:

  • Constructor Details

    • FromByteFunction

      public FromByteFunction(Coder<K> keyCoder, Coder<V> valueCoder)
      Parameters:
      keyCoder - Coder to deserialize keys.
      valueCoder - Coder to deserialize values.

  • Method Details

    • call

      public scala.Tuple2<K,V> call(scala.Tuple2<ByteArray,byte[]> tuple)
      Specified by:
      call in interface org.apache.spark.api.java.function.PairFunction<scala.Tuple2<ByteArray,byte[]>,K,V>

    • apply

      public scala.Tuple2<K,V> apply(@Nonnull scala.Tuple2<ByteArray,byte[]> tuple)
      Specified by:
      apply in interface Function<K,V>
      Specified by:
      apply in interface org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.base.Function<K,V>