This is an automated email from the ASF dual-hosted git repository.
guoweijie pushed a change to branch process-func-api-poc-weijie
in repository https://gitbox.apache.org/repos/asf/flink.git
at 43ca07e726c ProcessOperator supports operator list state.
This branch includes the following new commits:
new 1494ce4cecc Create modules.
new 82a01017c6f Introduce ExecutionEnvironment, whose implementation can
be obtained from API via reflection.
new 8e8d39a6057 Introduce DataStream, as well as supplier-source &
consumer-sink for testing purpose.
new 6b4f8ce5960 Introduce flink-process-function-parent module, to make it
easy building all related modules at once.
new 9616f46377d Supports submit job to minicluster environment.
new 242e9e57af7 Using ConsumerFunction and SupplierFunction to avoid
serialization exception and support lambda type inference.
new 1be9ad7a73f Supports supplier source and consumer sink.
new 8be47a72cab Introduce ProcessFunction interface.
new b6c1dc51e86 Introduce RuntimeContext interface.
new c6d04280adc Introduce interfaces for declaring and using states.
new f8e89abde72 Change ProcessFunction to support arbitrary number of
outputs.
new 28bd60f0f84 Implements process operator to handle user process
function.
new 51bfb5d1387 Extracts type information related interfaces and base
classes to core-api module
new 43ca07e726c ProcessOperator supports operator list state.
The 14 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
