Resolved #388.

j3-signalroom · Oct 20, 2024 · 4e37667 · 4e37667
1 parent 3528b35
commit 4e37667
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/.blog/images/streamlit-screenshot.png b/.blog/images/streamlit-screenshot.png
diff --git a/python/kickstarter/flink_kickstarter_visualization.py b/python/kickstarter/flink_kickstarter_visualization.py
@@ -37,15 +37,15 @@ def load_data(_tbl_env: StreamTableEnvironment, database_name: str) -> Tuple[pd.
                                                             airline,
                                                             extract(year from to_timestamp(departure_time)) as departure_year,
                                                             extract(month from to_timestamp(departure_time)) as departure_month, 
-                                                            date_format(to_timestamp(departure_time), 'MMM') as departure_month_abbr,
+                                                            concat(date_format(to_timestamp(departure_time), 'MM'), '-', date_format(to_timestamp(departure_time), 'MMM')) as departure_month_abbr,
                                                             count(*) as flight_count
                                                         from
                                                             airlines.flight
                                                         group by 
                                                             airline,
                                                             extract(year from to_timestamp(departure_time)),
                                                             extract(month from to_timestamp(departure_time)),
-                                                            date_format(to_timestamp(departure_time), 'MMM')
+                                                            concat(date_format(to_timestamp(departure_time), 'MM'), '-', date_format(to_timestamp(departure_time), 'MMM'))
                                                         order by
                                                             departure_year asc,
                                                             departure_month asc;