Commits

Breadcrumbs

History for

onmaster

User selector

All users

All time

Commit History

Commits on Jun 1, 2015

• Change ExpectedLogs to include better stack-traces

  Show description for bdde374
  

  bchambers

  authored and

  davorbonaci

  committed
  bdde374

  Copy full SHA for bdde374

• Makes Write compatible with windowing

  Show description for 45e0f9c
  

  ml8

  authored and

  davorbonaci

  committed
  45e0f9c

  Copy full SHA for 45e0f9c

• Improve Trigger interaction with the Watermark

  Show description for 6e32911
  

  bchambers

  authored and

  davorbonaci

  committed
  6e32911

  Copy full SHA for 6e32911

Commits on May 28, 2015

• Remove the experimental KeyedState API from DoFns

  Show description for 617b6c4
  

  robertwb

  authored and

  davorbonaci

  committed
  617b6c4

  Copy full SHA for 617b6c4

• Add allowedLateness to WindowingStrategy

  Show description for 26f222e
  

  bchambers

  authored and

  davorbonaci

  committed
  26f222e

  Copy full SHA for 26f222e

• Fix documentation and change visibility of FileResult

  Show description for 38a8327
  

  ml8

  authored and

  davorbonaci

  committed
  38a8327

  Copy full SHA for 38a8327

• Add Aggregator Value lookups

  Show description for 0aa1bca
  

  tgroh

  authored and

  davorbonaci

  committed
  0aa1bca

  Copy full SHA for 0aa1bca

• Make the StateSampler available to the abstract Reader super-class so it can be used by different concrete readers that need a more fine control over the breakdown of the reading (such as the Group…

  Show description for 7aa1a0c
  

  tudorm

  authored and

  davorbonaci

  committed
  7aa1a0c

  Copy full SHA for 7aa1a0c

• Make non-static TupleTag test robust to superficial changes

  Show description for ef1163e
  

  kennknowles

  authored and

  davorbonaci

  committed
  ef1163e

  Copy full SHA for ef1163e

• Improve toString on *Pipeline and *Runner classes

  Show description for dc5ef71
  

  lukecwik

  authored and

  davorbonaci

  committed
  dc5ef71

  Copy full SHA for dc5ef71

• Always produce at least one split of a Datastore query

  Show description for 1a7dc25
  

  ml8

  authored and

  davorbonaci

  committed
  1a7dc25

  Copy full SHA for 1a7dc25

• Add JobSpecification to DataflowPipelineTranslator

  Show description for d27534c
  

  tgroh

  authored and

  davorbonaci

  committed
  d27534c

  Copy full SHA for d27534c

• Ignore empty arguments when parsing PipelineOptions

  Show description for 0b7a610
  

  kennknowles

  authored and

  davorbonaci

  committed
  0b7a610

  Copy full SHA for 0b7a610

• Add AggregatorPipelineExtractor

  Show description for 09817e8
  

  tgroh

  authored and

  davorbonaci

  committed
  09817e8

  Copy full SHA for 09817e8

Commits on May 21, 2015

• Mark PCollections as bounded or unbounded

  Show description for af42f3a
  

  peihe

  authored and

  davorbonaci

  committed
  af42f3a

  Copy full SHA for af42f3a

• Move TimeDomain into TimerManager

  Show description for 0262ed9
  

  bchambers

  authored and

  davorbonaci

  committed
  0262ed9

  Copy full SHA for 0262ed9

Commits on May 20, 2015

• Decrease number of threads created in test

  Show description for fae548b
  

  lukecwik

  authored and

  davorbonaci

  committed
  fae548b

  Copy full SHA for fae548b

• Have WindowingInternals provide the TimerManager

  Show description for 3221d6e
  

  bchambers

  authored and

  davorbonaci

  committed
  3221d6e

  Copy full SHA for 3221d6e

• Make tests locale-independent

  Show description for 0a70440
  davorbonaci

  committed
  0a70440

  Copy full SHA for 0a70440

• Rename getWatermarkCutoff to getWatermarkThatGuaranteesFiring

  Show description for 1db93f3
  

  bchambers

  authored and

  davorbonaci

  committed
  1db93f3

  Copy full SHA for 1db93f3

• Allows a PTransform to be used more than once

  Show description for 4a4c23b
  

  robertwb

  authored and

  davorbonaci

  committed
  4a4c23b

  Copy full SHA for 4a4c23b

• Remove NoopStager. Warn if classpath contains non-existent resources.

  Show description for 151d1e0
  

  lukecwik

  authored and

  davorbonaci

  committed
  151d1e0

  Copy full SHA for 151d1e0

Commits on May 14, 2015

• Revert "Add MapFn and FlatMapFn"

  Show description for 0f00695
  

  tgroh

  authored and

  davorbonaci

  committed
  0f00695

  Copy full SHA for 0f00695

• Fix test failure issues on windows because of paths.

  Show description for 3f69cac
  

  lukecwik

  authored and

  davorbonaci

  committed
  3f69cac

  Copy full SHA for 3f69cac

• Centralize the choice of what window set to use.

  Show description for 7356c93
  

  bchambers

  authored and

  davorbonaci

  committed
  7356c93

  Copy full SHA for 7356c93

• Refactor the existing WindowSets.

  Show description for 3e7961c
  

  bchambers

  authored and

  davorbonaci

  committed
  3e7961c

  Copy full SHA for 3e7961c

• Expose Accumulating Mode via the Window.into operation.

  Show description for 3f6f308
  

  bchambers

  authored and

  davorbonaci

  committed
  3f6f308

  Copy full SHA for 3f6f308

Commits on May 12, 2015

• Migrate the package stager to use IOChannelUtils so that it can stage files to arbritrary locations.

  Show description for 571940f
  

  lukecwik

  authored and

  davorbonaci

  committed
  571940f

  Copy full SHA for 571940f

• Add MapFn and FlatMapFn

  Show description for 431b317
  

  tgroh

  authored and

  davorbonaci

  committed
  431b317

  Copy full SHA for 431b317

• Verify the status of windows at various points in Trigger Execution.

  Show description for 77452b1
  

  bchambers

  authored and

  davorbonaci

  committed
  77452b1

  Copy full SHA for 77452b1

• Use TypeVariable instead of String to name generic parameters during Coder inference.

  Show description for 2908894
  

  kennknowles

  authored and

  davorbonaci

  committed
  2908894

  Copy full SHA for 2908894

• Improve the description of Window.into operations.

  Show description for 399f0f9
  

  bchambers

  authored and

  davorbonaci

  committed
  399f0f9

  Copy full SHA for 399f0f9

• Add AccumulationMode enum and support for accumulating.

  Show description for a06ed78
  

  bchambers

  authored and

  davorbonaci

  committed
  a06ed78

  Copy full SHA for a06ed78

• Set maxTimestamp of GlobalWindow to be one day before max.

  Show description for e2e2ac6
  

  peihe

  authored and

  davorbonaci

  committed
  e2e2ac6

  Copy full SHA for e2e2ac6

• Stop sending progress updates if a workItem fails.

  Show description for e6c4384
  

  malo-denielou

  authored and

  davorbonaci

  committed
  e6c4384

  Copy full SHA for e6c4384