def __init__()

in marketing-analytics/predicting/future-customer-value-segments/bigquery_mod/__init__.py [0:0]


    def __init__(
            self,
            # gcs_location=None,
            get_destination_uri=None,
            table=None,
            dataset=None,
            project=None,
            query=None,
            validate=False,
            coder=None,
            use_standard_sql=False,
            flatten_results=True,
            kms_key=None,
            priority=None):
        if table is not None and query is not None:
            raise ValueError(
                'Both a BigQuery table and a query were specified.'
                ' Please specify only one of these.')
        elif table is None and query is None:
            raise ValueError('A BigQuery table or a query must be specified')
        elif table is not None:
            self.table_reference = bigquery_tools.parse_table_reference(
                table, dataset, project)
            self.query = None
            self.use_legacy_sql = True
        else:
            if isinstance(query, (str, unicode)):
                query = StaticValueProvider(str, query)
            self.query = query
            # TODO(BEAM-1082): Change the internal flag to be standard_sql
            self.use_legacy_sql = not use_standard_sql
            self.table_reference = None

        self.get_destination_uri = get_destination_uri
        self.priority = priority
        # self.gcs_location = gcs_location
        if isinstance(project, (str, unicode)):
            project = StaticValueProvider(str, query)
        self.project = project
        self.validate = validate
        self.flatten_results = flatten_results
        self.coder = coder or _JsonToDictCoder
        self.kms_key = kms_key
        self.split_result = None