Commits

Commits on Jun 15, 2019

[FLINK-12405] [DataSet] Introduce a way to generate BLOCKING_PERSISTENT ResultPartition through DataSet API

Xpray
authored and
StephanEwen
committedJun 15, 2019
[FLINK-12405] [runtime] Introduce BLOCKING_PERSISTENT ResultPartition type

Xpray
authored and
StephanEwen
committedJun 15, 2019

Commits on Nov 19, 2018

[FLINK-10670] [table] Fix Correlate codegen error

Xpray
authored and
twalthr
committedNov 19, 2018

Commits on Oct 2, 2018

[FLINK-10451] [table] TableFunctionCollector should handle the life cycle of ScalarFunction

Xpray
authored and
twalthr
committedOct 2, 2018

Commits on May 24, 2018

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

Xpray
authored and
twalthr
committedMay 24, 2018

Commits on May 23, 2018

[FLINK-7814] [table] Add BETWEEN and NOT BETWEEN expression to Table API

Xpray
authored and
twalthr
committedMay 23, 2018

Commits on May 11, 2018

[FLINK-9332] [table] Fix handling of null return values in CallGenerator.

Xpray
authored and
fhueske
committedMay 11, 2018

Commits on May 2, 2018

[FLINK-9216][Streaming] Fix comparator violation

Xpray
authored and
zentol
committedMay 2, 2018

Commits on Mar 2, 2018

[FLINK-8821] [table] Fix non-terminating decimal error

Xpray
authored and
twalthr
committedMar 2, 2018

Commits on Feb 12, 2018

[FLINK-8617] [table] Fix code generation bug while accessing Map type

Xpray
authored and
twalthr
committedFeb 12, 2018

Commits on Feb 6, 2018

[FLINK-8555] [table] Fix TableFunction varargs length exceed 254

Xpray
authored and
twalthr
committedFeb 6, 2018

Commits on Dec 29, 2017

[FLINK-8312][table] Fix ScalarFunction varargs length exceed 254

Xpray
authored and
sunjincheng121
committedDec 29, 2017

Commits on Dec 25, 2017

[FLINK-8301][table] Support Unicode in codegen for TableAPI && SQL

Xpray
authored and
sunjincheng121
committedDec 25, 2017

Commits on Nov 20, 2017

[FLINK-8095] [table] Introduce ProjectSetOpTransposeRule

Xpray
authored and
twalthr
committedNov 20, 2017

Commits on Nov 16, 2017

[FLINK-7986] [table] Introduce FilterSetOpTransposeRule

Xpray
authored and
twalthr
committedNov 16, 2017

Commits on Nov 8, 2017

[FLINK-7971] [table] Fix potential NPE in non-windowed aggregation.

Xpray
authored and
fhueske
committedNov 8, 2017

Commits on Oct 19, 2017

[FLINK-7759] [table] Add support for field names with Boolean prefix.

Xpray
authored and
fhueske
committedOct 19, 2017

Commits on Oct 10, 2017

[FLINK-7776] [table] Prevent emission of identical update records in group aggregation.

Xpray
authored and
fhueske
committedOct 10, 2017

Commits on Sep 26, 2017

[FLINK-7596] [table] Fix bug during Set Operation (Union, Minus ... ) with Any(GenericRelDataType)

Xpray
authored and
twalthr
committedSep 26, 2017

Commits on Aug 8, 2017

[FLINK-7385] Fix ArrayIndexOutOfBoundsException when object-reuse is enabled

Xpray
authored and
tzulitai
committedAug 8, 2017

Commits on Jun 29, 2017

[FLINK-7014] [table] Expose isDeterministic interface to UserDefinedFunction

Xpray
authored and
wuchong
committedJun 29, 2017

Commits on May 16, 2017

[FLINK-6593] [table] Fix Bug in ProctimeAttribute or RowtimeAttribute with CodeGenerator

Xpray
authored and
twalthr
committedMay 16, 2017

Commits on May 3, 2017

[FLINK-6334] [table] Refactor Table API TableFunction join methods.

Xpray
authored and
fhueske
committedMay 3, 2017