http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/7f201cbb/sdks/python/apache_beam/runners/inprocess/inprocess_watermark_manager.py
--
diff --git
a/sdks/python/apache_beam/runners/inprocess/inprocess_watermark_manager.py
Renames InprocessPipelineRunner to DirectPipelineRunner and removes the
existing DirectPipelineRunner. Renamed the folder to direct to keep all
related files in the same folder. Removed inprocess prefix from
file names/class names/comments.
DiskCachedPipelineRunner - not used, and it was a
Repository: incubator-beam
Updated Branches:
refs/heads/python-sdk 93a95d68b -> aa603872c
Closes #1240
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/aa603872
Tree:
Github user robertwb closed the pull request at:
https://github.com/apache/incubator-beam/pull/1274
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Implement key range tracker.
This will be useful for Bigtable and other key-based sources.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/54545c43
Tree:
Closes #1274
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/93a95d68
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/93a95d68
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/python-sdk 8f4551c4e -> 93a95d68b
Generic ordered position range tracker.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4768227c
Tree:
Github user robertwb closed the pull request at:
https://github.com/apache/incubator-beam/pull/1286
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Closes #1286
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8f4551c4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8f4551c4
Diff:
s/typecoders.py
@@ -125,6 +125,9 @@ class CoderRegistry(object):
# In some old code, None is used for Any.
# TODO(robertwb): Clean this up.
pass
+ elif typehint is object:
+# We explicitly want the fallback coder.
+pass
elif isin
Fix cythonization
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ef7e9727
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ef7e9727
Diff:
Closes #1237
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4bf84851
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4bf84851
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/python-sdk 32d719911 -> 4bf848511
Add support for proto coder
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e1e4b7ce
Tree:
DeterministicCoder rename
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5d14b080
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5d14b080
Diff:
GitHub user robertwb opened a pull request:
https://github.com/apache/incubator-beam/pull/1286
Don't default to PickleCoder for sources.
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title
Repository: incubator-beam
Updated Branches:
refs/heads/python-sdk a6e104d6d -> 32d719911
Closes #1250
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/32d71991
Tree:
Document the input and output of type conversions
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/456f9263
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/456f9263
Diff:
Make the BQ input for dataflow runner and local runner is identical for time
related types
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d66cb174
Tree:
Adding unit 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/b30208be
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b30208be
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/python-sdk 96c228675 -> a6e104d6d
Checking for integer types in json conversion
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3321064e
Tree:
Closes #1273
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a6e104d6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a6e104d6
Diff:
GitHub user robertwb opened a pull request:
https://github.com/apache/incubator-beam/pull/1274
Implement key range tracker.
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title is formatted like
Closes #1245
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7270471b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7270471b
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/python-sdk 9d2acc98e -> 7270471bf
Updated readme according to BEAM-693
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/43740a47
Tree:
BEAM-873 Support for BigQuery 2 SQL
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0a339653
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0a339653
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/python-sdk 7270471bf -> 96c228675
Closes #1242
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/96c22867
Tree:
Add unittests for BQ 2.0
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ce3f1726
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ce3f1726
Diff:
Closes #1267
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9d2acc98
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9d2acc98
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/python-sdk 7e870613f -> 9d2acc98e
Fixes two bugs in avroio_test 'test_corrupted_file'.
(1) Updates test to perform corruption properly (setting 'A' and 'B').
(2) Removes an invalid usage of bytearray().
Project:
GitHub user robertwb opened a pull request:
https://github.com/apache/incubator-beam/pull/1253
Optimize WindowedValueCoder
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title is formatted like
+ b/sdks/python/apache_beam/coders/coder_impl.py
@@ -152,6 +152,14 @@ class CallbackCoderImpl(CoderImpl):
def estimate_size(self, value, nested=False):
return self._get_nested_size(self._size_estimator(value), nested)
+ def get_estimated_size_and_observables(self, value, nested=False):
+
Closes #1244
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7e870613
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7e870613
Diff:
Github user robertwb closed the pull request at:
https://github.com/apache/incubator-beam/pull/1241
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Repository: incubator-beam
Updated Branches:
refs/heads/python-sdk 13dd9ff49 -> b33fdfdad
Closes #1235
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b33fdfda
Tree:
Improvements related to size estimation.
Updates FileBasedSource so that size estimation of glob patterns that expand
into a large number of files is done using sampling.
Updates Dataflow runner to set estimated sizes of sources when submitting jobs.
Project:
orms/timeutil.py
index 749cda1..5453b20 100644
--- a/sdks/python/apache_beam/transforms/timeutil.py
+++ b/sdks/python/apache_beam/transforms/timeutil.py
@@ -22,14 +22,16 @@ from __future__ import absolute_import
from abc import ABCMeta
from abc import abstractmethod
-import datetime
-
-
Repository: incubator-beam
Updated Branches:
refs/heads/python-sdk 979e299c7 -> 13dd9ff49
Move Timestamp and related classes into apache_beam/utils.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit:
Closes #1241
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/13dd9ff4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/13dd9ff4
Diff:
GitHub user robertwb opened a pull request:
https://github.com/apache/incubator-beam/pull/1241
Windowed value coder
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title is formatted like
Github user robertwb closed the pull request at:
https://github.com/apache/incubator-beam/pull/1224
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Closes #1224
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/979e299c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/979e299c
Diff:
Several fixes to coder size estimates.
The coder returned in alongside the observable must be the coder
of the observable's elements, not the coder of the observable
itself.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit:
Repository: incubator-beam
Updated Branches:
refs/heads/python-sdk 03c3c7074 -> 979e299c7
Implement size observation for FastPrimitivesCoderImpl.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/fba0e91b
Github user robertwb closed the pull request at:
https://github.com/apache/incubator-beam/pull/1223
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Adds IterableCoder, fast coding for sets, booleans.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9dd16455
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9dd16455
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/python-sdk ef01140d6 -> 03c3c7074
Closes #1223
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/03c3c707
Tree:
Repository: incubator-beam
Updated Branches:
refs/heads/python-sdk 00b17e542 -> ef01140d6
Improving error of missing sdk_location
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a68c2461
Tree:
Pushing check down. Rewritting error message
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/32f3214c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/32f3214c
Diff:
Closes #1200
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ef01140d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ef01140d
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/python-sdk 811858bca -> 00b17e542
Compare display data items, not dicts.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9d1cfa1a
Tree:
Github user robertwb closed the pull request at:
https://github.com/apache/incubator-beam/pull/1211
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
GitHub user robertwb opened a pull request:
https://github.com/apache/incubator-beam/pull/1223
Adds IterableCoder, fast coding for sets, booleans.
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR
Removing superfluous TODO after unittest is passing
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/595bd0d5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/595bd0d5
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/python-sdk 03662da9d -> 811858bca
Closes #1209
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/811858bc
Tree:
Repository: incubator-beam
Updated Branches:
refs/heads/python-sdk 57f03f793 -> 03662da9d
Addressing comments
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1d478dd4
Tree:
Closes #1112
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/03662da9
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/03662da9
Diff:
Moving files. Using DisplayDataItem to enable dictionaries to be used as
display data
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d864d968
Tree:
Adding documentation. Setting Python classes as STRING types.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/bfcff012
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/bfcff012
Diff:
Laying down infrastructure for static display data
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/07885c86
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/07885c86
Diff:
Adding license text to all files. Fixing one lint issue. Refactoring runner_test
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/11022016
Tree:
[BEAM-809] Create a KryoRegistrator for the SparkRunner.
Use Class#getName() instead of canonicalName().
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/13b83858
Tree:
Remove use of OldDoFn from some DirectRunner 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/3d086857
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/3d086857
Diff:
[BEAM-813] support metadata in Avro sink
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/eba099f5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/eba099f5
Diff:
This closes #1178
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/13af296d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/13af296d
Diff:
Improve teardown behavior in DoFnLifecycleManager
Use Cache invalidation hooks to teardown DoFns that are no longer in the
cache. Ensure that remove() and removeAll() report thrown exceptions
even though the exceptions are not thrown by the LoadingCache.
Project:
Streamline Travis CI build
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5c558e6f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5c558e6f
Diff:
Add utility to handle JSON option manipulation
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/35244a68
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/35244a68
Diff:
This closes #1174
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c03e3e92
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c03e3e92
Diff:
Closes #1181
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/09a80ecb
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/09a80ecb
Diff:
Remove unused GroupAlsoByWindowsDoFn.createDefault
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5ce3aac2
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5ce3aac2
Diff:
Revert "Fix invalid snapshot repo in Travis CI's maven settings.xml"
This reverts commit fbc23ed9234088c9d88bf88b19a3a4d6d5e52446.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3c71e4da
Tree:
This closes #1173
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/25102f79
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/25102f79
Diff:
[BEAM-799] Support GroupByKey directly.
Remove runner override for GroupByKey.
Avoid NPE if no sideInputs are available in reader.
Handle CombineFn with or without context.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit:
Add experimental ServiceAccount option
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/60907b21
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/60907b21
Diff:
Closes #1135
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d285e85d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d285e85d
Diff:
This closes #1158
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0ec956d3
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0ec956d3
Diff:
Encode bundle elements in the DirectRunner
This ensures that any changes that are caused when an element is encoded
and decoded is caught within the pipeline.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit:
Closes #1180
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7091a012
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7091a012
Diff:
Remove pieces of Trigger now owned by TriggerStateMachine
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1eff320d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1eff320d
Diff:
Closes #1105
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c94b8eac
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c94b8eac
Diff:
This closes #1185
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9f30b21a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9f30b21a
Diff:
Closes #1182
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f2fe1ae4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/f2fe1ae4
Diff:
[BEAM-816] Aggregators are not properly named when reported to Graphite.
Added NamedAggregatorTest.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6db94249
Tree:
[BEAM-658] Support Read.Unbounded primitive.
Changed mapSourceFunction to use scala's native Option.
Upgrade to kryo-serializers 0.39 that provides support for ReverseList (used by
Top).
Better logging.
Allow a longer read time-frame for read in tests.
Assert initial parallelism is gerater
Add default version for beam-sdks-java-io-kafka
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c8895338
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c8895338
Diff:
This closes #1163
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7abdcbfb
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7abdcbfb
Diff:
Use project-wise version in SparkRunner dep on KafkaIO
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9d6598d3
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9d6598d3
Diff:
pom.xml: make Dataflow runner like every other runner
Pom dependencies no longer require it to be treated specially.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6291a6f6
Tree:
Merge branch 'master' into py_merge_master
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/02b5b4c9
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/02b5b4c9
Diff:
update parent pom version in python/pom.xml
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/654b848b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/654b848b
Diff:
Remove checked exceptions from PipelineResult.waitUntilFinish interface.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1559a7f4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1559a7f4
Port some example utils from OldDoFn to DoFn
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3bec5e03
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/3bec5e03
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/python-sdk c37b89ec7 -> 57f03f793
Closes #1168
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/44b9f4eb
Tree:
Closes #1198
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/57f03f79
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/57f03f79
Diff:
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/1eff320d/sdks/java/core/src/test/java/org/apache/beam/sdk/util/FinishedTriggersProperties.java
--
diff --git
Limit version ranges for dependencies in the 0.* version range
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8dd1bd8c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8dd1bd8c
Diff:
Repository: incubator-beam
Updated Branches:
refs/heads/python-sdk 2b8d9f704 -> c37b89ec7
Pin the version of dependencies
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b26cb651
Tree:
Closes #1148
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c37b89ec
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c37b89ec
Diff:
Github user robertwb closed the pull request at:
https://github.com/apache/incubator-beam/pull/1132
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user robertwb closed the pull request at:
https://github.com/apache/incubator-beam/pull/1131
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
101 - 200 of 445 matches
Mail list logo
