[5/5] flink git commit: [FLINK-6429] [table] Bump Calcite version to 1.13.

2017-08-08 Thread twalthr
-us.apache.org/repos/asf/flink/diff/d5770fe8 Branch: refs/heads/master Commit: d5770fe8dd1486d457c87c17a7df8dba276e9bcd Parents: f471888 Author: Haohui Mai <whe...@apache.org> Authored: Wed Jul 19 14:34:37 2017 -0700 Committer: twalthr <twal...@apache.org> Committed: Tue Aug 8 12:56:3

[1/5] flink git commit: [FLINK-6429] [table] Fix build and simplifications

2017-08-08 Thread twalthr
org/repos/asf/flink/tree/4dfefd04 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/4dfefd04 Branch: refs/heads/master Commit: 4dfefd042b151a2ecf8d947da5364fc81470f3d9 Parents: d5770fe Author: twalthr <twal...@apache.org> Authored: Tue Aug 8 11:20:02 2017 +0200 Committer: twal

[3/5] flink git commit: [FLINK-6429] [table] Bump Calcite version to 1.13.

2017-08-08 Thread twalthr
http://git-wip-us.apache.org/repos/asf/flink/blob/d5770fe8/flink-libraries/flink-table/src/main/java/org/apache/calcite/sql2rel/SqlToRelConverter.java -- diff --git

[3/5] flink git commit: [FLINK-7337] [table] Refactor internal handling of time indicator attributes.

2017-08-23 Thread twalthr
http://git-wip-us.apache.org/repos/asf/flink/blob/93d0ae4a/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/OverWindowHarnessTest.scala -- diff --git

[5/5] flink git commit: [FLINK-7337] [table] Refactor internal handling of time indicator attributes.

2017-08-23 Thread twalthr
: 93d0ae4a9f059da4bd2b720f7503da0f9c0a8c7c Parents: 6ed5815 Author: Fabian Hueske <fhue...@apache.org> Authored: Fri Aug 4 02:20:56 2017 +0200 Committer: twalthr <twal...@apache.org> Committed: Wed Aug 23 10:09:21 2017 +0200 -

[1/5] flink git commit: [FLINK-7337] [table] Efficient handling of rowtime timestamps

2017-08-23 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 6ed5815e8 -> 47944b1bb http://git-wip-us.apache.org/repos/asf/flink/blob/47944b1b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/RowTimeUnboundedOver.scala

[4/5] flink git commit: [FLINK-7337] [table] Refactor internal handling of time indicator attributes.

2017-08-23 Thread twalthr
http://git-wip-us.apache.org/repos/asf/flink/blob/93d0ae4a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalTableSourceScan.scala -- diff --git

[2/5] flink git commit: [FLINK-7337] [table] Efficient handling of rowtime timestamps

2017-08-23 Thread twalthr
://git-wip-us.apache.org/repos/asf/flink/tree/47944b1b Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/47944b1b Branch: refs/heads/master Commit: 47944b1bb23136ae498971b3765a0d3fe6bf2f18 Parents: 93d0ae4 Author: twalthr <twal...@apache.org> Authored: Sat Aug 12 13:51:42 2017 +0200 Com

[1/2] flink git commit: [FLINK-4604] [table] Clean-ups, improved Sum0 aggregation, simplified tests and bug fixing

2017-05-03 Thread twalthr
mit/72dfce40 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/72dfce40 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/72dfce40 Branch: refs/heads/master Commit: 72dfce40b76f31cdf54959577977a33a0082a7bb Parents: 0af57fc Author: twalthr <twal...@apache.org> Authored: Wed May 3 11:4

[2/2] flink git commit: [FLINK-4604] [table] Add support for standard deviation/variance

2017-05-03 Thread twalthr
/0af57fc1 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0af57fc1 Branch: refs/heads/master Commit: 0af57fc1800d7430843a1e14bb70168bbd750389 Parents: 6d0c4c3 Author: Anton Mushin <anton_mus...@epam.com> Authored: Fri Feb 3 14:06:49 2017 +0400 Committer: twalthr <twal...@a

flink git commit: [FLINK-6517] [table] Support multiple consecutive windows

2017-05-15 Thread twalthr
ree: http://git-wip-us.apache.org/repos/asf/flink/tree/c86f46cd Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/c86f46cd Branch: refs/heads/master Commit: c86f46cdc1c0e2be30876ef358e7ab3c1daa14e9 Parents: ae423e1 Author: twalthr <twal...@apache.org> Authored: Fri May 12 10:03:25 2

flink git commit: [FLINK-6517] [table] Support multiple consecutive windows

2017-05-15 Thread twalthr
ree: http://git-wip-us.apache.org/repos/asf/flink/tree/e23328e4 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e23328e4 Branch: refs/heads/release-1.3 Commit: e23328e4ad4a370af94b1a7441dfcf356eda62f5 Parents: 5d05c18 Author: twalthr <twal...@apache.org> Authored: Fri May 12 10:0

flink git commit: [FLINK-6579] [table] Add proper support for BasicArrayTypeInfo

2017-05-15 Thread twalthr
da4 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0c2d0da4 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0c2d0da4 Branch: refs/heads/release-1.3 Commit: 0c2d0da46a354d24b6bc9682bd8b13b6ff3c617e Parents: e23328e Author: twalthr <twal...@apache.org> Authored: Mon May 15 11:3

flink git commit: [FLINK-6579] [table] Add proper support for BasicArrayTypeInfo

2017-05-15 Thread twalthr
ree: http://git-wip-us.apache.org/repos/asf/flink/tree/3cd95f02 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/3cd95f02 Branch: refs/heads/master Commit: 3cd95f0264beaea4c542421f962739c03e250f59 Parents: c86f46c Author: twalthr <twal...@apache.org> Authored: Mon May 15 11:38:19 2

flink git commit: [hotfix] Disable broken test in TableEnvironmentITCase

2017-05-15 Thread twalthr
wip-us.apache.org/repos/asf/flink/tree/93a03b00 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/93a03b00 Branch: refs/heads/master Commit: 93a03b00f0a62e57a020035f4acdcca2a2c941c8 Parents: 3cd95f0 Author: twalthr <twal...@apache.org> Authored: Mon May 15 15:38:14 2017 +0200 Committer: twal

flink git commit: [hotfix] Disable broken test in TableEnvironmentITCase

2017-05-15 Thread twalthr
wip-us.apache.org/repos/asf/flink/tree/30c476e4 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/30c476e4 Branch: refs/heads/release-1.3 Commit: 30c476e4cec19b2540e49d18da22143b563ee159 Parents: 0c2d0da Author: twalthr <twal...@apache.org> Authored: Mon May 15 15:38:14 2017 +0200 Committer

flink git commit: [FLINK-6601] [table] Use time indicators in DataStreamLogicalWindowAggregateRule

2017-05-17 Thread twalthr
ink/commit/a2580171 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a2580171 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a2580171 Branch: refs/heads/master Commit: a2580171dd6e9044c0694deea83a2a2f1f9eb1ee Parents: 7ad489d Author: twalthr <twal...@apache.org> Authored: Tue May

flink git commit: [FLINK-6601] [table] Use time indicators in DataStreamLogicalWindowAggregateRule

2017-05-17 Thread twalthr
asf/flink/commit/954a100d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/954a100d Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/954a100d Branch: refs/heads/release-1.3 Commit: 954a100dd5fe6ecbb2aac40f33e472d85a5822df Parents: 60873b0 Author: twalthr <twal...@apache.org> Auth

flink git commit: [FLINK-6587] [table] Simplification and bug fixing of the ExpressionParser

2017-05-17 Thread twalthr
mit/9244106b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9244106b Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/9244106b Branch: refs/heads/master Commit: 9244106b334ef54ba3e39a3f2c0c76f46ae4ecd3 Parents: a258017 Author: twalthr <twal...@apache.org> Authored: Mon May 15

flink git commit: [FLINK-6587] [table] Simplification and bug fixing of the ExpressionParser

2017-05-17 Thread twalthr
ink/commit/fe1316b3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fe1316b3 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/fe1316b3 Branch: refs/heads/release-1.3 Commit: fe1316b335cb970b7b721359d8a69e12fef700ba Parents: 954a100 Author: twalthr <twal...@apache.org> Authored: M

flink git commit: [hotfix] Add configuration notice to HistryServer overview

2017-05-17 Thread twalthr
wip-us.apache.org/repos/asf/flink/tree/b6afc06a Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b6afc06a Branch: refs/heads/master Commit: b6afc06ab1b5c227254941a512912f830da62b5d Parents: 00ce3f1 Author: twalthr <twal...@apache.org> Authored: Wed May 17 15:10:21 2017 +0200 Committer: twal

flink git commit: [hotfix] Add configuration notice to HistryServer overview

2017-05-17 Thread twalthr
wip-us.apache.org/repos/asf/flink/tree/7a045f20 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/7a045f20 Branch: refs/heads/release-1.3 Commit: 7a045f20432cbaf1dcfa70206004fbee3a91d875 Parents: 849dd9d Author: twalthr <twal...@apache.org> Authored: Wed May 17 15:10:21 2017 +0200

flink git commit: [FLINK-6881] [FLINK-6896] [table] Creating a table from a POJO and defining a time attribute fails

2017-06-20 Thread twalthr
ttp://git-wip-us.apache.org/repos/asf/flink/commit/930216ef Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/930216ef Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/930216ef Branch: refs/heads/release-1.3 Commit: 930216ef95cf7098d7f9f3ba7403dacc3b433817 Parents: 782c998 Author: twal

flink git commit: [FLINK-6994] [docs] Wrong base url in master docs

2017-06-26 Thread twalthr
git-wip-us.apache.org/repos/asf/flink/tree/cd8932f5 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/cd8932f5 Branch: refs/heads/master Commit: cd8932f5de967092a39fde5f1ba468b2542e91da Parents: 2d82030 Author: twalthr <twal...@apache.org> Authored: Fri Jun 23 15:40:49 2017 +0200

flink git commit: [FLINK-6942] [table] Add E() support in Table API

2017-06-26 Thread twalthr
git-wip-us.apache.org/repos/asf/flink/tree/2d820302 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2d820302 Branch: refs/heads/master Commit: 2d82030277da58040b24a14ff665a9356a4ee4b2 Parents: 524a1fa Author: twalthr <twal...@apache.org> Authored: Mon Jun 26 09:28:59 2017 +0200

[1/2] flink git commit: [FLINK-6237] [table] Performance improvements and code clean up

2017-06-23 Thread twalthr
wip-us.apache.org/repos/asf/flink/tree/a0b78146 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a0b78146 Branch: refs/heads/master Commit: a0b781461bcf8c2f1d00b93464995f03eda589f1 Parents: 6230cc5 Author: twalthr <twal...@apache.org> Authored: Fri Jun 23 11:22:30 2017 +0200 Committer

[2/2] flink git commit: [FLINK-6237] [table] support RAND and RAND_INTEGER on SQL

2017-06-23 Thread twalthr
-us.apache.org/repos/asf/flink/diff/6230cc55 Branch: refs/heads/master Commit: 6230cc55048b21ac5488e2a42372ba1a14500a8a Parents: 44ae21d Author: godfreyhe <godfre...@163.com> Authored: Sat Apr 1 14:28:49 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Fri Jun 23 11:43:3

flink git commit: [FLINK-6632] [table] Improved the method BoolLiteral of ExpressionParser for case insensitive.

2017-05-22 Thread twalthr
il.com> Authored: Fri May 19 18:24:09 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Mon May 22 19:00:19 2017 +0200 -- .../table/expressions/ExpressionParser.scala| 52 +---

flink git commit: [FLINK-6632] [table] Improved the method BoolLiteral of ExpressionParser for case insensitive.

2017-05-22 Thread twalthr
ncheng...@gmail.com> Authored: Fri May 19 18:24:09 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Mon May 22 19:01:49 2017 +0200 -- .../table/expressions/ExpressionParser.scala| 52 +---

flink git commit: [FLINK-6650] [table] Improve the error message for toAppendStream

2017-05-24 Thread twalthr
22 17:04:13 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Wed May 24 16:02:40 2017 +0200 -- .../org/apache/flink/table/api/StreamTableEnvironment.scala | 2 +- .../plan/n

flink git commit: [FLINK-6650] [table] Improve the error message for toAppendStream

2017-05-24 Thread twalthr
: Mon May 22 17:04:13 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Wed May 24 16:05:04 2017 +0200 -- .../org/apache/flink/table/api/StreamTableEnvironment.scala | 2 +- .../plan/n

flink git commit: [hotfix] [docs] Remove invalid REST path

2017-05-22 Thread twalthr
asf/flink/tree/5624c706 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5624c706 Branch: refs/heads/master Commit: 5624c7065f610a072ee5d26177a73b4334211dc1 Parents: d246515 Author: twalthr <twal...@apache.org> Authored: Mon May 22 12:30:25 2017 +0200 Committer: twalthr <twal..

flink git commit: [hotfix] [docs] Remove invalid REST path

2017-05-22 Thread twalthr
pos/asf/flink/tree/0d9087df Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0d9087df Branch: refs/heads/release-1.3 Commit: 0d9087df4e0ef099d0ad0c6b29690b14dd1d6496 Parents: f783e52 Author: twalthr <twal...@apache.org> Authored: Mon May 22 12:30:25 2017 +0200 Committer: twal

flink git commit: [FLINK-6760] [table] Fix OverWindowTest alias test error

2017-05-29 Thread twalthr
0:58 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Mon May 29 15:41:30 2017 +0200 -- .../api/scala/stream/sql/OverWindowITCase.scala | 32 +--- .../api/scala/stream/sql/OverWindowTe

flink git commit: [FLINK-6736] [table] Fix UDTF field access with time attribute record

2017-05-29 Thread twalthr
mit/64ca0fa2 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/64ca0fa2 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/64ca0fa2 Branch: refs/heads/master Commit: 64ca0fa22ac0af21b3a0a193b769a24d44947f18 Parents: 6b69c58 Author: twalthr <twal...@apache.org> Authored: Mon May 29 14:4

flink git commit: [FLINK-6737] [table] Fix string reference variable error

2017-05-29 Thread twalthr
3:06 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Mon May 29 16:15:48 2017 +0200 -- .../main/scala/org/apache/flink/table/api/TableEnvironment.scala | 2 +- .../flink/table/functions/utils/UserDefinedFunc

flink git commit: [FLINK-6737] [table] Fix string reference variable error

2017-05-29 Thread twalthr
27 14:03:06 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Mon May 29 16:17:42 2017 +0200 -- .../main/scala/org/apache/flink/table/api/TableEnvironment.scala | 2 +- .../flink/table/

flink git commit: [FLINK-6736] [table] Fix UDTF field access with time attribute record

2017-05-29 Thread twalthr
mit/5d3bb647 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5d3bb647 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5d3bb647 Branch: refs/heads/release-1.3 Commit: 5d3bb6475650df01abefa65205bd118c044e5eb4 Parents: 869554d Author: twalthr <twal...@apache.org> Authored: Mon May

flink git commit: [FLINK-6593] [table] Fix Bug in ProctimeAttribute or RowtimeAttribute with CodeGenerator

2017-05-16 Thread twalthr
: Tue May 16 16:59:14 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Tue May 16 14:43:09 2017 +0200 -- .../apache/flink/table/plan/nodes/datastream/DataStreamCalc.scala | 3 +-- 1 file changed, 1 insertion(

flink git commit: [FLINK-6593] [table] Fix Bug in ProctimeAttribute or RowtimeAttribute with CodeGenerator

2017-05-16 Thread twalthr
Authored: Tue May 16 16:59:14 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Tue May 16 14:45:15 2017 +0200 -- .../apache/flink/table/plan/nodes/datastream/DataStreamCalc.scala | 3 +-- 1 file changed, 1

flink git commit: [FLINK-6747] [table] [docs] Time attributes section added

2017-05-31 Thread twalthr
ree: http://git-wip-us.apache.org/repos/asf/flink/tree/cd329420 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/cd329420 Branch: refs/heads/tableDocs Commit: cd329420eba2210a0a3b49579114d327056b2ed8 Parents: e5f2471 Author: twalthr <twal...@apache.org> Authored: Tue May 30 17:26:07 2

flink git commit: [FLINK-6780] [table] ExternalTableSource should add time attributes in the row type.

2017-05-31 Thread twalthr
Authored: Wed May 31 01:40:53 2017 -0700 Committer: twalthr <twal...@apache.org> Committed: Wed May 31 13:42:41 2017 +0200 -- .../table/catalog/ExternalTableSourceUtil.scala | 18 -- .../catalog/ExternalTableSourceUtilTe

flink git commit: [FLINK-6780] [table] ExternalTableSource should add time attributes in the row type.

2017-05-31 Thread twalthr
: Wed May 31 01:40:53 2017 -0700 Committer: twalthr <twal...@apache.org> Committed: Wed May 31 13:40:47 2017 +0200 -- .../table/catalog/ExternalTableSourceUtil.scala | 18 -- .../catalog/ExternalTableSourceUtilTe

flink git commit: [FLINK-6753] [table] Fix flaky SqlITCase due to Janino bug

2017-05-31 Thread twalthr
ree: http://git-wip-us.apache.org/repos/asf/flink/tree/5982ea93 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5982ea93 Branch: refs/heads/master Commit: 5982ea93f4e5db790b3e1d95c22ecdf2923528d7 Parents: 1beab38 Author: twalthr <twal...@apache.org> Authored: Mon May 29 16:52:19 2

flink git commit: [FLINK-6753] [table] Fix flaky SqlITCase due to Janino bug

2017-05-31 Thread twalthr
63b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/144f663b Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/144f663b Branch: refs/heads/release-1.3 Commit: 144f663bd236c8d5febb1a0478f26c533cab00d1 Parents: 5f53052 Author: twalthr <twal...@apache.org> Authored: Mon May 29 16:5

flink git commit: [FLINK-6816] [table] Fix wrong usage of Scala string interpolation in Table API

2017-06-06 Thread twalthr
Authored: Fri Jun 2 21:15:55 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Tue Jun 6 12:17:53 2017 +0200 -- .../flink/table/runtime/aggregate/ProcTimeBoundedRangeOver.scala | 4 ++-- .../flink/table/ru

flink git commit: [FLINK-6746] [table] [docs] Updated Table API / SQL docs: Common API

2017-06-06 Thread twalthr
28 15:35:09 2017 +0200 Committer: twalthr <twal...@apache.org> Committed: Tue Jun 6 16:08:11 2017 +0200 -- docs/dev/table/common.md | 800 +++--- 1 file changed, 593 insertions(+)

[2/2] flink git commit: [FLINK-6377] [table] Support map types in the Table / SQL API

2017-04-30 Thread twalthr
-us.apache.org/repos/asf/flink/diff/5b6e71ce Branch: refs/heads/master Commit: 5b6e71ceb12d1fdf7d09d70744f3c0a8a4722768 Parents: 0a33431 Author: Haohui Mai <whe...@apache.org> Authored: Mon Apr 24 23:12:29 2017 -0700 Committer: twalthr <twal...@apache.org> Committed: Sun Apr 30 18:59:0

[1/2] flink git commit: [FLINK-6377] [table] Add additional map tests

2017-04-30 Thread twalthr
pos/asf/flink/tree/d49efbd2 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d49efbd2 Branch: refs/heads/master Commit: d49efbd222c1aa963f3f9a7fb3cf359071d1bbd3 Parents: 5b6e71c Author: twalthr <twal...@apache.org> Authored: Wed Apr 26 18:04:00 2017 +0200 Committer: twalthr <twal..

[2/3] flink git commit: [FLINK-6409] [table] TUMBLE/HOP/SESSION_START/END do not resolve time field correctly

2017-05-02 Thread twalthr
http://git-wip-us.apache.org/repos/asf/flink/blob/2d33c0be/flink-libraries/flink-table/src/main/java/org/apache/calcite/sql2rel/SqlToRelConverter.java -- diff --git

[1/3] flink git commit: [FLINK-6409] [table] TUMBLE/HOP/SESSION_START/END do not resolve time field correctly

2017-05-02 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 464d6f553 -> 2d33c0bea http://git-wip-us.apache.org/repos/asf/flink/blob/2d33c0be/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/sql/WindowAggregateTest.scala

[3/3] flink git commit: [FLINK-6409] [table] TUMBLE/HOP/SESSION_START/END do not resolve time field correctly

2017-05-02 Thread twalthr
/2d33c0be Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2d33c0be Branch: refs/heads/master Commit: 2d33c0bead3f13417acff0f18f78a5c2c5bef22e Parents: 464d6f5 Author: twalthr <twal...@apache.org> Authored: Fri Apr 28 17:17:30 2017 +0200 Committer: twalthr <twal...@apache.org> Committe

flink git commit: [FLINK-7005] [table] Optimization steps are missing for nested registered tables

2017-06-27 Thread twalthr
asf/flink/commit/58b3b19c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/58b3b19c Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/58b3b19c Branch: refs/heads/release-1.3 Commit: 58b3b19c91539f11d3d2636090e3bec1dd7b75d0 Parents: f39899d Author: twalthr <twal...@apache.org> Auth

flink git commit: [FLINK-7005] [table] Optimization steps are missing for nested registered tables

2017-06-27 Thread twalthr
ink/commit/02863f39 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/02863f39 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/02863f39 Branch: refs/heads/master Commit: 02863f397f343502f037f62466643903fb246d7e Parents: e1f8882 Author: twalthr <twal...@apache.org> Authored: Mon Jun

flink git commit: [FLINK-7371] [table] Add support for constant parameters in OVER aggregate

2017-10-16 Thread twalthr
mit/861c57cb Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/861c57cb Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/861c57cb Branch: refs/heads/master Commit: 861c57cb10a3ccc862ec068869582bc1551feaa5 Parents: 404e37d Author: twalthr <twal...@apache.org> Authored: Wed Sep 27

flink git commit: [FLINK-7426] [table] Support null values in keys

2017-10-17 Thread twalthr
git-wip-us.apache.org/repos/asf/flink/tree/14bc6274 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/14bc6274 Branch: refs/heads/master Commit: 14bc62740e90ecefd34f9202f4a37c883c3122e5 Parents: e79cedf Author: twalthr <twal...@apache.org> Authored: Wed Sep 27 13:05:44 2017 +0200

[1/2] flink git commit: [FLINK-7596] [table] Fix bug during Set Operation (Union, Minus ... ) with Any(GenericRelDataType)

2017-09-26 Thread twalthr
il.com> Authored: Fri Sep 15 08:24:17 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Tue Sep 26 16:52:17 2017 +0200 -- .../flink/table/calcite/FlinkTypeFactory.scala | 37

[2/2] flink git commit: [FLINK-7596] [table] Restrict equality and improve tests

2017-09-26 Thread twalthr
/flink/diff/314ca04b Branch: refs/heads/release-1.3 Commit: 314ca04b3a06b960ac324484b099fd66ffcb2fbd Parents: 701be5d Author: twalthr <twal...@apache.org> Authored: Tue Sep 26 16:37:31 2017 +0200 Committer: twalthr <twal...@apache.org> Committed: Tue Sep 26 16:52:2

[1/2] flink git commit: [FLINK-7596] [table] Fix bug during Set Operation (Union, Minus ... ) with Any(GenericRelDataType)

2017-09-26 Thread twalthr
Authored: Fri Sep 15 08:24:17 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Tue Sep 26 16:38:33 2017 +0200 -- .../flink/table/calcite/FlinkTypeFactory.scala | 37 .

[2/2] flink git commit: [FLINK-7596] [table] Restrict equality and improve tests

2017-09-26 Thread twalthr
/flink/diff/2b82578a Branch: refs/heads/master Commit: 2b82578abec20eb97bc0d641ca19977cc3805c9e Parents: 62ebda3 Author: twalthr <twal...@apache.org> Authored: Tue Sep 26 16:37:31 2017 +0200 Committer: twalthr <twal...@apache.org> Committed: Tue Sep 26 16:49:1

[2/2] flink git commit: [FLINK-7439] [table] Support variable arguments for UDTF in SQL

2017-09-26 Thread twalthr
-wip-us.apache.org/repos/asf/flink/diff/79c17afa Branch: refs/heads/master Commit: 79c17afa13cd3f6cbaa91d56e036530f53e7b54b Parents: 142bde0 Author: Jark Wu <j...@apache.org> Authored: Mon Aug 14 14:18:52 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Tue Sep 26 10:45:0

[1/2] flink git commit: [FLINK-7439] [table] Add possiblity to replace TypeExtractor call

2017-09-26 Thread twalthr
wip-us.apache.org/repos/asf/flink/tree/e9decac6 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e9decac6 Branch: refs/heads/master Commit: e9decac620cd528a937f827e4b107da7a43066af Parents: 79c17af Author: twalthr <twal...@apache.org> Authored: Tue Sep 26 10:33:12 2017 +0200 Committer

flink git commit: [hotfix] [docs] Simplify and fix Table UDF docs

2017-09-26 Thread twalthr
org/repos/asf/flink/tree/2d393e88 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2d393e88 Branch: refs/heads/master Commit: 2d393e882fd99fa6bcd5df19ff1aa345909c145c Parents: d3458ec Author: twalthr <twal...@apache.org> Authored: Tue Sep 26 13:54:23 2017 +0200 Committer: twalthr <twal..

[2/2] flink git commit: [hotfix] [docs] Add section in docs about writing unit and integration tests

2017-08-29 Thread twalthr
: http://git-wip-us.apache.org/repos/asf/flink/diff/00fc6413 Branch: refs/heads/master Commit: 00fc64134ae3b9ad8644b2c232853aeb02917ddf Parents: 1e2a638 Author: Piotr Nowojski <piotr.nowoj...@gmail.com> Authored: Tue Aug 1 15:02:56 2017 +0200 Committer: twalthr <twal...@apache.org> Commit

[1/2] flink git commit: [hotfix] [docs] Fix typos and improve testing docs

2017-08-29 Thread twalthr
org/repos/asf/flink/tree/5ce0ded1 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5ce0ded1 Branch: refs/heads/master Commit: 5ce0ded1b71faf7e5d90865ba9481e254c3fb5be Parents: 00fc641 Author: twalthr <twal...@apache.org> Authored: Tue Aug 29 17:19:50 2017 +0200 Committer: twal

flink git commit: [hotfix] [docs] Remove duplicate docs page

2017-08-29 Thread twalthr
asf/flink/tree/88848e74 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/88848e74 Branch: refs/heads/master Commit: 88848e74cfade38737f306aeba29a4fe9e26ba79 Parents: 5ce0ded Author: twalthr <twal...@apache.org> Authored: Tue Aug 29 17:27:33 2017 +0200 Committer: twalthr <twal..

flink git commit: [FLINK-8136] [table] Fix code generation with JodaTime shading

2017-11-22 Thread twalthr
ree: http://git-wip-us.apache.org/repos/asf/flink/tree/5017c679 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5017c679 Branch: refs/heads/master Commit: 5017c679c06de92bec6b094268d61ce5f3109b9e Parents: 775459d Author: twalthr <twal...@apache.org> Authored: Wed Nov 22 17:43:08 2

[2/2] flink git commit: [FLINK-8118] [table] Allow to specify the offsets of KafkaTableSources

2017-11-23 Thread twalthr
://git-wip-us.apache.org/repos/asf/flink/diff/4083c70d Branch: refs/heads/master Commit: 4083c70dc88e0022daaab807d67b922d426fb533 Parents: 458c909 Author: Xingcan Cui <xingc...@gmail.com> Authored: Thu Nov 23 00:00:39 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Thu Nov

[1/2] flink git commit: [FLINK-8118] [table] Fix documentation mistakes

2017-11-23 Thread twalthr
org/repos/asf/flink/tree/7ff3f373 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/7ff3f373 Branch: refs/heads/master Commit: 7ff3f373a353f9ed8cd1973f2bde172ab7bd992d Parents: 4083c70 Author: twalthr <twal...@apache.org> Authored: Thu Nov 23 14:30:15 2017 +0100 Committer: twalthr <twal..

flink git commit: [FLINK-8136] [table] Fix code generation with JodaTime shading

2017-11-22 Thread twalthr
962 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/28157962 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/28157962 Branch: refs/heads/release-1.4 Commit: 28157962196cecb94a59720e92cbf3682418e821 Parents: 6cb8b5b Author: twalthr <twal...@apache.org> Authored: Wed Nov 22 17:4

flink git commit: [FLINK-8173] [table] Fix input unboxing and support Avro Utf8

2017-12-01 Thread twalthr
ree: http://git-wip-us.apache.org/repos/asf/flink/tree/6aced125 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/6aced125 Branch: refs/heads/master Commit: 6aced1251878a4a98f66732d14336f3c86ec9d98 Parents: deea4b3 Author: twalthr <twal...@apache.org> Authored: Fri Dec 1 15:37:23 2

flink git commit: [FLINK-7452] [types] Add helper methods for all built-in Flink types to Types

2017-12-19 Thread twalthr
ink/commit/e30066db Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e30066db Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e30066db Branch: refs/heads/master Commit: e30066dbd1ebf3c5780df89d766554042c8345a7 Parents: 7f99a0d Author: twalthr <twal...@apache.org> Authored: Mon Aug 28

flink git commit: [hotfix][docs] Update debugging classloading doc to Java 8

2017-12-19 Thread twalthr
.nowoj...@gmail.com> Authored: Wed Dec 13 10:12:22 2017 +0100 Committer: twalthr <twal...@apache.org> Committed: Tue Dec 19 10:44:32 2017 +0100 -- docs/monitoring/debugging_classloading.md | 2 +- 1 file changed, 1 insertion

flink git commit: [FLINK-8215] [table] Support implicit type widening for array/map constructors in SQL

2017-12-19 Thread twalthr
on Dec 11 14:55:49 2017 -0800 Committer: twalthr <twal...@apache.org> Committed: Tue Dec 19 11:03:36 2017 +0100 -- .../org/apache/flink/table/codegen/CodeGenerator.scala| 4 ++-- .../apache/flink/table/expressions/Arra

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

2017-11-16 Thread twalthr
017 +0800 Committer: twalthr <twal...@apache.org> Committed: Thu Nov 16 16:16:22 2017 +0100 -- .../flink/table/plan/rules/FlinkRuleSets.scala | 2 + .../api/batch/table/SetOperatorsTest.scala | 80

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

2017-11-16 Thread twalthr
Committer: twalthr <twal...@apache.org> Committed: Thu Nov 16 14:43:50 2017 +0100 -- .../flink/table/plan/rules/FlinkRuleSets.scala | 2 + .../api/batch/table/SetOperatorsTest.scala | 80 .../a

[1/2] flink git commit: [FLINK-7657] [table] Add time types FilterableTableSource push down

2017-11-13 Thread twalthr
27 13:48:55 2017 -0700 Committer: twalthr <twal...@apache.org> Committed: Mon Nov 13 14:22:16 2017 +0100 -- .../flink/table/expressions/literals.scala | 34 +-- .../table/plan/util/RexProgramExtractor.scala | 33

[2/2] flink git commit: [FLINK-7657] [table] Add time types FilterableTableSource push down

2017-11-13 Thread twalthr
://git-wip-us.apache.org/repos/asf/flink/diff/3b333b28 Branch: refs/heads/master Commit: 3b333b289cbbe43f722edef2c36c370ff4550128 Parents: ad8ef6d Author: Kent Murra <ke...@remitly.com> Authored: Wed Sep 27 13:48:55 2017 -0700 Committer: twalthr <twal...@apache.org> Committed: Mon Nov 13 1

[1/2] flink git commit: [FLINK-7657] [table] Add all basic types to RexProgramExtractor

2017-11-13 Thread twalthr
wip-us.apache.org/repos/asf/flink/tree/32e5194d Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/32e5194d Branch: refs/heads/master Commit: 32e5194d95742dc0115a2b4d8c34e3f025feebd0 Parents: 3b333b2 Author: twalthr <twal...@apache.org> Authored: Mon Nov 13 14:09:45 2017 +0100 Committer

[2/2] flink git commit: [FLINK-7657] [table] Add all basic types to RexProgramExtractor

2017-11-13 Thread twalthr
/repos/asf/flink/diff/ce1cb8fd Branch: refs/heads/release-1.4 Commit: ce1cb8fd6d667713be9b5f9ec8f1c394b9ca4644 Parents: bb04187 Author: twalthr <twal...@apache.org> Authored: Mon Nov 13 14:09:45 2017 +0100 Committer: twalthr <twal...@apache.org> Committed: Mon Nov 13 14:22:2

flink git commit: [FLINK-8095] [table] Introduce ProjectSetOpTransposeRule

2017-11-20 Thread twalthr
Committer: twalthr <twal...@apache.org> Committed: Mon Nov 20 12:49:13 2017 +0100 -- .../flink/table/plan/rules/FlinkRuleSets.scala | 2 + .../api/batch/table/SetOperatorsTest.scala | 58 .../a

flink git commit: [FLINK-8095] [table] Introduce ProjectSetOpTransposeRule

2017-11-20 Thread twalthr
017 +0800 Committer: twalthr <twal...@apache.org> Committed: Mon Nov 20 12:50:40 2017 +0100 -- .../flink/table/plan/rules/FlinkRuleSets.scala | 2 + .../api/batch/table/SetOperatorsTest.scala | 58

flink git commit: [FLINK-8096] [table] Fix time attribute materialization when writing to TableSink

2017-11-20 Thread twalthr
: Fri Nov 17 10:53:31 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Mon Nov 20 10:52:27 2017 +0100 -- .../table/api/StreamTableEnvironment.scala | 39 .../runtime/stream/TimeAttribu

flink git commit: [FLINK-8096] [table] Fix time attribute materialization when writing to TableSink

2017-11-20 Thread twalthr
nc.com> Authored: Fri Nov 17 10:53:31 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Mon Nov 20 12:18:26 2017 +0100 -- .../table/api/StreamTableEnvironment.scala | 39 ...

[1/2] flink git commit: [FLINK-8038] [table] Clear maps and support cardinality

2017-11-21 Thread twalthr
wip-us.apache.org/repos/asf/flink/tree/9e3439c0 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/9e3439c0 Branch: refs/heads/master Commit: 9e3439c013928e52ea99fe87579512f1c2b2c28e Parents: c5f5615 Author: twalthr <twal...@apache.org> Authored: Tue Nov 21 16:57:04 2017 +0100 Committer: twal

[2/2] flink git commit: [FLINK-8038] [table] Support map value constructor, cardinality, and item

2017-11-21 Thread twalthr
: http://git-wip-us.apache.org/repos/asf/flink/diff/c5f5615c Branch: refs/heads/master Commit: c5f5615cf84026039614701b5e6b3b0e003eada0 Parents: 52599ff Author: Rong Rong <ro...@uber.com> Authored: Tue Nov 14 10:48:16 2017 -0800 Committer: twalthr <twal...@apache.org> Committed: Tue Nov 21 1

flink git commit: [FLINK-8097] [table] Add built-in support for min/max aggregation for Date/Time

2017-11-21 Thread twalthr
ri Nov 17 13:22:47 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Tue Nov 21 17:31:27 2017 +0100 -- .../functions/aggfunctions/MaxAggFunction.scala | 20 +- .../MaxAggFunctionWithRetract.scala

[1/2] flink git commit: [FLINK-7451] [table] Support non-ascii character literals in Table API and SQL

2017-11-15 Thread twalthr
ue Aug 15 19:24:57 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Wed Nov 15 14:49:52 2017 +0100 -- .../flink/table/calcite/FlinkTypeFactory.scala | 6 + .../table/expressions/LiteralPrefixTes

[2/2] flink git commit: [FLINK-7451] [table] Disable testing of the charset in TableTestBase

2017-11-15 Thread twalthr
/repos/asf/flink/diff/49aeb8f1 Branch: refs/heads/release-1.4 Commit: 49aeb8f1d98fe99eaf97c3009ba23008652964e7 Parents: 81e3a88 Author: twalthr <twal...@apache.org> Authored: Wed Nov 15 14:39:21 2017 +0100 Committer: twalthr <twal...@apache.org> Committed: Wed Nov 15 14:50:0

[1/2] flink git commit: [FLINK-7451] [table] Support non-ascii character literals in Table API and SQL

2017-11-15 Thread twalthr
19:24:57 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Wed Nov 15 14:11:57 2017 +0100 -- .../flink/table/calcite/FlinkTypeFactory.scala | 6 + .../table/expressions/LiteralPrefixTest.scala | 79 -

[2/2] flink git commit: [FLINK-7451] [table] Disable testing of the charset in TableTestBase

2017-11-15 Thread twalthr
/repos/asf/flink/diff/9d347157 Branch: refs/heads/master Commit: 9d34715747040352f6c0ca13c052763cd8049dad Parents: c32fcbc Author: twalthr <twal...@apache.org> Authored: Wed Nov 15 14:39:21 2017 +0100 Committer: twalthr <twal...@apache.org> Committed: Wed Nov 15 14:41:4

flink git commit: [FLINK-8013] [table] Support aggregate functions with generic arrays

2017-11-15 Thread twalthr
mit/11218a35 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/11218a35 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/11218a35 Branch: refs/heads/master Commit: 11218a35dc0fdd7439142a313e6628c51cffe689 Parents: 9d34715 Author: twalthr <twal...@apache.org> Authored: Tue Nov 14 11:0

flink git commit: [FLINK-8013] [table] Support aggregate functions with generic arrays

2017-11-15 Thread twalthr
mit/32bfc388 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/32bfc388 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/32bfc388 Branch: refs/heads/release-1.4 Commit: 32bfc38875faa5baea0dc63d91e1273d7df7b2ef Parents: 49aeb8f Author: twalthr <twal...@apache.org> Authored: Tue Nov

flink git commit: [FLINK-7678] [table] Support composite inputs for user-defined functions

2017-11-15 Thread twalthr
ink/commit/06a922e8 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/06a922e8 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/06a922e8 Branch: refs/heads/release-1.4 Commit: 06a922e8113709b6768d1b25b3bb6f59a360e428 Parents: 32bfc38 Author: twalthr <twal...@apache.org> Authored: Tue

flink git commit: [FLINK-7490] [table] Use correct classloader to compile generated code that calls UDAGGs.

2017-11-15 Thread twalthr
he.org> Authored: Wed Nov 15 10:12:55 2017 +0100 Committer: twalthr <twal...@apache.org> Committed: Wed Nov 15 17:55:25 2017 +0100 -- .../operators/translation/RichCombineToGroupCombineWrapper.java| 1 + .../flin

flink git commit: [FLINK-7490] [table] Use correct classloader to compile generated code that calls UDAGGs.

2017-11-15 Thread twalthr
he.org> Authored: Wed Nov 15 10:12:55 2017 +0100 Committer: twalthr <twal...@apache.org> Committed: Wed Nov 15 18:00:20 2017 +0100 -- .../operators/translation/RichCombineToGroupCombineWrapper.java| 1 + .../flin

flink git commit: [FLINK-7678] [table] Support composite inputs for user-defined functions

2017-11-15 Thread twalthr
mit/54eeccfe Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/54eeccfe Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/54eeccfe Branch: refs/heads/master Commit: 54eeccfe18ace636b77ff0226ce1f91d35e4d49d Parents: 11218a3 Author: twalthr <twal...@apache.org> Authored: Tue Sep 26 12:1

flink git commit: [FLINK-7490] [table] Use correct classloader to compile generated code that calls UDAGGs.

2017-11-15 Thread twalthr
Authored: Wed Nov 15 10:12:55 2017 +0100 Committer: twalthr <twal...@apache.org> Committed: Wed Nov 15 17:49:41 2017 +0100 -- .../operators/translation/RichCombineToGroupCombineWrapper.java| 1 + .../flink/table/ru

flink git commit: [FLINK-7942] [table] Reduce aliasing in RexNodes

2017-11-15 Thread twalthr
git-wip-us.apache.org/repos/asf/flink/tree/b6a2dc34 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b6a2dc34 Branch: refs/heads/master Commit: b6a2dc345f37c4b643789e98d02e23a022d31415 Parents: 59df4b7 Author: twalthr <twal...@apache.org> Authored: Wed Nov 15 12:07:16 2017 +0100

flink git commit: [FLINK-7942] [table] Reduce aliasing in RexNodes

2017-11-15 Thread twalthr
ttp://git-wip-us.apache.org/repos/asf/flink/tree/13962e1f Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/13962e1f Branch: refs/heads/release-1.4 Commit: 13962e1ffda62218031bf426ee9c06146c7c5573 Parents: 084ff68 Author: twalthr <twal...@apache.org> Authored: Wed Nov 15 12:07:16 2

<    1   2   3   4   5   6   7   8   9   10   >