Package org.apache.cassandra.service.paxos

Class PaxosPropose.RequestSerializer

  • All Implemented Interfaces:
    IVersionedAsymmetricSerializer<org.apache.cassandra.service.paxos.PaxosPropose.Request,​org.apache.cassandra.service.paxos.PaxosPropose.Request>, IVersionedSerializer<org.apache.cassandra.service.paxos.PaxosPropose.Request>
    Enclosing class:
    PaxosPropose<OnDone extends java.util.function.Consumer<? super org.apache.cassandra.service.paxos.PaxosPropose.Status>>
    public static class PaxosPropose.RequestSerializer
extends java.lang.Object
implements IVersionedSerializer<org.apache.cassandra.service.paxos.PaxosPropose.Request>

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.cassandra.service.paxos.PaxosPropose.Request deserialize​(DataInputPlus in, int version)
      Deserialize into the specified DataInputStream instance.
      void serialize​(org.apache.cassandra.service.paxos.PaxosPropose.Request request, DataOutputPlus out, int version)
      Serialize the specified type into the specified DataOutputStream instance.
      long serializedSize​(org.apache.cassandra.service.paxos.PaxosPropose.Request request, int version)
      Calculate serialized size of object without actually serializing.

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • RequestSerializer

        public RequestSerializer()

    • Method Detail

      • serialize

        public void serialize​(org.apache.cassandra.service.paxos.PaxosPropose.Request request,
                      DataOutputPlus out,
                      int version)
               throws java.io.IOException
        Description copied from interface: IVersionedAsymmetricSerializer
        Serialize the specified type into the specified DataOutputStream instance.
        Specified by:
        serialize in interface IVersionedAsymmetricSerializer<org.apache.cassandra.service.paxos.PaxosPropose.Request,​org.apache.cassandra.service.paxos.PaxosPropose.Request>
        Parameters:
        request - type that needs to be serialized
        out - DataOutput into which serialization needs to happen.
        version - protocol version
        Throws:
        java.io.IOException - if serialization fails

      • deserialize

        public org.apache.cassandra.service.paxos.PaxosPropose.Request deserialize​(DataInputPlus in,
                                                                           int version)
                                                                    throws java.io.IOException
        Description copied from interface: IVersionedAsymmetricSerializer
        Deserialize into the specified DataInputStream instance.
        Specified by:
        deserialize in interface IVersionedAsymmetricSerializer<org.apache.cassandra.service.paxos.PaxosPropose.Request,​org.apache.cassandra.service.paxos.PaxosPropose.Request>
        Parameters:
        in - DataInput from which deserialization needs to happen.
        version - protocol version
        Returns:
        the type that was deserialized
        Throws:
        java.io.IOException - if deserialization fails

      • serializedSize

        public long serializedSize​(org.apache.cassandra.service.paxos.PaxosPropose.Request request,
                           int version)
        Description copied from interface: IVersionedAsymmetricSerializer
        Calculate serialized size of object without actually serializing.
        Specified by:
        serializedSize in interface IVersionedAsymmetricSerializer<org.apache.cassandra.service.paxos.PaxosPropose.Request,​org.apache.cassandra.service.paxos.PaxosPropose.Request>
        Parameters:
        request - object to calculate serialized size
        version - protocol version
        Returns:
        serialized size of object t