public interface ExchangeSource
Source for exchanging data
See Also:
  • Method Summary

    Modifier and Type
    Method
    Description
    int
    Returns the number of pages that are buffered in this exchange source
    void
    Called when the source has enough input pages
    boolean
    Whether the associated sinks are finished and pages are processed.
    Remove the page from this source if any; otherwise, returns null
    Allows callers to stop reading from the source when it's blocked
  • Method Details

    • pollPage

      Page pollPage()
      Remove the page from this source if any; otherwise, returns null
    • finish

      void finish()
      Called when the source has enough input pages
    • isFinished

      boolean isFinished()
      Whether the associated sinks are finished and pages are processed.
    • bufferSize

      int bufferSize()
      Returns the number of pages that are buffered in this exchange source
    • waitForReading

      IsBlockedResult waitForReading()
      Allows callers to stop reading from the source when it's blocked