Commits

History for

Commits on Jan 29, 2021

[FLINK-21163][python] Fix the issue that Python dependencies specified via CLI override the dependencies specified in configuration
dianfu
committedJan 29, 2021

Commits on Jan 19, 2021

[FLINK-20971][table-api-java] Support calling SQL expressions in Table API
twalthr
committedJan 19, 2021
[FLINK-20963][python] Update examples to use the latest recommended API (apache#14673 )
lometheus
committedJan 19, 2021

Commits on Jan 18, 2021

[FLINK-20933][python] Fix the Python operators of Python DataStream API doesn't use managed memory when mixed use with Python Table API

HuangXingBo
authored and
dianfu
committedJan 18, 2021

Commits on Jan 8, 2021

[FLINK-20522][table] Add built-in IFNULL function
twalthr
committedJan 8, 2021

Commits on Jan 7, 2021

[FLINK-18090] Update tests for new Row.toString
twalthr
committedJan 7, 2021

Commits on Jan 2, 2021

[FLINK-20828][python] Fix some aggregate and flat_aggregate tests failed in py35 (apache#14540 )
HuangXingBo
committedJan 2, 2021

Commits on Dec 31, 2020

[FLINK-20769][python] Support minibatch to optimize Python UDAF

HuangXingBo
authored and
dianfu
committedDec 31, 2020

Commits on Dec 28, 2020

[FLINK-20712][python] Support join_lateral/left_outer_join_lateral to accept table function directly

HuangXingBo
authored and
dianfu
committedDec 28, 2020

Commits on Dec 25, 2020

[FLINK-20702][python] Support map operation chained together in Python Table API

HuangXingBo
authored and
dianfu
committedDec 25, 2020

Commits on Dec 23, 2020

[FLINK-20621][python] Improve the TypeInformation implementation in Python DataStream API

shuiqiangchen
authored and
dianfu
committedDec 23, 2020

Commits on Dec 22, 2020

[FLINK-20616][python] Support row-based operation to accept user-defined function directly
HuangXingBo
committedDec 22, 2020

Commits on Dec 19, 2020

[FLINK-20666][python] Fix the deserialized Row losing the fields name information

HuangXingBo
authored and
dianfu
committedDec 19, 2020

Commits on Dec 17, 2020

[FLINK-20528][python] Support table aggregation for group aggregation in streaming mode
HuangXingBo
committedDec 17, 2020

Commits on Dec 11, 2020

[FLINK-20507][python] Support Aggregate Operation in Python Table API

HuangXingBo
authored and
dianfu
committedDec 11, 2020

Commits on Dec 10, 2020

[FLINK-20506][python] Support FlatMap Operation in Python Table API

HuangXingBo
authored and
dianfu
committedDec 10, 2020
[FLINK-20483][python] Support Pandas UDF for Map Operation in Python Table API

HuangXingBo
authored and
dianfu
committedDec 10, 2020

Commits on Dec 9, 2020

[FLINK-20482][python] Support General Python UDF for Map Operation in Python Table API

HuangXingBo
authored and
dianfu
committedDec 9, 2020
[FLINK-20525][python] Fix StreamArrowPythonGroupWindowAggregateFunctionOperator incorrect handling of rowtime and proctime fields

HuangXingBo
authored and
dianfu
committedDec 9, 2020

Commits on Dec 3, 2020

[FLINK-19989][python] Add collect operation in Python DataStream API

SteNicholas
authored and
dianfu
committedDec 3, 2020

Commits on Nov 18, 2020

[FLINK-20202][python] Add the Check of Unsupported Result Type in Pandas UDAF

HuangXingBo
authored and
dianfu
committedNov 18, 2020

Commits on Nov 11, 2020

[FLINK-19842][python][tests] Fix the instable test case PyFlinkStreamUserDefinedTableFunctionTests.test_table_function_with_sql_query

HuangXingBo
authored and
dianfu
committedNov 11, 2020

Commits on Nov 4, 2020

[FLINK-19138][python] Support directly specifying input_types and result_types as DataTypes.ROW

HuangXingBo
authored and
dianfu
committedNov 4, 2020

Commits on Nov 3, 2020

[FLINK-16522][python] Add support of type hints

HuangXingBo
authored and
dianfu
committedNov 3, 2020
[FLINK-19740][python] Fix to_pandas to Support EventTime in Blink Planner

HuangXingBo
authored and
dianfu
committedNov 3, 2020
[FLINK-19235][python] Support mixed use with most built-in aggs for Python UDAF

WeiZhong94
authored and
dianfu
committedNov 3, 2020

Commits on Nov 2, 2020

[FLINK-19894][python] Fix the bug that from_pandas doesn't work well with index of float type

HuangXingBo
authored and
dianfu
committedNov 2, 2020

Commits on Oct 31, 2020

[FLINK-19892][python] Replace __metaclass__ field with metaclass keyword

SteNicholas
authored and
dianfu
committedOct 31, 2020

Commits on Oct 30, 2020

[FLINK-19235][python] Support mixed use of built-in aggs with Python UDAF

WeiZhong94
authored and
dianfu
committedOct 30, 2020

Commits on Oct 29, 2020

[FLINK-19786][avro] Fix the nullability and precision for Avro format deserialization

danny0405
authored and
dawidwys
committedOct 29, 2020

Commits on Oct 28, 2020

[FLINK-19233][python] Support distinct and filter keywords on Python UDAF

WeiZhong94
authored and
dianfu
committedOct 28, 2020

Commits on Oct 27, 2020

[FLINK-19232][python] Support iterating MapState and MapView

WeiZhong94
authored and
dianfu
committedOct 27, 2020

Commits on Oct 21, 2020

[FLINK-18415][python] Support TableResult#collect in the Python Table API to align with the Java Table API

shuiqiangchen
authored and
dianfu
committedOct 21, 2020
[FLINK-19232][python] Support MapState and MapView for Python UDAF

WeiZhong94
authored and
dianfu
committedOct 21, 2020

Commits on Oct 20, 2020

[FLINK-18836][python] Support Python UDTF return types which are not generator

HuangXingBo
authored and
dianfu
committedOct 20, 2020