Commits

Branch selector

 master

User selector

charlesccychen

Datepicker

All time

Commit History

Commits on Mar 28, 2018

• Revert apache#4781 which broke Python postsubmits

  charlesccychen

  committed
  1f681bb

  Copy full SHA for 1f681bb

Commits on Mar 20, 2018

• Replace side inputs when applying PTransformOverrides

  charlesccychen

  committed
  a853ff7

  Copy full SHA for a853ff7

Commits on Mar 19, 2018

• Add support for PaneInfo in WindowedValues

  Show description for 95956ae
  charlesccychen

  committed
  95956ae

  Copy full SHA for 95956ae

Commits on Mar 10, 2018

• Revert apache#4666 "Use beam.io.WriteToBigQuery()"

  Show description for 75e286a
  charlesccychen

  committed
  75e286a

  Copy full SHA for 75e286a

Commits on Feb 28, 2018

• Fix issue from incomplete removal of has_cache

  charlesccychen

  committed
  829d1d4

  Copy full SHA for 829d1d4

Commits on Feb 16, 2018

• Use the switching DirectRunner implementation

  charlesccychen

  committed
  2c31ba3

  Copy full SHA for 2c31ba3

Commits on Feb 14, 2018

• Use TestClock when TestStream is present in pipeline

  charlesccychen

  committed
  41311f5

  Copy full SHA for 41311f5

Commits on Feb 9, 2018

• Add switchable DirectRunner which uses the fast FnApiRunner when possible

  charlesccychen

  committed
  46931b4

  Copy full SHA for 46931b4

Commits on Feb 7, 2018

• Update snippets to fix pickling and clarify encoding issues

  charlesccychen

  committed
  8f9edbc

  Copy full SHA for 8f9edbc

• [BEAM-3635] Infer type hints on PTransformOverrides

  charlesccychen

  committed
  f887ed0

  Copy full SHA for f887ed0

Commits on Feb 3, 2018

• Address reviewer comments

  charlesccychen

  committed
  e1a96eb

  Copy full SHA for e1a96eb

Commits on Feb 2, 2018

• [BEAM-3566] Replace apply_* hooks in DirectRunner with PTransformOverrides

  charlesccychen

  committed
  16e5fef

  Copy full SHA for 16e5fef

Commits on Jan 29, 2018

• [BEAM-3537] Allow more general eager in-process pipeline execution (apache#4492)

  Show description for d920644
  

  charlesccychen

  authored and

  robertwb

  committed
  d920644

  Copy full SHA for d920644

Commits on Nov 13, 2017

• Fix flakiness in sideinputs_test

  charlesccychen

  committed
  ebeb3fd

  Copy full SHA for ebeb3fd

Commits on Nov 10, 2017

• Properly handle side input exception when all reader threads complete

  

  charlesccychen

  authored and

  chamikaramj

  committed
  6779b8e

  Copy full SHA for 6779b8e

Commits on Sep 20, 2017

• Revert "[BEAM-2377] Allow cross compilation (2.10,2.11) for flink runner"

  Show description for e154843
  

  charlesccychen

  authored and

  robertwb

  committed
  e154843

  Copy full SHA for e154843

• Exclude incompatible six release, part 2

  

  charlesccychen

  authored and

  robertwb

  committed
  fe6e95b

  Copy full SHA for fe6e95b

Commits on Aug 22, 2017

• Avoid passing extra argument to object() constructor in GcsIO

  

  charlesccychen

  authored and

  aaltay

  committed
  90a850e

  Copy full SHA for 90a850e

• Allow termination of DirectRunner execution with Ctrl-C

  

  charlesccychen

  authored and

  aaltay

  committed
  a493f32

  Copy full SHA for a493f32

Commits on Jul 6, 2017

• Fix PValue input in _PubSubReadEvaluator

  

  charlesccychen

  authored and

  aaltay

  committed
  a75202f

  Copy full SHA for a75202f

Commits on Jun 29, 2017

• Add PubSub I/O support to Python DirectRunner

  

  charlesccychen

  authored and

  aaltay

  committed
  fb7ec28

  Copy full SHA for fb7ec28

Commits on Jun 27, 2017

• Implement streaming GroupByKey in Python DirectRunner

  

  charlesccychen

  authored and

  aaltay

  committed
  eb379e7

  Copy full SHA for eb379e7

Commits on Jun 26, 2017

• Remove old deprecated PubSub code

  charlesccychen

  committed
  926f949

  Copy full SHA for 926f949

Commits on Jun 22, 2017

• Clean up test_stream_test and remove stray print statement

  

  charlesccychen

  authored and

  aaltay

  committed
  7471e27

  Copy full SHA for 7471e27

Commits on Jun 21, 2017

• Allow production of unprocessed bundles, introduce TestStream evaluator in DirectRunner

  

  charlesccychen

  authored and

  aaltay

  committed
  3520f94

  Copy full SHA for 3520f94

• Use state / timer API for DirectRunner timer firings

  

  charlesccychen

  authored and

  aaltay

  committed
  56041b7

  Copy full SHA for 56041b7

Commits on Jun 16, 2017

• Populate PBegin input when decoding from Runner API

  

  charlesccychen

  authored and

  robertwb

  committed
  4519681

  Copy full SHA for 4519681

• Introduce pending bundles and RootBundleProvider in DirectRunner

  

  charlesccychen

  authored and

  aaltay

  committed
  5aee624

  Copy full SHA for 5aee624

Commits on Jun 15, 2017

• Migrate DirectRunner evaluators to use Beam state API

  charlesccychen

  committed
  be09a16

  Copy full SHA for be09a16

Commits on Jun 14, 2017

• Choose GroupAlsoByWindows implementation based on streaming flag

  

  charlesccychen

  authored and

  aaltay

  committed
  0b600d2

  Copy full SHA for 0b600d2

Commits on Jun 13, 2017

• Move Runner API protos to portability/api

  charlesccychen

  committed
  7e4e51f

  Copy full SHA for 7e4e51f

Commits on Jun 12, 2017

• Reverse removal of NativeWrite evaluator in Python DirectRunner

  

  charlesccychen

  authored and

  aaltay

  committed
  809f178

  Copy full SHA for 809f178

Commits on Jun 8, 2017

• Move Runner API protos to portability/runners/api

  Show description for 7689e43
  

  charlesccychen

  authored and

  chamikaramj

  committed
  7689e43

  Copy full SHA for 7689e43

• Refine Python DirectRunner watermark advancement behavior

  Show description for 3e04902
  

  charlesccychen

  authored and

  aaltay

  committed
  3e04902

  Copy full SHA for 3e04902

• Remove support for NativeSinks from the Python DirectRunner

  charlesccychen

  committed
  f2e3088

  Copy full SHA for f2e3088

Pagination

Previous

Next