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-1450] Added fold operator for the Streaming API #481

Closed
wants to merge 13 commits into from
Closed

[FLINK-1450] Added fold operator for the Streaming API #481

wants to merge 13 commits into from

Commits on Mar 12, 2015

  1. [FLINK-1450] Added fold operator for the Streaming API

    @akshaydixi
    akshaydixi committed Mar 12, 2015
    Copy the full SHA
    9848f23 View commit details
    Browse the repository at this point in the history

  2. Remove unused imports from RichMapPartitionFunction. Wrap way too lon… 

    …g statements in NetworkBufferPool.
    @hsaputra
    hsaputra committed Mar 12, 2015
    Copy the full SHA
    378b487 View commit details
    Browse the repository at this point in the history

Commits on Mar 13, 2015

  1. [tests] Increase timeout for ProcessFailureBatchRecoveryITCase to com… 

    …pensate for slow Travis runs
    @StephanEwen
    StephanEwen committed Mar 13, 2015
    Copy the full SHA
    81ebe98 View commit details
    Browse the repository at this point in the history

  2. [FLINK-1683] [jobmanager] Fix scheduling preference choice for non-un… 

    …ary execution tasks.

This closes apache#476
    @fhueske
    fhueske committed Mar 13, 2015
    Copy the full SHA
    07a9a56 View commit details
    Browse the repository at this point in the history

  3. [maven] Remove flink-streaming-examples from flink-dist

    @rmetzger
    rmetzger committed Mar 13, 2015
    Copy the full SHA
    1c269e2 View commit details
    Browse the repository at this point in the history

  4. [FLINK-1450] Added fold operator for the Streaming API

    @akshaydixi
    akshaydixi committed Mar 13, 2015
    Copy the full SHA
    ddfab84 View commit details
    Browse the repository at this point in the history

  5. [FLINK-1450] Added GroupFoldFunction and GroupedFoldInvokable with a … 

    …test. Integrated them into DataStream
    @akshaydixi
    akshaydixi committed Mar 13, 2015
    Copy the full SHA
    2ccf21e View commit details
    Browse the repository at this point in the history

  6. [FLINK-1450] Integrated fold into WindowedDataStream and added a Wind… 

    …owFolder test
    @akshaydixi
    akshaydixi committed Mar 13, 2015
    Copy the full SHA
    b8270b8 View commit details
    Browse the repository at this point in the history

  7. Merge branch 'FLINK-1450' of github.com:akshaydixi/flink into FLINK-1450 

    Conflicts:
	flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/invokable/operator/StreamFoldInvokable.java
    @akshaydixi
    akshaydixi committed Mar 13, 2015
    Copy the full SHA
    b9bfebd View commit details
    Browse the repository at this point in the history

Commits on Mar 14, 2015

  1. [FLINK-1450] Fixed StreamFoldInvokable and GroupedStreamFoldInvokable… 

    … by implementing accumulator copying to prevent mutations and removed GroupFoldFunction.
    @akshaydixi
    akshaydixi committed Mar 14, 2015
    Copy the full SHA
    c381e3d View commit details
    Browse the repository at this point in the history

  2. [FLINK-1450] Fixed foldWindow on WindowedDataStreams so it doesn't fa… 

    …il on extracting type information from scala types
    @akshaydixi
    akshaydixi committed Mar 14, 2015
    Copy the full SHA
    8602ab8 View commit details
    Browse the repository at this point in the history

  3. [FLINK-1450] Fix foldWindow so now user doesn't have to supply output… 

    … TypeInformation while using it from Java API
    @akshaydixi
    akshaydixi committed Mar 14, 2015
    Copy the full SHA
    563f643 View commit details
    Browse the repository at this point in the history

Commits on Mar 15, 2015

  1. [FLINK-1450] Fixed typo in WindowedDataStream.java and style-nits in … 

    …DataStream.scala and WindowedDataStream.scala
    @akshaydixi
    akshaydixi committed Mar 15, 2015
    Copy the full SHA
    9c04cb1 View commit details
    Browse the repository at this point in the history