Package org.apache.wayang.flink.operators

Class ScalaTupleSerializer

java.lang.Object
com.esotericsoftware.kryo.Serializer<scala.Product>
org.apache.wayang.flink.operators.ScalaTupleSerializer
public class ScalaTupleSerializer extends com.esotericsoftware.kryo.Serializer<scala.Product>

  • Constructor Summary

    Constructors
    Constructor
    Description
    ScalaTupleSerializer()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    scala.Product
    read(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Input input, Class<scala.Product> type)
     
    void
    write(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Output output, scala.Product tuple)
     

    Methods inherited from class com.esotericsoftware.kryo.Serializer

    copy, getAcceptsNull, isImmutable, setAcceptsNull, setGenerics, setImmutable

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • ScalaTupleSerializer

      public ScalaTupleSerializer()

  • Method Details

    • write

      public void write(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Output output, scala.Product tuple)
      Specified by:
      write in class com.esotericsoftware.kryo.Serializer<scala.Product>

    • read

      public scala.Product read(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Input input, Class<scala.Product> type)
      Specified by:
      read in class com.esotericsoftware.kryo.Serializer<scala.Product>