Commits

Branch selector

 master

User selector

ggevay

Datepicker

All time

Commit History

Commits on Jul 13, 2016

• [FLINK-2246] [runtime] Add ChainedReduceCombineDriver

  Show description for 0db804b
  

  ggevay

  authored and

  greghogan

  committed
  0db804b

  Copy full SHA for 0db804b

• [FLINK-3477] [runtime] Add hash-based combine strategy for ReduceFunction

  Show description for 52e191a
  

  ggevay

  authored and

  greghogan

  committed
  52e191a

  Copy full SHA for 52e191a

Commits on May 4, 2016

• [FLINK-3519] [core] Add warning about subclasses to Tuple JavaDocs.

  Show description for f186446
  

  ggevay

  authored and

  fhueske

  committed
  f186446

  Copy full SHA for f186446

Commits on Jan 25, 2016

• [hotfix] [docs] Add missing licenses to programming guide redirects.

  Show description for 257f0b1
  

  ggevay

  authored and

  rmetzger

  committed
  257f0b1

  Copy full SHA for 257f0b1

Commits on Oct 19, 2015

• [FLINK-2809] [scala-api] Added UnitTypeInfo and UnitSerializer.

  Show description for 6491559
  

  ggevay

  authored and

  fhueske

  committed
  6491559

  Copy full SHA for 6491559

Commits on Oct 9, 2015

• [FLINK-2818] [docs] Correct javadocs of *ReduceDriver classes and some methods in the API.

  Show description for 48f614c
  

  ggevay

  authored and

  chiwanpark

  committed
  48f614c

  Copy full SHA for 48f614c

Commits on Oct 7, 2015

• [FLINK-2806] [scala-api] Add a TypeInformation[Nothing]

  Show description for 6e42f9f
  

  ggevay

  authored and

  chiwanpark

  committed
  6e42f9f

  Copy full SHA for 6e42f9f

Commits on Aug 17, 2015

• [FLINK-2527] [gelly] Ensure that VertexUpdateFunction.setNewVertexValue is called at most once per updateVertex

  Show description for 0ea0bc1
  

  ggevay

  authored and

  StephanEwen

  committed
  0ea0bc1

  Copy full SHA for 0ea0bc1

Commits on Aug 12, 2015

• [FLINK-2437] handle the case of a non-public default ctor in TypeExtractor.analyzePojo

  Show description for a41bc8c
  

  ggevay

  authored and

  mxm

  committed
  a41bc8c

  Copy full SHA for a41bc8c

Commits on Jul 21, 2015

• [FLINK-2198] [tests] Under Windows, skip tests that use setWritable

  Show description for 50344d7
  

  ggevay

  authored and

  StephanEwen

  committed
  50344d7

  Copy full SHA for 50344d7

• [FLINK-2376] Raise the time limit in testFindConnectableAddress under Windows

  Show description for bbbfd22
  

  ggevay

  authored and

  StephanEwen

  committed
  bbbfd22

  Copy full SHA for bbbfd22

• [FLINK-2377] [tests] Add reader.close() to readAllResultLines in TestBaseUtils

  Show description for 29454de
  

  ggevay

  authored and

  StephanEwen

  committed
  29454de

  Copy full SHA for 29454de

Commits on Jul 17, 2015

• [FLINK-2359] [java api] Add factory methods to the Java TupleX types

  Show description for 2d191ab
  

  ggevay

  authored and

  fhueske

  committed
  2d191ab

  Copy full SHA for 2d191ab

Commits on Jun 25, 2015

• [FLINK-2255] [streaming] Fixed a bug in TopSpeedWindowing examples

  Show description for af05b94
  

  ggevay

  authored and

  mbalassi

  committed
  af05b94

  Copy full SHA for af05b94

Commits on Jun 20, 2015

• [streaming] Refactor the accessing of the user specified field by sum, min, etc.

  Show description for 05bff22
  

  ggevay

  authored and

  mbalassi

  committed
  05bff22

  Copy full SHA for 05bff22

Commits on Jun 10, 2015

• Fixed a few trivial issues:

  Show description for c04a575
  

  ggevay

  authored and

  mbalassi

  committed
  c04a575

  Copy full SHA for c04a575

Commits on Jun 8, 2015

• [docs] Fix some typos and grammar in the Streaming Programming Guide.

  Show description for fcca75c
  

  ggevay

  authored and

  mbalassi

  committed
  fcca75c

  Copy full SHA for fcca75c

Commits on Jun 1, 2015

• [FLINK-2121] Fix the recursive summation in FileInputFormat.addFilesInDir

  Show description for 0334091
  

  ggevay

  authored and

  StephanEwen

  committed
  0334091

  Copy full SHA for 0334091

Commits on May 31, 2015

• [FLINK-2114] [streaming] Fix null check in PunctuationPolicy.toString()

  Show description for 5b79957
  

  ggevay

  authored and

  gyfora

  committed
  5b79957

  Copy full SHA for 5b79957

Commits on May 4, 2015

• [FLINK-1670] [streaming] Collect function for DataStream

  Show description for c9c9450
  

  ggevay

  authored and

  mbalassi

  committed
  c9c9450

  Copy full SHA for c9c9450

Commits on Apr 1, 2015

• [FLINK-1797] Add jumping pre-reducer for Count and Time windows

  Show description for c635802
  

  ggevay

  authored and

  gyfora

  committed
  c635802

  Copy full SHA for c635802

Commits on Mar 23, 2015

• [FLINK-1767] [streaming] Make StreamExecutionEnvironment return JobExecutionResult instead of void.

  Show description for e83d1ec
  

  ggevay

  authored and

  mbalassi

  committed
  e83d1ec

  Copy full SHA for e83d1ec

Commits on Mar 18, 2015

• [FLINK-1641] Make projection operator chainable.

  Show description for 1930678
  

  ggevay

  authored and

  gyfora

  committed
  1930678

  Copy full SHA for 1930678