Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on Apr 21, 2015

• [FLINK-377] Generic Interface

  supermegaciaccount

  committed
  af9248c

  Copy full SHA for af9248c

Commits on Apr 16, 2015

• [FLINK-1753] Extend KafkaITCase with large messages test + rework PersistentKafkaSource.

  Show description for 354922b
  rmetzger

  committed
  354922b

  Copy full SHA for 354922b

Commits on Apr 13, 2015

• [FLINK-1878] [APIs] Environments accept a flag that controls sysout logging during execution.

  StephanEwen

  committed
  e79813b

  Copy full SHA for e79813b

Commits on Apr 10, 2015

• [FLINK-1862] [apis] Add support for non-serializable types for collect() by switching from Java serialization to Flink serialization

  StephanEwen

  committed
  211d0bd

  Copy full SHA for 211d0bd

• [FLINK-1535] [core] Rework accumulators

  Show description for 6774054
  StephanEwen

  committed
  6774054

  Copy full SHA for 6774054

Commits on Apr 6, 2015

• [runtime] Remove old redundant classes

  Show description for 12c555f
  StephanEwen

  committed
  12c555f

  Copy full SHA for 12c555f

Commits on Apr 5, 2015

• [FLINK-1824] [streaming] Support added for missing types in DataStream api

  Show description for 1cf49e9
  

  gyfora

  authored and

  mbalassi

  committed
  1cf49e9

  Copy full SHA for 1cf49e9

Commits on Apr 3, 2015

• [FLINK-1664] Adds check if a selected sort key is sortable

  Show description for f36eb54
  fhueske

  committed
  f36eb54

  Copy full SHA for f36eb54

• [FLINK-1776] Add offsets to field indexes of semantic properties for operators with key selectors

  Show description for f39aec8
  fhueske

  committed
  f39aec8

  Copy full SHA for f39aec8

• [FLINK-1656] Filter ForwardedField properties for group-at-a-time operators in Optimizer.

  Show description for dda8565
  fhueske

  committed
  dda8565

  Copy full SHA for dda8565

Commits on Apr 2, 2015

• [FLINK-1589] Add option to pass configuration to LocalExecutor

  Show description for 7cf9586
  rmetzger

  committed
  7cf9586

  Copy full SHA for 7cf9586

Commits on Mar 29, 2015

• [FLINK-947] Add parser to Expression API for exposing it to Java

  aljoscha

  committed
  d7d9b63

  Copy full SHA for d7d9b63

Commits on Mar 25, 2015

• [FLINK-1512] [java api] Add CsvReader for reading into POJOs

  

  chiwanpark

  authored and

  fhueske

  committed
  7b1c19c

  Copy full SHA for 7b1c19c

• [Flink-1780] Rename FlatCombineFunction to GroupCombineFunction

  Show description for 033c69f
  

  smarthi

  authored and

  mxm

  committed
  033c69f

  Copy full SHA for 033c69f

Commits on Mar 23, 2015

• [FLINK-1679] use a consistent name for parallelism

  Show description for cf84bca
  mxm

  committed
  cf84bca

  Copy full SHA for cf84bca

• [FLINK-1679] deprecate API methods to set the parallelism

  mxm

  committed
  d994d2e

  Copy full SHA for d994d2e

Commits on Mar 21, 2015

• [FLINK-1761] [runtime] Fix sequence number mismatch on empty buffer drop.

  StephanEwen

  committed
  925481f

  Copy full SHA for 925481f

Commits on Mar 20, 2015

• [FLINK-1760] [maven] Added Scala version profiles to support building with Scala 2.11

  

  aalexandrov

  authored and

  StephanEwen

  committed
  2cd5e93

  Copy full SHA for 2cd5e93

• [FLINK-441] [optimizer] Rename "o.a.flink.compiler" to "o.a.flink.optimizer"

  StephanEwen

  committed
  258cede

  Copy full SHA for 258cede

Commits on Mar 19, 2015

• [FLINK-1752][streaming] Add KafkaITCase and various bugfixes

  Show description for c0917f2
  rmetzger

  committed
  c0917f2

  Copy full SHA for c0917f2

Commits on Mar 18, 2015

• [FLINK-1622][java-api][scala-api] add a GroupCombine operator

  Show description for e93e0cb
  mxm

  committed
  e93e0cb

  Copy full SHA for e93e0cb

• [FLINK-1350] [runtime] Add blocking result partition variant

  Show description for 9d7acf3
  uce

  committed
  9d7acf3

  Copy full SHA for 9d7acf3

Commits on Mar 15, 2015

• [FLINK-1450] Several minor stream fold fixes

  Show description for aaa231b
  gyfora

  committed
  aaa231b

  Copy full SHA for aaa231b

Commits on Mar 14, 2015

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

  

  akshaydixi

  authored and

  gyfora

  committed
  6c99cb6

  Copy full SHA for 6c99cb6

Commits on Mar 11, 2015

• [FLINK-1605] Bundle all hadoop dependencies and shade guava away

  Show description for 84e76f4
  rmetzger

  committed
  84e76f4

  Copy full SHA for 84e76f4

Commits on Mar 3, 2015

• [FLINK-1555] Add serializer hierarchy debug util

  Show description for 226e905
  rmetzger

  committed
  226e905

  Copy full SHA for 226e905

• [hotfix] Fix issue with nested Avro types

  rmetzger

  committed
  dec5e33

  Copy full SHA for dec5e33

Commits on Feb 27, 2015

• [java-api][scala-api] convenience methods count/collect to transfer a DataSet to the client

  Show description for 3dc2fe1
  mxm

  committed
  3dc2fe1

  Copy full SHA for 3dc2fe1

Commits on Feb 24, 2015

• fixed package statement

  Show description for bfbbbf9
  

  mjsax

  authored and

  hsaputra

  committed
  bfbbbf9

  Copy full SHA for bfbbbf9

Commits on Feb 23, 2015

• [FLINK-947] Add a declarative Expression API

  aljoscha

  committed
  e868d59

  Copy full SHA for e868d59

• Add methods to CompositeType for querying field types and names

  aljoscha

  committed
  98da559

  Copy full SHA for 98da559

• Change translateToDataflow to return Operator

  Show description for 86ca692
  aljoscha

  committed
  86ca692

  Copy full SHA for 86ca692

Commits on Feb 20, 2015

• [FLINK-1461][api-extending] Add SortPartition operator to Java and Scala APIs.

  Show description for 3d84970
  fhueske

  committed
  3d84970

  Copy full SHA for 3d84970

• [FLINK-1444][api-extending] Add support for attaching data properties to data sources

  Show description for f0a28bf
  fhueske

  committed
  f0a28bf

  Copy full SHA for f0a28bf

Commits on Feb 18, 2015

• [FLINK-1567] Add option to switch between Avro and Kryo serialization

  Show description for e6754a6
  rmetzger

  committed
  e6754a6

  Copy full SHA for e6754a6

Pagination

Previous

Next