Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[FLINK-6555] [futures] Generalize ConjunctFuture to return results #3873

Closed
wants to merge 2 commits into from
Closed

[FLINK-6555] [futures] Generalize ConjunctFuture to return results #3873

wants to merge 2 commits into from

Commits on May 15, 2017

  1. [FLINK-6555] [futures] Generalize ConjunctFuture to return results 

    The ConjunctFuture now returns the set of future values once it is completed.
    @tillrohrmann
    tillrohrmann committed May 15, 2017
    Configuration menu
    Copy the full SHA
    d629b13 View commit details
    Browse the repository at this point in the history

  2. Introduce WaitingConjunctFuture; Fix thread safety issue with ResultC… 

    …onjunctFuture

The WaitingConjunctFuture waits for the completion of its futures. The future values
are discarded making it more efficient than the ResultConjunctFuture which returns
the futures' values. The WaitingConjunctFuture is instantiated via
FutureUtils.waitForAll(Collection<Future>).
    @tillrohrmann
    tillrohrmann committed May 15, 2017
    Configuration menu
    Copy the full SHA
    b8de126 View commit details
    Browse the repository at this point in the history