Commits

Branch selector

 master

User selector

szape

Datepicker

All time

Commit History

Commits on Aug 7, 2015

• [FLINK-2243] [storm-compat] Demonstrating finite Storm spout functionality on exclamation example

  Show description for dba2946
  

  szape

  authored and

  mbalassi

  committed
  dba2946

• [FLINK-2243] [storm-compat] Added finite spout functionality to Storm compatibility layer

  

  szape

  authored and

  mbalassi

  committed
  6d9eeb5

Commits on Jun 14, 2015

• [storm-compat] Simple examples added

  

  szape

  authored and

  mbalassi

  committed
  09e5be4

• [storm-compat] Storm compatibility code cleanup

  

  szape

  authored and

  mbalassi

  committed
  e497a83

Commits on Jun 3, 2015

• [streaming] Fixing some javadoc typos

  

  szape

  authored and

  mbalassi

  committed
  bc7f6d9

Commits on May 29, 2015

• [FLINK-1687] [streaming] [api-extending] Synchronizing streaming source API to batch source API

  Show description for 1c3b67e
  

  szape

  authored and

  mbalassi

  committed
  1c3b67e

Commits on May 13, 2015

• [FLINK-1595] [streaming] Added complex streaming integration test

  

  szape

  authored and

  mbalassi

  committed
  4786b56

Commits on Apr 29, 2015

• [FLINK-1911] [streaming] Projection without specifying types

  

  szape

  authored and

  mbalassi

  committed
  8c46155

Commits on Apr 7, 2015

• [FLINK-1560] [streaming] Added ITCases to streaming examples

  

  szape

  authored and

  mbalassi

  committed
  464e782

• [FLINK-1560] [streaming] Streaming examples rework

  

  szape

  authored and

  mbalassi

  committed
  ed7d165

Commits on Apr 1, 2015

• [FLINK-1662] [streaming] Triggering on fake element bugfix

  

  szape

  authored and

  gyfora

  committed
  1a3ae03

Commits on Mar 25, 2015

• [FLINK-1544] [streaming] POJO types added to AggregationFunctionTest

  Show description for 597d8b8
  

  szape

  authored and

  mbalassi

  committed
  597d8b8

Commits on Mar 20, 2015

• [FLINK-1757] [streaming] Fixed type cast bug in SumFunction

  szape

  committed
  22e0065

Commits on Jan 21, 2015

• [FLINK-1403] [streaming] Distributed filesystem support for streaming filesinks

  Show description for dc0d81b
  

  szape

  authored and

  mbalassi

  committed
  dc0d81b

Commits on Dec 15, 2014

• [streaming] Basic support reading from local and distributed file systems in readTextFile methods

  Show description for 510a811
  

  szape

  authored and

  mbalassi

  committed
  510a811

Commits on Oct 17, 2014

• [streaming] Added CoBatchedDataStream and CoWindowDataStream with reduce functionality + CoBatchReduce bugfix

  Show description for b8e8bd7
  

  szape

  authored and

  mbalassi

  committed
  b8e8bd7

• [streaming] CoGroupedWindowReduceInvokable refactor

  Show description for e29833d
  

  szape

  authored and

  mbalassi

  committed
  e29833d

Commits on Oct 7, 2014

• [streaming] Several bugfixes and doc updates

  

  szape

  authored and

  mbalassi

  committed
  49812f3

Commits on Oct 1, 2014

• [streaming] Improved tests for CoReduceInvokables

  

  szape

  authored and

  mbalassi

  committed
  9e722df

• [streaming] Added CoBatchReduceInvokable, CoWindowReduceInvokable, CoGroupedBatchReduceInvokable, CoGroupedWindowReduceInvokable

  

  szape

  authored and

  mbalassi

  committed
  618effa

Commits on Sep 24, 2014

• [streaming] added batchReduceGroup, windowReduceGroup functionality to ConnectedDataStream and GroupedConnectedDataStream

  

  szape

  authored and

  mbalassi

  committed
  ad98337

Commits on Sep 20, 2014

• [streaming] Added CoBatchGroupReduceInvokable, CoWindowGroupReduceInvokable and grouped variants

  

  szape

  authored and

  mbalassi

  committed
  b6ffdba

Commits on Aug 29, 2014

• [streaming] GroupReduceInvokable update

  

  szape

  authored and

  StephanEwen

  committed
  f149197

• [streaming] CoFlatMap & CoGroupReduce functionality

  

  szape

  authored and

  StephanEwen

  committed
  7596012

Commits on Aug 18, 2014

• [streaming] added writeAsText and Csv

  

  szape

  authored and

  StephanEwen

  committed
  c79b48b