Commits

Branch selector

 bcbebed

User selector

All users

Datepicker

All time

Commit History

Commits on Sep 20, 2014

• [FLINK-1080] [streaming] Streaming aggregation update and refactor

  

  gyfora

  authored and

  mbalassi

  committed
  bcbebed

  Copy full SHA for bcbebed

• [streaming] Added TypeInfo to DataStream

  mbalassi

  committed
  4d73f51

  Copy full SHA for 4d73f51

• [FLINK-1080] [streaming] Streaming aggregation added

  Show description for 0c8f1da
  

  eszesd

  authored and

  mbalassi

  committed
  0c8f1da

  Copy full SHA for 0c8f1da

• [streaming] Updated directed emit to not use output names when all outputs are selected

  

  ghermann

  authored and

  mbalassi

  committed
  fbfcc9e

  Copy full SHA for fbfcc9e

• [streaming] Reduce operator added to ConnectedDataStream + test

  

  gyfora

  authored and

  mbalassi

  committed
  47dca69

  Copy full SHA for 47dca69

• [streaming] Fixed SlidingWindowStateIterator

  

  ghermann

  authored and

  mbalassi

  committed
  d97efde

  Copy full SHA for d97efde

Commits on Sep 19, 2014

• Remove CONTRIBUTORS file to prefer dynamically generate it

  Show description for 1c58eb8
  hsaputra

  committed
  1c58eb8

  Copy full SHA for 1c58eb8

Commits on Sep 17, 2014

• Remove space after comma for TupleXX.toString()

  Show description for 7adbf53
  rmetzger

  committed
  7adbf53

  Copy full SHA for 7adbf53

• Remove naive verification of tuple size

  Show description for 2f6a955
  

  physikerwelt

  authored and

  rmetzger

  committed
  2f6a955

  Copy full SHA for 2f6a955

• [FLINK-1097] Fixed multiple slf4j bindings when using Hadoop2

  Show description for 244c539
  tillrohrmann

  committed
  244c539

  Copy full SHA for 244c539

Commits on Sep 16, 2014

• Update CONTRIBUTORS file

  Show description for 7123c78
  uce

  committed
  7123c78

  Copy full SHA for 7123c78

• Fix typo in CONTRIBUTORS

  Show description for de0f346
  uce

  committed
  de0f346

  Copy full SHA for de0f346

Commits on Sep 11, 2014

• [Tools] Minor fixes in release script

  Show description for df477e6
  

  uce

  committed
  df477e6

  Copy full SHA for df477e6

Commits on Sep 9, 2014

• Fix typo in package LICENSE

  

  uce

  committed
  f8b6b79

  Copy full SHA for f8b6b79

Commits on Sep 8, 2014

• [FLINK-925] Extended for distinct operator and added test cases

  Show description for 122c9b0
  fhueske

  committed
  122c9b0

  Copy full SHA for 122c9b0

• [FLINK-925] Support KeySelector function returning Tuple types

  

  tobwiens

  authored and

  fhueske

  committed
  fb3bdea

  Copy full SHA for fb3bdea

Commits on Sep 7, 2014

• [FLINK-1063] Revert race introducing commit

  Show description for c0c2abd
  

  uce

  committed
  c0c2abd

  Copy full SHA for c0c2abd

Commits on Sep 6, 2014

• [FLINK-629] Updated getFieldNotNull usage and added it to TupleSerializers

  Show description for 66c1263
  

  mbalassi

  authored and

  fhueske

  committed
  66c1263

  Copy full SHA for 66c1263

• [FLINK-629] getFieldNotNull added to Tuple and updated Aggregators and Comparators to use that where appropriate

  

  gyfora

  authored and

  fhueske

  committed
  761952c

  Copy full SHA for 761952c

• Updated documentation figure: FlinkOnYarn.svg

  Show description for 679bdc1
  

  skunert

  authored and

  fhueske

  committed
  679bdc1

  Copy full SHA for 679bdc1

• [FLINK-1017] Add documentation for execution parallelism

  Show description for 0535683
  

  Hung Chang

  authored and

  fhueske

  committed
  0535683

  Copy full SHA for 0535683

Commits on Sep 5, 2014

• [FLINK-1086] Replace JCL with SLF4J and Log4j with LOGBack

  Show description for 0818850
  

  tillrohrmann

  authored and

  uce

  committed
  0818850

  Copy full SHA for 0818850

Commits on Sep 4, 2014

• Fix DeltaIteration Bug with Immutable Types

  Show description for 3aa5511
  aljoscha

  committed
  3aa5511

  Copy full SHA for 3aa5511

• Disable merging of Iteration Aux Tasks

  Show description for 80af60b
  aljoscha

  committed
  80af60b

  Copy full SHA for 80af60b

Commits on Sep 2, 2014

• Default generic serializer is Avro. Minor improvements in KryoSerializer. Add mini benchmark for Avro/Kryo.

  StephanEwen

  committed
  dac281f

  Copy full SHA for dac281f

• [FLINK-610] Added KryoSerializer

  Show description for 22203e7
  

  tillrohrmann

  authored and

  StephanEwen

  committed
  22203e7

  Copy full SHA for 22203e7

• [FLINK-1020] Introduce minBy and maxBy

  Show description for d60a316
  

  tobwiens

  authored and

  StephanEwen

  committed
  d60a316

  Copy full SHA for d60a316

Commits on Sep 1, 2014

• Some simplifications to the PiEstimation example

  StephanEwen

  committed
  4d4151d

  Copy full SHA for 4d4151d

• Add Pi approximation Java example

  Show description for 01ff302
  

  mariemayadi

  authored and

  StephanEwen

  committed
  01ff302

  Copy full SHA for 01ff302

• [FLINK-1084] Fix broken links in "How to add an operator"

  StephanEwen

  committed
  c9dd603

  Copy full SHA for c9dd603

• [FLINK-1078] PrintingOutputFormat uses same partition indexing as FileOutputFormat.

  StephanEwen

  committed
  0a6e53d

  Copy full SHA for 0a6e53d

• [FLINK-1079] Fix inconsistent parameter naming

  StephanEwen

  committed
  fbed013

  Copy full SHA for fbed013

• [FLINK-1075] Removed the AsynchronousPartialSorter.

  Show description for cbbcf78
  

  tillrohrmann

  authored and

  StephanEwen

  committed
  cbbcf78

  Copy full SHA for cbbcf78

• [FLINK-1070] Change return type of "getBroadcastVariable()" to List.

  Show description for 0b10051
  StephanEwen

  committed
  0b10051

  Copy full SHA for 0b10051

Commits on Aug 29, 2014

• [streaming] Add redis dependency notices to binary distribution NOTICE file and DEPENDENCIES file

  Show description for eba8df0
  StephanEwen

  committed
  eba8df0

  Copy full SHA for eba8df0

Pagination

Previous

Next