[
https://issues.apache.org/jira/browse/BEAM-469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15768525#comment-15768525
]
ASF GitHub Bot commented on BEAM-469:
-
GitHub user dhalperi opened a pull request:
GitHub user dhalperi opened a pull request:
https://github.com/apache/incubator-beam/pull/1680
[BEAM-XXX] Make KVCoder more efficient by removing unnecessary nesting
See [BEAM-469] for more information about why this is
correct.
You can merge this pull request into a Git reposit
[
https://issues.apache.org/jira/browse/BEAM-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15768483#comment-15768483
]
ASF GitHub Bot commented on BEAM-1201:
--
GitHub user dhalperi opened a pull request:
[
https://issues.apache.org/jira/browse/BEAM-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Halperin updated BEAM-1201:
--
Labels: backward-incompatible (was: )
> Remove producesSortedKeys from Source
>
[
https://issues.apache.org/jira/browse/BEAM-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Halperin updated BEAM-1201:
--
Summary: Remove producesSortedKeys from BoundedSource (was: Remove
producesSortedKeys from Sourc
GitHub user dhalperi opened a pull request:
https://github.com/apache/incubator-beam/pull/1679
[BEAM-1201] Remove BoundedSource.producesSortedKeys
R: @jkff
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/dhalperi/incubator-beam
r
[
https://issues.apache.org/jira/browse/BEAM-469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15768476#comment-15768476
]
Daniel Halperin commented on BEAM-469:
--
Sorry I missed this JIRA comment, [~mariusz8901
[
https://issues.apache.org/jira/browse/BEAM-646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15768470#comment-15768470
]
ASF GitHub Bot commented on BEAM-646:
-
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-beam/pull/1582
---
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, or if the featur
Repository: incubator-beam
Updated Branches:
refs/heads/master 57d9bbd79 -> 7984fe3fc
Add Parameters to finishSpecifying
Remove the need to use getProducingTransformInternal in TypedPValue.
Ensure that all nodes are finished specifying before a call to
TransformHierarchy#visit. This ensures t
Use CountingSource in ForceStreamingTest
Removes the requirement to have a FakeUnboundedSource, plus the read is
fully specified.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b053be46
Tree: http://git-wip
This closes #1582
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7984fe3f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7984fe3f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam
[
https://issues.apache.org/jira/browse/BEAM-1112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15768461#comment-15768461
]
ASF GitHub Bot commented on BEAM-1112:
--
Github user markflyhigh closed the pull reques
[
https://issues.apache.org/jira/browse/BEAM-1112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15768462#comment-15768462
]
ASF GitHub Bot commented on BEAM-1112:
--
GitHub user markflyhigh reopened a pull reques
GitHub user markflyhigh reopened a pull request:
https://github.com/apache/incubator-beam/pull/1639
[BEAM-1112] Python E2E Test Framework And Wordcount E2E Test
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [x] Make su
Github user markflyhigh closed the pull request at:
https://github.com/apache/incubator-beam/pull/1639
---
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, or if the f
Repository: incubator-beam
Updated Branches:
refs/heads/python-sdk bb09c07b6 -> 409d067b3
Add support for date partitioned table names
These names have the format "tablename$mmdd". Previously the dollar
sign caused this to be deemed invalid.
Project: http://git-wip-us.apache.org/repos/a
Closes #1534
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/409d067b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/409d067b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff
Repository: incubator-beam
Updated Branches:
refs/heads/python-sdk 3454d691f -> bb09c07b6
Fixing inconsistencies in PipelineOptions
The following options have changed:
* job_name - Default is 'beamapp-username-date-microseconds'. Test was added.
* staging_location and temp_location - staging_
Closes #1526
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/bb09c07b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/bb09c07b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff
Thomas Groh created BEAM-1202:
-
Summary: Coders should have meaningful equals methods
Key: BEAM-1202
URL: https://issues.apache.org/jira/browse/BEAM-1202
Project: Beam
Issue Type: Bug
C
[
https://issues.apache.org/jira/browse/BEAM-1202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Groh updated BEAM-1202:
--
Assignee: (was: Davor Bonaci)
> Coders should have meaningful equals methods
> --
Daniel Halperin created BEAM-1201:
-
Summary: Remove producesSortedKeys from Source
Key: BEAM-1201
URL: https://issues.apache.org/jira/browse/BEAM-1201
Project: Beam
Issue Type: Improvement
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: http://git-wip-us.apa
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 In
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: http://git
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: http://git-wip-us.apache.
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: http://git-wip
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: http://git-wip-us.apach
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: http://git-wip-
ExecutionContext and related classes to runners-core
Update Dataflow worker to beam-master-20161221
Require TimeDomain to delete a timer
Provide local tags in PInput, POutput expansions
Remove deprecated InMemoryTimerInternals from SDK
Remove deprecated AggregatorFactory from SDK
Update Dataflow
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: http://
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: http://git-wip
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: http://git-wip-us.apa
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: http://git-wip-us.ap
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: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-beam/pull/1676
---
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, or if the featur
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: http://git-wip-us.apache.org
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: http://git-wip-us.ap
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: http://git-wip-us.apache.org/r
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: http://git-wip-us.
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: http://git-wip-us.apache.org/repos/asf/incubator-bea
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: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree
Migrated the beam-runners-direct-java 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/09c404a6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/09c404a6
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
a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/CreateTest
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: http://git-wip-us.apache.org/repos/asf/incubator-be
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: http://git-wi
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: http://git-wip-us.apache
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 Test
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: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7e
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/9f1d3d15
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9f1d3d15
Diff: http://git-wip-us.apa
Propagate key through ParDo if DoFn is key-preserving
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d040b7f6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d040b7f6
Diff: http://git-wip-us
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: http://git-wip-us.apache.org/repos/asf/incubator-beam/tr
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:
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
---
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: http://git-wip-u
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: http://git-wip-us.apache.org/repos/asf/incubator-beam
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: http://git-wip-us.apache.org/repos
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: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/950aa7e
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 do
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
D
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: htt
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 KeyedPV
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
Di
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: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4b2
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: http://git-wip-us.apa
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: http://git-wip-us.apache.org/repos/asf/incubator-beam/co
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: http://git-wip-us.apache.o
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: http://git-wip-us
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: http://git-wip-us.apache.or
[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: http://git-wip-us.apache.org/repos/asf/incubator-b
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: http://git-wip-us.apac
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: ht
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: http://git-wip-us.apache.org/repos/asf/inc
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: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/fce4f65
[
https://issues.apache.org/jira/browse/BEAM-1198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15768387#comment-15768387
]
ASF GitHub Bot commented on BEAM-1198:
--
GitHub user kennknowles opened a pull request:
GitHub user kennknowles opened a pull request:
https://github.com/apache/incubator-beam/pull/1678
[BEAM-1198, BEAM-846, BEAM-260] Refactor Dataflow translator to decouple
input and output graphs more easily
Be sure to do all of the following to help us incorporate your contribution
[
https://issues.apache.org/jira/browse/BEAM-1198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kenneth Knowles reassigned BEAM-1198:
-
Assignee: Kenneth Knowles
> ViewFn: explicitly decouple runner materialization of side inp
GitHub user tgroh opened a pull request:
https://github.com/apache/incubator-beam/pull/1677
Add a Test for Flatten with Heterogeneous Coders
Add a category, and suppress in the Flink and Apex runners
Be sure to do all of the following to help us incorporate your contribution
GitHub user aaltay opened a pull request:
https://github.com/apache/incubator-beam/pull/1676
Merge remote-tracking branch 'origin/master' into python-sdk
There are frequent Apex runner failures the python-sdk branch, bringing up
pom.xml changes to update those.
You can merge this
Luke Cwik created BEAM-1200:
---
Summary: PubsubIO should allow for a user to supply the function
which computes the watermark that is reported
Key: BEAM-1200
URL: https://issues.apache.org/jira/browse/BEAM-1200
[
https://issues.apache.org/jira/browse/BEAM-1117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15768294#comment-15768294
]
ASF GitHub Bot commented on BEAM-1117:
--
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-beam/pull/1669
---
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, or if the featur
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: http://git-wip
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: http://git-wip-us.apach
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: http://git-wip-us.apa
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: http://git-wip-us.ap
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 In
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: http://git-wip-us.apa
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: http
[
https://issues.apache.org/jira/browse/BEAM-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15768284#comment-15768284
]
ASF GitHub Bot commented on BEAM-1194:
--
Github user dhalperi closed the pull request a
[
https://issues.apache.org/jira/browse/BEAM-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15768285#comment-15768285
]
ASF GitHub Bot commented on BEAM-1194:
--
GitHub user dhalperi reopened a pull request:
Github user dhalperi closed the pull request at:
https://github.com/apache/incubator-beam/pull/1671
---
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, or if the feat
GitHub user dhalperi reopened a pull request:
https://github.com/apache/incubator-beam/pull/1671
[BEAM-1194] Add DataflowLocationIT
Opening PR to test.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/dhalperi/incubator-beam traili
GitHub user staslev opened a pull request:
https://github.com/apache/incubator-beam/pull/1675
[Beam-1186] Migrating the remaining tests to use TestPipeline as a JUnit
rule.
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
[
https://issues.apache.org/jira/browse/BEAM-1112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15768212#comment-15768212
]
ASF GitHub Bot commented on BEAM-1112:
--
Github user markflyhigh closed the pull reques
Github user markflyhigh closed the pull request at:
https://github.com/apache/incubator-beam/pull/1639
---
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, or if the f
Thomas Groh created BEAM-1199:
-
Summary: Condense recordAsOutput, finishSpecifyingOutput from
POutput
Key: BEAM-1199
URL: https://issues.apache.org/jira/browse/BEAM-1199
Project: Beam
Issue Type
[
https://issues.apache.org/jira/browse/BEAM-1112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15768213#comment-15768213
]
ASF GitHub Bot commented on BEAM-1112:
--
GitHub user markflyhigh reopened a pull reques
GitHub user markflyhigh reopened a pull request:
https://github.com/apache/incubator-beam/pull/1639
[BEAM-1112] Python E2E Test Framework And Wordcount E2E Test
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [x] Make su
1 - 100 of 226 matches
Mail list logo