Class ControlledWorkerBoundJoin

    • Method Detail

      • setSubmitFirstResultImmediately

        protected void setSubmitFirstResultImmediately​(boolean flag)
        Deprecated, for removal: This API element is subject to removal in a future version.
      • handleBindings

        protected void handleBindings()
                               throws Exception
        Deprecated, for removal: This API element is subject to removal in a future version.
        Description copied from class: JoinExecutorBase
        Implementations must implement this method to handle bindings. Use the following as a template while (!closed && leftIter.hasNext()) { // your code } and add results to rightQueue. Note that addResult() is implemented synchronized and thus thread safe. In case you can guarantee sequential access, it is also possible to directly access rightQueue Note that the implementation must block until the entire join is executed.
        Overrides:
        handleBindings in class ControlledWorkerJoin
        Throws:
        Exception
      • getNextBindJoinSize

        protected int getNextBindJoinSize​(int configuredBindJoinSize,
                                          int totalBindings)
        Deprecated, for removal: This API element is subject to removal in a future version.
        Return the size of the next bind join block.
        Parameters:
        configuredBindJoinSize - the configured bind join size
        totalBindings - the current process bindings from the intermediate result set
        Returns: