Commits

Branch selector

 master

User selector

kl0u

Datepicker

All time

Commit History

Commits on Jul 6, 2017

• [FLINK-7044] [qs] Allow to specify namespace and descriptor in query.

  

  kl0u

  authored and

  aljoscha

  committed
  6c05abe

  Copy full SHA for 6c05abe

Commits on Jun 12, 2017

• [FLINK-6198] [cep] [doc] Update CEP documentation.

  kl0u

  committed
  cf05bcb

  Copy full SHA for cf05bcb

Commits on Jun 8, 2017

• [FLINK-6772] [cep] Fix ordering (by timestamp) of matched events.

  kl0u

  committed
  5d3506e

  Copy full SHA for 5d3506e

Commits on May 23, 2017

• [FLINK-6656] [cep] Change element PriorityQueue to MapState.

  Show description for 546e2ad
  kl0u

  committed
  546e2ad

  Copy full SHA for 546e2ad

Commits on May 19, 2017

• [FLINK-6634] [cep] NFASerializer serializes ComputationState counter.

  kl0u

  committed
  8e32136

  Copy full SHA for 8e32136

Commits on May 18, 2017

• [FLINK-6624] [cep] Fix SharedBuffer#hashCode().

  kl0u

  committed
  e283801

  Copy full SHA for e283801

Commits on May 17, 2017

• [FLINK-6604] [cep] Remove java serialization from the library.

  kl0u

  committed
  7a54d05

  Copy full SHA for 7a54d05

• [hotfix] [cep] Remove unused keySelector in operator.

  kl0u

  committed
  f7ebcb0

  Copy full SHA for f7ebcb0

• [FLINK-6578] [cep] Fix self-loop handling in SharedBuffer.

  kl0u

  committed
  8e4db42

  Copy full SHA for 8e4db42

• [FLINK-6255] [cep] Remove PatternStream.getSideOutput().

  kl0u

  committed
  05ad87f

  Copy full SHA for 05ad87f

• [FLINK-6536] [cep] Improve error message in SharedBuffer::put().

  kl0u

  committed
  02ea418

  Copy full SHA for 02ea418

• [FLINK-6371] [cep] NFA return matched patterns as Map<String, List<T>>.

  kl0u

  committed
  ae9c9d0

  Copy full SHA for ae9c9d0

Commits on May 5, 2017

• [FLINK-6463] [cep] Throw exception when NOT-NEXT is after OPTIONAL.

  kl0u

  committed
  28ab737

  Copy full SHA for 28ab737

Commits on May 4, 2017

• [FLINK-6445] [cep] Fix NPE in no-condition patterns.

  kl0u

  committed
  d6435e8

  Copy full SHA for d6435e8

Commits on Apr 26, 2017

• [FLINK-6356] [cep] Make times() eager by default and allow allowCombinations().

  Show description for 0d856b3
  kl0u

  committed
  0d856b3

  Copy full SHA for 0d856b3

• [FLINK-6248] [cep] Make the optional() available to all offered patterns.

  Show description for b3de48d
  kl0u

  committed
  b3de48d

  Copy full SHA for b3de48d

Commits on Apr 5, 2017

• [FLINK-6265] [cep] Fix consecutive() for times()

  kl0u

  committed
  ffca0e7

  Copy full SHA for ffca0e7

Commits on Apr 4, 2017

• [FLINK-6254] [cep] Same method name for late data outputs on PatternStream and WindowedStream

  kl0u

  committed
  1b6badd

  Copy full SHA for 1b6badd

Commits on Mar 31, 2017

• [FLINK-6205] [FLINK-6069] [cep] Correct watermark/late events in side output.

  Show description for 4889028
  kl0u

  committed
  4889028

  Copy full SHA for 4889028

Commits on Mar 28, 2017

• comments

  kl0u

  committed
  ad21a44

  Copy full SHA for ad21a44

Commits on Mar 27, 2017

• [FLINK-6197] [cep] Add support for iterative conditions.

  Show description for 7fbdc10
  kl0u

  committed
  7fbdc10

  Copy full SHA for 7fbdc10

Commits on Mar 17, 2017

• [FLINK-5846] [cep] Make the CEP operators backwards compatible with Flink 1.1

  kl0u

  committed
  521a53d

  Copy full SHA for 521a53d

• [FLINK-5932] initializeState() before legacy state restoring in operator

  kl0u

  committed
  d998ff9

  Copy full SHA for d998ff9

Commits on Mar 16, 2017

• [FLINK-6032] [cep] Clean-up operator state when not needed.

  Show description for e5057b7
  kl0u

  committed
  e5057b7

  Copy full SHA for e5057b7

Commits on Mar 15, 2017

• [hotfix] [doc] Fix error in ProcessFunction example.

  kl0u

  committed
  5b39002

  Copy full SHA for 5b39002

Commits on Mar 13, 2017

• [FLINK-6007] Allow key removal from within the watermark callback.

  Show description for 14c1941
  kl0u

  committed
  14c1941

  Copy full SHA for 14c1941

Commits on Mar 10, 2017

• [FLINK-5874] Restrict key types in the DataStream API.

  Show description for f15a7d2
  kl0u

  committed
  f15a7d2

  Copy full SHA for f15a7d2

Commits on Mar 3, 2017

• [FLINK-5937] [doc] Add documentation about the stream task lifecycle

  kl0u

  committed
  a2e6fb0

  Copy full SHA for a2e6fb0

Commits on Feb 28, 2017

• [FLINK-5420] [cep] Make the CEP operators rescalable

  Show description for daf0ccd
  kl0u

  committed
  daf0ccd

  Copy full SHA for daf0ccd

• [FLINK-5871] [cep] Enforce uniqueness of pattern names in CEP.

  kl0u

  committed
  a92d787

  Copy full SHA for a92d787

Commits on Feb 24, 2017

• [FLINK-5845] [cep] Unify keyed and non-keyed operators.

  Show description for 15ae922
  kl0u

  committed
  15ae922

  Copy full SHA for 15ae922

Commits on Feb 14, 2017

• [FLINK-5762] [runtime] Protect initializeState() and open() by the same lock

  Show description for a91b6ff
  

  kl0u

  authored and

  StephanEwen

  committed
  a91b6ff

  Copy full SHA for a91b6ff

Commits on Feb 2, 2017

• [FLINK-5502] [docs] Add migration guide in docs.

  

  kl0u

  authored and

  aljoscha

  committed
  35460d2

  Copy full SHA for 35460d2

Commits on Jan 27, 2017

• [FLINK-5529] [docs] Improve / extends windowing documentation

  

  kl0u

  authored and

  aljoscha

  committed
  c30c86b

  Copy full SHA for c30c86b

Commits on Jan 25, 2017

• [FLINK-5620] Fix unstable ContinuousFileProcessingTest

  

  kl0u

  authored and

  aljoscha

  committed
  171b110

  Copy full SHA for 171b110

Pagination

Previous

Next