[beam] 02/02: fix type error

2018-02-27 Thread xumingming
This is an automated email from the ASF dual-hosted git repository. xumingming pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit a7501289a23e2d8a3a7e5a3b9f5e920702d4d634 Author: mingmxu AuthorDate: Mon Feb 26 23:39:08 2018 -0800 fix type

[beam] branch master updated (8a39c80 -> a750128)

2018-02-27 Thread xumingming
This is an automated email from the ASF dual-hosted git repository. xumingming pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 8a39c80 Merge pull request #4695: Add To/From Proto Round Trip for ExecutableStage new 880caef @Parameter

[beam] 01/02: @Parameter annotation does not work for UDFs in Beam SQL

2018-02-27 Thread xumingming
This is an automated email from the ASF dual-hosted git repository. xumingming pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 880caef3fc17295f817648ccdffe369c2dc63fa1 Author: mingmxu AuthorDate: Mon Feb 26 15:42:55 2018 -0800 @Parameter

[beam] 01/02: add setup/teardown for BeamSqlSeekableTable.

2018-02-26 Thread xumingming
This is an automated email from the ASF dual-hosted git repository. xumingming pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit b0991a47a0e1a7bba416be1c0b3781c298966731 Author: mingmxu AuthorDate: Sun Feb 25 22:14:25 2018 -0800 add setup

[beam] 02/02: rename method as suggested and declare as default methods.

2018-02-26 Thread xumingming
This is an automated email from the ASF dual-hosted git repository. xumingming pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit dbaf09838c5d064fdd6d953b91ad9a1ce61af72b Author: mingmxu AuthorDate: Mon Feb 12 08:02:31 2018 -0800 rename

[beam] branch master updated (2b70d60 -> dbaf098)

2018-02-26 Thread xumingming
This is an automated email from the ASF dual-hosted git repository. xumingming pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 2b70d60 Merge pull request #4731: [BEAM-3732] Fix broken maven profiles new b0991a4 add setup/teardown for

[beam] branch master updated (c8585fa -> 35570f1)

2017-12-02 Thread xumingming
This is an automated email from the ASF dual-hosted git repository. xumingming pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from c8585fa This closes #4198 add 19e8159 convert JOIN as LOOKUP add c84e3f2 add BeamSqlSeekableTable to

[beam] 01/01: Merge pull request #4196 from XuMingmin/BEAM-3171

2017-12-02 Thread xumingming
This is an automated email from the ASF dual-hosted git repository. xumingming pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 35570f1accfd2e9ef04421c9f02b6cdfcb7c95f4 Merge: c8585fa c84e3f2 Author: James Xu AuthorDate: Sat Dec 2 16:53:17 2017

[beam] 01/02: [BEAM-3238][SQL] Move Coders to map in BeamRecordSqlType

2017-11-28 Thread xumingming
This is an automated email from the ASF dual-hosted git repository. xumingming pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit e2c3de092b0a7a5bbfcb5b7797984d5f4bd10138 Author: Anton Kedin AuthorDate: Wed Nov 22 16:04:05 2017 -0800 [BEAM

[beam] branch master updated (27f505e -> 2eb7de0)

2017-11-28 Thread xumingming
This is an automated email from the ASF dual-hosted git repository. xumingming pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 27f505e Merge pull request #4095 from rniemo-g/master new e2c3de0 [BEAM-3238][SQL] Move Coders to map in

[beam] 02/02: [BEAM-3238][SQL] Add BeamRecordSqlTypeBuilder

2017-11-28 Thread xumingming
This is an automated email from the ASF dual-hosted git repository. xumingming pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 2eb7de0fe6e96da9805fc827294da1e1329ff716 Author: Anton Kedin AuthorDate: Wed Nov 22 19:17:21 2017 -0800 [BEAM

[2/2] beam git commit: This closes #4115

2017-11-13 Thread xumingming
This closes #4115 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2b4a6b5d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2b4a6b5d Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2b4a6b5d Branch: refs/heads/maste

[1/2] beam git commit: support topicPartition in BeamKafkaTable

2017-11-13 Thread xumingming
Repository: beam Updated Branches: refs/heads/master acfab8965 -> 2b4a6b5d5 support topicPartition in BeamKafkaTable Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/92b3a9ac Tree: http://git-wip-us.apache.org/repos/asf/beam/

[2/2] beam git commit: This closes #4101

2017-11-08 Thread xumingming
This closes #4101 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4451d556 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4451d556 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/4451d556 Branch: refs/heads/maste

[1/2] beam git commit: change `withAllowedTimestampSkew`

2017-11-08 Thread xumingming
Repository: beam Updated Branches: refs/heads/master 867d81684 -> 4451d5566 change `withAllowedTimestampSkew` Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4a5741f2 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4a

[1/2] beam git commit: [BEAM-2203] Implement 'timestamp - interval'

2017-11-07 Thread xumingming
Repository: beam Updated Branches: refs/heads/master 299429394 -> e0166ceb6 [BEAM-2203] Implement 'timestamp - interval' Move TIMESTAMPDIFF implementation into BeamSqlTimestampMinusTimestampExpression, add BeamSqlTimestampMinusIntervalExpression Project: http://git-wip-us.apache.org/repos/

[2/2] beam git commit: This closes #4082

2017-11-07 Thread xumingming
This closes #4082 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e0166ceb Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e0166ceb Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e0166ceb Branch: refs/heads/maste

[1/2] beam git commit: [BEAM-2203] Implement TIMESTAMPDIFF()

2017-11-07 Thread xumingming
Repository: beam Updated Branches: refs/heads/master 269bf8946 -> f80bf2fdf [BEAM-2203] Implement TIMESTAMPDIFF() Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4fe7480a Tree: http://git-wip-us.apache.org/repos/asf/beam/tre

[2/2] beam git commit: This closes #4065

2017-11-07 Thread xumingming
This closes #4065 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f80bf2fd Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f80bf2fd Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f80bf2fd Branch: refs/heads/maste

[GitHub] beam pull request #4041: [BEAM-2528] BeamSQL DDL :: CreateTable

2017-10-26 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/4041 [BEAM-2528] BeamSQL DDL :: CreateTable I started this PR as an initial attempt to implement the BeamSQL `create table` statement. The implementation might not be so mature, but I hope this

[GitHub] beam pull request #3481: [BEAM-2528] BeamSql: DDL: create table

2017-10-26 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3481 ---

[GitHub] beam pull request #3708: [BEAM-2740] introduce the new InnerBeamSqlEnv/BeamS...

2017-08-15 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3708 --- 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] beam pull request #3702: [BEAM-2744] rename BeamRecordType#size()

2017-08-11 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3702 --- 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] beam pull request #3700: [BEAM-2745] add BeamRecordSqlType.getFieldTypeByInd...

2017-08-09 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3700 --- 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] beam pull request #3708: [BEAM-2740] introduce the new InnerBeamSqlEnv/BeamS...

2017-08-09 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3708 [BEAM-2740] introduce the new InnerBeamSqlEnv/BeamSqlEnv Summary: * Simplified `BeamSqlEnv`: now you can only register UDF/UDAF in `BeamSqlEnv`, and `BeamSqlEnv` just record the udfName

[GitHub] beam pull request #3699: [BEAM-2742] change Field type from primitives to bo...

2017-08-08 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3699 --- 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] beam pull request #3704: [BEAM-2733] update javadoc for BeamSql

2017-08-08 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3704 --- 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] beam pull request #3704: [BEAM-2733] update javadoc for BeamSql

2017-08-08 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3704 [BEAM-2733] update javadoc for BeamSql Summary: * `Exception` declaration are removed from `BeamSql.query ()` * Added javadoc to explain when the sql query use a non-exist table、a

[GitHub] beam pull request #3702: [BEAM-2744] rename BeamRecordType#size()

2017-08-08 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3702 [BEAM-2744] rename BeamRecordType#size() Summary: * BeamRecord.size() -> BeamRecord.getFieldCount() * BeamRecordType.size() -> BeamRecordType.getFieldCount() *

[GitHub] beam pull request #3700: [BEAM-2745] add BeamRecordSqlType.getFieldTypeByInd...

2017-08-07 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3700 [BEAM-2745] add BeamRecordSqlType.getFieldTypeByIndex() Summary: * BeamSqlRecordType -> BeamRecordSqlType * fieldsName -> fieldNames * fieldsType -> fieldTypes

[GitHub] beam pull request #3699: [BEAM-2742] change Field type from primitives to bo...

2017-08-07 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3699 [BEAM-2742] change Field type from primitives to boxed types change Field type of `BeamRecord` from primitive types to boxed types, and removed `isNull` method. You can merge this pull request

[GitHub] beam pull request #3666: [BEAM-2441] move dsls/sql to sdks/java/extensions/s...

2017-07-31 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3666 [BEAM-2441] move dsls/sql to sdks/java/extensions/sql R: @XuMingmin @takidau You can merge this pull request into a Git repository by running: $ git pull https://github.com/xumingming/beam

[GitHub] beam pull request #3583: [BEAM-2613] add integration test for comparison ope...

2017-07-19 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3583 --- 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] beam pull request #3571: [BEAM-2621] BeamSqlRecordType -> BeamSqlRowType

2017-07-18 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3571 --- 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] beam pull request #3570: [BEAM-2565] add integration test for conditional fu...

2017-07-18 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3570 --- 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] beam pull request #3547: [BEAM-2561] add integration test for date functions

2017-07-18 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3547 --- 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] beam pull request #3583: [BEAM-2613] add integration test for comparison ope...

2017-07-17 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3583 [BEAM-2613] add integration test for comparison operators Summary: 1. added integration test for comparison operators. 2. refactored comparison operator expressions into a separate

[GitHub] beam pull request #3571: [BEAM-2621] BeamSqlRecordType -> BeamSqlRowType

2017-07-17 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3571 [BEAM-2621] BeamSqlRecordType -> BeamSqlRowType @XuMingmin @jbonofre @takidau You can merge this pull request into a Git repository by running: $ git pull https://github.com/xumingming/b

[GitHub] beam pull request #3570: [BEAM-2565] add integration test for conditional fu...

2017-07-17 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3570 [BEAM-2565] add integration test for conditional functions @XuMingmin @jbonofre @takidau You can merge this pull request into a Git repository by running: $ git pull https://github.com

[GitHub] beam pull request #3557: [BEAM-2560] Add integration test for arithmetic ope...

2017-07-13 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3557 [BEAM-2560] Add integration test for arithmetic operators. Re-implemented the arithmetic operators & refactored string functions integration test to utilize `ExpressionChecker`. You can m

[GitHub] beam pull request #3532: [BEAM-2564] add integration test for string functio...

2017-07-12 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3532 --- 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] beam pull request #3506: [BEAM-2550] add UnitTest for JOIN in DSL

2017-07-12 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3506 --- 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] beam pull request #3547: [BEAM-2561] add integration test for date functions

2017-07-11 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3547 [BEAM-2561] add integration test for date functions R: @XuMingmin @takidau there are some duplications with PR #3532 , will be some refactor after #3532 is merged. You can merge this

[GitHub] beam pull request #3532: [BEAM-2564] add integration test for string functio...

2017-07-10 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3532 [BEAM-2564] add integration test for string functions Add integration test for string functions and fixed a bug in `BeamSqlTrimExpression`. You can merge this pull request into a Git repository

[GitHub] beam pull request #3506: [BEAM-2550] add UnitTest for JOIN in DSL

2017-07-05 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3506 [BEAM-2550] add UnitTest for JOIN in DSL @XuMingmin @takidau I have only tested `bounded vs bounded` join scenario, since we already have enumerated every cases like `bounded vs bounded

[GitHub] beam pull request #3478: [BEAM-2515] BeamSql: refactor the MockedBeamSqlTabl...

2017-07-05 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3478 --- 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] beam pull request #3481: [BEAM-2528] BeamSql: DDL: create table

2017-06-30 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3481 [BEAM-2528] BeamSql: DDL: create table I started this PR as an initial attempt to implement the `create table` statement. The implementation might not be so mature, but I hope this could be a

[GitHub] beam pull request #3478: [BEAM-2515] BeamSql: refactor the MockedBeamSqlTabl...

2017-06-30 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3478 [BEAM-2515] BeamSql: refactor the MockedBeamSqlTable and related tests Summary: * rename `MockedBeamSqlTable` to `MockedBoundedTable` * Use the `RowsBuilder` to build rows in Unit

[GitHub] beam pull request #3277: [BEAM-2193] implement join

2017-06-29 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3277 --- 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] beam pull request #3377: [BEAM-2443] apply AutoValue to BeamSqlRecordType

2017-06-16 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3377 --- 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] beam pull request #3377: [BEAM-2443] apply AutoValue to BeamSqlRecordType

2017-06-15 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3377 [BEAM-2443] apply AutoValue to BeamSqlRecordType You can merge this pull request into a Git repository by running: $ git pull https://github.com/xumingming/beam BEAM-2443-autovalues

[GitHub] beam pull request #3357: [BEAM-2442] BeamSql api surface test

2017-06-15 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3357 --- 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] beam pull request #3365: [BEAM-2444] BeamSql: use java standard exception

2017-06-14 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3365 [BEAM-2444] BeamSql: use java standard exception R: @XuMingmin R: @takidau You can merge this pull request into a Git repository by running: $ git pull https://github.com/xumingming

[GitHub] beam pull request #3364: [BEAM-2440] BeamSql: reduce visibility

2017-06-14 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3364 [BEAM-2440] BeamSql: reduce visibility Since the packages are cross-import each other, many of them can't be set to `package private` access level. You can merge this pull request into

[GitHub] beam pull request #3218: [BEAM-2356] add NOT operator & some refactoring

2017-06-14 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3218 --- 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] beam pull request #3357: [BEAM-2442] BeamSql api surface test

2017-06-14 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3357 [BEAM-2442] BeamSql api surface test Summary: * The surface api of BeamSql includes the following: * BeamSql * BeamSqlCli * BeamSqlEnv * All the classes in package

[GitHub] beam pull request #3183: [BEAM-2325] support Set operator: intersect, except...

2017-06-13 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3183 --- 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] beam pull request #3207: [BEAM-2247] implement date functions

2017-06-13 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3207 --- 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] beam pull request #3254: [BEAM-2375] upgrade beam-version to 2.0.0

2017-06-02 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3254 --- 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] beam pull request #3277: [BEAM-2193] implement join

2017-06-01 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3277 [BEAM-2193] implement join implement join You can merge this pull request into a Git repository by running: $ git pull https://github.com/xumingming/beam BEAM-2193-join Alternatively you

[GitHub] beam pull request #3267: [BEAM-2378] support FULL OUTER JOIN

2017-05-30 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3267 [BEAM-2378] support FULL OUTER JOIN @davorbonaci can you take a look at this please? You can merge this pull request into a Git repository by running: $ git pull https://github.com

[GitHub] beam pull request #3257: fix javadoc of View

2017-05-29 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3257 fix javadoc of View While reading javadoc of `org.apache.beam.sdk.transforms.View`, find the sample code of `View` seems not correct, hope the PR will fix it. You can merge this pull request

[GitHub] beam pull request #3254: [BEAM-2375] upgrade beam-version to 2.0.0

2017-05-28 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3254 [BEAM-2375] upgrade beam-version to 2.0.0 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] beam pull request #3253: rebase master for feature branch DSL_SQL

2017-05-28 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3253 --- 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] beam pull request #3248: rebasing DSL_SQL branch from master

2017-05-28 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3248 --- 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] beam pull request #3253: rebase master for feature branch DSL_SQL

2017-05-28 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3253 rebase master for feature branch DSL_SQL Since it is just a rebase, so didn't create a dedicated issue for it. And since it is a rebase, it cann't be merged automatically, need to merg

[GitHub] beam pull request #3244: DSL_SQL: merge master into DSL_SQL feature branch

2017-05-27 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3244 --- 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] beam pull request #3248: rebasing DSL_SQL branch from master

2017-05-27 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3248 rebasing DSL_SQL branch from master first time do this(rebase feature branch from master), not sure whether it is the right way. @jbonofre can you take a look at it? You can merge this pull

[GitHub] beam pull request #3247: rebasing test

2017-05-27 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3247 --- 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] beam pull request #3247: rebasing test

2017-05-27 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3247 rebasing test 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] beam pull request #3246: rebasing DSL_SQL branch from master

2017-05-27 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3246 --- 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] beam pull request #3246: rebasing DSL_SQL branch from master

2017-05-27 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3246 rebasing DSL_SQL branch from master 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] beam pull request #3244: DSL_SQL: merge master into DSL_SQL feature branch

2017-05-26 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3244 DSL_SQL: merge master into DSL_SQL feature branch Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

[GitHub] beam pull request #3168: [BEAM-2310] support new data type: DECIMAL

2017-05-24 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3168 --- 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] beam pull request #3166: [BEAM-2309] implement VALUES

2017-05-24 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3166 --- 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] beam pull request #3218: [BEAM-2356] add NOT operator & some refactoring

2017-05-23 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3218 [BEAM-2356] add NOT operator & some refactoring Seems only `NOT` operator is missing, other operators will be implicitly converted to `AND`, `OR`, `NOT`, during parsing phase, e.g. `IS FALSE

[GitHub] beam pull request #3207: [BEAM-2247] implement date functions

2017-05-23 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3207 [BEAM-2247] implement date functions @XuMingmin @jbonofre can you guys take a look at this one? You can merge this pull request into a Git repository by running: $ git pull https

[GitHub] beam pull request #3162: [BEAM-2297] support UNION

2017-05-19 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3162 --- 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] beam pull request #3183: [BEAM-2325] support Set operator: intersect & excep...

2017-05-19 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3183 [BEAM-2325] support Set operator: intersect & except R: @XuMingmin R: @jbonofre guys, can you take a look at this one? You can merge this pull request into a Git repositor

[GitHub] beam pull request #3168: [BEAM-2310] support new data type: DECIMAL

2017-05-17 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3168 [BEAM-2310] support new data type: DECIMAL 1. support new data type: DECIMAL 2. support encoding/decoding for TIME 3. add tests all the supported data types. R: @XuMingmin You

[GitHub] beam pull request #3166: [BEAM-2309] implement VALUES

2017-05-16 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3166 [BEAM-2309] implement VALUES 1. implement VALUES 2. add support for data type CHAR(to be able to test VALUES) R: @XuMingmin You can merge this pull request into a Git repository by

[GitHub] beam pull request #3082: [BEAM-2255] implement ORDER BY

2017-05-16 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3082 --- 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] beam pull request #3162: [BEAM-2297] support UNION

2017-05-15 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3162 [BEAM-2297] support UNION support UNION You can merge this pull request into a Git repository by running: $ git pull https://github.com/xumingming/beam BEAM-2297-union Alternatively you can

[GitHub] beam pull request #3122: [BEAM-2149] Improved kafka table implemention

2017-05-15 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3122 --- 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] beam pull request #3042: [BEAM-2195] support conditional operators

2017-05-12 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/3042 --- 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] beam pull request #3122: [BEAM-2149] Improved kafka table implemention

2017-05-12 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3122 [BEAM-2149] Improved kafka table implemention 1. use robust CSV library to parse & print. 2. support different data types rather than just `String`. 3. a little cleanup for TextTable

[GitHub] beam pull request #3082: [BEAM-2255] implement ORDER BY

2017-05-11 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3082 [BEAM-2255] implement ORDER BY You can merge this pull request into a Git repository by running: $ git pull https://github.com/xumingming/beam BEAM-2255-order-by Alternatively you can

[GitHub] beam pull request #3077: Fix typo in org.apache.beam.sdk.transforms.Top

2017-05-11 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3077 Fix typo in org.apache.beam.sdk.transforms.Top Hope I understand the method comments correctly:) You can merge this pull request into a Git repository by running: $ git pull https

[GitHub] beam pull request #3042: [BEAM-2195] support conditional operators

2017-05-10 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/3042 [BEAM-2195] support conditional operators Support conditional operators(CASE, NULLIF, COALESCE). @XuMingmin can you please take a look? You can merge this pull request into a Git

[GitHub] beam pull request #2942: [BEAM-2079] Support TextIO as SQL source/sink

2017-05-09 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/2942 --- 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] beam pull request #2919: [BEAM-2161] support string operators

2017-05-09 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/2919 --- 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] beam pull request #2893: [BEAM-2158] implement the arithmetic operators

2017-05-09 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/2893 --- 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] beam pull request #2942: [BEAM-2079] Support TextIO as SQL source/sink

2017-05-07 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/2942 [BEAM-2079] Support TextIO as SQL source/sink Support TextIO as SQL source/sink You can merge this pull request into a Git repository by running: $ git pull https://github.com/xumingming

[GitHub] beam pull request #2886: [BEAM-2151]Fix inconsistent mapping for SQL FLOAT

2017-05-06 Thread xumingming
Github user xumingming closed the pull request at: https://github.com/apache/beam/pull/2886 --- 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] beam pull request #2919: [BEAM-2161] support string operators

2017-05-05 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/2919 [BEAM-2161] support string operators https://issues.apache.org/jira/browse/BEAM-2161 @XuMingmin You can merge this pull request into a Git repository by running: $ git pull https

[GitHub] beam pull request #2893: [BEAM-2158] implement the arithmetic operators

2017-05-04 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/2893 [BEAM-2158] implement the arithmetic operators implement the arithmetic operators: https://issues.apache.org/jira/browse/BEAM-2158 @XuMingmin can you take a look at this? You can merge

[GitHub] beam pull request #2886: [BEAM-2151]Fix inconsistent mapping for SQL FLOAT

2017-05-03 Thread xumingming
GitHub user xumingming opened a pull request: https://github.com/apache/beam/pull/2886 [BEAM-2151]Fix inconsistent mapping for SQL FLOAT This pull request is mainly to fix the SQL FLOAT mapping, previously it is mapped to Float in `BeamSQLRow`, but mapped to `Double` in