Feature Request:
We propose adding a new Jupyter notebook to the gravitino-playground repository that demonstrates how to use the Flink stream processing engine to query a Hive database. The notebook will provide an example of setting up the PyFlink environment, connecting to a Hive database, executing queries, and displaying the results. This feature will showcase how to leverage Flink and Hive in a Jupyter notebook environment.
Requirements:
Set up PyFlink Environment: Integrate the PyFlink API and configure the Flink environment.
Connect to Hive Database: Set up the connection between Flink and Hive, and demonstrate how to execute queries on the Hive database.
Query and Result Presentation: Write example queries and display the results within the notebook.
Feature Request:
We propose adding a new Jupyter notebook to the
gravitino-playgroundrepository that demonstrates how to use the Flink stream processing engine to query a Hive database. The notebook will provide an example of setting up the PyFlink environment, connecting to a Hive database, executing queries, and displaying the results. This feature will showcase how to leverage Flink and Hive in a Jupyter notebook environment.Requirements:
Resources for Reference: