Skip to content

Commit

Permalink
Merge pull request #136 from stat-kwon/master
Browse files Browse the repository at this point in the history
Add debug code for JOIN operator
  • Loading branch information
stat-kwon authored Dec 23, 2024
2 parents d5be58e + a80423e commit f34f0ca
Showing 1 changed file with 3 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -135,7 +135,9 @@ def join_data_tables(
origin_vo = self.data_table_vos[0]
other_vo = self.data_table_vos[1]
origin_df = self._get_data_table(origin_vo, granularity, start, end, vars)
_LOGGER.debug(f"[join_data_tables] origin_df columns: {origin_df.columns}")
other_df = self._get_data_table(other_vo, granularity, start, end, vars)
_LOGGER.debug(f"[join_data_tables] other_df columns: {other_df.columns}")

self._validate_join_keys(left_keys, right_keys, origin_vo, other_vo)

Expand All @@ -144,6 +146,7 @@ def join_data_tables(
merged_df = self._merge_data_frames(
origin_df, other_df, how, left_keys, right_keys
)
_LOGGER.debug(f"[join_data_tables] merged_df columns: {merged_df.columns}")
merged_df = self._rename_duplicated_columns(
merged_df, origin_vo.name, other_vo.name
)
Expand Down

0 comments on commit f34f0ca

Please sign in to comment.