flink git commit: [FLINK-7986] [table] Introduce FilterSetOpTransposeRule

2017-11-16 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.4 e7f7d0c93 -> 42e24413b [FLINK-7986] [table] Introduce FilterSetOpTransposeRule This closes #4956. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/42e24413 Tree:

flink git commit: [FLINK-7986] [table] Introduce FilterSetOpTransposeRule

2017-11-16 Thread twalthr
Repository: flink Updated Branches: refs/heads/master cd1fbc078 -> 81dc260dc [FLINK-7986] [table] Introduce FilterSetOpTransposeRule This closes #4956. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/81dc260d Tree:

[1/5] flink git commit: [FLINK-7003] [table] Fix 'SELECT *' for tables with nested schema.

2017-11-16 Thread fhueske
Repository: flink Updated Branches: refs/heads/release-1.4 397f0d150 -> e7f7d0c93 [FLINK-7003] [table] Fix 'SELECT *' for tables with nested schema. This closes #4989. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[5/5] flink git commit: [FLINK-8069] [table] Add preserving WatermarkStrategy.

2017-11-16 Thread fhueske
[FLINK-8069] [table] Add preserving WatermarkStrategy. This closes #5016. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e7f7d0c9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e7f7d0c9 Diff:

[3/5] flink git commit: [FLINK-8014] [table] Add Kafka010JsonTableSink.

2017-11-16 Thread fhueske
[FLINK-8014] [table] Add Kafka010JsonTableSink. - Refactor KafkaTableSink tests. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2fd53112 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2fd53112 Diff:

[2/5] flink git commit: [FLINK-7389] [table] Remove Calcite PushProjector

2017-11-16 Thread fhueske
[FLINK-7389] [table] Remove Calcite PushProjector This closes #5022. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8883fa2d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8883fa2d Diff:

[4/5] flink git commit: [FLINK-8016] [docs] Add documentation for KafkaJsonTableSinks.

2017-11-16 Thread fhueske
[FLINK-8016] [docs] Add documentation for KafkaJsonTableSinks. This closes #4990. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f14fcefb Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f14fcefb Diff:

[1/5] flink git commit: [FLINK-7003] [table] Fix 'SELECT *' for tables with nested schema.

2017-11-16 Thread fhueske
Repository: flink Updated Branches: refs/heads/master 101fef739 -> cd1fbc078 [FLINK-7003] [table] Fix 'SELECT *' for tables with nested schema. This closes #4989. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a63d2be5

[5/5] flink git commit: [FLINK-7389] [table] Remove Calcite PushProjector

2017-11-16 Thread fhueske
[FLINK-7389] [table] Remove Calcite PushProjector This closes #5022. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fc3eebd1 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fc3eebd1 Diff:

[2/5] flink git commit: [FLINK-8014] [table] Add Kafka010JsonTableSink.

2017-11-16 Thread fhueske
[FLINK-8014] [table] Add Kafka010JsonTableSink. - Refactor KafkaTableSink tests. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/50fba9aa Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/50fba9aa Diff:

[4/5] flink git commit: [FLINK-8069] [table] Add preserving WatermarkStrategy.

2017-11-16 Thread fhueske
[FLINK-8069] [table] Add preserving WatermarkStrategy. This closes #5016. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cd1fbc07 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cd1fbc07 Diff:

[3/5] flink git commit: [FLINK-8016] [docs] Add documentation for KafkaJsonTableSinks.

2017-11-16 Thread fhueske
[FLINK-8016] [docs] Add documentation for KafkaJsonTableSinks. This closes #4990. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c697bc14 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c697bc14 Diff:

flink git commit: [FLINK-7698] [table] Tests joins with null literals

2017-11-16 Thread twalthr
Repository: flink Updated Branches: refs/heads/master d0b2aa28d -> 101fef739 [FLINK-7698] [table] Tests joins with null literals Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/101fef73 Tree:

flink git commit: [FLINK-7698] [table] Tests joins with null literals

2017-11-16 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.4 13962e1ff -> 397f0d150 [FLINK-7698] [table] Tests joins with null literals Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/397f0d15 Tree: