Commits

Branch selector

 natsio

User selector

dpmills

Datepicker

All time

Commit History

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

Commits on Jul 23, 2015

• Pass the internal step name to Windmill as a state family

  Show description for 8118e47
  

  dpmills

  authored and

  davorbonaci

  committed
  8118e47

  Copy full SHA for 8118e47

• Support UnboundedSource in direct and batch modes

  Show description for f5a208f
  

  dpmills

  authored and

  davorbonaci

  committed
  f5a208f

  Copy full SHA for f5a208f

• Remove unneeded ExecutionContext arg to BoundedSource.createReader

  Show description for 1f594f0
  

  dpmills

  authored and

  davorbonaci

  committed
  1f594f0

  Copy full SHA for 1f594f0

• Change state_family proto field back to string

  Show description for 8ce5742
  

  dpmills

  authored and

  davorbonaci

  committed
  8ce5742

  Copy full SHA for 8ce5742

• Improve performance of BigQueryIO.Write

  Show description for 9a984f2
  

  dpmills

  authored and

  davorbonaci

  committed
  9a984f2

  Copy full SHA for 9a984f2

• Support record ids for UnboundedSources

  Show description for d3a8a87
  

  dpmills

  authored and

  davorbonaci

  committed
  d3a8a87

  Copy full SHA for d3a8a87

• Improve performance of BigQueryIO.Write.

  Show description for e9be9d0
  

  dpmills

  authored and

  davorbonaci

  committed
  e9be9d0

  Copy full SHA for e9be9d0

• Track active keys and tokens in StreamingDataflowWorker

  Show description for 381dcce
  

  dpmills

  authored and

  davorbonaci

  committed
  381dcce

  Copy full SHA for 381dcce

• Updates Windmill API to support reading watermark holds

  Show description for 4b527da
  

  dpmills

  authored and

  davorbonaci

  committed
  4b527da

  Copy full SHA for 4b527da

• Update Windmill API.

  Show description for 66680db
  

  dpmills

  authored and

  davorbonaci

  committed
  66680db

  Copy full SHA for 66680db

• Adds explicit watermark holds to the Windmill API.

  Show description for 7a18472
  

  dpmills

  authored and

  davorbonaci

  committed
  7a18472

  Copy full SHA for 7a18472

Commits on Jul 10, 2015

• Plumb timestampLabel and idLabel through PubsubSink.

  Show description for ac0c5df
  

  dpmills

  authored and

  lukecwik

  committed
  ac0c5df

  Copy full SHA for ac0c5df

• Use system names instead of user names for storing state

  Show description for 1787c97
  

  dpmills

  authored and

  lukecwik

  committed
  1787c97

  Copy full SHA for 1787c97

• Update Windmill API protos.

  Show description for 3d0223a
  

  dpmills

  authored and

  lukecwik

  committed
  3d0223a

  Copy full SHA for 3d0223a

Pagination

Previous

Next