Commits

Branch selector

 master

User selector

dpmills

Datepicker

All time

Commit History

Commits on Jan 15, 2016

• Fix data races in BigQueryTableInserter and BigQueryUtilTest

  Show description for 9c1473c
  

  dpmills

  authored and

  lukecwik

  committed
  9c1473c

  Copy full SHA for 9c1473c

• Bound the size of commit queues in the streaming worker

  Show description for 6805ac9
  

  dpmills

  authored and

  lukecwik

  committed
  6805ac9

  Copy full SHA for 6805ac9

• Roll forward state caching

  Show description for eb92417
  

  dpmills

  authored and

  lukecwik

  committed
  eb92417

  Copy full SHA for eb92417

Commits on Jan 8, 2016

• Rollback state caching.

  Show description for 34dee75
  

  dpmills

  authored and

  lukecwik

  committed
  34dee75

  Copy full SHA for 34dee75

• Enable state caching for per-key windmill state

  Show description for 61bd081
  

  dpmills

  authored and

  lukecwik

  committed
  61bd081

  Copy full SHA for 61bd081

• Avoid integer overflow when computing maximum cache weight

  Show description for 23d96f3
  

  dpmills

  authored and

  lukecwik

  committed
  23d96f3

  Copy full SHA for 23d96f3

Commits on Nov 30, 2015

• Update Dataflow to use 11/17 version of prebuilt proto library

  Show description for 70efc8d
  

  dpmills

  authored and

  davorbonaci

  committed
  70efc8d

  Copy full SHA for 70efc8d

• Adds Protocol Buffer definition for gRPC communication with Windmill

  Show description for 48f8147
  

  dpmills

  authored and

  davorbonaci

  committed
  48f8147

  Copy full SHA for 48f8147

• Updates to windowing javadoc

  Show description for 198eb1f
  

  dpmills

  authored and

  davorbonaci

  committed
  198eb1f

  Copy full SHA for 198eb1f

• Minor fixes to trigger javadoc

  Show description for 3385cbb
  

  dpmills

  authored and

  davorbonaci

  committed
  3385cbb

  Copy full SHA for 3385cbb

Commits on Nov 12, 2015

• Testing improvements regarding custom sources in streaming

  Show description for 42b878a
  

  dpmills

  authored and

  davorbonaci

  committed
  42b878a

  Copy full SHA for 42b878a

Commits on Nov 10, 2015

• Update prebuilt proto libraries for Dataflow to 11/9 version

  Show description for 2b20075
  

  dpmills

  authored and

  davorbonaci

  committed
  2b20075

  Copy full SHA for 2b20075

• Fix continuation of OrFinally trigger

  Show description for c33aaaa
  

  dpmills

  authored and

  davorbonaci

  committed
  c33aaaa

  Copy full SHA for c33aaaa

Commits on Oct 1, 2015

• Plumb PaneInfo through DoFnWithContext.ProcessContext

  Show description for 63c7fbe
  

  dpmills

  authored and

  davorbonaci

  committed
  63c7fbe

  Copy full SHA for 63c7fbe

Commits on Sep 15, 2015

• Flush invalid entries from UnboundedReader cache

  Show description for b94d176
  

  dpmills

  authored and

  davorbonaci

  committed
  b94d176

  Copy full SHA for b94d176

Commits on Sep 10, 2015

• Don't include time spent fetching side inputs as user time

  Show description for 9f3e15b
  

  dpmills

  authored and

  davorbonaci

  committed
  9f3e15b

  Copy full SHA for 9f3e15b

Commits on Sep 4, 2015

• Adds counters for bytes written to and read from Windmill

  Show description for 195f528
  

  dpmills

  authored and

  davorbonaci

  committed
  195f528

  Copy full SHA for 195f528

• Make OutputObjectAndByteCounter.countBytes correct, and add tests

  Show description for 58450c1
  

  dpmills

  authored and

  davorbonaci

  committed
  58450c1

  Copy full SHA for 58450c1

• Adds a bytes-read counter for UnboundedSource for autoscaling

  Show description for 63e8e74
  

  dpmills

  authored and

  davorbonaci

  committed
  63e8e74

  Copy full SHA for 63e8e74

• Allow UnboundedSources to report backlog

  Show description for 1778f13
  

  dpmills

  authored and

  davorbonaci

  committed
  1778f13

  Copy full SHA for 1778f13

• Provide default for UnboundedSource.getCurrentRecordId

  Show description for 5ea6f90
  

  dpmills

  authored and

  davorbonaci

  committed
  5ea6f90

  Copy full SHA for 5ea6f90

Commits on Aug 19, 2015

• Exclude Windmill Reads from StateSampler

  Show description for 1033243
  

  dpmills

  authored and

  davorbonaci

  committed
  1033243

  Copy full SHA for 1033243

• Fix default insertion logic in Combine

  Show description for 79a717f
  

  dpmills

  authored and

  davorbonaci

  committed
  79a717f

  Copy full SHA for 79a717f

• Properly deactive work when it non-retriably fails

  Show description for 14b99d2
  

  dpmills

  authored and

  davorbonaci

  committed
  14b99d2

  Copy full SHA for 14b99d2

Commits on Aug 6, 2015

• Do small amount of backoff in worker for UnboundedSources

  Show description for 09b943a
  

  dpmills

  authored and

  davorbonaci

  committed
  09b943a

  Copy full SHA for 09b943a

• Switch Readers to be abstract classes

  Show description for e575a4e
  

  dpmills

  authored and

  davorbonaci

  committed
  e575a4e

  Copy full SHA for e575a4e

• Update SDK to depend on PubSub V1

  Show description for 5b7c0d5
  

  dpmills

  authored and

  davorbonaci

  committed
  5b7c0d5

  Copy full SHA for 5b7c0d5

• Process event time timers before processing time ones

  Show description for 332f9a3
  

  dpmills

  authored and

  davorbonaci

  committed
  332f9a3

  Copy full SHA for 332f9a3

• Improve choice of number of unbounded source splits

  Show description for 2ba3efc
  

  dpmills

  authored and

  davorbonaci

  committed
  2ba3efc

  Copy full SHA for 2ba3efc

• Fixes bugs in hot-key combining

  Show description for 43ace3b
  

  dpmills

  authored and

  davorbonaci

  committed
  43ace3b

  Copy full SHA for 43ace3b

• Give early errors when using unsupported bounded sources in streaming

  Show description for 2725c64
  

  dpmills

  authored and

  davorbonaci

  committed
  2725c64

  Copy full SHA for 2725c64

• Improve streaming sdk integration tests

  Show description for e9f687d
  

  dpmills

  authored and

  davorbonaci

  committed
  e9f687d

  Copy full SHA for e9f687d

• Use new watermark hold API.

  Show description for bf2f093
  

  dpmills

  authored and

  davorbonaci

  committed
  bf2f093

  Copy full SHA for bf2f093

• Update special-cases of GroupAlsoByWindow to use getOutputTimestamp

  Show description for 07396ad
  

  dpmills

  authored and

  davorbonaci

  committed
  07396ad

  Copy full SHA for 07396ad

Commits on Jul 26, 2015

• Fix View.AsSingleton with default values in streaming

  Show description for 45e336a
  

  dpmills

  authored and

  davorbonaci

  committed
  45e336a

  Copy full SHA for 45e336a

Pagination

Previous

Next