Commits

Branch selector

 master

User selector

All users

All time

Commit History

Commits on Apr 1, 2016

• Bump up version to 0.2.2

  Show description for f37afc2
  silviulica

  committed
  f37afc2

  Copy full SHA for f37afc2

• Implement and use WindowedValue.with_value

  Show description for 06dc6bf
  

  robertwb

  authored and

  silviulica

  committed
  06dc6bf

  Copy full SHA for 06dc6bf

• Support pagination for large list states in Windmill

  Show description for 345228a
  

  charlesccychen

  authored and

  silviulica

  committed
  345228a

  Copy full SHA for 345228a

• Add reference counting for consumers of AppliedPTransform outputs

  Show description for 30aac61
  silviulica

  committed
  30aac61

  Copy full SHA for 30aac61

• Remove sdk pipeline options from the DoFn context

  Show description for d7a2b0a
  

  aaltay

  authored and

  silviulica

  committed
  d7a2b0a

  Copy full SHA for d7a2b0a

• Add plumbing to pass a coder to the byte-size counter updater

  Show description for 4f7f210
  

  gildea

  authored and

  silviulica

  committed
  4f7f210

  Copy full SHA for 4f7f210

• Report work item exceptions in the streaming worker

  Show description for fff0718
  

  charlesccychen

  authored and

  silviulica

  committed
  fff0718

  Copy full SHA for fff0718

• Make sdk pipeline options available in the DoFn context

  Show description for a1ca465
  

  aaltay

  authored and

  silviulica

  committed
  a1ca465

  Copy full SHA for a1ca465

• Cythonize Timestamp- and FloatCoder

  Show description for 2c4c414
  

  robertwb

  authored and

  silviulica

  committed
  2c4c414

  Copy full SHA for 2c4c414

Commits on Mar 28, 2016

• Merge pull request #4 from broady/patch-1

  Show description for 7beec91
  silviulica

  committed
  7beec91

  Copy full SHA for 7beec91

Commits on Mar 27, 2016

• README: fix pip install link

  broady

  committed
  a5def81

  Copy full SHA for a5def81

Commits on Mar 24, 2016

• Add TimestampCoder for timeutil.Timestamp objects

  Show description for 4075ca9
  

  charlesccychen

  authored and

  aaltay

  committed
  4075ca9

  Copy full SHA for 4075ca9

• Several fixes related to schema specified when creating a BigQuery sink.

  Show description for b2816c6
  

  chamikaramj

  authored and

  aaltay

  committed
  b2816c6

  Copy full SHA for b2816c6

• Add support for deduplicating id_label in PubSubSource

  Show description for c4e9656
  

  charlesccychen

  authored and

  aaltay

  committed
  c4e9656

  Copy full SHA for c4e9656

• Clearer error message when SDK file cannot be found to stage

  Show description for 08c56ac
  

  gildea

  authored and

  aaltay

  committed
  08c56ac

  Copy full SHA for 08c56ac

• Rename OutputTimeFn.OUTPUT_AT_MAX to OUTPUT_AT_LATEST for clarity

  Show description for 66cd0e6
  

  charlesccychen

  authored and

  aaltay

  committed
  66cd0e6

  Copy full SHA for 66cd0e6

• Don't use KV coder for ungrouped shuffle reads/writes

  Show description for eb4f582
  

  charlesccychen

  authored and

  aaltay

  committed
  eb4f582

  Copy full SHA for eb4f582

• Avoid calling logging.debug on every element

  Show description for a44f1e2
  

  robertwb

  authored and

  aaltay

  committed
  a44f1e2

  Copy full SHA for a44f1e2

• New class ReceiverSet in the worker

  Show description for 5cfe9a5
  

  gildea

  authored and

  aaltay

  committed
  5cfe9a5

  Copy full SHA for 5cfe9a5

• Explicitly set all required pipeline options in the minimal example

  Show description for c6ec8bb
  aaltay

  committed
  c6ec8bb

  Copy full SHA for c6ec8bb

• Better error messaging on missing gcloud

  Show description for 695e522
  

  robertwb

  authored and

  aaltay

  committed
  695e522

  Copy full SHA for 695e522

• Store timestamps and time intervals with microsecond granularity

  Show description for 0228864
  

  charlesccychen

  authored and

  aaltay

  committed
  0228864

  Copy full SHA for 0228864

Commits on Mar 21, 2016

• Update some str methods for recent SDK representation changes

  Show description for fc0e8cc
  

  gildea

  authored and

  silviulica

  committed
  fc0e8cc

  Copy full SHA for fc0e8cc

• Reformat some doc strings to be acceptable to Pydocs Sphinx

  Show description for 9bbc79e
  

  gildea

  authored and

  silviulica

  committed
  9bbc79e

  Copy full SHA for 9bbc79e

• Bump up version to 0.2.1

  Show description for 5a178c3
  silviulica

  committed
  5a178c3

  Copy full SHA for 5a178c3

• Fixed the example docs to use the correct name for staging_location

  Show description for 0c05ad5
  

  aaltay

  authored and

  silviulica

  committed
  0c05ad5

  Copy full SHA for 0c05ad5

• Update the short link for the Alpha signup form

  Show description for 8183879
  silviulica

  committed
  8183879

  Copy full SHA for 8183879

• Remove some deprecated names.

  Show description for 20e2e6d
  

  robertwb

  authored and

  silviulica

  committed
  20e2e6d

  Copy full SHA for 20e2e6d

• Disable VarIntCoder for long values

  Show description for b76cc24
  

  charlesccychen

  authored and

  silviulica

  committed
  b76cc24

  Copy full SHA for b76cc24

• Handle two versions of oauth2client (>=2.0.0 and 1.5.2)

  Show description for 647ab8a
  silviulica

  committed
  647ab8a

  Copy full SHA for 647ab8a

• After a job fails, wait for any error messages to show up

  Show description for dfcfded
  

  gildea

  authored and

  silviulica

  committed
  dfcfded

  Copy full SHA for dfcfded

• Change option names to: --worker_machine_type and --worker_disk_type

  Show description for f7e98f0
  silviulica

  committed
  f7e98f0

  Copy full SHA for f7e98f0

• Monitoring interface snippets.

  Show description for 79171a0
  

  aaltay

  authored and

  silviulica

  committed
  79171a0

  Copy full SHA for 79171a0

• WordCount, minimal WordCount, and debugging WordCount snippets

  Show description for a94e7e3
  

  aaltay

  authored and

  silviulica

  committed
  a94e7e3

  Copy full SHA for a94e7e3

• Forbid use of PubSub I/O in batch and local jobs

  Show description for ac319b0
  

  charlesccychen

  authored and

  silviulica

  committed
  ac319b0

  Copy full SHA for ac319b0