

@apply_defaults
def __init__(self, table, partition, extra_exprs=None, col_blacklist=None, assignment_func=None, metastore_conn_id='metastore_default', presto_conn_id='presto_default', mysql_conn_id='airflow_db', *args, **kwargs):
    super(HiveStatsCollectionOperator, self).__init__(*args, **kwargs)
    self.table = table
    self.partition = partition
    self.extra_exprs = (extra_exprs or {
        
    })
    self.col_blacklist = (col_blacklist or {
        
    })
    self.metastore_conn_id = metastore_conn_id
    self.presto_conn_id = presto_conn_id
    self.mysql_conn_id = mysql_conn_id
    self.assignment_func = assignment_func
    self.ds = '{{ ds }}'
    self.dttm = '{{ execution_date.isoformat() }}'

dataset/ETHPy150Open airbnb/airflow/airflow/operators/hive_stats_operator.py HiveStatsCollectionOperator.__init__/original