Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on Feb 17, 2016

• [FLINK-3419] [streaming] Drop 'partitionByHash' function, subsumed by 'keyBy()'

  StephanEwen

  committedFeb 17, 2016
  06a42bf

• [FLINK-3421] [streaming scala] Remove unneeded ClassTag context bounds

  StephanEwen

  committedFeb 17, 2016
  a8afec3

• [FLINK-3413] [streaming] Make implicit conversions from Java DataStream to Scala DataStream explicit

  StephanEwen

  committedFeb 17, 2016
  6dda531

• [FLINK-3401] [streaming] [api breaking] AscendingTimestampExtractor only logs violations of ascending timestamp order.

  StephanEwen

  committedFeb 17, 2016
  e08d7a6

• [FLINK-3379] [FLINK-3415] [streaming] Refactor TimestampExtractor into two separate classes

  StephanEwen

  committedFeb 17, 2016
  74c2b80

• [FLINK-3243] Fix Interplay of TimeCharacteristic and Time Windows

  aljoscha

  committedFeb 17, 2016
  ce8f966

• [FLINK-3420] [api-breaking] Remove utility functions 'readTextFileWithValue' and 'readFileOfPrimitives' from StreamExecutionEnvironment

  StephanEwen

  committedFeb 17, 2016
  ebab470

Commits on Feb 16, 2016

• [FLINK-3413] [streaming] Remove implicit Seq -> DataStream conversion

  StephanEwen

  committedFeb 16, 2016
  8cce136

• [FLINK-3296] Remove 'flushing' behavior of the OutputFormat support of the DataStream API

  rmetzger

  committedFeb 16, 2016
  2714aaf

Commits on Feb 15, 2016

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

  tillrohrmann

  committedFeb 15, 2016
  5eae47f

Commits on Feb 14, 2016

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

  fhueske

  committedFeb 14, 2016
  c9db63b

Commits on Feb 12, 2016

• [FLINK-2991] Add Folding State and use in WindowOperator

  

  aljoscha

  authored and

  StephanEwen

  committedFeb 12, 2016
  94cba89

Commits on Feb 10, 2016

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

  fhueske

  committedFeb 10, 2016
  572855d

Commits on Feb 8, 2016

• [hotfix] Remove @experimental from DataStream.forward()

  aljoscha

  committedFeb 8, 2016
  412dcbd

• [FLINK-3336] Add Rescale Data Shipping for DataStream

  aljoscha

  committedFeb 8, 2016
  9f6a8b6

Commits on Feb 5, 2016

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

  rmetzger

  committedFeb 5, 2016
  b54499b

Commits on Feb 4, 2016

• [streaming] [scala] Revert removing getJavaStream() from DataStream

  

  mbalassi

  authored and

  StephanEwen

  committedFeb 4, 2016
  116337f

Commits on Feb 3, 2016

• [FLINK-3312] Add simple constructors for State Descriptors

  StephanEwen

  committedFeb 3, 2016
  180cd3f

• [FLINK-3312] Add accessors for various state types to RuntimeContext

  StephanEwen

  committedFeb 3, 2016
  e4d05f7

• [FLINK-3201] Add operator state to make change backwards compatible

  StephanEwen

  committedFeb 3, 2016
  6f75596

• [FLINK-3200] Use Partitioned State in WindowOperator

  

  aljoscha

  authored and

  StephanEwen

  committedFeb 3, 2016
  67ca4a4

• [FLINK-3201] Enhance Partitioned State Interface with State Types

  

  aljoscha

  authored and

  StephanEwen

  committedFeb 3, 2016
  caf4672

Commits on Jan 30, 2016

• [streaming] [scala] Exposed environment from DataStream

  mbalassi

  committedJan 30, 2016
  086acf6

Commits on Jan 27, 2016

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

  mxm

  committedJan 27, 2016
  2c4e4d1

Commits on Jan 25, 2016

• [FLINK-3209] Remove Unused ProcessingTime, EventTime and AbstractTime

  

  aljoscha

  authored and

  fhueske

  committedJan 25, 2016
  cf75f42

Commits on Jan 11, 2016

• [FLINK-2976] [streaming-java, streaming-scala] Set JobVertexID based on stream node hash

  uce

  committedJan 11, 2016
  ad7b21b

Commits on Dec 21, 2015

• [FLINK-2622] [streaming] Align Scala streaming writeAsCsv API call with Java API

  

  tillrohrmann

  authored and

  fhueske

  committedDec 21, 2015
  c08bcf1

Commits on Dec 9, 2015

• [FLINK-3073] Replace Streaming Mode by Memory Allocation Mode

  aljoscha

  committedDec 9, 2015
  4f12356

Commits on Dec 2, 2015

• [FLINK-3080] Relax restrictions of DataStream.union()

  aljoscha

  committedDec 2, 2015
  04b3802

Commits on Nov 27, 2015

• [FLINK-3054] Remove R (return) type variable from SerializationSchema

  rmetzger

  committedNov 27, 2015
  09ea3dd

Commits on Nov 26, 2015

• [FLINK-3051] [streaming] Add mechanisms to control the maximum number of concurrent checkpoints

  StephanEwen

  committedNov 26, 2015
  55fd5f3

Commits on Nov 24, 2015

• [streaming] [ml] Code cleanup: unused imports, fix javadocs

  

  smarthi

  authored and

  tillrohrmann

  committedNov 24, 2015
  66b5def

Commits on Nov 3, 2015

• [FLINK-2930] Respect ExecutionConfig execution retry delay

  

  uce

  authored and

  mxm

  committedNov 3, 2015
  aa1c145

Commits on Oct 23, 2015

• [release] update version to 1.0-SNAPSHOT

  mxm

  committedOct 23, 2015
  0c03e9a

Commits on Oct 21, 2015

• [FLINK-2877] Move Streaming API out of Staging package

  

  Rufus Refactor

  authored and

  aljoscha

  committedOct 21, 2015
  06f6ac5

Loading