Class StreamBaseClient.TupleBuffer

    • Method Detail

      • addToBuffer

        protected abstract void addToBuffer​(Tuple tuple,
                                            int id)
                                     throws TupleException
        Add to buffer
        Parameters:
        tuple - Tuple to add
        id - Identifier
        Throws:
        TupleException - Error adding to buffer
      • props

        public StreamProperties props()
        get stream properties for this Buffer
        Returns:
        stream properties for the buffer
      • checkTuple

        protected void checkTuple​(Tuple tuple)
        Check tuple to make sure it is up to snuff
        Parameters:
        tuple - tuple to check
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class Object
      • tupleCount

        public int tupleCount()
        Get tuple count
        Returns:
        Number of tuples
      • canEnqueue

        public boolean canEnqueue​(StreamProperties props)
        Can enqueue?
        Parameters:
        props - Properties
        Returns:
        true if can enqueue, false otherwise
      • canDequeue

        public boolean canDequeue​(StreamProperties props)
        Can dequeue?
        Parameters:
        props - Properties
        Returns:
        true if can dequeue, false otherwise