See #378. Initial commit.

j3-signalroom · Oct 19, 2024 · c150614 · c150614
1 parent 839294d
commit c150614
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/.blog/images/streamlit-run-from-terminal-screenshot.png b/.blog/images/streamlit-run-from-terminal-screenshot.png
diff --git a/python/kickstarter/flink_kickstarter_visualization.py b/python/kickstarter/flink_kickstarter_visualization.py
@@ -1,9 +1,9 @@
-import streamlit as st
 from pyflink.datastream import StreamExecutionEnvironment
 from pyflink.table import TableEnvironment, EnvironmentSettings, StreamTableEnvironment
 from pyflink.table.catalog import ObjectPath
 import argparse
 import pandas as pd
+import streamlit as st
 from st_aggrid import AgGrid, GridOptionsBuilder
 
 from helper.utilities import catalog_exist
@@ -91,6 +91,8 @@ def main(args):
     # Read `flight`data from the Iceberg table
     flight_table = tbl_env.sql_query(f"SELECT * FROM {database_name}.flight")
     df_flight_table = flight_table.to_pandas()
+
+
 
     # Create grid options with only specific columns
     gb = GridOptionsBuilder.from_dataframe(df_flight_table)