Repository: incubator-beam
Updated Branches:
refs/heads/master cc448e976 -> 9a3896d69
Remove Unnecessary Fn cloning
The ParDoInProcessEvaluator is provided clones of a DoFn when
appropriate, and should not serialize them.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
This closes #418
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9a3896d6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9a3896d6
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/master fcf5bc71d -> 2173000c3
Allow DoFns to be Reused
Modify the documentation of ParDo to allow DoFns to be reused for
multiple bundles in the general case. This allows DoFns which implement
start and finish bundle to be reused.
Repository: incubator-beam
Updated Branches:
refs/heads/master 9a8cb95db -> ffbfc66e1
Remove DirectRunner implementations from DoFnTester
Part of the removal of runners-core from the Core SDK, and the deletion
of the DirectRunner from the core SDK.
Project:
Repository: incubator-beam
Updated Branches:
refs/heads/master 787b3351a -> 9a8cb95db
Relocate Immutability Enforcement Tests
These tests are of runner behavior rather than the model, and should be
tested as a runner test.
Stop wrapping IllegalMutationExceptions to surface failures due to
This closes #429
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/787b3351
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/787b3351
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/master 5a80bdc61 -> 787b3351a
Reset Writer in WriteBundles.finishBundle
This allows the WriteBundles DoFn to be reused.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit:
This closes #422
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ffbfc66e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ffbfc66e
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/master 983d467a7 -> d6adbbf96
Shutdown the InProcessPipelineRunner after Terminating Abnormally
Ensure that the executor service is shutdown, and the monitor is not
rescheduled, after an exception is thrown.
Project:
This closes #435
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d6adbbf9
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d6adbbf9
Diff:
Fix TriggerExampleTest
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/77aa0938
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/77aa0938
Diff:
Switch Spark streaming tests to custom assertions
The current use of PAssert in the streaming tests for
the Spark runner work via coincidence. PAssert does not
truly support non-global windowing. The switch from
side inputs to GBK, with no change in semantics but hopefully
an easier on-ramp for
Base PAssert on GBK instead of side inputs
Previously PAssert - hence all RunnableOnService/NeedsRunner
tests - required side input support. This created a very steep
on ramp for new runners.
GroupByKey is a bit more fundamental and most backends will be
able to group by key in the global window
Repository: incubator-beam
Updated Branches:
refs/heads/master d6adbbf96 -> d53e96a0d
Spark runner: Assign windows when re-windowing into global window
Previously, window assignment was elided when the window was the
global window. But when the source windows are not the global window,
this
Repository: incubator-beam
Updated Branches:
refs/heads/master d53e96a0d -> 829121960
Execute NeedsRunner tests in the 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/9e797e3d
Tree:
/diff/82912196
Branch: refs/heads/master
Commit: 82912196080b7ae79b39e355d10077ad8654eda6
Parents: d53e96a 9e797e3
Author: Kenn Knowles <k...@kennknowles.com>
Authored: Thu Jun 9 19:26:23 2016 -0700
Committer: Kenn Knowles <k...@kennknowles.com>
Committed: Thu Jun 9 19:26:2
Use a DirectExecutor for Watermark Callbacks
This fixes a resource leak where the executor service is not properly
shut down with the rest of the DirectRunner.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit:
This closes #388
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d4c052c3
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d4c052c3
Diff:
This closes #361
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/bde2a856
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/bde2a856
Diff:
This closes #449
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9e0d7d65
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9e0d7d65
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/master fe5b8db6c -> a3feeefa2
Add success/failure counters to new PAssert mechanism
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/dd07cba3
Tree:
This closes #448
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a3feeefa
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a3feeefa
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/master dbddb9f3c -> 9e0d7d650
[BEAM-336] update examples-java README
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/99c596eb
Tree:
Repository: incubator-beam
Updated Branches:
refs/heads/master a3feeefa2 -> dbddb9f3c
Changed Word Counts to use TypeDescriptors.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f0e266bb
Tree:
This closes #393
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/dbddb9f3
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/dbddb9f3
Diff:
This closes #457
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c8ad2e7d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c8ad2e7d
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/master f9a9214dd -> c8ad2e7dd
Revert GBK-based PAssert
This changed neglected the use of counters by the Dataflow runner,
which is used to prevent tests for spuriously passing when
a PCollection is empty.
Obvious fixes for that revealed
Update Direct Module tests to explicitly set Pipeline
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a8a33b19
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a8a33b19
Diff:
Update Pipeline Execution Style in WindowedWordCountTest
This sets the runner a Pipeline creation time rather than sending a
(potentially rewritten) pipeline to a new runner instance.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit:
Set Runner in DataflowRunner Tests
Otherwise the Default Runner is used, which may be unavailable.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4d1e68af
Tree:
Use TestPipeline#testingPipelineOptions in IO Tests
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f73bd73c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/f73bd73c
Diff:
Increase Visibility of Flink Test PipelineOptions
This fixes an issue where the package-private nature would cause an
exception
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/816a3bf1
Tree:
Update the Default Pipeline Runner
Select the InProcessRunner if it is on the classpath, and throw an
exception otherwise.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a3ffd510
Tree:
This closes #446
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/77494401
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/77494401
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/master c8ad2e7dd -> 774944014
Move GcsUtil TextIO Tests to TextIOTest
These tests are not a test of the DataflowRunner, nor any
DataflowRunner specific behavior, so they should be part of TextIOTest
Project:
Repository: incubator-beam
Updated Branches:
refs/heads/master 774944014 -> 2b269559f
Use TimestampedValue in DoFnTester
This removes the duplicate OutputElementWithTimestamp data structure.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit:
/diff/2b269559
Branch: refs/heads/master
Commit: 2b269559f3afa11a1defb74de8d33075fdc90274
Parents: 7749440 c627fa8
Author: Kenn Knowles <k...@kennknowles.com>
Authored: Tue Jun 14 20:18:19 2016 -0700
Committer: Kenn Knowles <k...@kennknowles.com>
Committed: Tue Jun 14 20:18:1
Add DoFnTester#peekOutputValuesInWindow
This permits DoFns that interact with windowing to test the windowed,
rather than overall output.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c627fa84
Tree:
This closes #391
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/cca2577c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/cca2577c
Diff:
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/0fef8e63/runners/core-java/src/test/java/org/apache/beam/sdk/util/ReduceFnTester.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/0fef8e63/runners/core-java/src/main/java/org/apache/beam/sdk/util/PushbackSideInputDoFnRunner.java
--
diff --git
Repository: incubator-beam
Updated Branches:
refs/heads/master 73862b422 -> e255cd6be
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/0fef8e63/sdks/java/core/src/test/java/org/apache/beam/sdk/util/ReduceFnTester.java
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/0fef8e63/sdks/java/core/src/test/java/org/apache/beam/sdk/util/ReduceFnRunnerTest.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/0fef8e63/sdks/java/core/src/main/java/org/apache/beam/sdk/util/ReduceFnRunner.java
--
diff --git
Directly instantiate SimpleDoFnRunner in its test suite
Previously, it went through a static utility class, creating
quasi-circular dependency.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/efaad322
Tree:
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/0fef8e63/sdks/java/core/src/main/java/org/apache/beam/sdk/util/WatermarkHold.java
--
diff --git
a/sdks/java/core/src/main/java/org/apache/beam/sdk/util/WatermarkHold.java
This closes #510
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e255cd6b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e255cd6b
Diff:
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/0fef8e63/sdks/java/core/src/main/java/org/apache/beam/sdk/util/GroupByKeyViaGroupByKeyOnly.java
--
diff --git
Repository: incubator-beam
Updated Branches:
refs/heads/master e255cd6be -> 741ef266f
Run Pipelines in tests that expect them
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/916bf3a8
Tree:
This closes #492
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/741ef266
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/741ef266
Diff:
This closes #509
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/73862b42
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/73862b42
Diff:
Remove temporary GroupAlsoByWindowViaWindowSetDoFn shim
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/2d563795
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/2d563795
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/master 3001804e3 -> 73862b422
Set runtime scope for Dataflow runner dep on 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/b52688f4
Repository: incubator-beam
Updated Branches:
refs/heads/master d9cdcadf5 -> 1a200a65d
Configure RunnableOnService tests for Spark runner, batch mode
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit:
This closes #294
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1a200a65
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1a200a65
Diff:
This closes #474
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/518b23c2
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/518b23c2
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/master 414bb4bc3 -> 518b23c2d
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/2bafda1d/runners/direct-java/src/main/java/org/apache/beam/runners/direct/TransformEvaluator.java
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/4649eebe/runners/direct-java/src/main/java/org/apache/beam/runners/direct/InMemoryWatermarkManager.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/4649eebe/runners/direct-java/src/test/java/org/apache/beam/runners/direct/DirectTimerInternalsTest.java
--
diff --git
Remove InProcess Prefixes
These prefixes are out of date with the rename of the runner. Most of
the prefixes are be droped in their entirety, as the classes are scoped
to the direct runner module.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit:
Rename InProcessPipelineRunner to DirectRunner
Completes BEAM-243
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/2bafda1d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/2bafda1d
Diff:
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/4649eebe/runners/direct-java/src/test/java/org/apache/beam/runners/direct/InProcessEvaluationContextTest.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/4649eebe/runners/direct-java/src/main/java/org/apache/beam/runners/direct/TransformExecutor.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/4649eebe/runners/direct-java/src/main/java/org/apache/beam/runners/direct/InProcessExecutor.java
--
diff --git
Repository: incubator-beam
Updated Branches:
refs/heads/master 518b23c2d -> f8c59bd6c
Fix type error in Eclipse
This type error occurs in my Eclipse installation. It apparently
does not bother the various JDKs we test with. But this is an
accurate typing, so it may help other Eclipse-using
Remove the DirectPipelineRunner from the Core 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/bf476e12
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/bf476e12
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/master 11eb9f65f -> 021fa1e5f
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/bf476e12/sdks/java/core/src/test/java/org/apache/beam/sdk/PipelineTest.java
--
Remove DoFnRunner from GroupAlsoByWindowsProperties
DoFnRunner is a runner implementation detail, and core SDK code should
instead use DoFnTester.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b31be38a
This closes #466
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/021fa1e5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/021fa1e5
Diff:
This closes #471
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/41fe8eec
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/41fe8eec
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/master 3b66f5919 -> 41fe8eecf
[Spark] Elide assigning windows when WindowFn is null
Previously, when translating a Window.Bound transform, the case
where the WindowFn was null was missed, resulting in a
NullPointerException.
Project:
This closes #468
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a60b58ef
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a60b58ef
Diff:
This closes #464
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/455aaed5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/455aaed5
Diff:
Fix overflow in ReduceFnRunner garbage collection times
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/dc60dc7c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/dc60dc7c
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/master 0a3425e77 -> 455aaed55
Add test for ReduceFnRunner GC time overflow
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/925264e3
Tree:
Added BigDecimal coder and tests.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f93c92cb
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/f93c92cb
Diff:
Add BigIntegerCoder and tests
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/91b8905a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/91b8905a
Diff:
Add basic WindowMatchersTest
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/edf11fa7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/edf11fa7
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/master f2d2ce5f4 -> 82ae661c5
Explode windows in DirectRunner's Window.into evaluator
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a3aa4c7f
Simple PaneInfo.toString() for interned constants
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d9bca25a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d9bca25a
Diff:
This closes #308
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/82ae661c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/82ae661c
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/master 41faee4f9 -> bf67d8edc
Remove TriggerBuilder backwards-compatibility adapter
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/244e8e85
Tree:
Repository: incubator-beam
Updated Branches:
refs/heads/master bf67d8edc -> bd21ead63
Use only WindowFn in TriggerTester
This change is preparatory for separating trigger syntax
from implementation.
Previously, the whole WindowingStrategy was passed in, but
not used. Since the tester is
This closes #528
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/bf67d8ed
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/bf67d8ed
Diff:
Remove references to multi-window representation from model
Some areas of the Beam model in the SDK allude to the use of a
compressed representation of an element along with the set
of windows it is assigned to. However, the model itself views
elements in different windows as fully independent,
Update test for GatherAllPanes
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ec1bb3a6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ec1bb3a6
Diff:
This closes #518
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ff72e27f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ff72e27f
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/testing [created] 0f944adc1
Just testing, do not merge
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0f944adc
Tree:
Undo
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a1e3d86d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a1e3d86d
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/master a91e11500 -> a13dd2910
Fix versions and artifact names in runner poms
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c168533e
Tree:
This closes #54
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6ba288d6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6ba288d6
Diff:
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/e5c7cf88/java8examples/src/main/java/com/google/cloud/dataflow/examples/complete/game/README.md
--
diff --git
Repository: incubator-beam
Updated Branches:
refs/heads/testing [deleted] 0f944adc1
Move Java 8 examples to their own module
This allows easy setting of the compiler source and target version to
1.8 without any fragile plugin configuration. It also allows the
import into Eclipse to easily set separate compliance levels, as this
is done per-Eclipse-project.
This parallels the
Repository: incubator-beam
Updated Branches:
refs/heads/master f8f3745a8 -> 4f91c2eae
Move Model Enforcements into the proper module
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/111e3932
Tree:
Repository: incubator-beam
Updated Branches:
refs/heads/master 9cc2c2b7f -> 17863c851
Exclude Eclipse .checkstyle files from RAT check
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/2ea54626
Tree:
This closes #81
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/17863c85
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/17863c85
Diff:
This closes #93
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0c47cad4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0c47cad4
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/master 6467afb74 -> 1451a0ec9
Fix up conflict markers
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1451a0ec
Tree:
Apply ModelEnforcement in the InProcessPipelineRunner
This ensures that user code does not violate the model.
Add a flag to control application of immutability enforcement. This flag
is enabled by default.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit:
1 - 100 of 1254 matches
Mail list logo