Proto commits in apache/flink

These 62 commits are when the Protocol Buffers files have changed:

Commit:df03ada
Author:dsaisharath
Committer:Benchao Li

[FLINK-33611][flink-protobuf] Split last segment only when size exceeds split threshold limit in deserializer Close apache/flink#23937

The documentation is generated from this commit.

Commit:a2ec4c3
Author:lijingwei.5018
Committer:Benchao Li

[FLINK-32650][protobuf] Split generated code in protobuf format to mitigate huge method problems Close apache/flink#23162

Commit:7ea4476
Author:laughingman7743
Committer:Benchao Li

[FLINK-30093][protobuf] Fix compile errors for google.protobuf.Timestamp type Close #21613

Commit:5cb434c
Author:Dian Fu
Committer:Dian Fu

[FLINK-14023][python] Support accessing job parameters in Python user-defined functions This closes #21644.

Commit:afc8fb0
Author:Dian Fu
Committer:Dian Fu

[FLINK-30607][python] Support NoneType for Pandas UDF This closes #21639.

Commit:64305b3
Author:Martijn Visser
Committer:MartijnVisser

[FLINK-30397][Connector/Pulsar] Remove Pulsar connector

Commit:5e4da2c
Author:Juntao Hu
Committer:huangxingbo

[FLINK-29658][python] Fix the missing LocalTime support when converting Table to DataStream This closes #21086.

Commit:1c40dc1
Author:Juntao Hu
Committer:GitHub

[FLINK-28827][python] Complete DataType support in DataStream API (#20460)

Commit:5c87b69
Author:maosuhan
Committer:Benchao Li

[FLINK-18202][protobuf] Introduce protobuf format This closes #14376

Commit:7a9016c
Author:Juntao Hu
Committer:huangxingbo

[FLINK-27587][python] Support keyed co-broadcast processing This closes #20144.

Commit:ae409d0
Author:Juntao Hu
Committer:Dian Fu

[FLINK-28182][python][avro] Support Avro generic record decoder in PyFlink This closes #20040.

Commit:dfdf7af
Author:Juntao Hu
Committer:huangxingbo

[FLINK-27586][python] Support non-keyed co-broadcast processing in PyFlink This closes #19878.

Commit:efa0618
Author:Juntao Hu
Committer:Dian Fu

[FLINK-26477][python] Support side output in Python DataStream API This closes #19453.

Commit:6352197
Author:Dian Fu
Committer:Dian Fu

[FLINK-27126][python] Respect the state cache size configuration for Python DataStream operators This closes #19394.

Commit:388dac8
Author:Dian Fu
Committer:Dian Fu

[FLINK-27126][python] Respect the state cache size configuration for Python DataStream operators This closes #19394.

Commit:c675f78
Author:Yufan Sheng
Committer:Arvid Heise

[FLINK-20731] Introduce new pulsar source connector for flink.

Commit:a77d052
Author:huangxingbo
Committer:Dian Fu

[FLINK-22912][python] Support state ttl in Python DataStream API This closes #16667.

Commit:54beaaf
Author:Dian Fu
Committer:Dian Fu

[FLINK-23616][python] Support to chain the Python DataStream operators as much as possible This closes #16777.

Commit:67dfee0
Author:Dian Fu
Committer:Dian Fu

[FLINK-23619][python] Remove PythonTimestampsAndWatermarksOperator This closes #16703.

Commit:3c85799
Author:Dian Fu
Committer:Dian Fu

[FLINK-23584][python] Introduce PythonCoProcessOperator and remove PythonCoFlatMapOperator & PythonCoMapOperator This closes #16672.

Commit:1a1c567
Author:huangxingbo
Committer:huangxingbo

[FLINK-22911][python] Rework from_data_stream/create_temporary_view/to_data_stream of TableEnvironment in Python Table API This closes #16611.

Commit:acaa5a8
Author:Dian Fu
Committer:Dian Fu

[FLINK-23578][python] Remove PythonFlatMapOperator/PythonMapOperator/PythonPartitionCustomOperator operators This closes #16664.

Commit:208d1ef
Author:huangxingbo
Committer:huangxingbo

[FLINK-22862][python] Support profiling in PyFlink This closes #16063.

Commit:41d3e22
Author:Dian Fu
Committer:Dian Fu

[FLINK-23400][python] Support to decode a single record for the Python coder This closes #16508.

Commit:a07450d
Author:Dian Fu
Committer:GitHub

[FLINK-23033][python] Add the missing ObjectArrayTypeInfo (#16220)

Commit:9986e6f
Author:huangxingbo
Committer:huangxingbo

[FLINK-22612][python] Restructure the coders in PyFlink This closes #15877.

Commit:5abd413
Author:Dian Fu
Committer:Dian Fu

[FLINK-22297][python] Perform early validation for the result of Pandas UDF This closes #15681.

Commit:599b7ee
Author:Dian Fu
Committer:Dian Fu

[FLINK-22297][python] Perform early validation for the result of Pandas UDF This closes #15682.

Commit:24031e5
Author:Dian Fu
Committer:Dian Fu

[FLINK-22297][python] Perform early validation for the result of Pandas UDF This closes #15681.

Commit:581ffc5
Author:Leonard Xu
Committer:GitHub

[FLINK-21714][table] Use TIMESTAMP_LTZ as return type for function PROCTIME() This closes #15280

Commit:62838c9
Author:Wei Zhong
Committer:Wei Zhong

[FLINK-21842][python] Support user defined WindowAssigner, Trigger and ProcessWindowFunction on Python DataStream API This closes #15416

Commit:9404d46
Author:Dian Fu
Committer:Dian Fu

[FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation This closes #15362.

Commit:7e49b1a
Author:Wei Zhong
Committer:Wei Zhong

[FLINK-21294][python] Support state access API for the map/flat_map operation of Python ConnectedStreams This closes #15149

Commit:797b382
Author:huangxingbo
Committer:huangxingbo

[FLINK-21628][python] Support Python UDAF in Tumbling Window This closes #15212

Commit:582c7b5
Author:Wei Zhong
Committer:GitHub

[FLINK-21242][python] Support state access API for the map/flat_map/filter/reduce operations of Python KeyedStream This closes #15083

Commit:25664c6
Author:huangxingbo
Committer:huangxingbo

[FLINK-20964][python] Introduce PythonStreamGroupWindowAggregateOperator This closes #14775

Commit:dca092f
Author:acqua.csq
Committer:Dian Fu

[FLINK-20621][python] Improve the TypeInformation implementation in Python DataStream API This closes #14401.

Commit:467a0d1
Author:HuangXingBo
Committer:GitHub

[FLINK-20616][python] Support row-based operation to accept user-defined function directly This closes #14410.

Commit:492965c
Author:acqua.csq
Committer:Dian Fu

[FLINK-200137][python] Handle the timestamp of elements properly in Python DataStream API This closes #14068.

Commit:f24cb3f
Author:acqua.csq
Committer:Dian Fu

[FLINK-20016][python] Support TimestampAssigner and WatermarkGenerator for Python DataStream API. This closes #13986.

Commit:473d2c5
Author:acqua.csq
Committer:Dian Fu

[FLINK-19821][python] Add ProcessFunction and timer access in Python DataStream API This closes #13803.

Commit:2dc872a
Author:Wei Zhong
Committer:Dian Fu

[FLINK-19235][python] Support mixed use of built-in aggs with Python UDAF This closes #13843.

Commit:6ddd2c9
Author:Wei Zhong
Committer:Dian Fu

[FLINK-19233][python] Support distinct and filter keywords on Python UDAF This closes #13804.

Commit:079bbac
Author:Wei Zhong
Committer:Dian Fu

[FLINK-19232][python] Support MapState and MapView for Python UDAF This closes #13665.

Commit:c8938f9
Author:Dian Fu
Committer:Dian Fu

[FLINK-19480][python] Support RichFunction in Python DataStream API This closes #13611.

Commit:b60c59d
Author:Wei Zhong
Committer:Dian Fu

[FLINK-19231][python] Support ListState and ListView for Python UDAF This closes #13507.

Commit:b358926
Author:Gao Yun
Committer:Aljoscha Krettek

[FLINK-11427][formats] Add protobuf parquet support for StreamingFileSink This reverts commit a9436d69d39652579a162a2d5822e08d96b849ff.

Commit:8525c5c
Author:acqua.csq
Committer:Dian Fu

[FLINK-19134][python] Introduce BasicArrayTypeInfo and PrimitiveArrayTypeInfo for Python DataStream API This closes #13327.

Commit:1e6c187
Author:huangxingbo
Committer:Dian Fu

[FLINK-19333][python] Introduce BatchArrowPythonOverWindowAggregateFunctionOperator This closes #13451

Commit:452b043
Author:Wei Zhong
Committer:GitHub

[FLINK-19229][python] Introduce the PythonStreamGroupAggregateOperator for Python UDAF. (#13420)

Commit:175038b
Author:hequn.chq
Committer:Hequn Cheng

[FLINK-18943][python] Support CoMapFunction for Python DataStream API

Commit:240a1e8
Author:Hequn Cheng
Committer:GitHub

[FLINK-18883][python] Support reduce() operation for Python KeyedStream. (#13113)

Commit:862c9eb
Author:Shuiqiang Chen
Committer:GitHub

[FLINK-18765][python] Support map() and flat_map() for Python DataStream API. (#13066)

Commit:ea1d15c
Author:Hequn Cheng
Committer:GitHub

[FLINK-16672][python] Support Counter, Gauge, Meter, Distribution metric type for Python UDF (#11543)

Commit:428c778
Author:Dian Fu
Committer:Hequn Cheng

[FLINK-16607][python] Update flink-fn-execution.proto adding more schema information

Commit:2d0841c
Author:huangxingbo
Committer:hequn8128

[FLINK-15972][python] Add TableFunctionRowCoder

Commit:fee187e
Author:HuangXingBo
Committer:GitHub

[FLINK-15913][python] Add Python TableFunction Runner and Operator in old planner (#11020)

Commit:87f067d
Author:huangxingbo
Committer:hequn8128

[FLINK-14584][python] Support DecimalType

Commit:0d72b2a
Author:huangxingbo
Committer:hequn8128

[FLINK-14573][python] Support TimestampType for Python UDF This closes #10055.

Commit:ddfed72
Author:huangxingbo
Committer:hequn8128

[FLINK-14208][python] Support Python UDFs with parameters of constant values Support Python UDFs with parameters of constant values. The constant parameters are not needed to be transferred between the Java operator and the Python worker for each input record. This closes #9858.

Commit:df44cce
Author:Dian Fu
Committer:hequn8128

[FLINK-14306][python] Add the code-generated flink_fn_execution_pb2.py to the source code Previously, we generate some python file during the building. However, it introduces python dependencies which makes the building complicated. This commit adds the generated file directly into the source code manually so that there is no python dependencies during building. This closes #9855.

Commit:cc3a27b
Author:Dian Fu
Committer:hequn8128

[FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution * Introduces a series of PythonFunctionRunners. They are responsible for using Beam's portability framework for Python UDF execution. * Handle the license statements as it introduces a few third-part dependences are introduced because of we depends on Beam. This closes #9653