[GitHub] [flink] dianfu opened a new pull request #8474: [FLINK-12409][python] Adds from_elements in TableEnvironment

[GitBox <gi...@apache.org>]

dianfu opened a new pull request #8474: [FLINK-12409][python] Adds from_elements in TableEnvironment
URL: https://github.com/apache/flink/pull/8474
 
 
   ## What is the purpose of the change
   
   *This pull request adds the API from_elements in TableEnvironment. It's a convenient API to create a table from a collection of elements.*
   It works as follows:
   1) Serializes the python data to a local file via PickleSerializer
   2) Reads the local file and deserializes the python object and creates a DataStream from the deserialized elements in Java
   3) Creates a Table from the created DataStream
   
   ## Brief change log
   
     - *Adds from_elements API in TableEnvironment*
     - *Adds PythonDataStreamUtil to create a DataStream from a file containing the serialized python objects*
     - *Adds PythonTableUtil to create a Table from a DataStream*
     - *Adds PythonTypeUtil to convert the deserialized objects according to the schema*
   
   ## Verifying this change
   
   This change added tests and can be verified as follows:
   
     - *Added unit test test_calc.test_from_elements*
   
   ## Does this pull request potentially affect one of the following parts:
   
     - Dependencies (does it add or upgrade a dependency): (no)
     - The public API, i.e., is any changed class annotated with `@Public(Evolving)`: (no)
     - The serializers: (no)
     - The runtime per-record code paths (performance sensitive): (no)
     - Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Yarn/Mesos, ZooKeeper: (no)
     - The S3 file system connector: (no)
   
   ## Documentation
   
     - Does this pull request introduce a new feature? (no)
     - If yes, how is the feature documented? (not applicable)
   

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services