def METHOD_NAME(self, conf: ConfigTree) -> None:
    conf = conf.with_fallback(SnowflakeTableLastUpdatedExtractor.DEFAULT_CONFIG)
    self._cluster = conf.get_string(SnowflakeTableLastUpdatedExtractor.CLUSTER_KEY)
    if conf.get_bool(SnowflakeTableLastUpdatedExtractor.USE_CATALOG_AS_CLUSTER_NAME):
        cluster_source = "t.table_catalog"
    else:
        cluster_source = f"'{self._cluster}'"
    self._database = conf.get_string(SnowflakeTableLastUpdatedExtractor.DATABASE_KEY)
    self._snowflake_database = conf.get_string(SnowflakeTableLastUpdatedExtractor.SNOWFLAKE_DATABASE_KEY)
    self.sql_stmt = SnowflakeTableLastUpdatedExtractor.SQL_STATEMENT.format(
        where_clause_suffix=conf.get_string(SnowflakeTableLastUpdatedExtractor.WHERE_CLAUSE_SUFFIX_KEY),
        cluster_source=cluster_source,
        database=self._snowflake_database
    )
    LOGGER.info('SQL for snowflake table last updated timestamp: %s', self.sql_stmt)
    # use an sql_alchemy_extractor to execute sql
    self._alchemy_extractor = sql_alchemy_extractor.from_surrounding_config(conf, self.sql_stmt)
    self._extract_iter: Union[None, Iterator] = None