Class ProcessObject


  • public class ProcessObject
    extends java.lang.Object
    Passed in the pipeline as water through a hose. The process object hold a queue with Writables.
    • Field Summary

      Fields 
      Modifier and Type Field Description
      private java.util.Queue<Writable> queue  
    • Constructor Summary

      Constructors 
      Constructor Description
      ProcessObject()  
    • Field Detail

      • queue

        private final java.util.Queue<Writable> queue
    • Constructor Detail

      • ProcessObject

        public ProcessObject()
    • Method Detail

      • containsWritable

        public boolean containsWritable()
        Returns:
        true if a writable is contained.
      • poll

        public Writable poll()
        Returns:
        a Writable or null if none.
      • add

        public void add​(Writable writable)
        Add a writable.
        Parameters:
        writable - the writable to add
      • addAll

        public void addAll​(java.util.List<Writable> elems)
        Adds a list of writable.
        Parameters:
        elems - the writables