flink git commit: [FLINK-1471][java-api] Fixes wrong input validation if function has no generics

/d033fa8f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d033fa8f Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d033fa8f Branch: refs/heads/master Commit: d033fa8fa834d288ec977ef7bda043dfdc397e59 Parents: 4046819 Author: twalthr twal...@apache.org Authored: Tue Feb 3 22:51:10

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

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 <twal...@apache.org> Authored: Fri Oct 2

flink git commit: [FLINK-3046] Integrate the Either Java type with the TypeExtractor

2e7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f73a12e7 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f73a12e7 Branch: refs/heads/master Commit: f73a12e728431d87065f7d0082380a527df39e44 Parents: e69d145 Author: twalthr <twal...@apache.org> Authored: Mon Nov 23 15:08:47 2

flink git commit: [FLINK-2961] [table] Add support for basic type Date in Table API

nts: a997dd6 Author: twalthr <twal...@apache.org> Authored: Tue Nov 3 15:18:19 2015 +0100 Committer: twalthr <twal...@apache.org> Committed: Sun Nov 29 16:48:27 2015 +0100 -- docs/libs/table.md

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

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 <twal...@apache.org> Authored: Fri Jun

flink git commit: [FLINK-3140] [table] NULL value data layout in Row Serializer/Comparator

mit/440137cc Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/440137cc Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/440137cc Branch: refs/heads/master Commit: 440137cc3ad8ab47dff84212c81e960e0a254eaa Parents: 499b60f Author: twalthr <twal...@apache.org> Authored: Fri Jan 22 15:2

[1/2] flink git commit: [FLINK-3226] Translation of scalar function substring()

wip-us.apache.org/repos/asf/flink/tree/3e220745 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/3e220745 Branch: refs/heads/tableOnCalcite Commit: 3e22074553cedde1c3a1754d91d26a9f35ac3c2f Parents: 1c53c87 Author: twalthr <twal...@apache.org> Authored: Sat Feb 20 21:41:44 2016 +0100

flink git commit: [FLINK-3574] Implement math functions for Table API

7:42 2016 +0100 Committer: twalthr <twal...@apache.org> Committed: Mon Mar 14 14:08:25 2016 +0100 -- .../flink/api/scala/table/expressionDsl.scala | 34 ++- .../table/codegen/calls/BuiltInMethods.scala| 29 +++ ..

flink git commit: [FLINK-3573] [table] Implement more String functions for Table API

ttp://git-wip-us.apache.org/repos/asf/flink/tree/e9b9b6f3 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e9b9b6f3 Branch: refs/heads/tableOnCalcite Commit: e9b9b6f3a61ac18b92b183408abf85aa243ccb54 Parents: 2fcdad9 Author: twalthr <twal...@apache.org> Authored: Fri Mar 4 11:37:58 2

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

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 <twal...@apache.org> Auth

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

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 <twal...@apache.org> Authored: Thu Apr 28 10:51:23 2016 +0200 Committer

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

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 <twal...@apache.org> Authored: Wed Apr

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

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 <twal...@apache.org> Authored: Wed Apr 13 12:18:16 2016 +0200

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

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 <twal...@apache.org> Authored: Wed Apr 13 14:36:36 2016 +0200

[1/2] flink git commit: [FLINK-4103] [table] Modify CsvTableSource to implement StreamTableSource

23:55:14 2016 -0400 Committer: twalthr <twal...@apache.org> Committed: Tue Jul 26 10:47:57 2016 +0200 -- .../api/table/sources/CsvTableSource.scala | 41 - .../api/table/validate/FunctionCatalog.scala|

[2/2] flink git commit: [FLINK-4103] [table] Add CsvTableSource docs and Java accessibility

/repos/asf/flink/diff/110bba38 Branch: refs/heads/master Commit: 110bba386a3ac89a8f312cd4d1405571eee9d4b5 Parents: 7e309ee Author: twalthr <twal...@apache.org> Authored: Tue Jul 26 10:44:24 2016 +0200 Committer: twalthr <twal...@apache.org> Committed: Tue Jul 26 11:03:2

flink git commit: [FLINK-4244] [docs] Field names for union operator do not have to be equal

Jul 21 23:25:44 2016 +0800 Committer: twalthr <twal...@apache.org> Committed: Mon Jul 25 15:47:07 2016 +0200 -- docs/apis/table.md | 11 --- 1 file changed, 4 insertions(

[1/2] flink git commit: [FLINK-3901] [table] Convert Java implementation to Scala and fix bugs

mit/2f9a28ae Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2f9a28ae Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2f9a28ae Branch: refs/heads/master Commit: 2f9a28ae113f0e941b8bf3676ab84e1492fbf26f Parents: c5d1d12 Author: twalthr <twal...@apache.org> Authored: Fri Jul 22 11:2

flink git commit: [FLINK-3891] [table] Add a class containing all supported Table API types

mit/b6f9308c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b6f9308c Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b6f9308c Branch: refs/heads/master Commit: b6f9308c9841db1e775358da50a8498409cde298 Parents: 2f9a28a Author: twalthr <twal...@apache.org> Authored: Mon Jul 25

[2/2] flink git commit: [FLINK-4179] [table] Update TPCHQuery3Table example

-us.apache.org/repos/asf/flink/diff/ec4c9bef Branch: refs/heads/master Commit: ec4c9bef47ea6daec80476e2e37e9171451b3e6e Parents: 5eb0e38 Author: smarthi <smar...@apache.org> Authored: Tue Jul 12 20:47:53 2016 -0400 Committer: twalthr <twal...@apache.org> Committed: Thu Jul 28 09:56:0

[1/2] flink git commit: [FLINK-4179] [table] Additional TPCHQuery3Table example improvements

git-wip-us.apache.org/repos/asf/flink/tree/185b5f6c Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/185b5f6c Branch: refs/heads/master Commit: 185b5f6c6b91e4ae61ff77c7d22d1296153a320c Parents: ec4c9be Author: twalthr <twal...@apache.org> Authored: Thu Jul 28 09:52:46 2016 +0200

[2/2] flink git commit: [FLINK-4180] [FLINK-4181] [table] add Batch SQL and Stream SQL and Stream Table API examples

/tree/123c637e Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/123c637e Branch: refs/heads/master Commit: 123c637e804bfdd6569051cf705ec73b5cb95352 Parents: 45df1b2 Author: Jark Wu <wuchong...@alibaba-inc.com> Authored: Thu Jul 21 00:31:01 2016 +0800 Committer: twalthr <twal...@a

[1/2] flink git commit: [FLINK-4180] [FLINK-4181] [table] Ensure examples consistency

wip-us.apache.org/repos/asf/flink/tree/a1fef27b Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a1fef27b Branch: refs/heads/master Commit: a1fef27b9c9ddd03b3de9bfe35f1d9e7d973c756 Parents: 123c637e Author: twalthr <twal...@apache.org> Authored: Tue Aug 2 16:21:45 2016 +0200 Committer: twal

flink git commit: [FLINK-4203] [table] [docs] Improve Table API documentation

ree: http://git-wip-us.apache.org/repos/asf/flink/tree/3f1e8b91 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/3f1e8b91 Branch: refs/heads/master Commit: 3f1e8b91574d66a8e9d8b74a6be1227535064405 Parents: a1fef27 Author: twalthr <twal...@apache.org> Authored: Thu Jul 21 17:15:07 2

flink git commit: [hotfix] Fix exception message

ree/5d2c465a Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5d2c465a Branch: refs/heads/master Commit: 5d2c465afdf1f2e4f630568435c69e1668a184c1 Parents: 3f1e8b9 Author: twalthr <twal...@apache.org> Authored: Tue Aug 2 17:08:58 2016 +0200 Committer: twalthr <twal...@apache.org>

flink git commit: [FLINK-4270] [table] 'as' in front of join does not work

016 +0800 Committer: twalthr <twal...@apache.org> Committed: Thu Aug 11 12:23:22 2016 +0200 -- .../org/apache/flink/api/table/plan/logical/operators.scala | 9 + .../org/apache/flink/api/scala/batch/table/JoinITCase.sc

flink git commit: [FLINK-4242] [table] Improve validation exception messages

016 +0800 Committer: twalthr <twal...@apache.org> Committed: Thu Aug 11 14:16:26 2016 +0200 -- .../api/table/expressions/arithmetic.scala | 6 +++--- .../flink/api/table/expressions/logic.scala | 8 .../ta

flink git commit: [FLINK-4359] [table] Add INTERVAL type

wip-us.apache.org/repos/asf/flink/tree/f170e04a Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f170e04a Branch: refs/heads/master Commit: f170e04ab93fba75c517b0f9184587d7b306113e Parents: f0992aa Author: twalthr <twal...@apache.org> Authored: Mon Aug 8 10:15:49 2016 +0200 Committer: twal

flink git commit: [FLINK-4385] [table] Union on Timestamp fields does not work

8:23 2016 +0800 Committer: twalthr <twal...@apache.org> Committed: Mon Aug 15 09:27:14 2016 +0200 -- .../apache/flink/api/table/plan/nodes/dataset/DataSetRel.scala | 5 - .../org/apache/flink/api/table/typeutils/IntervalTyp

[1/2] flink git commit: [FLINK-3940] [table] Additional improvements

cb9 Author: twalthr <twal...@apache.org> Authored: Wed Aug 10 23:49:27 2016 +0200 Committer: twalthr <twal...@apache.org> Committed: Thu Aug 11 10:27:11 2016 +0200 -- docs/apis/table.md

[2/2] flink git commit: [FLINK-3940] [table] Add support for ORDER BY OFFSET FETCH

-us.apache.org/repos/asf/flink/diff/0472cb9b Branch: refs/heads/master Commit: 0472cb9ba44de7223fffbc0eca0232d558730772 Parents: dc50625 Author: gallenvara <gallenv...@126.com> Authored: Fri Jul 22 11:39:46 2016 +0800 Committer: twalthr <twal...@apache.org> Committed: Thu Aug 11 10:27:1

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

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 <twal...@apache.org> Authored: Tue May 17 16:14:29 2

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

n 6 16:30:41 2016 +0800 Committer: twalthr <twal...@apache.org> Committed: Tue Jul 19 14:16:39 2016 +0200 -- .../flink/api/table/codegen/CodeGenerator.scala | 2 +- .../api/table/plan/logical/operators.scala | 3 ++-

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

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 <twal...@apache.org> Authored: Fri

flink git commit: [FLINK-3729] [table] Several SQL tests fail on Windows OS

Committer: twalthr <twal...@apache.org> Committed: Wed Jul 20 16:25:53 2016 +0200 -- .../flink/api/table/BatchTableEnvironment.scala | 9 +--- .../flink/api/java/batch/ExplainTest.java | 24 ++--

flink git commit: [FLINK-4070] [table] Support literals on left side of binary expressions

17 11:39:21 2016 +0800 Committer: twalthr <twal...@apache.org> Committed: Wed Jul 20 15:01:47 2016 +0200 -- .../org/apache/flink/api/scala/table/expressionDsl.scala | 11 ++- .../flink/api/scala/batch/table/Expressi

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

19:57:09 2016 +0800 Committer: twalthr <twal...@apache.org> Committed: Fri Jul 8 14:52:01 2016 +0200 -- docs/apis/table.md | 50 +++- .../api/table/plan/logical/operators.scala | 38 ++-

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

016 +0100 Committer: twalthr <twal...@apache.org> Committed: Mon Jul 11 13:57:49 2016 +0200 -- docs/apis/table.md | 51 ++- .../api/table/plan/logical/operators.scala | 31 +

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

Jun 17 15:16:42 2016 +0200 Committer: twalthr <twal...@apache.org> Committed: Mon Jul 4 17:52:10 2016 +0200 -- .../api/table/expressions/Expression.scala | 24 +++ .../api/table/expressions/InputTypeSpec.scala |

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

ored: Tue Jun 28 12:37:12 2016 +0800 Committer: twalthr <twal...@apache.org> Committed: Mon Jul 4 17:01:30 2016 +0200 -- docs/apis/table.md | 4 ++-- .../flink/api/scala/table/expressionD

[2/3] flink git commit: [FLINK-4304] [runtime-web] Jar names that contain whitespace cause problems in web client

http://git-wip-us.apache.org/repos/asf/flink/blob/8d25c641/flink-runtime-web/web-dashboard/web/js/index.js -- diff --git a/flink-runtime-web/web-dashboard/web/js/index.js b/flink-runtime-web/web-dashboard/web/js/index.js index

[1/3] flink git commit: [FLINK-4304] [runtime-web] Jar names that contain whitespace cause problems in web client

Repository: flink Updated Branches: refs/heads/master c9b0dad89 -> 8d25c6414 http://git-wip-us.apache.org/repos/asf/flink/blob/8d25c641/flink-runtime-web/web-dashboard/web/js/vendor.js -- diff --git

[3/3] flink git commit: [FLINK-4304] [runtime-web] Jar names that contain whitespace cause problems in web client

/8d25c641 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/8d25c641 Branch: refs/heads/master Commit: 8d25c64146ef0a2d0e9ee4c3e8ac3229e72a1416 Parents: c9b0dad Author: twalthr <twal...@apache.org> Authored: Tue Aug 2 14:53:30 2016 +0200 Committer: twalthr <twal...@apache.org> Co

flink git commit: [FLINK-3138] [types] Method References are not supported as lambda expressions

ink/commit/ff777084 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ff777084 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ff777084 Branch: refs/heads/master Commit: ff777084ba2e1f1070ce5ecbc5afc122756ba851 Parents: 8d25c64 Author: twalthr <twal...@apache.org> Authored: Wed Aug 3

flink git commit: [hotfix] Fix failing Table API test and checkstyle violation

wip-us.apache.org/repos/asf/flink/tree/31837a75 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/31837a75 Branch: refs/heads/master Commit: 31837a7571dd79795a75d74e3b54245cb720a57c Parents: 36c09b0 Author: twalthr <twal...@apache.org> Authored: Tue Aug 2 20:07:20 2016 +0200 Committer: twal

flink git commit: [FLINK-3097] [table] Add support for custom functions in Table API

e45 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/90fdae45 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/90fdae45 Branch: refs/heads/master Commit: 90fdae452b6a03fafd4ec7827030d78ae87dbcd3 Parents: 83c4b97 Author: twalthr <twal...@apache.org> Authored: Tue Jul 12 12:22:41 2

flink git commit: [FLINK-4281] [table] Wrap all Calcite Exceptions in Flink Exceptions

23:25:08 2016 +0800 Committer: twalthr <twal...@apache.org> Committed: Wed Aug 17 16:46:23 2016 +0200 -- .../flink/api/table/FlinkPlannerImpl.scala | 56 +++- .../org/apache/flink/api/table/except

flink git commit: [FLINK-5678] [table] Fix User-defined Functions do not support all types of parameters

Authored: Sun Jan 29 18:36:28 2017 +0600 Committer: twalthr <twal...@apache.org> Committed: Mon Jan 30 14:51:57 2017 +0100 -- .../codegen/calls/ScalarFunctionCallGen.scala | 12 +++ .../codegen/calls/TableFunctionCallGe

flink git commit: [FLINK-5678] [table] Fix User-defined Functions do not support all types of parameters

nc.com> Authored: Sun Jan 29 18:36:28 2017 +0600 Committer: twalthr <twal...@apache.org> Committed: Mon Jan 30 14:56:44 2017 +0100 -- .../codegen/calls/ScalarFunctionCallGen.scala | 12 +++ ..

flink git commit: [FLINK-5224] [table] Improve UDTF: emit rows directly instead of buffering them

: Fri Jan 13 21:53:49 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Thu Jan 26 10:45:11 2017 +0100 -- .../flink/table/codegen/CodeGenerator.scala | 94 ++ .../codegen/calls/TableFunctionCallGen

flink git commit: [FLINK-5224] [table] Improve UDTF: emit rows directly instead of buffering them

Authored: Fri Jan 13 21:53:49 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Thu Jan 26 11:02:16 2017 +0100 -- .../flink/table/codegen/CodeGenerator.scala | 94 ++ .../codegen/calls/TableFuncti

flink git commit: [hotfix] [table] Update documentation about limitations

wip-us.apache.org/repos/asf/flink/tree/8ccedd10 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/8ccedd10 Branch: refs/heads/master Commit: 8ccedd103f1c6f31047e4dcd62b7bf4889e89d0f Parents: 1fc3450 Author: twalthr <twal...@apache.org> Authored: Fri Jan 20 14:17:45 2017 +0100 Committer: twal

flink git commit: [FLINK-5571] [table] add open and close methods for UserDefinedFunction

2:12 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Mon Feb 20 15:38:34 2017 +0100 -- docs/dev/table_api.md | 92 + .../flink/table/codegen/CodeGenerator.

flink git commit: [FLINK-5406] [table] Add normalization phase for predicate logical plan rewriting

Jan 12 18:42:49 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Tue Feb 14 14:30:04 2017 +0100 -- .../flink/table/api/BatchTableEnvironment.scala | 52 +++ .../table/api/StreamTableEnvironment.s

[1/3] flink git commit: [FLINK-5662] [table] Rework internal type handling of Table API

Repository: flink Updated Branches: refs/heads/master 1ce10c877 -> 6bc6b225e http://git-wip-us.apache.org/repos/asf/flink/blob/6bc6b225/flink-libraries/flink-table/src/test/java/org/apache/flink/table/api/java/batch/TableEnvironmentITCase.java

[3/3] flink git commit: [FLINK-5662] [table] Rework internal type handling of Table API

-wip-us.apache.org/repos/asf/flink/diff/6bc6b225 Branch: refs/heads/master Commit: 6bc6b225e55095eb8797db2903b0546410e7fdd9 Parents: 1ce10c8 Author: twalthr <twal...@apache.org> Authored: Mon Feb 6 17:18:08 2017 +0100 Committer: twalthr <twal...@apache.org> Committed: Mon Feb 13 17:50:0

[2/3] flink git commit: [FLINK-5662] [table] Rework internal type handling of Table API

http://git-wip-us.apache.org/repos/asf/flink/blob/6bc6b225/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetCalc.scala -- diff --git

flink git commit: [FLINK-5714] [table] Use a builder pattern for creating CsvTableSource

21:57:04 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Wed Feb 15 16:07:17 2017 +0100 -- docs/dev/table_api.md | 73 --- .../flink/table/sources/CsvTableSource

flink git commit: [FLINK-4692] [table] Add tumbling group-windows for batch tables

8:01 2016 +0800 Committer: twalthr <twal...@apache.org> Committed: Mon Jan 16 12:17:27 2017 +0100 -- docs/dev/table_api.md | 3 +- .../org/apache/flink/table/api/table.scala | 6 - .../ta

flink git commit: [hotfix] [table] Test does not extend TableProgramsTestBase

wip-us.apache.org/repos/asf/flink/tree/68228ffd Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/68228ffd Branch: refs/heads/master Commit: 68228ffdd852ac696c48a848ec66a4951b22f372 Parents: 1753b1d Author: twalthr <twal...@apache.org> Authored: Mon Jan 16 13:19:05 2017 +0100 Committer: twal

flink git commit: [FLINK-5303] [table] Add CUBE/ROLLUP/GROUPING SETS operator in SQL

: Wed Dec 7 10:57:04 2016 +0300 Committer: twalthr <twal...@apache.org> Committed: Mon Jan 16 16:40:01 2017 +0100 -- docs/dev/table_api.md | 50 - .../table/expressions/ExpressionParser

flink git commit: [FLINK-5447] [table] Sync documentation of built-in functions for Table API with SQL

asf/flink/commit/a062f4b8 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a062f4b8 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a062f4b8 Branch: refs/heads/master Commit: a062f4b8e6bfd46ad7220b09479ac726d12002a1 Parents: 7a339a6 Author: twalthr <twal...@apache.org> Authored: F

flink git commit: [FLINK-5268] Split TableProgramsTestBase into TableProgramsCollectionTestBase and TableProgramsClusterTestBase

t;oatg...@gmail.com> Authored: Thu Jan 12 17:30:57 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Tue Jan 17 13:41:12 2017 +0100 -- .../api/java/batch/TableEnvironmentITCase.java | 15 - .../table

flink git commit: [FLINK-5394] [table] Fix row count estimation

Committer: twalthr <twal...@apache.org> Committed: Tue Jan 17 12:53:25 2017 +0100 -- .../flink/table/calcite/FlinkRelBuilder.scala | 7 .../cost/FlinkDefaultRelMetadataProvider.scala | 32 ++ .../

flink git commit: [FLINK-5447] [table] Sync documentation of built-in functions for Table API with SQL

pos/asf/flink/commit/f3aea01e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f3aea01e Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f3aea01e Branch: refs/heads/release-1.2 Commit: f3aea01eb6ebecbb58c368cae9006a7831f07f41 Parents: 2eb926f Author: twalthr <twal...@apache.org>

flink git commit: [FLINK-5394] [table] Fix row count estimation

016 +0800 Committer: twalthr <twal...@apache.org> Committed: Tue Jan 17 12:55:36 2017 +0100 -- .../flink/table/calcite/FlinkRelBuilder.scala | 7 .../cost/FlinkDefaultRelMetadataProvider.scala | 32 ++ .../

[2/3] flink git commit: [FLINK-5144] [table] Fix error while applying rule AggregateJoinTransposeRule

http://git-wip-us.apache.org/repos/asf/flink/blob/e187b5ee/flink-libraries/flink-table/src/main/java/org/apache/flink/table/calcite/sql2rel/FlinkRelDecorrelator.java -- diff --git

[1/3] flink git commit: [FLINK-5144] [table] Fix error while applying rule AggregateJoinTransposeRule

Repository: flink Updated Branches: refs/heads/master dba7d7da9 -> e187b5ee9 http://git-wip-us.apache.org/repos/asf/flink/blob/e187b5ee/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/sql/QueryDecorrelationTest.scala

[3/3] flink git commit: [FLINK-5144] [table] Fix error while applying rule AggregateJoinTransposeRule

: http://git-wip-us.apache.org/repos/asf/flink/diff/e187b5ee Branch: refs/heads/master Commit: e187b5ee9aa6d1bf9feec151ff460d1a28c4e5f0 Parents: dba7d7d Author: Kurt Young <ykt...@gmail.com> Authored: Thu Jan 5 11:32:04 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Tue

[3/3] flink git commit: [FLINK-5144] [table] Fix error while applying rule AggregateJoinTransposeRule

: http://git-wip-us.apache.org/repos/asf/flink/diff/61ac3605 Branch: refs/heads/release-1.2 Commit: 61ac3605f6e56f49b83891c0f348b3fbddb2e075 Parents: 02b0e65 Author: Kurt Young <ykt...@gmail.com> Authored: Thu Jan 5 11:32:04 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: T

[1/3] flink git commit: [FLINK-5144] [table] Fix error while applying rule AggregateJoinTransposeRule

Repository: flink Updated Branches: refs/heads/release-1.2 02b0e6503 -> 61ac3605f http://git-wip-us.apache.org/repos/asf/flink/blob/61ac3605/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/sql/QueryDecorrelationTest.scala

[2/3] flink git commit: [FLINK-5144] [table] Fix error while applying rule AggregateJoinTransposeRule

http://git-wip-us.apache.org/repos/asf/flink/blob/61ac3605/flink-libraries/flink-table/src/main/java/org/apache/flink/table/calcite/sql2rel/FlinkRelDecorrelator.java -- diff --git

flink git commit: [FLINK-5549] [core] TypeExtractor fails with RuntimeException, but should use GenericTypeInfo

org/repos/asf/flink/commit/0a24611a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0a24611a Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0a24611a Branch: refs/heads/release-1.2 Commit: 0a24611a865ae6e321016672c951a8a632363bd4 Parents: d431373 Author: twalthr <twal...@apac

flink git commit: [FLINK-5549] [core] TypeExtractor fails with RuntimeException, but should use GenericTypeInfo

org/repos/asf/flink/commit/2703d339 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2703d339 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2703d339 Branch: refs/heads/master Commit: 2703d339abafdd9f39bc35faa1eed718501f71a7 Parents: 6bf556e Author: twalthr <twal...@apache.org>

flink git commit: [FLINK-4693] [table] Add session group-windows for batch tables

12:34:34 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Fri Jan 20 13:57:13 2017 +0100 -- .../nodes/dataset/DataSetWindowAggregate.scala | 102 +++- .../AggregateAllTimeWindowFunction.sca

flink git commit: [FLINK-3497] [table] Add IS (NOT) TRUE/IS (NOT) FALSE functions

wip-us.apache.org/repos/asf/flink/tree/dc3337a9 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/dc3337a9 Branch: refs/heads/master Commit: dc3337a93b20dfc8dc8cdc0ec8c2bc4843e76a69 Parents: 78f2a15 Author: twalthr <twal...@apache.org> Authored: Fri Sep 2 16:23:04 2016 +0200 Committer

flink git commit: [FLINK-3580] [table] Add current time point functions

ttp://git-wip-us.apache.org/repos/asf/flink/tree/e376c003 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e376c003 Branch: refs/heads/master Commit: e376c003c0fac456136e63e9d4cac4bfc07c02d4 Parents: fb8f2c9 Author: twalthr <twal...@apache.org> Authored: Tue Aug 30 17:21:13 2016 +0200

flink git commit: [hotfix] [table] Add docs about SQL's lexical policy

org/repos/asf/flink/tree/db919a58 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/db919a58 Branch: refs/heads/master Commit: db919a58584e9aafe0d3b8b738a9bd17361b05b5 Parents: b7d8389 Author: twalthr <twal...@apache.org> Authored: Wed Aug 31 10:45:26 2016 +0200 Committer: twal

flink git commit: [FLINK-3580] [table] Add QUARTER function

asf/flink/tree/9420a775 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/9420a775 Branch: refs/heads/master Commit: 9420a775f4689ec57c9026b418c5961c33263265 Parents: 8c0d624 Author: twalthr <twal...@apache.org> Authored: Fri Sep 9 17:17:44 2016 +0200 Committer: twalthr <twal..

flink git commit: [FLINK-4592] [table] Fix flaky test ScalarFunctionsTest.testCurrentTimePoint

ttp://git-wip-us.apache.org/repos/asf/flink/tree/8c0d6243 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/8c0d6243 Branch: refs/heads/master Commit: 8c0d62433a3f57d0753edb00e5c2bbc1adc467df Parents: e92f91a Author: twalthr <twal...@apache.org> Authored: Fri Sep 9 13:19:18 2016 +0200

flink git commit: [FLINK-4599] [table] Add 'explain()' also to StreamTableEnvironment

7:41 2016 +0200 Committer: twalthr <twal...@apache.org> Committed: Thu Sep 15 17:45:30 2016 +0200 -- docs/dev/table_api.md | 53 .../api/table/StreamTableEnvironment.scala | 16

flink git commit: [FLINK-3497] [table] Add POSITION/OVERLAY functions

org/repos/asf/flink/tree/95b673f0 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/95b673f0 Branch: refs/heads/master Commit: 95b673f0bbb302f6f2ed274183941d063fc1feca Parents: bdd3c0d Author: twalthr <twal...@apache.org> Authored: Fri Sep 9 11:56:12 2016 +0200 Committer: twal

flink git commit: [FLINK-4601] [java] Check for empty string properly

016 -0700 Committer: twalthr <twal...@apache.org> Committed: Fri Sep 9 12:16:18 2016 +0200 -- .../org/apache/flink/api/java/sca/UdfAnalyzerExamplesTest.java | 2 +- .../test/java/org/apache/flink/api/java/sca/UdfAnalyzer

flink git commit: [FLINK-4590] [table] Some Table API tests are failing when debug lvl is set to DEBUG

asf/flink/commit/7eb45c13 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7eb45c13 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/7eb45c13 Branch: refs/heads/master Commit: 7eb45c133c49933b14719f06bf68ccf162a3e0b2 Parents: 70e71c1 Author: twalthr <twal...@apache.org> Authored: F

flink git commit: [FLINK-4241] [table] Cryptic expression parser exceptions

ree: http://git-wip-us.apache.org/repos/asf/flink/tree/ef159849 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ef159849 Branch: refs/heads/master Commit: ef15984988e883ced5311b332e5e5d8521c9573f Parents: f150f98 Author: twalthr <twal...@apache.org> Authored: Wed Sep 21 17:12:31 2

flink git commit: [FLINK-4252] [table] Validate input and output classes of Table API

987 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f150f987 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f150f987 Branch: refs/heads/master Commit: f150f987772c8d96f41a5acd1d20cba6622cb5c9 Parents: 7eb45c1 Author: twalthr <twal...@apache.org> Authored: Fri Sep 16 14:2

[3/3] flink git commit: [FLINK-3656] [table] Consolidate ITCases

://git-wip-us.apache.org/repos/asf/flink/commit/7758571a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7758571a Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/7758571a Branch: refs/heads/master Commit: 7758571ae7a6a26859d91eb80e7b4df689e79c46 Parents: 8243138 Author: twalthr <t

[2/3] flink git commit: [FLINK-3656] [table] Consolidate ITCases

http://git-wip-us.apache.org/repos/asf/flink/blob/7758571a/flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/batch/table/SelectITCase.java -- diff --git

[1/3] flink git commit: [FLINK-3656] [table] Consolidate ITCases

Repository: flink Updated Branches: refs/heads/master 8243138c3 -> 7758571ae http://git-wip-us.apache.org/repos/asf/flink/blob/7758571a/flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/table/GroupedAggregationsITCase.scala

flink git commit: [FLINK-3874] Rewrite Kafka JSON Table sink tests

016 +0100 Committer: twalthr <twal...@apache.org> Committed: Wed Oct 5 14:36:17 2016 +0200 -- .../connectors/kafka/Kafka08JsonTableSink.java | 1 + .../kafka/Kafka08JsonTableSinkITCase.java | 40 -

flink git commit: [FLINK-3656] [table] Convert expression tests to unit tests

ree: http://git-wip-us.apache.org/repos/asf/flink/tree/171d1093 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/171d1093 Branch: refs/heads/master Commit: 171d10930b3904f51b7d60531bfc0837b7cc19bd Parents: 95c08ea Author: twalthr <twal...@apache.org> Authored: Thu Sep 29 14:54:36 2

[1/2] flink git commit: [FLINK-4068] [table] Move constant computations out of code-generated

10:31:59 2016 +0800 Committer: twalthr <twal...@apache.org> Committed: Tue Oct 4 12:02:36 2016 +0200 -- .../flink/api/table/BatchTableEnvironment.scala | 48 + .../flink/api/table/FlinkRelBuilder.scala |

[2/2] flink git commit: [FLINK-4068] [table] Reduce expression also for filter/project

/asf/flink/diff/f00e1e7c Branch: refs/heads/master Commit: f00e1e7c5578caf52eaffc5cbdd102589c13f52d Parents: a711339 Author: twalthr <twal...@apache.org> Authored: Fri Sep 30 17:30:44 2016 +0200 Committer: twalthr <twal...@apache.org> Committed: Tue Oct 4 14:30:4

flink git commit: [FLINK-4546] [table] Remove STREAM keyword in Stream SQL

016 +0800 Committer: twalthr <twal...@apache.org> Committed: Tue Oct 4 15:24:48 2016 +0200 -- docs/dev/table_api.md | 8 +-- .../api/java/table/StreamTableEnvironment.scala | 8 +--

flink git commit: [FLINK-3042] [FLINK-3060] [types] Define a way to let types create their own TypeInformation

pos/asf/flink/commit/4cc38fd3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4cc38fd3 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/4cc38fd3 Branch: refs/heads/master Commit: 4cc38fd36f3190f9c0066e9cf94580669b2410cf Parents: 68709b0 Author: twalthr <twal...@apache.org> Auth

flink git commit: [FLINK-3497] [table] Add SQRT function

asf/flink/tree/5fdc7206 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5fdc7206 Branch: refs/heads/master Commit: 5fdc7206936248dca3310b78206246c9f9c5b9a8 Parents: 9420a77 Author: twalthr <twal...@apache.org> Authored: Thu Sep 15 12:01:34 2016 +0200 Committer: twalthr <twal..

flink git commit: [FLINK-4081] [core] [table] FieldParsers should support empty strings

mit/4b1a9c72 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4b1a9c72 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/4b1a9c72 Branch: refs/heads/master Commit: 4b1a9c72e99125680035e5dadc148b187d9d4124 Parents: d7b59d7 Author: twalthr <twal...@apache.org> Authored: Tue Jul 26 16:2

flink git commit: [FLINK-4550] [table] Clearly define SQL operator table

ttp://git-wip-us.apache.org/repos/asf/flink/tree/ecbccd94 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ecbccd94 Branch: refs/heads/master Commit: ecbccd940d2df462215b7a79e895114b3d2df3cf Parents: 51a5048 Author: twalthr <twal...@apache.org> Authored: Thu Sep 15 16:56:16 2016 +0200

flink git commit: [FLINK-3580] [table] Add OVERLAPS function

wip-us.apache.org/repos/asf/flink/tree/e6fbda90 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e6fbda90 Branch: refs/heads/master Commit: e6fbda906a173660df306e78eee010ed3fc59d8e Parents: 3507d59 Author: twalthr <twal...@apache.org> Authored: Sat Sep 3 08:00:58 2016 +0200 Committer: twal

flink git commit: [FLINK-4268] [core] Add a parsers for BigDecimal/BigInteger

ree: http://git-wip-us.apache.org/repos/asf/flink/tree/5c02988b Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5c02988b Branch: refs/heads/master Commit: 5c02988b05c56f524fc8c65b15e16b0c24278a5e Parents: e58fd6e Author: twalthr <twal...@apache.org> Authored: Wed Jul 27 15:48:48 2

  1   2   3   4   5   6   7   8   9   10   >