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-4460] Allow ProcessFunction on non-keyed streams #3438

Merged
merged 5 commits into from
Mar 6, 2017
Merged

[FLINK-4460] Allow ProcessFunction on non-keyed streams #3438

merged 5 commits into from
Mar 6, 2017

Commits on Mar 6, 2017

  1. [FLINK-4460] Make ProcessFunction abstract, add default onTime() method 

    This is in preparation of allowing ProcessFunction on DataStream because
we will use it to allow side outputs from the ProcessFunction Context.
    @aljoscha
    aljoscha committed Mar 6, 2017
    Configuration menu
    Copy the full SHA
    82eddca View commit details
    Browse the repository at this point in the history

  2. [FLINK-4660] Allow ProcessFunction on DataStream 

    Introduce new ProcessOperator for this. Rename the pre-existing
ProcessOperator to KeyedProcessOperator.
    @aljoscha
    aljoscha committed Mar 6, 2017
    Configuration menu
    Copy the full SHA
    0228676 View commit details
    Browse the repository at this point in the history

  3. [FLINK-4460] Make CoProcessFunction abstract, add default onTime() me… 

    …thod

This is in preparation of allowing CoProcessFunction on a non-keyed
connected stream.  we will use it to allow side outputs from the
ProcessFunction Context.
    @aljoscha
    aljoscha committed Mar 6, 2017
    Configuration menu
    Copy the full SHA
    e12f320 View commit details
    Browse the repository at this point in the history

  4. [FLINK-4660] Allow CoProcessFunction on non-keyed ConnectedStreams 

    Introduce new CoProcessOperator for this. Rename the pre-existing
CoProcessOperator to KeyedCoProcessOperator.
    @aljoscha
    aljoscha committed Mar 6, 2017
    Configuration menu
    Copy the full SHA
    06740fb View commit details
    Browse the repository at this point in the history

  5. [FLINK-4460] Update doc: ProcessFunction now possible on DataStream

    @aljoscha
    aljoscha committed Mar 6, 2017
    Configuration menu
    Copy the full SHA
    746c1ef View commit details
    Browse the repository at this point in the history