GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/4115
[BEAM-3170] support topicPartition in BeamKafkaTable
Follow this checklist to help us incorporate your contribution quickly and
easily:
- [ ] Make sure there is a [JIRA
issue](https
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/4101
[BEAM-3161] Cannot output with timestamp
R: @xumingming
CC: @takidau
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/XuMingmin/beam
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3848
[BEAM-2954] update shade configurations in extension/sql
Follow this checklist to help us incorporate your contribution quickly and
easily:
- [ ] Make sure there is a [JIRA
issue](https
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/3794
---
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3794
[TEST PR] to verify [BEAM-301]
Follow this checklist to help us incorporate your contribution quickly and
easily:
- [ ] Make sure there is a [JIRA
issue](https://issues.apache.org/jira
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3767
[BEAM-2809] update JavaDoc of BeamSortRel
R: @xumingming @takidau
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/XuMingmin/beam BEAM-2809
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3752
[BEAM-2798] rename simpleQuery to query and query to queryMulti
R: @takidau @xumingming
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/3606
---
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
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/3648
---
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
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/3716
---
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
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3716
[BEAM-2747] accept CombineFn as UDAF
Follow this checklist to help us incorporate your contribution quickly and
easily:
- [ ] Make sure there is a [JIRA
issue](https://issues.apache.org
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/3710
---
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
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/3707
---
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
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3710
[BEAM-2741] update JavaDoc for BeamRecord
R: @takidau @xumingming
Ps, the change of `BeamSqlUdfExpression` is to address the question in #3707
You can merge this pull request into a Git
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/3706
---
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
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3707
[BEAM-2748] accept SerializableFunction as UDF
R: @takidau @xumingming
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/XuMingmin/beam BEAM
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3706
[BEAM-2749] update BeamSqlExample
R: @takidau
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/XuMingmin/beam BEAM-2749
Alternatively you can
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/3692
---
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
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3692
[BEAM-2730] make BeamRecord an immutable type
@robertwb
Ps, some lines are expected to delete with #3691 and #3689
You can merge this pull request into a Git repository by running
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3691
[BEAM-2725] remove nullFields in BeamRecord
R: @robertwb
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/XuMingmin/beam BEAM-2725
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3689
[BEAM-2722] Remove redundant windowing information from the BeamRecord
itself
R: @robertwb
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/3675
---
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
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3675
[BEAM-2676] move BeamSqlRow and BeamSqlRowType to sdk/java/core
create a new PR to get rid of the huge rebase work after #3666.
Following the discussion in
[BEAM-2676](https
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/3633
---
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
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3648
sync-up from master branch
BEAM-2672 requires a new function added in #3628
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/apache/beam master
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3633
[BEAM-2676] move BeamSqlRow and BeamSqlRowType to sdk/java/core
It contains two parts:
1. remove SQL word in the name,
`BeamSqlRow` --> `BeamRow`
`BeamSqlRowType` --> `BeamR
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3614
[BEAM-2652] cleanup pom.xml
R: @kennknowles @rangadi
@rangadi I also update pom.xml in kafka-io as now kafka-client is shared in
multiple modules.
You can merge this pull request
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3606
Merge DSL_SQL to Master
Merge DSL_SQL feature branch back to master branch, with Beam SQL DSL
function is ready to use.
Resources:
1. thread in apache-beam-dev mail-list
https
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3605
[BEAM-2555] add README page in dsl/sql
1. remove README.md to keep align with other BEAM modules;
2. update usages in BeamSqlExample;
You can merge this pull request into a Git repository
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3603
redo PR 3553
Follow this checklist to help us incorporate your contribution quickly and
easily:
- [ ] Make sure there is a [JIRA
issue](https://issues.apache.org/jira/projects/BEAM
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3602
Revert "[BEAM-2610] This closes #3553"
This reverts commit ec494f675aa73fbdc7929f9592f33951941962b0, reversing
changes made to d89d1ee1a3085269cdf44ec50e29a95c8f43757b.
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/3569
---
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
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/3552
---
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
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/3560
---
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
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3569
[BEAM-2563] Add integration test for math operators
Add integration test for built-in MATH functions,
Misc:
1. no SQRT in Calcite, converted to POWER;
2. add DECIMAL
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3561
[BEAM-2609] refine UDF interface
A proposal solution for UDF interface.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/XuMingmin/beam BEAM
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/3553
---
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
GitHub user XuMingmin reopened a pull request:
https://github.com/apache/beam/pull/3553
[BEAM-2610] upgrade to version 2.2.0
As described in task
[BEAM-2610](https://issues.apache.org/jira/browse/BEAM-2610), this is the first
PR to do the job. Feel free to merge it if no mis
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3560
[BEAM-2562] Add integration test for logical operators
R: @xumingming @takidau @jbonofre
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/3553
---
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
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3554
[BEAM-2610] upgrade to version 2.2.0
placeholder for 2nd PR, may need update after #3553
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3553
[BEAM-2610] upgrade to version 2.2.0
As described in task
[BEAM-2610](https://issues.apache.org/jira/browse/BEAM-2610), this is the first
PR to do the job. Feel free to merge it if no mis
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/3491
---
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
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3552
[BEAM-2585] add math function RAND_INTEGER and RAND
R: @xumingming @takidau
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/XuMingmin/beam
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/3527
---
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
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/3477
---
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
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/3530
---
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
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3530
[BEAM-2574] test unsupported/invalid cases in DSL
R: @xumingming @takidau
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/XuMingmin/beam BEAM
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3527
[BEAM-2204] support TUMBLE/HOP/SESSION_START
*_START function is supported for TUMBLE/HOP/SESSION window, however *_END
is not available due to some issue with Calcite relational expressions, need
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3491
[BEAM-2520] add UDF/UDAF in BeamSql.query/simpleQuery
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/XuMingmin/beam BEAM-2520
Alternatively
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/3447
---
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
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3477
[BEAM-2527] Test queries on unbounded PCollections with BeamSql dsl API
R: @xumingming @takidau
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3447
[BEAM-2287] UDAF support
R: @xumingming @takidau
add an abstract class `BeamSqlUdaf` following the UDAF definition in
Calcite, also COUNT/SUM/AVG/MAX/MIN/ are rewritten with this new
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3427
[BEAM-2503] use static table name in BeamSql.simpleQuery
R: @takidau
As discussed in #3372, here's the part to use fixed table name
`PCOLLECTION` in `BeamSql.simpleQuery`.
You can merge
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/3372
---
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
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/3371
---
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
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3372
[BEAM-2446] restrict scope of BeamSqlEnv in dsl query
R: @xumingming @takidau
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/XuMingmin/beam
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3371
[BEAM-2452] Update filter/project/aggregation tests with BeamSql
R: @xumingming @takidau
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/3342
---
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
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/3340
---
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
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3340
[BEAM-2433] unify SQL/Sql words in class name
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title is formatted
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3323
upgrade to 2.1.0-SNAPSHOT
upgrade to version 2.1.0-SNAPSHOT in branch `DSL_SQL`.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/XuMingmin/beam
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3314
sync-up DSL_SQL from Master
pull latest code from `master` branch to `DSL_SQL` branch.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/apache
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/3250
---
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
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3250
[Beam-2010] expose programming interface
It's the DSL implementation described in [Apache Beam: design of DSL SQL
interface](https://docs.google.com/document/d
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/3137
---
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
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3138
[BEAM-2292] PCollection as a Table
add BeamPCollectionTable to create table from PCollection
Note that it changes the interface of `BaseBeamTable`, as a
`BeamPCollectionTable` doesn't
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3137
[BEAM-2288] Refine DSL interface
Refine DSL interface as design doc of BEAM-2010:
1. rename BeamSqlRunner to BeamSQLEnvironment;
2. Move pipeline as external parameter, to integrate
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/3135
---
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
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3136
[BEAM-2196] support UDF
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
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3135
[BEAM-2234] expose PCollection of each RelNode
Change the return of `buildBeamPipeline` to `PCollection`, this
helps to:
1). donot need to manage the upstream-downstream
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3067
[BEAM-2008] aggregation functions support
Support common-used aggregation functions in SQL, including:
`COUNT`, `SUM`, `AVG`, `MAX`, `MIN`
Be sure to do all of the following to help
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/2903
---
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
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/3039
[BEAM-2006] window support
Add support for aggregation: _global_, _HOP_, _TUMBLE_, _SESSION_, only
aggregation function `COUNT`
You can merge this pull request into a Git repository by running
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/2903
[BEAM-2006] window support
Add support for aggregation: global, `HOP`, `TUMBLE`, `SESSION`, only
aggregation function `COUNT`
Some other changes:
1. upgrade to Apache Calcite 1.12.0
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/2656
---
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
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/2878
Forward integrate from `master` to `DSL_SQL`
To fix the unit test failure
`org.apache.beam.examples.WordCountIT.testE2EWordCount`
You can merge this pull request into a Git repository by running
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/2339
---
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
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/2837
[BEAM-2134] expose AUTO_COMMIT to KafkaIO.read()
â¦e visible.
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam-site/pull/226
[BEAM-2078] add BeamSQL feature branch in site
create a new PR as previous #224 edited the wrong file.
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/2784
[BEAM-2125] update JavaDoc of BoundedWindow
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title is formatted
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam-site/pull/224
[BEAM-2078] add BeamSQL feature branch in site
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/XuMingmin/beam-site BEAM-2078
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/2656
[BEAM-2018] refine expression of Calcite method/function
In this PR, `BeamSQLFnExecutor` is introduced to replace
`BeamSQLSpELExecutor`, as the executor of `SqlOperator` expressions
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/2622
[BEAM-1917] add 'equal' function to Filter
a minor change to add `equal` in
[Filter.java](https://github.com/apache/beam/blob/master/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/2603
[BEAM-2019] Count.globally() requires default values for non-GlobalWindows
fix below error of Count.globally() when not using `GlobalWindows`:
```
Exception in thread "
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/2458
---
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
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/2530
[BEAM-301] Add a Beam SQL DSL
1. add `checkstyle` to `dsls` module, and update as indicated;
2. correct the package name from `org.beam.dsls.sql` to
`org.apache.beam.dsls.sql`;
You can merge
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/2479
---
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
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/2479
[BEAM-301] Add a Beam SQL DSL
The initial PR to setup skeleton of Beam SQL.
Pass `mvn verify` locally, a Jenkins job is required later for pre-commit
check.
You can merge this pull request
Github user XuMingmin closed the pull request at:
https://github.com/apache/beam/pull/2478
---
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
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/2478
Dsl sql init
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
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/2477
[BEAM-1921] expose connectionProperties in JdbcIO
Be sure to do all of the following to help us incorporate your contribution
quickly and easily:
- [ ] Make sure the PR title
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/2458
[Beam-1705]: add method in Pipeline to visualize the DAG
Add a method `visualizePipeline` in `Pipeline` to visualize data flow.
You can merge this pull request into a Git repository by running
GitHub user XuMingmin opened a pull request:
https://github.com/apache/beam/pull/2411
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
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
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
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 GroupByKey
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
1 - 100 of 107 matches
Mail list logo
