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.

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

[FLINK-4361] Introduce Flink's own future abstraction #2472

Closed
wants to merge 3 commits into from

Commits on Sep 5, 2016

  1. [FLINK-4361] Introduce Flink's own future abstraction

    Flink's future abstraction whose API is similar to Java 8's CompletableFuture.
    That's in order to ease a future transition to this class once we ditch Java 7.
    The current set of operations comprises:
    
    - isDone to check the completion of the future
    - get/getNow to obtain the future's value
    - cancel to cancel the future (best effort basis)
    - thenApplyAsync to transform the future's value into another value
    - thenAcceptAsync to register a callback for a successful completion of the future
    - exceptionallyAsync to register a callback for an exception completion of the future
    - thenComposeAsync to transform the future's value and flatten the returned future
    - handleAsync to register a callback which is called either with the regular result
    or the exceptional result
    
    Additionally, Flink offers a CompletableFuture which can be completed with a regular
    value or an exception:
    
    - complete/completeExceptionally
    tillrohrmann committed Sep 5, 2016
    Copy the full SHA
    14023bb View commit details
    Browse the repository at this point in the history

Commits on Sep 20, 2016

  1. Copy the full SHA
    9952bd8 View commit details
    Browse the repository at this point in the history
  2. Fix wrong Java doc

    tillrohrmann committed Sep 20, 2016
    Copy the full SHA
    ee54b2b View commit details
    Browse the repository at this point in the history