Commits

Branch selector

 master

User selector

All users

All time

Commit History

Commits on Feb 1, 2017

• Merge pull request #35 from volnt/master

  Show description for 97e6d7b
  aaltay

  authored
  97e6d7b

  Copy full SHA for 97e6d7b

• Update Apache Beam link

  Show description for 0470598
  volnt

  authored
  0470598

  Copy full SHA for 0470598

Commits on Sep 1, 2016

• Updated README about move to Apache Beam

  aaltay

  committed
  9fb6f01

  Copy full SHA for 9fb6f01

Commits on Jun 29, 2016

• Add note that we moved to Apache Beam

  silviulica

  authored
  adf0d26

  Copy full SHA for adf0d26

Commits on Jun 14, 2016

• Bump up version to 0.2.7

  Show description for 94aa8f9
  aaltay

  committed
  94aa8f9

  Copy full SHA for 94aa8f9

• Retry idempotent I/O operations on GCS timeout

  Show description for 68f85e3
  

  charlesccychen

  authored and

  aaltay

  committed
  68f85e3

  Copy full SHA for 68f85e3

• Use multiple file rename threads in finalize_write

  Show description for c2c1bc7
  aaltay

  committed
  c2c1bc7

  Copy full SHA for c2c1bc7

• Raise an IOError when source file in GcsIO.copy does not exist

  Show description for 4e38084
  

  charlesccychen

  authored and

  aaltay

  committed
  4e38084

  Copy full SHA for 4e38084

• Remove unused GcsIO class attribute

  Show description for c752b7f
  

  charlesccychen

  authored and

  aaltay

  committed
  c752b7f

  Copy full SHA for c752b7f

• Implement fixed sharding in Text sink.

  Show description for 8a31915
  

  robertwb

  authored and

  aaltay

  committed
  8a31915

  Copy full SHA for 8a31915

• Fix is_service_runner to detect endpoints ending with /

  Show description for 5ff2c3e
  aaltay

  committed
  5ff2c3e

  Copy full SHA for 5ff2c3e

• Reintroduce OperationCounters.should_sample

  Show description for 5cf2b03
  

  charlesccychen

  authored and

  aaltay

  committed
  5cf2b03

  Copy full SHA for 5cf2b03

Commits on Jun 10, 2016

• Bump up version to 0.2.6

  Show description for a0f881f
  aaltay

  committed
  a0f881f

  Copy full SHA for a0f881f

• Add autoscaling pipeline options

  Show description for 2f9e11c
  

  robertwb

  authored and

  aaltay

  committed
  2f9e11c

  Copy full SHA for 2f9e11c

• Augment file utils with recursive copy

  Show description for 9782343
  

  robertwb

  authored and

  aaltay

  committed
  9782343

  Copy full SHA for 9782343

• Undo introduction of OperationCounters.should_sample

  Show description for 15bef52
  

  charlesccychen

  authored and

  aaltay

  committed
  15bef52

  Copy full SHA for 15bef52

• Allow Pipeline objects to be used in Python with statements

  Show description for c644665
  

  robertwb

  authored and

  aaltay

  committed
  c644665

  Copy full SHA for c644665

• Introduce OperationCouters.should_sample

  Show description for 30af51a
  

  charlesccychen

  authored and

  aaltay

  committed
  30af51a

  Copy full SHA for 30af51a

• Fix buffer overruns in fast OutputStream implementaion

  Show description for c731121
  aaltay

  committed
  c731121

  Copy full SHA for c731121

• Make retry logic idempotent in GcsIO.delete and GcsIO.rename

  Show description for ba23cca
  

  charlesccychen

  authored and

  aaltay

  committed
  ba23cca

  Copy full SHA for ba23cca

• Fix module dict pickling.

  Show description for 4d1fedb
  

  robertwb

  authored and

  aaltay

  committed
  4d1fedb

  Copy full SHA for 4d1fedb

• Internal changes for documentation validation

  Show description for ecaea38
  

  gildea

  authored and

  aaltay

  committed
  ecaea38

  Copy full SHA for ecaea38

• Remove separate worker version file

  Show description for 8f8c318
  

  charlesccychen

  authored and

  aaltay

  committed
  8f8c318

  Copy full SHA for 8f8c318

Commits on May 31, 2016

• Bump up version to 0.2.5

  Show description for 4d230cd
  aaltay

  committed
  4d230cd

  Copy full SHA for 4d230cd

• Update filehandling utilities

  Show description for 46f758c
  

  robertwb

  authored and

  aaltay

  committed
  46f758c

  Copy full SHA for 46f758c

• Use shelve as a disk backed dictionary optionally in PValueCache

  Show description for c586bac
  aaltay

  committed
  c586bac

  Copy full SHA for c586bac

• Undo introduction of OperationCounters.should_sample

  Show description for f84b9d9
  

  charlesccychen

  authored and

  aaltay

  committed
  f84b9d9

  Copy full SHA for f84b9d9

• Internal rollback.

  Show description for 2b670d8
  

  sammcveety

  authored and

  aaltay

  committed
  2b670d8

  Copy full SHA for 2b670d8

• Remove separate worker version file

  Show description for 4e586c9
  

  charlesccychen

  authored and

  aaltay

  committed
  4e586c9

  Copy full SHA for 4e586c9

• Ignore undeclared side outputs of DoFns in cloud executor

  Show description for 96583d0
  aaltay

  committed
  96583d0

  Copy full SHA for 96583d0

• Adds support for reading custom sources using DataflowPipelineRunner.

  Show description for 574a29e
  

  chamikaramj

  authored and

  aaltay

  committed
  574a29e

  Copy full SHA for 574a29e

• New method OperationCounters.should_sample

  Show description for 67033fc
  

  gildea

  authored and

  aaltay

  committed
  67033fc

  Copy full SHA for 67033fc

• Skip modules without a __name__ attribute

  Show description for de04d7e
  

  silviulica

  authored and

  aaltay

  committed
  de04d7e

  Copy full SHA for de04d7e

• Dynamic work rebalancing support for InMemory reader.

  Show description for cb60c6c
  

  chamikaramj

  authored and

  aaltay

  committed
  cb60c6c

  Copy full SHA for cb60c6c

• Adds the base API for creating new sources.

  Show description for 1d44fdb
  

  chamikaramj

  authored and

  aaltay

  committed
  1d44fdb

  Copy full SHA for 1d44fdb