#NEWLINE# @ apply_defaults #NEWLINE# def __init__( self , bucket , source_objects , destination_project_dataset_table , schema_fields = False , schema_object = False , source_format = 'CSV' , create_disposition = 'CREATE_IF_NEEDED' , skip_leading_rows = 0 , write_disposition = 'WRITE_EMPTY' , field_delimiter = ',' , max_id_key = False , bigquery_conn_id = 'bigquery_default' , google_cloud_storage_conn_id = 'google_cloud_storage_default' , delegate_to = None , * args , **kwargs ) : #NEWLINE# #INDENT# "\n        The schema to be used for the BigQuery table may be specified in one of\n        two ways. You may either directly pass the schema fields in, or you may\n        point the operator to a Google cloud storage object name. The object in\n        Google cloud storage must be a JSON file with the schema fields in it.\n\n        :param bucket: The bucket to load from.\n        :type bucket: string\n        :param source_objects: List of Google cloud storage URIs to load from.\n        :type object: list\n        :param destination_project_dataset_table: The dotted (<project>.)<dataset>.<table> BigQuery table to load data\n            into. If <project> is not included, project will be the project defined in the connection json.\n        :type destination_project_dataset_table: string\n        :param schema_fields: If set, the schema field list as defined here:\n            https://cloud.google.com/bigquery/docs/reference/v2/jobs#configuration.load\n        :type schema_fields: list\n        :param schema_object: If set, a GCS object path pointing to a .json file that contains the schema for the table.\n        :param schema_object: string\n        :param source_format: File format to export.\n        :type source_format: string\n        :param create_disposition: The create disposition if the table doesn't exist.\n        :type create_disposition: string\n        :param skip_leading_rows: Number of rows to skip when loading from a CSV.\n        :type skip_leading_rows: int\n        :param write_disposition: The write disposition if the table already exists.\n        :type write_disposition: string\n        :param field_delimiter: The delimiter to use when loading from a CSV.\n        :type field_delimiter: string\n        :param max_id_key: If set, the name of a column in the BigQuery table\n            that's to be loaded. Thsi will be used to select the MAX value from\n            BigQuery after the load occurs. The results will be returned by the\n            execute() command, which in turn gets stored in XCom for future\n            operators to use. This can be helpful with incremental loads--during\n            future executions, you can pick up from the max ID.\n        :type max_id_key: string\n        :param bigquery_conn_id: Reference to a specific BigQuery hook.\n        :type bigquery_conn_id: string\n        :param google_cloud_storage_conn_id: Reference to a specific Google\n            cloud storage hook.\n        :type google_cloud_storage_conn_id: string\n        :param delegate_to: The account to impersonate, if any. For this to\n            work, the service account making the request must have domain-wide\n            delegation enabled.\n        :type delegate_to: string\n        " #NEWLINE# super ( GoogleCloudStorageToBigQueryOperator , self ) . __init__ ( * args , ** kwargs ) #NEWLINE# self . bucket = bucket #NEWLINE# self . source_objects = source_objects #NEWLINE# self . schema_object = schema_object #NEWLINE# self . destination_project_dataset_table = destination_project_dataset_table #NEWLINE# self . schema_fields = schema_fields #NEWLINE# self . source_format = source_format #NEWLINE# self . create_disposition = create_disposition #NEWLINE# self . skip_leading_rows = skip_leading_rows #NEWLINE# self . write_disposition = write_disposition #NEWLINE# self . field_delimiter = field_delimiter #NEWLINE# self . max_id_key = max_id_key #NEWLINE# self . bigquery_conn_id = bigquery_conn_id #NEWLINE# self . google_cloud_storage_conn_id = google_cloud_storage_conn_id #NEWLINE# self . delegate_to = delegate_to