Class WritableRequest<I extends org.apache.hadoop.io.WritableComparable,​V extends org.apache.hadoop.io.Writable,​E extends org.apache.hadoop.io.Writable>

  • All Implemented Interfaces:
    org.apache.giraph.conf.GiraphConfigurationSettable<I,​V,​E>, org.apache.giraph.conf.ImmutableClassesGiraphConfigurable<I,​V,​E>, org.apache.hadoop.io.Writable
    Direct Known Subclasses:
    BatchWritableRequest, ByteBufRequest, GidLongWritableRequest, OneLongWritableRequest

    public abstract class WritableRequest<I extends org.apache.hadoop.io.WritableComparable,​V extends org.apache.hadoop.io.Writable,​E extends org.apache.hadoop.io.Writable>
    extends Object
    implements org.apache.hadoop.io.Writable, org.apache.giraph.conf.ImmutableClassesGiraphConfigurable<I,​V,​E>
    • Constructor Detail

      • WritableRequest

        public WritableRequest()
    • Method Detail

      • getRequestType

        public abstract RequestType getRequestType()
        Serialization of request type is taken care by encoder.
        Returns:
        request type.
      • getNumBytes

        public abstract int getNumBytes()
      • doRequest

        public abstract void doRequest​(MessageStore<I,​org.apache.hadoop.io.Writable,​?> messageStore)
        Apply this request on this message storage.
        Parameters:
        messageStore - message store.
      • readFields

        public final void readFields​(DataInput input)
                              throws IOException
        Specified by:
        readFields in interface org.apache.hadoop.io.Writable
        Throws:
        IOException
      • write

        public final void write​(DataOutput output)
                         throws IOException
        Specified by:
        write in interface org.apache.hadoop.io.Writable
        Throws:
        IOException
      • getBuffer

        public abstract io.netty.buffer.ByteBuf getBuffer()
      • setBuffer

        public abstract void setBuffer​(io.netty.buffer.ByteBuf buf)
        Parameters:
        buf -
      • getConf

        public final ImmutableClassesGiraphConfiguration<I,​V,​E> getConf()
        Specified by:
        getConf in interface org.apache.giraph.conf.ImmutableClassesGiraphConfigurable<I extends org.apache.hadoop.io.WritableComparable,​V extends org.apache.hadoop.io.Writable,​E extends org.apache.hadoop.io.Writable>
      • setConf

        public final void setConf​(ImmutableClassesGiraphConfiguration<I,​V,​E> conf)
        Specified by:
        setConf in interface org.apache.giraph.conf.GiraphConfigurationSettable<I extends org.apache.hadoop.io.WritableComparable,​V extends org.apache.hadoop.io.Writable,​E extends org.apache.hadoop.io.Writable>