Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on Aug 26, 2015

• [FLINK-2555] Properly pass security credentials in the Hadoop Input/Output format wrappers

  Show description for b264b01
  

  rmetzger

  authored and

  uce

  committed
  b264b01

  Copy full SHA for b264b01

• [FLINK-2394] HadoopOutputFormats use correct OutputCommitters.

  Show description for 6e1de98
  

  fhueske

  authored and

  uce

  committed
  6e1de98

  Copy full SHA for 6e1de98

Commits on Aug 21, 2015

• [FLINK-1901] [core] Create sample operator for Dataset.

  Show description for c9cfb17
  

  chengxiang li

  authored and

  tillrohrmann

  committed
  c9cfb17

  Copy full SHA for c9cfb17

Commits on Aug 18, 2015

• [FLINK-1962] Add Gelly Scala API

  Show description for 240e889
  

  Pieter-Jan Van Aeken

  authored and

  StephanEwen

  committed
  240e889

  Copy full SHA for 240e889

Commits on Aug 11, 2015

• [FLINK-2277] [scala api] Add flag to set delta iteration solution set to unmanaged

  Show description for f50ae26
  

  Pieter-Jan Van Aeken

  authored and

  StephanEwen

  committed
  f50ae26

  Copy full SHA for f50ae26

Commits on Jul 30, 2015

• [FLINK-2238][api] Generalized fromCollection(Seq) to fromCollection(Iterable)

  Show description for 3c236b2
  

  sachingoel0101

  authored and

  fhueske

  committed
  3c236b2

  Copy full SHA for 3c236b2

Commits on Jul 29, 2015

• [FLINK-2231] Create Serializer and Comparator for Scala Enumerations.

  Show description for a34c941
  

  aalexandrov

  authored and

  aljoscha

  committed
  a34c941

  Copy full SHA for a34c941

• [docs] Updated method documentation. Changed .isEqualTo(..) to .equalsTo(..)

  Show description for 3e49daf
  

  peterschrott

  authored and

  StephanEwen

  committed
  3e49daf

  Copy full SHA for 3e49daf

Commits on Jul 23, 2015

• [FLINK-2385] [scala api] Add parenthesis to 'distinct' transformation.

  Show description for 5d475f8
  StephanEwen

  committed
  5d475f8

  Copy full SHA for 5d475f8

Commits on Jul 16, 2015

• [FLINK-1963] Improve distinct() transformation

  Show description for 08ca9ff
  

  pietro pinoli

  authored and

  fhueske

  committed
  08ca9ff

  Copy full SHA for 08ca9ff

Commits on Jul 11, 2015

• [FLINK-2138] [streaming] Added custom partitioning to scala DataStream

  

  Gábor Hermann

  authored and

  gyfora

  committed
  bc8d7c4

  Copy full SHA for bc8d7c4

Commits on Jul 2, 2015

• [FLINK-2150] Added zipWithUniqueIds

  Show description for 7c2bbb6
  

  andralungu

  authored and

  andra

  committed
  7c2bbb6

  Copy full SHA for 7c2bbb6

Commits on Jun 28, 2015

• [FLINK-2152] [java api] [scala api] Add zipWithIndex

  Show description for df42160
  

  andralungu

  authored and

  chiwanpark

  committed
  df42160

  Copy full SHA for df42160

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 18, 2015

• Version bumped to 0.10-SNAPSHOT

  Show description for 9ee4fa5
  mbalassi

  committed
  9ee4fa5

  Copy full SHA for 9ee4fa5

Commits on Jun 10, 2015

• [FLINK-2196] [javaAPI] Moved misplaced SortPartitionOperator class

  Show description for a8e0850
  fhueske

  committed
  a8e0850

  Copy full SHA for a8e0850

Commits on Jun 3, 2015

• [FLINK-2070] [core] Deprecate "print(prefix)" methods and add "printOnTaskManager(prefix)" method.

  StephanEwen

  committed
  11643c0

  Copy full SHA for 11643c0

Commits on May 29, 2015

• [streaming] [scala] [api-breaking] StreamExecutionEnvironment API update

  Show description for 145b2ba
  mbalassi

  committed
  145b2ba

  Copy full SHA for 145b2ba

Commits on May 22, 2015

• [FLINK-2050] [ml] Ports existing ML algorithms to new pipeline mechanism

  Show description for 1e57475
  tillrohrmann

  committed
  1e57475

  Copy full SHA for 1e57475

• [FLINK-2050] [ml] Introduces new pipelining mechanism using implicit classes to wrap the algorithm logic

  Show description for fde0341
  tillrohrmann

  committed
  fde0341

  Copy full SHA for fde0341

Commits on May 21, 2015

• [FLINK-2023] [scala] Improve type analysis

  Show description for f8a381f
  

  aljoscha

  authored and

  StephanEwen

  committed
  f8a381f

  Copy full SHA for f8a381f

• [FLINK-1418] [apis] Minor cleanups for eager on-client print() statement.

  StephanEwen

  committed
  6220f34

  Copy full SHA for 6220f34

• [FLINK-1418] [apis] Fix eager print() and adjust all tests and examples to not fail due to "eager" print method

  Show description for 78d954b
  

  nikste

  authored and

  StephanEwen

  committed
  78d954b

  Copy full SHA for 78d954b

• [FLINK-1418] [apis] Change print() to print on the client and to eagerly execute the program.

  Show description for e9c1562
  

  aljoscha

  authored and

  StephanEwen

  committed
  e9c1562

  Copy full SHA for e9c1562

Commits on May 15, 2015

• [hotfix] Add missing import

  aljoscha

  committed
  8f28f41

  Copy full SHA for 8f28f41

• [FLINK-1711] Converted all usages of commons validate to guava checks(for Java classes), scala predef require(for scala classes)

  Show description for f950def
  

  lrajaram

  authored and

  aljoscha

  committed
  f950def

  Copy full SHA for f950def

• [FLINK-1525] Implement a tool for parsing input parameters and provide facilities to use them in the system.

  Show description for b335f58
  rmetzger

  committed
  b335f58

  Copy full SHA for b335f58

Commits on May 8, 2015

• [scala] Introduces trait type to TypeAnalyzer which avoids compiler warnings due to misclassification as a pojo type

  tillrohrmann

  committed
  f0b45c4

  Copy full SHA for f0b45c4

Commits on Apr 30, 2015

• [hotfix] Remove asm dependency from root pom

  aljoscha

  committed
  58de10a

  Copy full SHA for 58de10a

Commits on Apr 24, 2015

• [hotfix] Bump asm version to 5.0.3

  aljoscha

  committed
  2347363

  Copy full SHA for 2347363

Commits on Apr 23, 2015

• [FLINK-1799][scala] Fix handling of generic arrays

  aljoscha

  committed
  4672e95

  Copy full SHA for 4672e95

Commits on Apr 22, 2015

• [FLINK-1486] add additional print method for prefixing a user-defined string

  Show description for df7c61e
  mxm

  committed
  df7c61e

  Copy full SHA for df7c61e

Commits on Apr 21, 2015

• [FLINK-703] [scala api] Use complete element as join key

  Show description for 45e680c
  

  chiwanpark

  authored and

  fhueske

  committed
  45e680c

  Copy full SHA for 45e680c

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

Pagination

Previous

Next