[46/51] [abbrv] incubator-beam git commit: Allow setting timer by ID in DirectTimerInternals

Allow setting timer by ID in DirectTimerInternals Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7f14c463 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7f14c463 Diff:

[49/51] [abbrv] incubator-beam git commit: This closes #1669: Preliminaries for timers in the direct runner

This closes #1669: Preliminaries for timers in the direct runner Hold output watermark according to pending timers Allow setting timer by ID in DirectTimerInternals Add UsesTestStream for use with JUnit @Category Add static Window.withOutputTimeFn to match build method Use informative

[50/51] [abbrv] incubator-beam git commit: Merge remote-tracking branch 'origin/master' into python-sdk

Merge remote-tracking branch 'origin/master' into python-sdk Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/77742979 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/77742979 Diff:

[41/51] [abbrv] incubator-beam git commit: Fix windowing in direct runner Stateful ParDo

Fix windowing in direct runner Stateful ParDo Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4fb16e8f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4fb16e8f Diff:

[44/51] [abbrv] incubator-beam git commit: Add static Window.withOutputTimeFn to match build method

Add static Window.withOutputTimeFn to match build method Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8188040d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8188040d Diff:

[45/51] [abbrv] incubator-beam git commit: Add UsesTestStream for use with JUnit @Category

Add UsesTestStream for use with JUnit @Category Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4d71924c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4d71924c Diff:

[36/51] [abbrv] incubator-beam git commit: This closes #1673: Require TimeDomain to delete a timer

This closes #1673: Require TimeDomain to delete a timer Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4843dc59 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4843dc59 Diff:

[51/51] [abbrv] incubator-beam git commit: This closes #1676: Merge master (57d9bbd) into python-sdk

This closes #1676: Merge master (57d9bbd) into python-sdk No fixups. Commit from master: Hold output watermark according to pending timers Allow setting timer by ID in DirectTimerInternals Add UsesTestStream for use with JUnit @Category Add static Window.withOutputTimeFn to match build

[38/51] [abbrv] incubator-beam git commit: Support set and delete of timer by ID in InMemoryTimerInternals

Support set and delete of timer by ID in InMemoryTimerInternals Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/df2e540d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/df2e540d Diff:

[35/51] [abbrv] incubator-beam git commit: Update Dataflow worker to beam-master-20161221

Update Dataflow worker to beam-master-20161221 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/64336e40 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/64336e40 Diff:

[47/51] [abbrv] incubator-beam git commit: Hold output watermark according to pending timers

Hold output watermark according to pending timers Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/dfe2e62d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/dfe2e62d Diff:

[43/51] [abbrv] incubator-beam git commit: Add informative Instant formatter to BoundedWindow

Add informative Instant formatter to BoundedWindow Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/280a6a8f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/280a6a8f Diff:

[28/51] [abbrv] incubator-beam git commit: This closes #1665: Remove deprecated AggregatorFactory from SDK

This closes #1665: Remove deprecated AggregatorFactory from SDK Update Dataflow worker to beam-master-20161220 Remove deprecated AggregatorFactory from SDK Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[37/51] [abbrv] incubator-beam git commit: This closes #1666: Move ExecutionContext and related classes to runners-core

This closes #1666: Move ExecutionContext and related classes to runners-core Move ExecutionContext and related classes to runners-core Update Dataflow worker to beam-master-20161221 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[48/51] [abbrv] incubator-beam git commit: Use informative Instant formatter in WatermarkHold

Use informative Instant formatter in WatermarkHold Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/fa4958a6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/fa4958a6 Diff:

[42/51] [abbrv] incubator-beam git commit: This closes #1670: Fixes for direct runner expansion and evaluation of stateful ParDo

This closes #1670: Fixes for direct runner expansion and evaluation of stateful ParDo Actually propagate and commit state in direct runner Fix windowing in direct runner Stateful ParDo Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[40/51] [abbrv] incubator-beam git commit: Actually propagate and commit state in direct runner

Actually propagate and commit state in direct runner Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/55176c38 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/55176c38 Diff:

[10/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-extensions-join-library module to TestPipeline as a JUnit rule.

Migrated the beam-sdks-java-extensions-join-library module to TestPipeline as a JUnit rule. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/24ad1831 Tree:

[09/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-extensions-sorter module to TestPipeline as a JUnit rule.

Migrated the beam-sdks-java-extensions-sorter module to TestPipeline as a JUnit rule. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/63331aa8 Tree:

[02/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-core module to TestPipeline as a JUnit rule. Plus, fixed some checkstyle errors from previous modules' migration.

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/75a4c918/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/CreateTest.java -- diff --git

[08/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-io-google-cloud-platform module to TestPipeline as a JUnit rule.

Migrated the beam-sdks-java-io-google-cloud-platform module to TestPipeline as a JUnit rule. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6dea0992 Tree:

[34/51] [abbrv] incubator-beam git commit: Move ExecutionContext and related classes to runners-core

Move ExecutionContext and related classes to runners-core Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9d2b8e09 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9d2b8e09 Diff:

[27/51] [abbrv] incubator-beam git commit: Update Dataflow worker to beam-master-20161220

Update Dataflow worker to beam-master-20161220 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a3f68d34 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a3f68d34 Diff:

[14/51] [abbrv] incubator-beam git commit: This closes #1664: [BEAM-1176] Migrating tests to use TestPipeline as a JUnit rule

This closes #1664: [BEAM-1176] Migrating tests to use TestPipeline as a JUnit rule Migrated the beam-sdks-java-io-java8tests module to TestPipeline as a JUnit rule + fixed WithTimestampsJava8Test.withTimestampsLambdaShouldApplyTimestamps. Migrated the beam-sdks-java-io-mongodb module to

[39/51] [abbrv] incubator-beam git commit: This closes #1160: Support set and delete of timer by ID in InMemoryTimerInternals

This closes #1160: Support set and delete of timer by ID in InMemoryTimerInternals Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7ee8c86d Tree:

[23/51] [abbrv] incubator-beam git commit: Fixup usage of canonical name with name since canonical name != name for inner classes.

Fixup usage of canonical name with name since canonical name != name for inner classes. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/96d39314 Tree:

[05/51] [abbrv] incubator-beam git commit: Migrated the beam-runners-core module to TestPipeline as a JUnit rule.

Migrated the beam-runners-core module to TestPipeline as a JUnit rule. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b6710251 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b6710251 Diff:

[01/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-core module to TestPipeline as a JUnit rule. Plus, fixed some checkstyle errors from previous modules' migration.

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 3b4fd5c7d -> 3454d691f http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/75a4c918/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ViewTest.java

[30/51] [abbrv] incubator-beam git commit: Provide local tags in PInput, POutput expansions

Provide local tags in PInput, POutput expansions Output an ordered colleciton in PInput and POutput expansions. This provides information that is necessary to reconstruct a PInput or POutput from its expansion. Implement PCollectionList.equals, PCollectionTuple.equals Project:

[31/51] [abbrv] incubator-beam git commit: This closes #1569

This closes #1569 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/aadcf3a1 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/aadcf3a1 Diff:

[33/51] [abbrv] incubator-beam git commit: Require TimeDomain to delete a timer

Require TimeDomain to delete a timer Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/35a02740 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/35a02740 Diff:

[13/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-io-kinesis module to TestPipeline as a JUnit rule.

Migrated the beam-sdks-java-io-kinesis module to TestPipeline as a JUnit rule. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/950aa7e1 Tree:

[24/51] [abbrv] incubator-beam git commit: Provide a better error message for non-existing gcpTempLocation

Provide a better error message for non-existing gcpTempLocation gcpTempLocation will default to using the value for tmpLocation, as long as the value is a valid GCP path. Non-valid GCP paths are silently discarded. This change removes existence validation from the default value logic such that

[07/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-io-jdbc module to TestPipeline as a JUnit rule.

Migrated the beam-sdks-java-io-jdbc module to TestPipeline as a JUnit rule. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5ccbe679 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5ccbe679

[03/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-core module to TestPipeline as a JUnit rule. Plus, fixed some checkstyle errors from previous modules' migration.

Migrated the beam-sdks-java-core module to TestPipeline as a JUnit rule. Plus, fixed some checkstyle errors from previous modules' migration. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/75a4c918 Tree:

[22/51] [abbrv] incubator-beam git commit: This closes #1581: [BEAM-1117] Port direct runner StatefulParDo to KeyedWorkItem

This closes #1581: [BEAM-1117] Port direct runner StatefulParDo to KeyedWorkItem Port direct runner StatefulParDo to KeyedWorkItem Propagate key through ParDo if DoFn is key-preserving Move responsibility for knowing about keyedness into EvaluationContext Add some key-preserving to

[06/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-io-jms module to TestPipeline as a JUnit rule.

Migrated the beam-sdks-java-io-jms module to TestPipeline as a JUnit rule. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8d478c0f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8d478c0f

[11/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-io-java8tests module to TestPipeline as a JUnit rule + fixed WithTimestampsJava8Test.withTimestampsLambdaShouldApplyTimestamps.

Migrated the beam-sdks-java-io-java8tests module to TestPipeline as a JUnit rule + fixed WithTimestampsJava8Test.withTimestampsLambdaShouldApplyTimestamps. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[18/51] [abbrv] incubator-beam git commit: Port direct runner StatefulParDo to KeyedWorkItem

Port direct runner StatefulParDo to KeyedWorkItem Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1f018ab6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1f018ab6 Diff:

[17/51] [abbrv] incubator-beam git commit: Move responsibility for knowing about keyedness into EvaluationContext

Move responsibility for knowing about keyedness into EvaluationContext This will allow transform evaluators to inquire about whether various collections are keyed. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[26/51] [abbrv] incubator-beam git commit: Remove deprecated AggregatorFactory from SDK

Remove deprecated AggregatorFactory from SDK Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/aab46a0e Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/aab46a0e Diff:

[32/51] [abbrv] incubator-beam git commit: This closes #1668: Remove deprecated InMemoryTimerInternals from SDK

This closes #1668: Remove deprecated InMemoryTimerInternals from SDK Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0d0a5e28 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0d0a5e28 Diff:

[15/51] [abbrv] incubator-beam git commit: Add some key-preserving to KeyedPValueTrackingVisitor

Add some key-preserving to KeyedPValueTrackingVisitor Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/81702e67 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/81702e67 Diff:

[20/51] [abbrv] incubator-beam git commit: Move InMemoryTimerInternals to runners-core

Move InMemoryTimerInternals to runners-core Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/445c1205 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/445c1205 Diff:

[25/51] [abbrv] incubator-beam git commit: [BEAM-1097] Provide a better error message for non-existing gcpTempLocation

[BEAM-1097] Provide a better error message for non-existing gcpTempLocation This closes #1522 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/acd2196c Tree:

[19/51] [abbrv] incubator-beam git commit: Restore SDK's InMemoryTimerInternals, deprecated

Restore SDK's InMemoryTimerInternals, deprecated Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/69d2c47b Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/69d2c47b Diff:

[21/51] [abbrv] incubator-beam git commit: This closes #1652: Move InMemoryTimerInternals to runners-core

This closes #1652: Move InMemoryTimerInternals to runners-core * github/pr/1652: Restore SDK's InMemoryTimerInternals, deprecated Move InMemoryTimerInternals to runners-core Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[12/51] [abbrv] incubator-beam git commit: Migrated the beam-sdks-java-io-mongodb module to TestPipeline as a JUnit rule.

Migrated the beam-sdks-java-io-mongodb module to TestPipeline as a JUnit rule. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/fce4f658 Tree:

[5/7] incubator-beam git commit: Add static Window.withOutputTimeFn to match build method

Add static Window.withOutputTimeFn to match build method Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8188040d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8188040d Diff:

[6/7] incubator-beam git commit: Add UsesTestStream for use with JUnit @Category

Add UsesTestStream for use with JUnit @Category Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4d71924c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4d71924c Diff:

[2/7] incubator-beam git commit: Hold output watermark according to pending timers

Hold output watermark according to pending timers Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/dfe2e62d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/dfe2e62d Diff:

[3/7] incubator-beam git commit: Use informative Instant formatter in WatermarkHold

Use informative Instant formatter in WatermarkHold Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/fa4958a6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/fa4958a6 Diff:

[7/7] incubator-beam git commit: This closes #1669: Preliminaries for timers in the direct runner

This closes #1669: Preliminaries for timers in the direct runner Hold output watermark according to pending timers Allow setting timer by ID in DirectTimerInternals Add UsesTestStream for use with JUnit @Category Add static Window.withOutputTimeFn to match build method Use informative

[4/7] incubator-beam git commit: Allow setting timer by ID in DirectTimerInternals

Allow setting timer by ID in DirectTimerInternals Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7f14c463 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7f14c463 Diff:

[1/7] incubator-beam git commit: Add informative Instant formatter to BoundedWindow

Repository: incubator-beam Updated Branches: refs/heads/master ff3951699 -> 57d9bbd79 Add informative Instant formatter to BoundedWindow Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/280a6a8f Tree:

[1/3] incubator-beam git commit: Actually propagate and commit state in direct runner

Repository: incubator-beam Updated Branches: refs/heads/master 7ee8c86d3 -> ff3951699 Actually propagate and commit state in direct runner Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/55176c38 Tree:

[3/3] incubator-beam git commit: This closes #1670: Fixes for direct runner expansion and evaluation of stateful ParDo

This closes #1670: Fixes for direct runner expansion and evaluation of stateful ParDo Actually propagate and commit state in direct runner Fix windowing in direct runner Stateful ParDo Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[2/3] incubator-beam git commit: Fix windowing in direct runner Stateful ParDo

Fix windowing in direct runner Stateful ParDo Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4fb16e8f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4fb16e8f Diff:

[49/50] incubator-beam git commit: [BEAM-79] Upgrade to beam-0.5.0-incubating-SNAPSHOT

[BEAM-79] Upgrade to beam-0.5.0-incubating-SNAPSHOT Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/647034cf Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/647034cf Diff:

[40/50] incubator-beam git commit: This closes #1659: More escaping in Jenkins timestamp spec

This closes #1659: More escaping in Jenkins timestamp spec Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d13f11f8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d13f11f8 Diff:

[02/50] incubator-beam git commit: Make {Metric, Counter, Distribution}Cell public

Make {Metric,Counter,Distribution}Cell public These classes may be useful to hold on to within a runner where the step context is known to be unchanging and there may be a desire to avoid the extra indirection of using {Counter,Distribution} directly. Project:

[30/50] incubator-beam git commit: [BEAM-1165] Fix unexpected file creation when checking dependencies

[BEAM-1165] Fix unexpected file creation when checking dependencies This error happens because maven-dependency-plugin asumes the property output used by the flink tests as the export file for the depedency:tree command. Ref.

[15/50] incubator-beam git commit: Use empty SideInputReader, fixes NPE in SimpleDoFnRunnerTest

Use empty SideInputReader, fixes NPE in SimpleDoFnRunnerTest Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b78aa669 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b78aa669 Diff:

[01/50] incubator-beam git commit: Closes #1622

Repository: incubator-beam Updated Branches: refs/heads/gearpump-runner b6e7bb659 -> 4c445dd0b Closes #1622 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1ee191fb Tree:

[44/50] incubator-beam git commit: [BEAM-59] initial interfaces and classes of Beam FileSystem

[BEAM-59] initial interfaces and classes of Beam FileSystem This closes #1558 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/28d7913b Tree:

[43/50] incubator-beam git commit: [BEAM-59] initial interfaces and classes of Beam FileSystem.

[BEAM-59] initial interfaces and classes of Beam FileSystem. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/467f7d17 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/467f7d17 Diff:

[28/50] incubator-beam git commit: [BEAM-716] This closes #1577

[BEAM-716] This closes #1577 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1e148cd7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1e148cd7 Diff:

[33/50] incubator-beam git commit: Show timestamps on log lines in Jenkins

Show timestamps on log lines in Jenkins Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4d964734 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4d964734 Diff:

[20/50] incubator-beam git commit: Change counter name in TestDataflowRunner

Change counter name in TestDataflowRunner Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6b055d2d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6b055d2d Diff:

[37/50] incubator-beam git commit: Add RunnableOnService test for Metrics

Add RunnableOnService test for Metrics Add UsesMetrics interface and exclude from runners that don't yet support Metrics Add Serializability as needed for Metrics to be created during pipeline construction Remove test from DirectRunnerTest Project:

[46/50] incubator-beam git commit: Closes #1656

Closes #1656 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b3de17b3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b3de17b3 Diff:

[18/50] incubator-beam git commit: Closes #1651

Closes #1651 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5255a338 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5255a338 Diff:

[31/50] incubator-beam git commit: This closes #1632

This closes #1632 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/203b7b17 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/203b7b17 Diff:

[50/50] incubator-beam git commit: This closes #1663: Merge master (b3de17b) into gearpump-runner

This closes #1663: Merge master (b3de17b) into gearpump-runner Adjustments in gearpump-runner: [BEAM-79] Upgrade to beam-0.5.0-incubating-SNAPSHOT [BEAM-79] Update to latest Gearpump API >From master: Disable automatic archiving of Maven builds [BEAM-59] initial interfaces and classes

[35/50] incubator-beam git commit: Fix seed job fetch spec

Fix seed job fetch spec Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/2148adb8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/2148adb8 Diff:

[41/50] incubator-beam git commit: Change counter name in TestDataflowRunner

Change counter name in TestDataflowRunner Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a2f44923 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a2f44923 Diff:

[14/50] incubator-beam git commit: Add timer support to DoFnRunner(s)

Add timer support to DoFnRunner(s) Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8af13b01 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8af13b01 Diff:

[16/50] incubator-beam git commit: [BEAM-853] Force streaming execution on batch pipelines for testing. Expose the adapted source.

[BEAM-853] Force streaming execution on batch pipelines for testing. Expose the adapted source. Force streaming execution, if set in PipelineOptions. Added test. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[29/50] incubator-beam git commit: [BEAM-1178] Make naming of logger objects consistent

[BEAM-1178] Make naming of logger objects consistent Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4cf59170 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4cf59170 Diff:

[09/50] incubator-beam git commit: View.asMap: minor javadoc fixes

View.asMap: minor javadoc fixes Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6a4a6997 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6a4a6997 Diff:

[10/50] incubator-beam git commit: Closes #1650

Closes #1650 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7d1976b2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7d1976b2 Diff:

[08/50] incubator-beam git commit: Revert "Removes code for wrapping DoFn as an OldDoFn"

Revert "Removes code for wrapping DoFn as an OldDoFn" This reverts commit a22de15012c51e8b7e31143021f0a298e093bf51. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a12fd8c5 Tree:

[36/50] incubator-beam git commit: This closes #1657: Fix seed job fetch spec

This closes #1657: Fix seed job fetch spec Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/66318d82 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/66318d82 Diff:

[04/50] incubator-beam git commit: Closes #1649

Closes #1649 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/abdbee61 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/abdbee61 Diff:

[39/50] incubator-beam git commit: More escaping in Jenkins timestamp spec

More escaping in Jenkins timestamp spec Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/627ccb52 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/627ccb52 Diff:

[32/50] incubator-beam git commit: This closes #1655: [BEAM-1178] Make naming of logger objects consistent

This closes #1655: [BEAM-1178] Make naming of logger objects consistent [BEAM-1178] Make naming of logger objects consistent Fix grammar error (repeated for) Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[38/50] incubator-beam git commit: Closes #1638

Closes #1638 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a972b233 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a972b233 Diff:

[05/50] incubator-beam git commit: Revert "Move InMemoryTimerInternals to runners-core"

Revert "Move InMemoryTimerInternals to runners-core" This reverts commit ec0bf7b4023ff75f4ec6723d2e77ed507eb57c51. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/45ed5c70 Tree:

[25/50] incubator-beam git commit: Fix grammar error (repeated for)

Fix grammar error (repeated for) Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/fbfea595 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/fbfea595 Diff:

[26/50] incubator-beam git commit: [BEAM-716] Use AutoValue in JmsIO

[BEAM-716] Use AutoValue in JmsIO Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/caf1c720 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/caf1c720 Diff:

[11/50] incubator-beam git commit: This closes #1648: Undeletes DoFnInvokers.of(OldDoFn)

This closes #1648: Undeletes DoFnInvokers.of(OldDoFn) Revert "Move InMemoryTimerInternals to runners-core" Revert "Moves DoFnAdapters to runners-core" Revert "Removes ArgumentProvider.windowingInternals" Revert "Removes code for wrapping DoFn as an OldDoFn" Project:

[12/50] incubator-beam git commit: Make TimerSpec and StateSpec fields accessible

Make TimerSpec and StateSpec fields accessible Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c1e1017d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c1e1017d Diff:

[19/50] incubator-beam git commit: BigQueryIO: fix streaming write, typo in API

BigQueryIO: fix streaming write, typo in API and improve testing Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5fb4f5de Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5fb4f5de Diff:

[22/50] incubator-beam git commit: [BEAM-85, BEAM-298] Make TestPipeline a JUnit Rule checking proper usage

[BEAM-85, BEAM-298] Make TestPipeline a JUnit Rule checking proper usage Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/443b25a4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/443b25a4

[48/50] incubator-beam git commit: [BEAM-79] Update to latest Gearpump API

[BEAM-79] Update to latest Gearpump API Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c2fb7c07 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c2fb7c07 Diff:

[42/50] incubator-beam git commit: This closes #1631: Change counter name in TestDataflowRunner

This closes #1631: Change counter name in TestDataflowRunner Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4f97efc1 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4f97efc1 Diff:

[47/50] incubator-beam git commit: Merge branch 'master' of https://github.com/apache/incubator-beam into gearpump-runner

Merge branch 'master' of https://github.com/apache/incubator-beam into gearpump-runner Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/81d94cfa Tree:

[21/50] incubator-beam git commit: This closes #1612: [BEAM-27] Support timer setting and receiving in SimpleDoFnRunner

This closes #1612: [BEAM-27] Support timer setting and receiving in SimpleDoFnRunner Use empty SideInputReader, fixes NPE in SimpleDoFnRunnerTest Test that SimpleDoFnRunner wraps exceptions in startBundle and finishBundle Add timer support to DoFnRunner(s) Make TimerSpec and StateSpec

[13/50] incubator-beam git commit: Test that SimpleDoFnRunner wraps exceptions in startBundle and finishBundle

Test that SimpleDoFnRunner wraps exceptions in startBundle and finishBundle Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3b4c7d10 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/3b4c7d10

[03/50] incubator-beam git commit: checkstyle: missed newline in DistributionCell

checkstyle: missed newline in DistributionCell Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/92dbab8e Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/92dbab8e Diff:

  1   2   3   4   5   6   7   8   9   10   >