This processor is deprecated and may be removed in future releases.
Please be aware this processor is deprecated and may be removed in the near future. Use PutBigQuery instead. Batch loads flow files content to a Google BigQuery table.
| Display Name | API Name | Default Value | Allowable Values | Description |
|---|
| Project ID | gcp-project-id | | | Google Cloud Project ID
Supports Expression Language: true (will be evaluated using variable registry only) |
| GCP Credentials Provider Service | GCP Credentials Provider Service | | Controller Service API:
GCPCredentialsService
Implementation: GCPCredentialsControllerService | The Controller Service used to obtain Google Cloud Platform credentials. |
| Number of retries | gcp-retry-count | 6 | | How many retry attempts should be made before routing to the failure relationship. |
| Proxy host | gcp-proxy-host | | | IP or hostname of the proxy to be used.
You might need to set the following properties in bootstrap for https proxy usage:
-Djdk.http.auth.tunneling.disabledSchemes=
-Djdk.http.auth.proxying.disabledSchemes=
Supports Expression Language: true (will be evaluated using variable registry only) |
| Proxy port | gcp-proxy-port | | | Proxy port number
Supports Expression Language: true (will be evaluated using variable registry only) |
| HTTP Proxy Username | gcp-proxy-user-name | | | HTTP Proxy Username
Supports Expression Language: true (will be evaluated using variable registry only) |
| HTTP Proxy Password | gcp-proxy-user-password | | | HTTP Proxy Password
Sensitive Property: true
Supports Expression Language: true (will be evaluated using variable registry only) |
| Proxy Configuration Service | proxy-configuration-service | | Controller Service API:
ProxyConfigurationService
Implementation: StandardProxyConfigurationService | Specifies the Proxy Configuration Controller Service to proxy network requests. If set, it supersedes proxy settings configured per component. Supported proxies: HTTP + AuthN |
| Dataset | bq.dataset | ${bq.dataset} | | BigQuery dataset name (Note - The dataset must exist in GCP)
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry) |
| Table Name | bq.table.name | ${bq.table.name} | | BigQuery table name
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry) |
| Ignore Unknown Values | bq.load.ignore_unknown | false | | Sets whether BigQuery should allow extra values that are not represented in the table schema. If true, the extra values are ignored. If false, records with extra columns are treated as bad records, and if there are too many bad records, an invalid error is returned in the job result. By default unknown values are not allowed.
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry) |
| Table Schema | bq.table.schema | | | BigQuery schema in JSON format
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry) |
| Read Timeout | bq.readtimeout | 5 minutes | | Load Job Time Out
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry) |
| Load file type | bq.load.type | | | Data type of the file to be loaded. Possible values: AVRO, NEWLINE_DELIMITED_JSON, CSV.
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry) |
| Create Disposition | bq.load.create_disposition | CREATE_IF_NEEDED | - CREATE_IF_NEEDED
 - CREATE_NEVER
| Sets whether the job is allowed to create new tables |
| Write Disposition | bq.load.write_disposition | WRITE_EMPTY | - WRITE_EMPTY
- WRITE_APPEND
- WRITE_TRUNCATE
| Sets the action that should occur if the destination table already exists. |
| Max Bad Records | bq.load.max_badrecords | 0 | | Sets the maximum number of bad records that BigQuery can ignore when running the job. If the number of bad records exceeds this value, an invalid error is returned in the job result. By default no bad record is ignored. |
| CSV Input - Allow Jagged Rows | bq.csv.allow.jagged.rows | false | | Set whether BigQuery should accept rows that are missing trailing optional columns. If true, BigQuery treats missing trailing columns as null values. If false, records with missing trailing columns are treated as bad records, and if there are too many bad records, an invalid error is returned in the job result. By default, rows with missing trailing columns are considered bad records. |
| CSV Input - Allow Quoted New Lines | bq.csv.allow.quoted.new.lines | false | | Sets whether BigQuery should allow quoted data sections that contain newline characters in a CSV file. By default quoted newline are not allowed. |
| CSV Input - Character Set | bq.csv.charset | UTF-8 | | Sets the character encoding of the data. |
| CSV Input - Field Delimiter | bq.csv.delimiter | , | | Sets the separator for fields in a CSV file. BigQuery converts the string to ISO-8859-1 encoding, and then uses the first byte of the encoded string to split the data in its raw, binary state. BigQuery also supports the escape sequence " " to specify a tab separator. The default value is a comma (',').
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry) |
| CSV Input - Quote | bq.csv.quote | " | | Sets the value that is used to quote data sections in a CSV file. BigQuery converts the string to ISO-8859-1 encoding, and then uses the first byte of the encoded string to split the data in its raw, binary state. The default value is a double-quote ('"'). If your data does not contain quoted sections, set the property value to an empty string. If your data contains quoted newline characters, you must also set the Allow Quoted New Lines property to true.
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry) |
| CSV Input - Skip Leading Rows | bq.csv.skip.leading.rows | 0 | | Sets the number of rows at the top of a CSV file that BigQuery will skip when reading the data. The default value is 0. This property is useful if you have header rows in the file that should be skipped.
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry) |
| Avro Input - Use Logical Types | bq.avro.use.logical.types | false | | If format is set to Avro and if this option is set to true, you can interpret logical types into their corresponding types (such as TIMESTAMP) instead of only using their raw types (such as INTEGER). |