Class RichSpoutBatchIdSerializer

java.lang.Object
com.esotericsoftware.kryo.Serializer<RichSpoutBatchId>
org.apache.storm.trident.spout.RichSpoutBatchIdSerializer

public class RichSpoutBatchIdSerializer extends com.esotericsoftware.kryo.Serializer<RichSpoutBatchId>
  • Constructor Details

    • RichSpoutBatchIdSerializer

      public RichSpoutBatchIdSerializer()
  • Method Details

    • write

      public void write(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Output output, RichSpoutBatchId id)
      Specified by:
      write in class com.esotericsoftware.kryo.Serializer<RichSpoutBatchId>
    • read

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