Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/2374
---
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 feature is
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/2374
Quickfix: JavaDoc for function `PaneInfo.getTiming()`
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title is
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam-site/pull/195
[BEAM-1797] add CoGroupByKey to chapter 'Using GroupByKey'
`CoGroupByKey` is the main component to create a JOIN operation in Beam
pipeline, add the usage to chapter `Using
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/2339
[BEAM-1805] a new option `asInnerJoin` for CoGroupByKey
*INNER_JOIN* is available with
[Join](https://github.com/apache/beam/blob/master/sdks/java/extensions/join-library/src/main/java/org/apache
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam-site/pull/188
[BEAM-1744] add code snippet in page Design_Your_Pipeline
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/XuMingmin/beam-site asf-site
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/2135
---
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 feature is
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/2205
BEAM-1661 shade guava in beam-sdks-java-io-jdbc
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title is
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/2203
BEAM-1660 withCoder() error in JdbcIO JavaDoc example
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title is
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/2135
BEAM-1514: change default timestamp in KafkaIO
I use Java reflection here to check if timestamp is available and get the
value, based on the performance test as below. As the function is called
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/2134
---
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 feature is
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/2134
Beam 1514
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:
`[BEAM-] Description
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/2069
BEAM-307: Upgrade/Test to Kafka 0.10
Run *KafkaIOTest.java* with `mvn test -Dkafka.clients.version=0.10.1.1`, or
`mvn test -Dkafka.clients.version=0.9.0.1` for either Kafka client version
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/2044
[BEAM-1407] Support multiple Kafka client in KakaIO
PR for *[Solution 3. Rewrite Consumer method call at runtime].* SpEL is
used to hide the difference of Kafka client 0.9/0.10
101 - 113 of 113 matches
Mail list logo
