flink git commit: [FLINK-5983] [table] Convert FOR into WHILE loops for aggregation functions.

2017-03-08 Thread twalthr
100 Committer: twalthr Committed: Wed Mar 8 17:59:31 2017 +0100 -- .../aggregate/AggregateAggFunction.scala| 29 ++- .../aggregate/AggregateMapFunction.scala| 17 --- .../AggregateReduceCombineFunction.sc

flink git commit: [FLINK-5963] [table] Remove prepare mapper of DataSetAggregate.

2017-03-09 Thread twalthr
ter: twalthr Committed: Thu Mar 9 11:27:37 2017 +0100 -- .../plan/nodes/dataset/DataSetAggregate.scala | 75 ++--- .../aggregate/AggregateMapFunction.scala| 69 .../AggregateReduceCombineFunction.scala|

flink git commit: [FLINK-5984] [table] Add resetAccumulator method for AggregateFunction

2017-03-09 Thread twalthr
ter: twalthr Committed: Thu Mar 9 12:05:19 2017 +0100 -- .../table/functions/AggregateFunction.scala | 11 ++-- .../functions/aggfunctions/AvgAggFunction.scala | 28 +--- .../aggfuncti

flink git commit: [FLINK-5881] [table] ScalarFunction(UDF) should support variable types and variable arguments

2017-03-13 Thread twalthr
:53:34 2017 +0800 Committer: twalthr Committed: Mon Mar 13 10:29:35 2017 +0100 -- .../codegen/calls/ScalarFunctionCallGen.scala | 17 ++-- .../functions/utils/ScalarSqlFunction.scala | 26 -- .../ut

flink git commit: [FLINK-5882] [table] TableFunction (UDTF) should support variable types and variable arguments

2017-03-13 Thread twalthr
:02:46 2017 +0800 Committer: twalthr Committed: Mon Mar 13 10:55:10 2017 +0100 -- .../codegen/calls/TableFunctionCallGen.scala| 17 ++--- .../DataSetUserDefinedFunctionITCase.scala |

flink git commit: [FLINK-5441] [table] Directly allow SQL queries on a Table

2017-03-14 Thread twalthr
ree: http://git-wip-us.apache.org/repos/asf/flink/tree/f333723b Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f333723b Branch: refs/heads/master Commit: f333723bcdaaa1cdc99dce16b00151d1c5365869 Parents: ffb8d05 Author: Jark Wu Authored: Thu Jan 12 22:26:52 2017 +0800 Committer: twal

flink git commit: [FLINK-6037] [table] Metadata provider didn't work in SQL

2017-03-21 Thread twalthr
ac8 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/86d32ac8 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/86d32ac8 Branch: refs/heads/master Commit: 86d32ac847d3f5663f350210cecc70205b9fa0b9 Parents: ffb0560 Author: jingzhang Authored: Sun Mar 19 15:29:41 2017 +0800 Committer:

flink git commit: [FLINK-6124] [table] support max/min aggregations for string type

2017-03-21 Thread twalthr
ter: twalthr Committed: Tue Mar 21 12:18:30 2017 +0100 -- .../functions/aggfunctions/MaxAggFunction.scala | 8 + .../functions/aggfunctions/MinAggFunction.scala | 8 + .../table/runtime/aggregate/AggregateUtil.scala |

[2/3] flink-web git commit: Rebuild website and update date of release 1.1.5

2017-03-29 Thread twalthr
+ + +https://twitter.com/apacheflink"; target="_blank">@ApacheFlink + + +Plan Visualizer + + + + + + + + + + + From Streams to Tables and Back Again: An Update on Flink's Table & SQL API + + +29 Mar 2017 by Timo Walther (http

[1/3] flink-web git commit: New blog post about Table & SQL API's current state

2017-03-29 Thread twalthr
tp://git-wip-us.apache.org/repos/asf/flink-web/tree/d3e398ee Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/d3e398ee Branch: refs/heads/asf-site Commit: d3e398eefd55f444d78b3e2e7b99bc8c66f8c266 Parents: 98e9d76 Author: twalthr Authored: Wed Mar 29 18:25:39 2017 +0200 Committer: twalth

[3/3] flink-web git commit: Rebuild website and update date of release 1.1.5

2017-03-29 Thread twalthr
/asf/flink-web/diff/661f7648 Branch: refs/heads/asf-site Commit: 661f76489b9a1a1cf7b19b94e729f2cf7974a1f4 Parents: d3e398e Author: twalthr Authored: Wed Mar 29 18:34:21 2017 +0200 Committer: twalthr Committed: Wed Mar 29 18:34:21 2017 +0200

flink git commit: [FLINK-5829] [table] Bump Calcite version to 1.12.

2017-04-03 Thread twalthr
git-wip-us.apache.org/repos/asf/flink/tree/05ceec0a Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/05ceec0a Branch: refs/heads/master Commit: 05ceec0ace45135bc1cc17934a0b8721f4f85a03 Parents: f1ff99f Author: Haohui Mai Authored: Tue Mar 28 11:50:51 2017 -0700 Committer: twalthr Commit

flink git commit: [FLINK-6124] [table] Add min/max string aggregation with retracion

2017-04-03 Thread twalthr
cbc Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c5282cbc Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/c5282cbc Branch: refs/heads/master Commit: c5282cbcf898b99593ca753fce7557bae1ae09aa Parents: 05ceec0 Author: twalthr Authored: Wed Mar 22 10:03:56 2017 +0100 Committer: twal

flink git commit: [FLINK-3739] [table] Add a null literal to Table API

2016-04-15 Thread twalthr
ttp://git-wip-us.apache.org/repos/asf/flink/tree/50d8797b Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/50d8797b Branch: refs/heads/master Commit: 50d8797bba926d14b0873be3972e7f97b306f675 Parents: 494212b Author: twalthr Authored: Wed Apr 13 12:18:16 2016 +0200 Committer: twalthr Commit

flink git commit: [FLINK-3748] [table] Add CASE function to Table API

2016-04-19 Thread twalthr
ttp://git-wip-us.apache.org/repos/asf/flink/tree/4be297ec Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/4be297ec Branch: refs/heads/master Commit: 4be297ec29601a25ee5c12268d38b5f4f6203bd6 Parents: 85fcfc4 Author: twalthr Authored: Wed Apr 13 14:36:36 2016 +0200 Committer: twalthr Committed:

flink git commit: [FLINK-3086] [table] ExpressionParser does not support concatenation of suffix operations

2016-04-27 Thread twalthr
pos/asf/flink/commit/16059ea2 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/16059ea2 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/16059ea2 Branch: refs/heads/master Commit: 16059ea20b794d347bb44f01d6f78af781465447 Parents: 445d5e3 Author: twalthr Authored: Mon Apr 18 16:28:19 2

flink git commit: [FLINK-3786] [core] [api-extending] Add BigDecimal and BigInteger as Basic types

2016-05-02 Thread twalthr
ink/commit/b3231aca Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b3231aca Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b3231aca Branch: refs/heads/master Commit: b3231acaa445994a4bd234482364bb74b4bffae3 Parents: 290a566 Author: twalthr Authored: Wed Apr 20 15:57:39 2016 +0

flink git commit: [FLINK-3837] [table] Create FLOOR/CEIL function

2016-05-02 Thread twalthr
wip-us.apache.org/repos/asf/flink/tree/a0f53973 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a0f53973 Branch: refs/heads/master Commit: a0f5397384524bee9d5764fefe2eeaea708d723e Parents: 8be1a02 Author: twalthr Authored: Thu Apr 28 10:51:23 2016 +0200 Committer: twalthr Committed: Mon

[2/2] flink git commit: [FLINK-3859] [table] Add BigDecimal/BigInteger support to Table API

2016-06-23 Thread twalthr
://git-wip-us.apache.org/repos/asf/flink/diff/37defbb4 Branch: refs/heads/master Commit: 37defbb428fc6fbf2f425bdfa03bafca8b2b6a5e Parents: b6e6b81 Author: twalthr Authored: Mon May 9 12:10:57 2016 +0200 Committer: twalthr Committed: Thu Jun 23 11:05:57 2016 +0200

[1/2] flink git commit: [FLINK-3859] [table] Add BigDecimal/BigInteger support to Table API

2016-06-23 Thread twalthr
Repository: flink Updated Branches: refs/heads/master b6e6b8189 -> 37defbb42 http://git-wip-us.apache.org/repos/asf/flink/blob/37defbb4/flink-libraries/flink-table/src/test/scala/org/apache/flink/api/table/expressions/ScalarFunctionsTest.scala ---

flink git commit: [FLINK-3580] [table] Reintroduce Date/Time and implement scalar functions for it

2016-06-29 Thread twalthr
ink/commit/6979d060 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6979d060 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/6979d060 Branch: refs/heads/master Commit: 6979d060b8bf323ba08169d3e4a63e8f7f292058 Parents: e64237d Author: twalthr Authored: Fri Jun 17 09:27:57 2016 +0

flink git commit: [FLINK-4109] [tableAPI] Change the name of ternary condition operator 'eval' to '?'

2016-07-04 Thread twalthr
28 12:37:12 2016 +0800 Committer: twalthr Committed: Mon Jul 4 17:01:30 2016 +0200 -- docs/apis/table.md | 4 ++-- .../flink/api/scala/table/expressionDsl.scala | 8 .../table/expressions

[2/2] flink git commit: Merge branch 'FLINK-4086'

2016-07-04 Thread twalthr
8c Branch: refs/heads/master Commit: 18995c8c7b8f9c75035b1a95a00379944c6f2b0c Parents: e34fea5 429b844 Author: twalthr Authored: Mon Jul 4 18:21:04 2016 +0200 Committer: twalthr Committed: Mon Jul 4 18:21:04 2016 +0200 -- ...

[1/2] flink git commit: [FLINK-4086] [tableAPI] Hide internal methods of Expressions from Table API.

2016-07-04 Thread twalthr
200 Committer: twalthr Committed: Mon Jul 4 17:52:10 2016 +0200 -- .../api/table/expressions/Expression.scala | 24 +++ .../api/table/expressions/InputTypeSpec.scala | 4 +- .../api/table/expressions/aggregations.sc

flink git commit: [FLINK-3942] [tableAPI] Add support for INTERSECT and update document

2016-07-08 Thread twalthr
ter: twalthr Committed: Fri Jul 8 14:52:01 2016 +0200 -- docs/apis/table.md | 50 +++- .../api/table/plan/logical/operators.scala | 38 ++- .../plan/nodes/dataset/DataSetAggregate.scala |

flink git commit: [FLINK-3943] [table] Add support for EXCEPT operator

2016-07-11 Thread twalthr
ttp://git-wip-us.apache.org/repos/asf/flink/tree/97533939 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/97533939 Branch: refs/heads/master Commit: 97533939596c90fab69e2b4000846fc588f2a07b Parents: 5df0b27 Author: Ivan Mushketyk Authored: Sun Jun 26 15:20:25 2016 +0100 Committer: twal

flink git commit: [FLINK-3916] [table] Allow generic types passing the Table API

2016-07-12 Thread twalthr
ree: http://git-wip-us.apache.org/repos/asf/flink/tree/1b327f1a Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/1b327f1a Branch: refs/heads/master Commit: 1b327f1ae7d078e22700729524e374b449b0f209 Parents: 971dcc5 Author: twalthr Authored: Tue May 17 16:14:29 2016 +0200 Committer: twal

flink git commit: [FLINK-4111] [table] Flink Table & SQL doesn't work in very simple example

2016-07-12 Thread twalthr
flink/commit/508965e6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/508965e6 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/508965e6 Branch: refs/heads/master Commit: 508965e69cfb99724b69f1e5dc59e5f5d5a70315 Parents: cc9ee2c Author: twalthr Authored: Tue Jul 5 22:56:39 2016 +02

flink git commit: [FLINK-2985] [table] Allow different field names for unionAll() in Table API

2016-07-19 Thread twalthr
800 Committer: twalthr Committed: Tue Jul 19 14:16:39 2016 +0200 -- .../flink/api/table/codegen/CodeGenerator.scala | 2 +- .../api/table/plan/logical/operators.scala | 3 ++- .../plan/nodes/dataset/DataSetAggregate.scala |

flink git commit: [FLINK-4130] [table] CallGenerator could generate illegal code when taking no operands

2016-07-19 Thread twalthr
800 Committer: twalthr Committed: Tue Jul 19 14:45:58 2016 +0200 -- .../flink/api/table/codegen/calls/CallGenerator.scala| 11 --- 1 file changed, 8 insertions(+), 3 deleti

flink git commit: [FLINK-4183] [table] Move checking for StreamTableEnvironment into validation layer

2016-07-19 Thread twalthr
asf/flink/commit/e85f787b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e85f787b Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e85f787b Branch: refs/heads/master Commit: e85f787b280b63960e7f3add5aa8613b4ee23795 Parents: dd53831 Author: twalthr Authored: Fri Jul 8 16:50:17 2016 +0

(flink) branch master updated: [FLINK-35923][table-planner] Add CompiledPlan annotations to BatchExecSort/BatchExecExchange

2024-08-07 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new be11c63a21f [FLINK-35923][table-planner] Add

(flink) branch master updated: [FLINK-35934][table-planner] Add CompiledPlan annotations to BatchExecValues

2024-08-07 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 8ab011243a8 [FLINK-35934][table-planner] Add

(flink) branch master updated: [FLINK-35942][table-planner] Add CompiledPlan annotations to BatchExecCorrelate

2024-08-07 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 783150aa9ab [FLINK-35942][table-planner] Add

(flink) branch master updated: [FLINK-35943][table-planner] Add CompiledPlan annotations to BatchExecHashJoin and BatchExecNestedLoopJoin

2024-08-08 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new a885f4ffd08 [FLINK-35943][table-planner] Add

(flink) branch master updated: [FLINK-35941][table-planner] Add CompiledPlan annotations to BatchExecLimit

2024-08-08 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 8a45cd6cffb [FLINK-35941][table-planner] Add

(flink) branch master updated: [FLINK-36003][table-planner] Add CompiledPlan annotations to BatchExecExpand and BatchExecSortAggregate

2024-08-13 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 268144c30fa [FLINK-36003][table-planner] Add

(flink) branch master updated (e8c1d1b9d41 -> 9ecf4cf405c)

2024-08-21 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from e8c1d1b9d41 [FLINK-35963][table] Add the built-in function REGEXP_SUBSTR add 9ecf4cf405c [FLINK-35716] Adds a

(flink) branch master updated: [FLINK-35708][table-planner] Allow defining a schema in REPLACE TABLE AS (RTAS)

2024-08-27 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new c1fa29ac91a [FLINK-35708][table-planner] Allow

(flink) branch master updated: [FLINK-35790][docs] Update docs for new schema definition in CTAS and RTAS

2024-08-27 Thread twalthr
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 8c116def0b5 [FLINK-35790][docs] Update docs for

flink git commit: [FLINK-2642] [table] Scala Table API crashes when executing word count example

2015-10-06 Thread twalthr
ink/commit/4938ff09 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4938ff09 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/4938ff09 Branch: refs/heads/master Commit: 4938ff09f692d7b8b1c3af16125d2216eb5c623c Parents: 4c5d43b Author: twalthr Authored: Fri Oct 2 11:12:01 2015 +0

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 Authored: Wed Sep 27 17:11:28 2017 +0200 Commit

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 Authored: Wed Sep 27 13:05:44 2017 +0200 Committer: twalthr Committed:

[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 Authored: Wed Sep 27 13:48:55 2017 -0700 Committer: twalthr Committed: Mon Nov 13 14:20:25 2017 +0100

[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 Authored: Mon Nov 13 14:09:45 2017 +0100 Committer: twalthr Committed: Mon Nov

[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 Authored: Mon Nov 13 14:09:45 2017 +0100 Committer: twalthr Committed: Mon Nov 13 14:22:27 2017 +0100

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

2017-11-13 Thread twalthr
700 Committer: twalthr Committed: Mon Nov 13 14:22:16 2017 +0100 -- .../flink/table/expressions/literals.scala | 34 +-- .../table/plan/util/RexProgramExtractor.scala | 33 ++- .../flink/table/api/TableSourceTest.sc

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

2017-11-15 Thread twalthr
800 Committer: twalthr Committed: Wed Nov 15 14:11:57 2017 +0100 -- .../flink/table/calcite/FlinkTypeFactory.scala | 6 + .../table/expressions/LiteralPrefixTest.scala | 79 - .../flink/table/expressions/LiteralTest.sc

[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 Authored: Wed Nov 15 14:39:21 2017 +0100 Committer: twalthr Committed: Wed Nov 15 14:41:47 2017 +0100

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

2017-11-15 Thread twalthr
017 +0800 Committer: twalthr Committed: Wed Nov 15 14:49:52 2017 +0100 -- .../flink/table/calcite/FlinkTypeFactory.scala | 6 + .../table/expressions/LiteralPrefixTest.scala | 79 - .../flink/table/expressi

[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 Authored: Wed Nov 15 14:39:21 2017 +0100 Committer: twalthr Committed: Wed Nov 15 14:50:01 2017 +0100

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 Authored: Tue Nov 14 11:06:54 2017 +0100 Commit

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 Authored: Tue Nov 14 11:06:54 2017 +0

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 Authored: Tue Sep 26 12:10:33 2017 +0200 Commit

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 Authored: Tue Sep 26 12:10:33 2017 +0

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

2017-11-15 Thread twalthr
:55 2017 +0100 Committer: twalthr Committed: Wed Nov 15 17:49:41 2017 +0100 -- .../operators/translation/RichCombineToGroupCombineWrapper.java| 1 + .../flink/table/runtime/aggregate/AggregateAggFunction.scala

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

2017-11-15 Thread twalthr
15 10:12:55 2017 +0100 Committer: twalthr Committed: Wed Nov 15 17:55:25 2017 +0100 -- .../operators/translation/RichCombineToGroupCombineWrapper.java| 1 + .../flink/table/runtime/aggregate/AggregateAggFunction.scala

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

2017-11-15 Thread twalthr
15 10:12:55 2017 +0100 Committer: twalthr Committed: Wed Nov 15 18:00:20 2017 +0100 -- .../operators/translation/RichCombineToGroupCombineWrapper.java| 1 + .../flink/table/runtime/aggregate/AggregateAggFunction.scala

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 Authored: Wed Nov 15 12:07:16 2017 +0100 Committer: twalthr Committed:

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 Authored: Wed Nov 15 12:07:16 2017 +0100 Committer: twal

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

2017-11-16 Thread twalthr
org/repos/asf/flink/tree/101fef73 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/101fef73 Branch: refs/heads/master Commit: 101fef7397128b0aba23221481ab86f62b18118f Parents: d0b2aa2 Author: twalthr Authored: Thu Nov 16 11:00:30 2017 +0100 Committer: twalthr Committed: Thu Nov 16 11:00

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

2017-11-16 Thread twalthr
wip-us.apache.org/repos/asf/flink/tree/397f0d15 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/397f0d15 Branch: refs/heads/release-1.4 Commit: 397f0d150255ea24fd5fd4cc38848441bb0fff58 Parents: 13962e1 Author: twalthr Authored: Thu Nov 16 11:00:30 2017 +0100 Committer: twalthr Committed: Thu Nov 16

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

2017-11-16 Thread twalthr
ttp://git-wip-us.apache.org/repos/asf/flink/tree/81dc260d Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/81dc260d Branch: refs/heads/master Commit: 81dc260dc653085b9dbf098e8fd70a72d2d0828e Parents: cd1fbc0 Author: Xpray Authored: Mon Nov 6 23:47:33 2017 +0800 Committer: twalthr Commit

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

2017-11-16 Thread twalthr
ree: http://git-wip-us.apache.org/repos/asf/flink/tree/42e24413 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/42e24413 Branch: refs/heads/release-1.4 Commit: 42e24413b5a47928e06f2a61086f7559370c65d8 Parents: e7f7d0c Author: Xpray Authored: Mon Nov 6 23:47:33 2017 +0800 Committer: twal

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

2017-11-20 Thread twalthr
800 Committer: twalthr Committed: Mon Nov 20 10:52:27 2017 +0100 -- .../table/api/StreamTableEnvironment.scala | 39 .../runtime/stream/TimeAttributesITCase.scala | 26 - 2 files changed,

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

2017-11-20 Thread twalthr
017 +0800 Committer: twalthr Committed: Mon Nov 20 12:18:26 2017 +0100 -- .../table/api/StreamTableEnvironment.scala | 39 .../runtime/stream/TimeAttributesITCase.scala | 26 - 2 files chan

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

2017-11-20 Thread twalthr
ttp://git-wip-us.apache.org/repos/asf/flink/tree/0a22acef Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0a22acef Branch: refs/heads/master Commit: 0a22acef41ede452b3df1a9874b5ae4a336d8a77 Parents: 691c48a Author: Xpray Authored: Fri Nov 17 11:01:27 2017 +0800 Committer: twalthr Commit

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

2017-11-20 Thread twalthr
ree: http://git-wip-us.apache.org/repos/asf/flink/tree/3fe70d76 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/3fe70d76 Branch: refs/heads/release-1.4 Commit: 3fe70d761239d03b7433976ff19e1bbb83855b37 Parents: 4d55987 Author: Xpray Authored: Fri Nov 17 11:01:27 2017 +0800 Committer: twal

[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 Authored: Tue Nov 21 16:57:04 2017 +0100 Committer: twalthr Committed: Tue Nov 21 17:09

[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 Authored: Tue Nov 14 10:48:16 2017 -0800 Committer: twalthr Committed: Tue Nov 21 17:09:02 2017 +0100

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

2017-11-21 Thread twalthr
800 Committer: twalthr Committed: Tue Nov 21 17:31:27 2017 +0100 -- .../functions/aggfunctions/MaxAggFunction.scala | 20 +- .../MaxAggFunctionWithRetract.scala | 20 +- .../functions/aggfunctions/MinAggFunction.sc

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 Authored: Wed Nov 22 17:43:08 2017 +0100 Committer: 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 Authored: Wed Nov 22 17:43:08 2017 +0100 Commit

[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 Authored: Thu Nov 23 00:00:39 2017 +0800 Committer: twalthr Committed: Thu Nov 23 14:49:14 2017 +0100

[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 Authored: Thu Nov 23 14:30:15 2017 +0100 Committer: twalthr Committed: Thu Nov 23 14:49:14 2

flink git commit: [FLINK-8151] [table] Fix map type equality

2017-12-01 Thread twalthr
wip-us.apache.org/repos/asf/flink/tree/deea4b32 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/deea4b32 Branch: refs/heads/master Commit: deea4b32bab4160e2279e9f57d7272df2d91e434 Parents: 740f711 Author: Rong Rong Authored: Sat Nov 25 17:17:14 2017 -0800 Committer: twalthr Committed: Fri De

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 Authored: Fri Dec 1 15:37:23 2017 +0100 Committer: twal

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

2017-12-01 Thread twalthr
e3f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6ca2be3f Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/6ca2be3f Branch: refs/heads/release-1.4 Commit: 6ca2be3ffbf3f8a92c21b0990e317ff3a60a3e82 Parents: 6628f19 Author: twalthr Authored: Fri Dec 1 15:37:23 2017 +0100 Commit

flink git commit: [FLINK-8104] [table] Add ROW value constructor

2017-12-04 Thread twalthr
wip-us.apache.org/repos/asf/flink/tree/e1d65662 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e1d65662 Branch: refs/heads/master Commit: e1d656621d8b291087652fee15d577d43d22f2d7 Parents: 4bd0ef1 Author: Rong Rong Authored: Mon Nov 20 13:47:50 2017 -0800 Committer: twalthr Committed:

flink git commit: [hotfix] [docs] Upgrade Scala version to 2.11

2017-12-07 Thread twalthr
org/repos/asf/flink/tree/2435fe90 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2435fe90 Branch: refs/heads/release-1.4 Commit: 2435fe9091edfac212e1bcf7d1d0c534da32a824 Parents: 9b63cba Author: twalthr Authored: Thu Dec 7 13:59:20 2017 +0100 Committer: twalthr Committed: Thu Dec 7 13:59

flink git commit: [FLINK-9181] [docs] [sql-client] Add documentation for the SQL Client

2018-05-14 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 1726a63b1 -> a89cc5076 [FLINK-9181] [docs] [sql-client] Add documentation for the SQL Client This closes #5913. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a89cc50

flink git commit: [FLINK-9181] [docs] [sql-client] Add documentation for the SQL Client

2018-05-14 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.5 865c60848 -> 552435e48 [FLINK-9181] [docs] [sql-client] Add documentation for the SQL Client This closes #5913. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/55

[1/2] flink git commit: [FLINK-6926] [table] Add support for SHA-224, SHA-384, SHA-512

2018-05-15 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 33d3b767e -> d5de2bcf1 [FLINK-6926] [table] Add support for SHA-224, SHA-384, SHA-512 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5544ab5d Tree: http://git-wip-us.a

[2/2] flink git commit: [FLINK-6926] [table] Add support for SHA2 (Compatible with SQL vendors like MySQL)

2018-05-15 Thread twalthr
[FLINK-6926] [table] Add support for SHA2 (Compatible with SQL vendors like MySQL) This closes #5324. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d5de2bcf Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d5de2bcf

flink git commit: [FLINK-9361] [sql-client] Fix refresh interval in changelog mode

2018-05-15 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 89ac3dbe4 -> 0b5e124ba [FLINK-9361] [sql-client] Fix refresh interval in changelog mode This closes #6012. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0b5e124b Tre

flink git commit: [FLINK-9361] [sql-client] Fix refresh interval in changelog mode

2018-05-15 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.5 f07f36fcf -> 6da10a13c [FLINK-9361] [sql-client] Fix refresh interval in changelog mode This closes #6012. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6da10a1

[1/2] flink git commit: [FLINK-8428] [table] Implement stream-stream non-window left outer join

2018-05-17 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 489e42811 -> 8b95ba399 http://git-wip-us.apache.org/repos/asf/flink/blob/8b95ba39/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/batch/table/JoinITCase.scala

[2/2] flink git commit: [FLINK-8428] [table] Implement stream-stream non-window left outer join

2018-05-17 Thread twalthr
[FLINK-8428] [table] Implement stream-stream non-window left outer join Two different CoProcessFunctions are used to implement left join for performance reasons. One for left join with non-equal predicates, the other for left join without non-equal predicates. The main difference between them is

flink git commit: [FLINK-8429] [table] Implement stream-stream non-window right outer join

2018-05-22 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 2cc5bd6e1 -> 26509e50d [FLINK-8429] [table] Implement stream-stream non-window right outer join This closes #6046. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2650

flink git commit: [FLINK-6909] [types] Add tests for Lombok POJOs

2018-05-22 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 26509e50d -> 5ac96c7c2 [FLINK-6909] [types] Add tests for Lombok POJOs This closes #6033. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5ac96c7c Tree: http://git-wip

flink git commit: [FLINK-6909] [types] Fix error message in CsvReader for wrong type class

2018-05-22 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 5ac96c7c2 -> 1c5a929c7 [FLINK-6909] [types] Fix error message in CsvReader for wrong type class This closes #6037. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1c5a

flink git commit: [FLINK-6909] [types] Fix error message in CsvReader for wrong type class

2018-05-22 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.5 5e71bf872 -> 30c224abd [FLINK-6909] [types] Fix error message in CsvReader for wrong type class This closes #6037. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit

flink git commit: [FLINK-6909] [types] Fix error message in CsvReader for wrong type class

2018-05-22 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.4 7cd2b392a -> 73ca6cc0f [FLINK-6909] [types] Fix error message in CsvReader for wrong type class This closes #6037. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit

flink git commit: [hotfix] [types] Expose type extraction error for fromElements/Collection()

2018-05-22 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 1c5a929c7 -> c80e76bd7 [hotfix] [types] Expose type extraction error for fromElements/Collection() This closes #6036. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c

flink git commit: [FLINK-8838] [table] Add support for UNNEST on MultiSet fields

2018-05-22 Thread twalthr
Repository: flink Updated Branches: refs/heads/master c80e76bd7 -> a273f645b [FLINK-8838] [table] Add support for UNNEST on MultiSet fields This closes #5619. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a273f645 Tree:

flink git commit: [FLINK-7814] [table] Add BETWEEN and NOT BETWEEN expression to Table API

2018-05-23 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 2aca82545 -> 5563681bc [FLINK-7814] [table] Add BETWEEN and NOT BETWEEN expression to Table API This closes #6027. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5563

flink git commit: [FLINK-8511] [table] Remove legacy code for the TableType annotation

2018-05-24 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 9bdd70cad -> 355ec15cb [FLINK-8511] [table] Remove legacy code for the TableType annotation This closes #6055. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/355ec15c

flink git commit: [FLINK-9420] [table] Add tests and docs for SQL IN sub-query operator in streaming

2018-05-24 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 88987ebb9 -> c47cc87e5 [FLINK-9420] [table] Add tests and docs for SQL IN sub-query operator in streaming This closes #6065. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/

flink git commit: [FLINK-9384] [table] Fix KafkaAvroTableSource type mismatch

2018-05-25 Thread twalthr
Repository: flink Updated Branches: refs/heads/master cb48019ff -> bc8d1b1f6 [FLINK-9384] [table] Fix KafkaAvroTableSource type mismatch This closes #6026. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bc8d1b1f Tree: ht

flink git commit: [FLINK-9409] [formats] Remove flink-avro and flink-json from /opt

2018-05-25 Thread twalthr
Repository: flink Updated Branches: refs/heads/master bc8d1b1f6 -> aa07be225 [FLINK-9409] [formats] Remove flink-avro and flink-json from /opt This closes #6070. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/aa07be22 Tr

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