Commits

Branch selector

 master

User selector

je-ik

Datepicker

All time

Commit History

Commits on May 6, 2020

• [BEAM-9888] Drop data based on input watermark in @RequiresTimeSortedInput

  je-ik

  committed
  96804c9

  Copy full SHA for 96804c9

• Merge pull request apache#11614: Disable two flaky tests (BEAM-8035, BEAM-9164)

  je-ik

  authored
  e5dfa5b

  Copy full SHA for e5dfa5b

Commits on May 5, 2020

• Disable two flaky tests (BEAM-8035, BEAM-9164)

  je-ik

  committed
  a481397

  Copy full SHA for a481397

Commits on Mar 26, 2020

• add @RequiresTimeSortedInput to CHANGES.md (apache#11228)

  je-ik

  authored
  c93928f

  Copy full SHA for c93928f

Commits on Feb 14, 2020

• Merge pull request apache#10816: [BEAM-9273] Explicitly disable @RequiresTimeSortedInput on unsupported runners

  je-ik

  authored
  a149b6b

  Copy full SHA for a149b6b

• Merge pull request apache#10795: [BEAM-9265] @RequiresTimeSortedInput respects allowedLateness

  je-ik

  authored
  9710fce

  Copy full SHA for 9710fce

• [BEAM-9265] @RequiresTimeSortedInput respects allowedLateness

  je-ik

  committed
  8654f20

  Copy full SHA for 8654f20

Commits on Feb 12, 2020

• [BEAM-9273] code review - to be squashed

  je-ik

  committed
  9e45f9d

  Copy full SHA for 9e45f9d

Commits on Feb 10, 2020

• [BEAM-9273] Explicitly disable @RequiresTimeSortedInput on unsupported runners

  je-ik

  committed
  85eeb10

  Copy full SHA for 85eeb10

Commits on Feb 6, 2020

• Merge pull request apache#8774 from je-ik/requires-time-sorted-input-draft: [BEAM-8550] Requires time sorted input

  je-ik

  authored
  041f7af

  Copy full SHA for 041f7af

Commits on Jan 30, 2020

• [BEAM-8550] @RequiresTimeSortedInput: working with legacy flink and spark

  je-ik

  committed
  377f1ac

  Copy full SHA for 377f1ac

Commits on Nov 6, 2019

• Merge pull request apache#9848 from je-ik/BEAM-8450: [BEAM-8450] Allow empty bundles in ParDoLifecycleTest

  je-ik

  authored
  49ef06e

  Copy full SHA for 49ef06e

• [BEAM-8450] Allow empty bundles in ParDoLifecycleTest

  je-ik

  committed
  b3cb103

  Copy full SHA for b3cb103

Commits on Oct 31, 2019

• [BEAM-8530] disable UsesStrictEventTimeOrdering for portable dataflow

  je-ik

  committed
  add58f8

  Copy full SHA for add58f8

Commits on Oct 25, 2019

• Merge pull request apache#9869 from je-ik/BEAM-7520-ignore-timer-ordering-for-flink-pvr-batch:[BEAM-7520] ignore UsesStrictTimerOrdering for Flink

  je-ik

  authored
  21f9fe1

  Copy full SHA for 21f9fe1

Commits on Oct 24, 2019

• [BEAM-7520] ignore UsesStrictTimerOrdering for both batch and streaming flink

  je-ik

  committed
  4725b54

  Copy full SHA for 4725b54

Commits on Oct 23, 2019

• Merge pull request apache#9190 from je-ik/BEAM-7520: [BEAM-7520] Fix timer firing order in DirectRunner

  je-ik

  authored
  2ef2736

  Copy full SHA for 2ef2736

• [BEAM-7520] add UsesStrictTimerOrdering category, ignore test for samza and portable flink

  je-ik

  committed
  0049037

  Copy full SHA for 0049037

• [BEAM-7520] Synchronize watermarks with bundle processing and add timer pushback

  je-ik

  committed
  c29d06b

  Copy full SHA for c29d06b

• [BEAM-7520] Add ValidatesRunner test for timer ordering

  je-ik

  committed
  a7c8766

  Copy full SHA for a7c8766

Commits on Oct 21, 2019

• Merge pull request apache#9841 from je-ik/BEAM-8439: [BEAM-8439] avoid creation of empty bundles

  je-ik

  authored
  7f8e4e4

  Copy full SHA for 7f8e4e4

Commits on Oct 4, 2019

• Merge pull request apache#9431 from je-ik/BEAM-8092: [BEAM-8092] change guava's Optional to java.util in DirectRunner

  je-ik

  authored
  ff8653d

  Copy full SHA for ff8653d

Commits on Aug 26, 2019

• [BEAM-8092] changed guava's Optional to java.util

  je-ik

  committed
  bfdf6b8

  Copy full SHA for bfdf6b8

• [BEAM-6127] upgrade junit dependency

  je-ik

  committed
  468ca09

  Copy full SHA for 468ca09

Commits on Jul 29, 2019

• [BEAM-7574] Optimize GC performance, finalize implementation

  je-ik

  committed
  1691935

  Copy full SHA for 1691935

• [BEAM-7574] Explode windows to key when needed

  je-ik

  committed
  7be5dff

  Copy full SHA for 7be5dff

• [BEAM-7574] unify Combine.perKey and Combine.globally

  je-ik

  committed
  945a606

  Copy full SHA for 945a606

• [BEAM-7574] use Merging and NonMerging accumulating strategies

  je-ik

  committed
  6c1d115

  Copy full SHA for 6c1d115

• [BEAM-7574] Use Map-based window combining

  je-ik

  committed
  3ee9da9

  Copy full SHA for 3ee9da9

Commits on Jul 19, 2019

• [BEAM-7785] synchronize watermark update with bundle processing

  je-ik

  committed
  84ef8aa

  Copy full SHA for 84ef8aa

Commits on Jun 19, 2019

• [BEAM-7543] deprecate old #combineBy(Sums.ofLongs(), TypeDescriptors.longs())

  je-ik

  committed
  175a8d2

  Copy full SHA for 175a8d2

Commits on Jun 17, 2019

• [BEAM-7543] ReduceByKey.combineBy must accept BinaryFunction<V, V, V>

  je-ik

  committed
  b0bf009

  Copy full SHA for b0bf009

Commits on Jun 11, 2019

• [BEAM-7529] Add Sums.ofFloats() and Sums.ofDoubles()

  je-ik

  committed
  c603563

  Copy full SHA for c603563

Commits on May 10, 2019

• [BEAM-7269] remove StateSpec from hashCode of SimpleStateTag

  je-ik

  committed
  7bc1f48

  Copy full SHA for 7bc1f48

Commits on Apr 17, 2019

• [BEAM-7091] fix NPE in DoFnOperator#dispose

  je-ik

  committed
  bbfe8a7

  Copy full SHA for bbfe8a7

Pagination

Previous

Next