Commits

Branch selector

 master

User selector

acrites

Datepicker

All time

Commit History

Commits on Aug 20, 2024

• Adds an ORDERED_LIST_STATE capability to the Java SDK. (apache#32067)

  acrites

  committedAug 20, 2024
  26cd5df

Commits on Aug 1, 2024

• Adds null checks when accessing OperationalLimits in config since they might not have been set yet. (apache#32053)

  acrites

  committedAug 1, 2024
  b795a61

Commits on Jul 30, 2024

• Validate commits in StreamingDataflowWorker (apache#31822)

  acrites

  committedJul 30, 2024
  89d5e2f

Commits on Jul 24, 2024

• Adds ordered list user state support to fnapi accessor cache. (apache#31923)

  acrites

  committedJul 24, 2024
  e2b8acb

Commits on Jul 2, 2024

• Updates Dataflow service API version. (apache#31751)

  acrites

  committedJul 2, 2024
  8a4a250

Commits on Feb 6, 2024

• When failing work items during commit, make sure to call completeWork… (apache#30215)

  acrites

  committedFeb 6, 2024
  b0f2eeb

Commits on Jan 30, 2024

• Volatile heartbeat (apache#30148)

  acrites

  committedJan 30, 2024
  5a9a27c

Commits on Jan 23, 2024

• Heartbeats (apache#29963)

  acrites

  committedJan 23, 2024
  5e7edc4

Commits on Jun 16, 2020

• [BEAM-10251] Adds transform id to TestStream step (apache#12003)

  acrites

  committedJun 16, 2020
  72d9744

Commits on Apr 8, 2020

• Uses iterable coder for windows and copies all of timestamp encoding specification.

  acrites

  committedApr 8, 2020
  3038900

Commits on Apr 7, 2020

• Updates documentation for WINDOWED_VALUE coder.

  acrites

  committedApr 7, 2020
  964c307

Commits on Apr 2, 2020

• [BEAM-9624] Adds Convert to Accumulators operator for use in combiner lifting for streaming pipelines (apache#11271)

  acrites

  committedApr 2, 2020
  9e01c5a

Commits on Mar 11, 2020

• Adds clearing of pane info state when windows get merged away.

  acrites

  committedMar 11, 2020
  77798e5

Commits on Feb 26, 2020

• Clean up of TestStreamTranscriptTests. Remvoes check for final field in PaneInfo since it is not reported properly by direct runner. Updates index for session panes and changes test with Count(2) e…

  acrites

  committedFeb 26, 2020
  385caa0

Commits on Feb 25, 2020

• Changes TestStreamTranscriptTest to only emit two elements so that its behavior is the same across all runners.

  acrites

  committedFeb 25, 2020
  85fca1b

Commits on Jan 15, 2020

• Changes watermark advance from 1001 to 1000 since Dataflow TestStream only advances watermark at 1s resolution.

  acrites

  committedJan 15, 2020
  17398f7

Commits on Dec 20, 2019

• Minor cleanup of tests using TestStream. (apache#10188)

  

  acrites

  authored and

  lukecwik

  committedDec 20, 2019
  b06fb9d

Commits on Dec 2, 2019

• Formatting cleanup using gradlew spotnessApply.

  acrites

  committedDec 2, 2019
  2021531

• Adds translation support for TestStream to Dataflow Java runner.

  acrites

  committedDec 2, 2019
  1763fd8

Commits on Nov 8, 2019

• Replaces unittest annotation with setting __test__ = False to prevent nosetest from trying to run the method.

  acrites

  committedNov 8, 2019
  f31a0df

• Fixes line-to-long lint error.

  acrites

  committedNov 8, 2019
  be08efd

• Marks run_TestStream as not a unittest, since it was trying to be 'run' when running other tests. Moves bad copy of internal/names.py to dataflow/internal/names.py, where it was supposed to go.

  acrites

  committedNov 8, 2019
  f6ce376

Commits on Nov 7, 2019

• Adds TestStream support for Dataflow runner.

  acrites

  committedNov 7, 2019
  3535958