Package org.apache.cassandra.service.paxos

Class PaxosCommitAndPrepare.RequestSerializer

  • All Implemented Interfaces:
    IVersionedAsymmetricSerializer<org.apache.cassandra.service.paxos.PaxosCommitAndPrepare.Request,​org.apache.cassandra.service.paxos.PaxosCommitAndPrepare.Request>, IVersionedSerializer<org.apache.cassandra.service.paxos.PaxosCommitAndPrepare.Request>
    Enclosing class:
    PaxosCommitAndPrepare
    public static class PaxosCommitAndPrepare.RequestSerializer
extends java.lang.Object

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.cassandra.service.paxos.PaxosCommitAndPrepare.Request deserialize​(DataInputPlus in, int version)
      Deserialize into the specified DataInputStream instance.
      R deserialize​(T param, DataInputPlus in, int version)  
      void serialize​(org.apache.cassandra.service.paxos.PaxosCommitAndPrepare.Request request, DataOutputPlus out, int version)
      Serialize the specified type into the specified DataOutputStream instance.
      long serializedSize​(org.apache.cassandra.service.paxos.PaxosCommitAndPrepare.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.PaxosCommitAndPrepare.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.PaxosCommitAndPrepare.Request,​org.apache.cassandra.service.paxos.PaxosCommitAndPrepare.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.PaxosCommitAndPrepare.Request deserialize​(DataInputPlus in,
                                                                                    int version)
                                                                             throws java.io.IOException
        Description copied from interface: IVersionedAsymmetricSerializer
        Deserialize into the specified DataInputStream instance.
        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.PaxosCommitAndPrepare.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.PaxosCommitAndPrepare.Request,​org.apache.cassandra.service.paxos.PaxosCommitAndPrepare.Request>
        Parameters:
        request - object to calculate serialized size
        version - protocol version
        Returns:
        serialized size of object t

      • deserialize

        public R deserialize​(T param,
                     DataInputPlus in,
                     int version)
              throws java.io.IOException
        Throws:
        java.io.IOException