Commits

Commits on Aug 7, 2019

Commits on Jul 23, 2019

[FLINK-13318][table-planner-blink] Fix Blink planner tests failing on Scala 2.12 by setting SerialVersionUID to Scala UDFs

beyond1920
authored and
wuchong
committedJul 23, 2019
[FLINK-13314][table-planner-blink] Correct resultType of some PlannerExpression when operands contains DecimalTypeInfo or BigDecimalTypeInfo in Blink planner

beyond1920
authored and
wuchong
committedJul 23, 2019

Commits on Jul 19, 2019

[FLINK-13321][table-planner-blink] Fix lateral join udtf with constant parameters doesn't work in blink planner

beyond1920
authored and
wuchong
committedJul 19, 2019

Commits on Jul 11, 2019

[FLINK-13107][table-planner-blink] Copy TableApi IT and UT to Blink planner.

beyond1920
authored and
KurtYoung
committedJul 11, 2019
[FLINK-13107][table-planner-blink] Fix Bug to check whether OverCall is RowMode or RangeMode.

beyond1920
authored and
KurtYoung
committedJul 11, 2019
[FLINK-13107][table-planner-blink] Derive sum, avg, div return type in planner expressions using behavior of blink

beyond1920
authored and
KurtYoung
committedJul 11, 2019
[FLINK-13107][table-planner-blink] Fix Bug when convert DataType which has primitiveClass as convensionClass to TypeInformation.

beyond1920
authored and
KurtYoung
committedJul 11, 2019
[FLINK-13107][table-planner-blink] Introduce fieldNames to TypedFlinkTableFunction to using fieldNames which is specified.

beyond1920
authored and
KurtYoung
committedJul 11, 2019
[FLINK-12348][table-planner-blink] Use TableConfig in api module to replace TableConfig in blink-planner module.

beyond1920
authored and
KurtYoung
committedJul 11, 2019

Commits on Jul 4, 2019

[FLINK-13071][table-planner-blink] Remove toRexNode methods from the PlannerExpressions in blink planner & add TableApi testcases.

beyond1920
authored and
KurtYoung
committedJul 4, 2019
[FLINK-13071][table-planner-blink] QueryOperationConverter in Blink planner support add kinds of QueryOperations.

beyond1920
authored and
KurtYoung
committedJul 4, 2019
[FLINK-13071][table-planner-blink] Support more functions in RexNodeConverter.

beyond1920
authored and
KurtYoung
committedJul 4, 2019

Commits on May 21, 2019

[FLINK-12496][table-planner-blink] Support translation from StreamExecGroupWindowAggregate to StreamTransformation

beyond1920
authored and
wuchong
committedMay 21, 2019

Commits on May 14, 2019

[FLINK-12374][table-planner-blink] Support translation from StreamExecTableSourceScan/BatchExecTableSourceScan to StreamTransformation. (apache#8407 )

beyond1920
authored and
KurtYoung
committedMay 14, 2019

Commits on Apr 28, 2019

[FLINK-12307][table-planner-blink] Support translation from StreamExecWindowJoin to StreamTransformation.

beyond1920
authored and
KurtYoung
committedApr 28, 2019

Commits on Apr 23, 2019

[Flink-12208] [table-runtime-blink] Introduce Sort & TemporalSort & SortLimit & Limit operators for blink streaming runtime

beyond1920
authored and
wuchong
committedApr 23, 2019

Commits on Apr 16, 2019

[FLINK-12017][table-planner-blink] Introduce Rank and Deduplicate operators for blink streaming runtime

beyond1920
authored and
wuchong
committedApr 16, 2019

Commits on Mar 26, 2019

[FLINK-11975][table-planner-blink] Support running a simple select from values query (apache#8035 )

beyond1920
authored and
KurtYoung
committedMar 26, 2019

Commits on Mar 20, 2019

[FLINK-11946][table-planner-blink] Introduce ExecNode to blink planner (apache#8010 )

beyond1920
authored and
KurtYoung
committedMar 20, 2019

Commits on Mar 24, 2017

[FLINK-5570] [table] Register ExternalCatalogs in TableEnvironment.

beyond1920
authored and
fhueske
committedMar 24, 2017

Commits on Mar 21, 2017

[FLINK-6037] [table] Metadata provider didn't work in SQL

beyond1920
authored and
twalthr
committedMar 21, 2017

Commits on Mar 18, 2017

[FLINK-5568] [table] Introduce ExternalCatalog interface, integrated with calcite and provide an in-memory implementation for testing.

beyond1920
authored and
KurtYoung
committedMar 18, 2017

Commits on Jan 17, 2017

[FLINK-5394] [table] Fix row count estimation

beyond1920
authored and
twalthr
committedJan 17, 2017

Commits on Dec 23, 2016

[FLINK-4606] Integrate the new ResourceManager with the existed FlinkResourceManager

beyond1920
authored and
StephanEwen
committedDec 23, 2016
[FLINK-4535] [cluster management] resourceManager process the registration from TaskExecutor

beyond1920
authored and
StephanEwen
committedDec 23, 2016
[FLINK-4537] [cluster management] ResourceManager registration with JobManager

beyond1920
authored and
StephanEwen
committedDec 23, 2016
[FLINK-4516] leader election of resourcemanager

beyond1920
authored and
StephanEwen
committedDec 23, 2016

Commits on Dec 13, 2016

[FLINK-3848] [table] Add ProjectableTableSource and push projections into BatchTableSourceScan.

beyond1920
authored and
fhueske
committedDec 13, 2016

Commits on Dec 2, 2016

[FLINK-5158] [table] Refactor BatchScan, DataSetScan, and BatchTableSourceScan.

beyond1920
authored and
fhueske
committedDec 2, 2016