src/dirbs/importer/base_delta_importer.py
def _calc_delta_removes_single_shard(self, *, staging_tbl_part_name, import_tbl_part_name, delta_tbl_part_name,
                                         import_filter=None):
        """Calculate the delta 'remove' entries for a single shard if the import is a full list."""
        # When remove entries are added to the delta table, the imei column will be NULL as import
        # table only has an imei_norm column.
        return self._calc_delta_common_single_shard(containing_table_part_name=import_tbl_part_name,
                                                    not_containing_table_part_name=staging_tbl_part_name,
                                                    delta_tbl_part_name=delta_tbl_part_name,
                                                    change_type='remove',
                                                    containing_filter=import_filter,
                                                    not_containing_filter=None)
Calculate the delta 'remove' entries for a single shard if the import is a full list.
Calculate the delta 'remove' entries for a single shard if the import is a full list.
Calculate the delta ' remove ' entries for a single shard if the import is a full list .
def _calc_delta_removes_single_shard(self, *, staging_tbl_part_name, import_tbl_part_name, delta_tbl_part_name,
                                         import_filter=None):
        return self._calc_delta_common_single_shard(containing_table_part_name=import_tbl_part_name,
                                                    not_containing_table_part_name=staging_tbl_part_name,
                                                    delta_tbl_part_name=delta_tbl_part_name,
                                                    change_type='remove',
                                                    containing_filter=import_filter,
                                                    not_containing_filter=None)
def _calc_delta_removes_single_shard ( self , * , staging_tbl_part_name , import_tbl_part_name , delta_tbl_part_name , import_filter = None ) : return self . _calc_delta_common_single_shard ( containing_table_part_name = import_tbl_part_name , not_containing_table_part_name = staging_tbl_part_name , delta_tbl_part_name = delta_tbl_part_name , change_type = 'remove' , containing_filter = import_filter , not_containing_filter = None )
Calculate the delta 'remove' entries for a single shard if the import is a full list.
Calculate the delta ' remove ' entries for a single shard if the import is a full list .
"""Calculate the delta 'remove' entries for a single shard if the import is a full list.""" # When remove entries are added to the delta table, the imei column will be NULL as import # table only has an imei_norm column.
self
staging_tbl_part_name
import_tbl_part_name
delta_tbl_part_name
import_filter