Class StatisticsObjectData

    • Constructor Detail

      • StatisticsObjectData

        public StatisticsObjectData​(StatisticsKeyMessage key,
                                    long rowsCnt,
                                    StatisticsType type,
                                    int partId,
                                    long updCnt,
                                    Map<String,​StatisticsColumnData> data)
        Constructor.
        Parameters:
        key - Statistics key.
        rowsCnt - Total row count.
        type - Statistics type.
        partId - Partition id.
        updCnt - Partition update counter.
        data - Map of statistics column data.
      • StatisticsObjectData

        public StatisticsObjectData()
        Default constructor.
    • Method Detail

      • rowsCnt

        public long rowsCnt()
        Returns:
        Total rows count.
      • partId

        public int partId()
        Returns:
        Partition id.
      • updCnt

        public long updCnt()
        Returns:
        Partition update counter.
      • writeTo

        public boolean writeTo​(ByteBuffer buf,
                               MessageWriter writer)
        Writes this message to provided byte buffer.
        Specified by:
        writeTo in interface Message
        Parameters:
        buf - Byte buffer.
        writer - Writer.
        Returns:
        Whether message was fully written.
      • readFrom

        public boolean readFrom​(ByteBuffer buf,
                                MessageReader reader)
        Reads this message from provided byte buffer.
        Specified by:
        readFrom in interface Message
        Parameters:
        buf - Byte buffer.
        reader - Reader.
        Returns:
        Whether message was fully read.
      • directType

        public short directType()
        Gets message type.
        Specified by:
        directType in interface Message
        Returns:
        Message type.
      • fieldsCount

        public byte fieldsCount()
        Gets fields count.
        Specified by:
        fieldsCount in interface Message
        Returns:
        Fields count.
      • onAckReceived

        public void onAckReceived()
        Method called when ack message received.
        Specified by:
        onAckReceived in interface Message