Commits

Commits on Mar 31, 2021

[FLINK-21842][python] Support user defined WindowAssigner, Trigger and ProcessWindowFunction on Python DataStream API
WeiZhong94
committedMar 31, 2021

Commits on Mar 29, 2021

[FLINK-21969][python] Invoke finish bundle method before emitting the max timestamp watermark in PythonTimestampsAndWatermarksOperator

WeiZhong94
authored and
HuangXingBo
committedMar 29, 2021

Commits on Mar 25, 2021

[FLINK-21294][python] Support state access API for the map/flat_map operation of Python ConnectedStreams
WeiZhong94
committedMar 25, 2021

Commits on Mar 11, 2021

[FLINK-21242][python] Support state access API for the map/flat_map/filter/reduce operations of Python KeyedStream
WeiZhong94
committedMar 11, 2021

Commits on Mar 10, 2021

[FLINK-21679][table] Set output type for transformations from SourceProvider and DataStreamScanProvider in CommonExecTableSourceScan
WeiZhong94
committedMar 10, 2021

Commits on Mar 3, 2021

Commits on Mar 2, 2021

[FLINK-21509][python] add 'withProcessingTime()' method call when creating proctime slide window assigner in 'StreamExecPythonGroupWindowAggregate' class
WeiZhong94
committedMar 2, 2021

Commits on Feb 26, 2021

[FLINK-21114][python] Add ReducingState and corresponding StateDescriptor for Python DataStream API

WeiZhong94
authored and
HuangXingBo
committedFeb 26, 2021

Commits on Feb 23, 2021

Commits on Nov 25, 2020

[FLINK-20333][python] Fix the issue that metaspace OOM will be thrown after submitting PyFlink UDF jobs multiple times to the standalone cluster

WeiZhong94
authored and
dianfu
committedNov 25, 2020

Commits on Nov 18, 2020

[FLINK-20207][python] Improve the error message printed when submitting the pyflink jobs via 'flink run'

WeiZhong94
authored and
dianfu
committedNov 18, 2020

Commits on Nov 12, 2020

[FLINK-20046][python] Fix the unstable test StreamTableAggregateTests.test_map_view_iterate

WeiZhong94
authored and
dianfu
committedNov 12, 2020

Commits on Nov 6, 2020

[FLINK-18926][python][docs] Add a "Environment Variables" document under the "Python API" -> "User Guide" -> "Table API" section

WeiZhong94
authored and
dianfu
committedNov 6, 2020
[FLINK-19284][python][docs] Add documentation about how to use Python UDF in the Java Table API program

WeiZhong94
authored and
dianfu
committedNov 6, 2020

Commits on Nov 4, 2020

[FLINK-19844][python][docs] Add documentation for Python UDAF

WeiZhong94
authored and
dianfu
committedNov 4, 2020
[FLINK-18716][python][docs] Remove the deprecated execute and insert_into calls in PyFlink Table API docs

WeiZhong94
authored and
dianfu
committedNov 4, 2020

Commits on Nov 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 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 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-19232][python] Support MapState and MapView for Python UDAF

WeiZhong94
authored and
dianfu
committedOct 21, 2020

Commits on Oct 13, 2020

[FLINK-19231][python] Support ListState and ListView for Python UDAF

WeiZhong94
authored and
dianfu
committedOct 13, 2020

Commits on Sep 26, 2020

[FLINK-19421][python] Support Python UDAF in streaming mode

WeiZhong94
authored and
dianfu
committedSep 26, 2020

Commits on Sep 23, 2020

[FLINK-19229][python] Introduce the PythonStreamGroupAggregateOperator for Python UDAF. (apache#13420 )
WeiZhong94
committedSep 23, 2020

Commits on Sep 17, 2020

[FLINK-17879][python] Update Python row serializer to support RowKind

WeiZhong94
authored and
dianfu
committedSep 17, 2020

Commits on Sep 8, 2020

[FLINK-18913][docs][python] Add a "TableEnvironment" document under the "Python API" -> "Table API User's Guide" section

WeiZhong94
authored and
dianfu
committedSep 8, 2020

Commits on Sep 3, 2020

[FLINK-19110][docs][python] Flatten current PyFlink documentation structure.

WeiZhong94
authored and
dianfu
committedSep 3, 2020

Commits on Sep 2, 2020

[FLINK-18801][docs][python] Add a "10 minutes to Table API" document under the "Python API" -> "User Guide" -> "Table API" section.

WeiZhong94
authored and
dianfu
committedSep 2, 2020

Commits on Aug 27, 2020

[FLINK-18917][docs][python] Add a "Built-in Functions" link (linked to dev/table/functions/systemFunctions.md) under the "Python API" -> "User Guide" -> "Table API" section

WeiZhong94
authored and
dianfu
committedAug 27, 2020

Commits on Aug 18, 2020

[FLINK-18910][docs][python] Create the new documentation structure for Python documentation according to FLIP-133.

WeiZhong94
authored and
dianfu
committedAug 18, 2020

Commits on Aug 13, 2020

[FLINK-18849][docs] Improve the code tabs of the Flink documents.

WeiZhong94
authored and
sjwiesman
committedAug 13, 2020

Commits on Jul 17, 2020

[FLINK-18463][python] Make the "input_types" parameter of the Python UDF/UDTF decorator optional.

WeiZhong94
authored and
dianfu
committedJul 17, 2020

Commits on Jun 12, 2020

[FLINK-18246][python][e2e] Disable PyFlink e2e tests when running on jdk11

WeiZhong94
authored and
dianfu
committedJun 12, 2020