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

This closes #3461 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/85a99e29 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/85a99e29 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/85a99e29 Branch: refs/heads/maste

[1/2] beam git commit: [BEAM-2534] Handle offset gaps in Kafka messages.

Repository: beam Updated Branches: refs/heads/master bf6dda320 -> 85a99e294 [BEAM-2534] Handle offset gaps in Kafka messages. KafkaIO logged a warning when there is a gap in offstes for messages. Kafka also support 'KV' store style topics where some of the messages are deleted leading gaps in

[2/3] beam git commit: [BEAM-2560] Add integration test for arithmetic operators.

[BEAM-2560] Add integration test for arithmetic operators. And also refactor BeamSqlStringFunctionsIntegrationTest to use ExpressionChecker Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a976ec04 Tree: http://git-wip-us.apache

[3/3] beam git commit: This closes #3557

This closes #3557 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a452b802 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a452b802 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a452b802 Branch: refs/heads/DSL_S

[1/3] beam git commit: cleanup BeamSqlRow

Repository: beam Updated Branches: refs/heads/DSL_SQL 5fea74638 -> a452b8020 cleanup BeamSqlRow Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bdea7a6b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/bdea7a6b Diff: h

[1/2] beam git commit: [BEAM-2562] Add integration test for logical operators

Repository: beam Updated Branches: refs/heads/DSL_SQL bed209e41 -> 2f8ee9884 [BEAM-2562] Add integration test for logical operators Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/71eb024f Tree: http://git-wip-us.apache.org/

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

This closes #3560 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2f8ee988 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2f8ee988 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2f8ee988 Branch: refs/heads/DSL_S

[1/2] beam git commit: [BEAM-2384] CEIL, FLOOR, TRUNCATE, PI, ATAN2 math functions

Repository: beam Updated Branches: refs/heads/DSL_SQL 2f8ee9884 -> 4c47ba00b [BEAM-2384] CEIL, FLOOR, TRUNCATE, PI, ATAN2 math functions Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/caa9450a Tree: http://git-wip-us.apache

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

This closes #3525 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4c47ba00 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4c47ba00 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/4c47ba00 Branch: refs/heads/DSL_S

[3/3] beam git commit: This closes #3547

This closes #3547 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e12d7664 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e12d7664 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e12d7664 Branch: refs/heads/DSL_S

[1/3] beam git commit: [BEAM-2561] add integration test for date functions

Repository: beam Updated Branches: refs/heads/DSL_SQL 4c47ba00b -> e12d7664a [BEAM-2561] add integration test for date functions Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6c289d32 Tree: http://git-wip-us.apache.org/rep

[2/3] beam git commit: refactor the datetime test to use ExpressionChecker and fix BeamSqlDivideExpression to speicify round mode.

refactor the datetime test to use ExpressionChecker and fix BeamSqlDivideExpression to speicify round mode. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1d826dae Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1d826da

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

This closes #3570 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/caf647da Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/caf647da Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/caf647da Branch: refs/heads/DSL_S

[1/2] beam git commit: [BEAM-2565] add integration test for conditional functions

Repository: beam Updated Branches: refs/heads/DSL_SQL e12d7664a -> caf647daf [BEAM-2565] add integration test for conditional functions Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0c857ba4 Tree: http://git-wip-us.apache.

[3/3] beam git commit: This closes #3571

This closes #3571 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d4d615a7 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d4d615a7 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d4d615a7 Branch: refs/heads/DSL_S

[1/3] beam git commit: [BEAM-2621] BeamSqlRecordType -> BeamSqlRowType

Repository: beam Updated Branches: refs/heads/DSL_SQL a1f7cf6de -> d4d615a72 http://git-wip-us.apache.org/repos/asf/beam/blob/a9c8a8a1/dsls/sql/src/main/java/org/apache/beam/dsls/sql/schema/text/BeamTextCSVTable.java -- diff --

[2/3] beam git commit: [BEAM-2621] BeamSqlRecordType -> BeamSqlRowType

[BEAM-2621] BeamSqlRecordType -> BeamSqlRowType Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a9c8a8a1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a9c8a8a1 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a9c8

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

This closes #3569 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bff21499 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/bff21499 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/bff21499 Branch: refs/heads/DSL_S

[1/2] beam git commit: [BEAM-2563] Add integration test for math operators Misc: 1. no SQRT in Calcite, converted to POWER; 2. add DECIMAL in BeamSqlDslBase; 3. fix error in BeamSqlRoundExpression; 4.

Repository: beam Updated Branches: refs/heads/DSL_SQL d4d615a72 -> bff21499c [BEAM-2563] Add integration test for math operators Misc: 1. no SQRT in Calcite, converted to POWER; 2. add DECIMAL in BeamSqlDslBase; 3. fix error in BeamSqlRoundExpression; 4. fix error in BeamSqlSignExpression; Pr

[1/2] beam git commit: [BEAM-2613] add integration test for comparison operators

Repository: beam Updated Branches: refs/heads/DSL_SQL bff21499c -> 97a156c30 [BEAM-2613] add integration test for comparison operators Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c5445668 Tree: http://git-wip-us.apache.o

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

This closes #3583 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/97a156c3 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/97a156c3 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/97a156c3 Branch: refs/heads/DSL_S