Commits

Breadcrumbs

History for

onaec8b5a

User selector

All users

All time

Commit History

Commits on May 31, 2016

• [FLINK-2673] [core] Add a comparator for Scala Option type

  Show description for c60326f
  chiwanpark

  committed
  c60326f

Commits on May 4, 2016

• [FLINK-1827] [tests] Move test classes in test folders and fix scope of test dependencies.

  Show description for 70978f5
  

  stefanobortoli

  authored and

  fhueske

  committed
  70978f5

Commits on Apr 27, 2016

• [hotfix] minor: make type explicit to allow Scala test to compile in Eclipse

  mjsax

  committed
  8ad264d

Commits on Apr 26, 2016

• [hotfix] OptionSerializer.duplicate to respect stateful element serializer

  tillrohrmann

  committed
  1ccc798

Commits on Apr 15, 2016

• [FLINK-3657] [dataSet] Change access of DataSetUtils.countElements() to 'public'

  Show description for 5f993c6
  

  smarthi

  authored and

  fhueske

  committed
  5f993c6

Commits on Apr 4, 2016

• [FLINK-1159] [Scala API] Add API extension to support case-style anonymous functions

  Show description for 5cb84f1
  

  stefanobaghino

  authored and

  StephanEwen

  committed
  5cb84f1

Commits on Mar 23, 2016

• [FLINK-2997] [dataSet] Add support for range partitioning with custom data distribution.

  Show description for b8299bf
  

  gallenvara

  authored and

  fhueske

  committed
  b8299bf

Commits on Mar 11, 2016

• [build] Consolidate scala checkstyle usage and update version to 0.8.0

  Show description for 5aca6f4
  mbalassi

  committed
  5aca6f4

Commits on Mar 4, 2016

• [FLINK-3550] [examples] Rework WindowJoin to properly demonstrate continuous window joins (Java + Scala)

  StephanEwen

  committed
  271071a

Commits on Feb 29, 2016

• Bump version to 1.1-SNAPSHOT

  rmetzger

  committed
  512c84f

Commits on Feb 17, 2016

• [FLINK-3430] Remove "no POJO" warning in TypeAnalyzer

  Show description for cee135a
  

  aljoscha

  authored and

  StephanEwen

  committed
  cee135a

Commits on Feb 15, 2016

• [FLINK-3187] [restart] Introduce RestartStrategy to ExecutionGraph

  Show description for 5eae47f
  tillrohrmann

  committed
  5eae47f

Commits on Feb 14, 2016

• [FLINK-3367] Add PublicEvolving and Internal annotations to flink-java and flink-scala

  fhueske

  committed
  e5f33b6

Commits on Feb 10, 2016

• [FLINK-3234] [dataSet] Add KeySelector support to sortPartition operation.

  Show description for 0a63797
  

  chiwanpark

  authored and

  fhueske

  committed
  0a63797

• [FLINK-3366] Rename @experimental annotation to @PublicEvolving

  Show description for 572855d
  fhueske

  committed
  572855d

Commits on Feb 5, 2016

• [FLINK-3093] Introduce annotations for interface stability in remaining modules

  Show description for b54499b
  rmetzger

  committed
  b54499b

Commits on Feb 2, 2016

• [FLINK-3303] [core] Move all type utilities to flink-core

  StephanEwen

  committed
  21a7158

Commits on Jan 28, 2016

• [FLINK-3140] [table] NULL value data layout in Row Serializer/Comparator

  Show description for 440137c
  twalthr

  committed
  440137c

Commits on Jan 27, 2016

• [FLINK-2933][maven] add suffix to Scala dependent modules

  Show description for 2c4e4d1
  mxm

  committed
  2c4e4d1

Commits on Jan 26, 2016

• [FLINK-3198][dataSet] Renames and documents better the use of the getDataSet() in Grouping.

  Show description for 902d420
  

  kl0u

  authored and

  fhueske

  committed
  902d420

• [FLINK-1045][dataSet] Remove Combinable annotation.

  Show description for 5914e9a
  fhueske

  committed
  5914e9a

• [FLINK-1666][FLINK-1903][FLINK-3233] Refactor expression keys.

  Show description for af029e7
  fhueske

  committed
  af029e7

• [cleanup] Remove spark repl detection code from closure cleaner

  Show description for 9840136
  

  sksamuel

  authored and

  tillrohrmann

  committed
  9840136

Commits on Jan 25, 2016

• [hotfix] [docs] Tidy up documentation. Fix some non-idiomatic usage of return in scala code.

  Show description for 2ad1d5e
  

  sksamuel

  authored and

  fhueske

  committed
  2ad1d5e

Commits on Jan 15, 2016

• [FLINK-2716] [gelly] [apis] New checksum method on DataSet and Graph

  Show description for a8be52a
  

  greghogan

  authored and

  StephanEwen

  committed
  a8be52a

• [FLINK-3219] [java scala] Implement DataSet.count and DataSet.collect using a single operator

  

  greghogan

  authored and

  StephanEwen

  committed
  e9a5358

Commits on Dec 21, 2015

• [FLINK-7] Add range partitioning with automatic sampling of key distribution

  Show description for f5957ce
  

  chengxiang li

  authored and

  fhueske

  committed
  f5957ce

Commits on Dec 9, 2015

• [FLINK-3143] update Closure Cleaner's ASM references to ASM5

  Show description for e28b62e
  mxm

  committed
  e28b62e

• [FLINK-3136] Fix shaded imports in ClosureCleaner.scala

  aljoscha

  committed
  718a17b

Commits on Nov 30, 2015

• [FLINK-2972] [JavaAPI] Remove Chill dependency from flink-java.

  Show description for cd899f3
  fhueske

  committed
  cd899f3

Commits on Nov 25, 2015

• [FLINK-3059] Improve JavaDocs for DataSet.writeAsText()

  Show description for e03e60d
  

  jaoki

  authored and

  fhueske

  committed
  e03e60d

Commits on Nov 18, 2015

• [FLINK-2692] Untangle CsvInputFormat

  Show description for bd61f2d
  zentol

  committed
  bd61f2d

Commits on Nov 17, 2015

• [hotfix] [utils] Change the parameter 'numSample' in DataSetUtils.sampleWithSize() to 'numSamples', remove redundant Java 6 code

  Show description for e692a10
  

  smarthi

  authored and

  StephanEwen

  committed
  e692a10

Commits on Nov 3, 2015

• [FLINK-2918] [api-extending] Add methods to read Hadoop SequenceFiles.

  Show description for 30a832e
  

  smarthi

  authored and

  fhueske

  committed
  30a832e

• [FLINK-2930] Respect ExecutionConfig execution retry delay

  Show description for aa1c145
  

  uce

  authored and

  mxm

  committed
  aa1c145

Pagination

Previous

Next