Class AsyncConfig

    • Constructor Detail

      • AsyncConfig

        public AsyncConfig()
    • Method Detail

      • getEmitWithinMillis

        public long getEmitWithinMillis()
      • setEmitWithinMillis

        public void setEmitWithinMillis​(long emitWithinMillis)
        If nothing has been emitted in this amount of time and the getEmitMaxEstimatedBytes() has not been reached yet, emit what's in the emit queue.
        Parameters:
        emitWithinMillis -
      • getEmitMaxEstimatedBytes

        public long getEmitMaxEstimatedBytes()
        When the emit queue hits this estimated size (sum of estimated extract sizes), emit the batch.
        Returns:
      • setEmitMaxEstimatedBytes

        public void setEmitMaxEstimatedBytes​(long emitMaxEstimatedBytes)
      • setNumEmitters

        public void setNumEmitters​(int numEmitters)
      • getQueueSize

        public int getQueueSize()
        FetchEmitTuple queue size
        Returns:
      • setQueueSize

        public void setQueueSize​(int queueSize)
      • getNumEmitters

        public int getNumEmitters()
        Number of emitters
        Returns:
      • setPipesReporter

        public void setPipesReporter​(PipesReporter pipesReporter)
      • setEmitIntermediateResults

        public void setEmitIntermediateResults​(boolean emitIntermediateResults)
      • isEmitIntermediateResults

        public boolean isEmitIntermediateResults()