{"objects":[{"metadata":{"identifier":{"packageName":"Matillion Exchange","name":"Google BigQuery Incremental Load","revision":1,"type":"DYNAMIC"},"rootJobReference":{"name":"Google BigQuery - 1 - Iterate Objects","type":"ORCHESTRATION","parameterMetadata":[{"slot":2,"variableName":"oauth","variableType":"SCALAR","displayName":"OAuth","description":"The name of the OAuth entry to be used from the Matillion OAuth Manager to connect to the source. These must be set up in advance, using Project → Manage OAuth.","defaultValue":[{"values":{"1":""}}],"defaultValueType":"TEXT","required":true},{"slot":3,"variableName":"source_list","variableType":"GRID","displayName":"Tables and Columns","description":"Contains the list of tables and columns (and in some cases an incremental_column to specify which column the load should be incremented on [accepts values of 0 or 1]) to be processed. ","defaultValue":[{"values":{"1":""}}],"defaultValueType":null,"required":true},{"slot":4,"variableName":"advanced_connection_options","variableType":"GRID","displayName":"Connection Options","description":"A list of values and parameters. Parameters and their allowed values are database/driver specific. Referring to the data model will provide insight of what you could provide here.\n
\nThey are usually not required as sensible defaults are assumed.","defaultValue":[{"values":{"1":""}}],"defaultValueType":null,"required":false},{"slot":5,"variableName":"source_dataset","variableType":"SCALAR","displayName":"Source Dataset","description":"The dataset name where the source data is located.","defaultValue":[{"values":{"1":""}}],"defaultValueType":"TEXT","required":true},{"slot":6,"variableName":"source_project","variableType":"SCALAR","displayName":"Source Project","description":"The project name where the source data is located.","defaultValue":[{"values":{"1":""}}],"defaultValueType":"TEXT","required":true},{"slot":7,"variableName":"load_concurrent","variableType":"SCALAR","displayName":"Load Type","description":"Sequential - Iterations are done in sequence, waiting for each to complete before starting the next. \nThis is the default.\n
\nConcurrent - Iterations are run concurrently. This requires all \"Variables to Iterate\" to be defined as\nCopied variables, so that each iteration gets its own copy of the variable isolated from the same\nvariable being used by other concurrent executions.\n
Note: The maximum concurrency is limited by the number of available threads (2x the number of virtual cpus on your cloud instance).","defaultValue":[{"values":{"1":""}}],"defaultValueType":"TEXT","required":true},{"slot":8,"variableName":"stage_warehouse","variableType":"SCALAR","displayName":"Stage Warehouse","description":"The warehouse name where the staging data will be stored.","defaultValue":[{"values":{"1":""}}],"defaultValueType":"TEXT","required":true},{"slot":9,"variableName":"stage_database","variableType":"SCALAR","displayName":"Stage Database","description":"The database name where the staging data will be stored.","defaultValue":[{"values":{"1":""}}],"defaultValueType":"TEXT","required":true},{"slot":10,"variableName":"stage_schema","variableType":"SCALAR","displayName":"Stage Schema","description":"The schema name where the staging data will be stored.","defaultValue":[{"values":{"1":""}}],"defaultValueType":"TEXT","required":true},{"slot":11,"variableName":"stage_prefix","variableType":"SCALAR","displayName":"Stage Prefix","description":"A prefix value that will be added to the start of the stage table names.\n
\ne.g. If a Stage Prefix of 'stage_' is specified and the table being processed is named 'test_data' then the target table will be named 'stage_test_data'.","defaultValue":[{"values":{"1":"stg_"}}],"defaultValueType":"TEXT","required":true},{"slot":12,"variableName":"target_warehouse","variableType":"SCALAR","displayName":"Target Warehouse","description":"The warehouse name where the target data will be stored.","defaultValue":[{"values":{"1":""}}],"defaultValueType":"TEXT","required":true},{"slot":13,"variableName":"target_database","variableType":"SCALAR","displayName":"Target Database","description":"The database name where the target data will be stored.","defaultValue":[{"values":{"1":""}}],"defaultValueType":"TEXT","required":true},{"slot":14,"variableName":"target_schema","variableType":"SCALAR","displayName":"Target Schema","description":"The schema name where the target data will be stored.","defaultValue":[{"values":{"1":""}}],"defaultValueType":"TEXT","required":true},{"slot":15,"variableName":"target_prefix","variableType":"SCALAR","displayName":"Target Prefix","description":"A prefix value that will be added to the start of the target table names.\n
\ne.g. If a Target Prefix of 'target_' is specified and the table being processed is named 'test_data' then the target table will be named 'target_test_data'.","defaultValue":[{"values":{"1":""}}],"defaultValueType":"TEXT","required":false},{"slot":16,"variableName":"staging_type","variableType":"SCALAR","displayName":"Staging","description":"(AWS Only) Snowflake Managed: Allow Matillion ETL to create and use a temporary internal stage on Snowflake for staging the data. This stage, along with the staged data, will cease to exist after loading is complete.
\n Existing Amazon S3 Location: Selecting this will avail the user of properties to specify a custom staging area on S3.","defaultValue":[{"values":{"1":"Snowflake Managed"}}],"defaultValueType":"TEXT","required":false},{"slot":17,"variableName":"s3_bucket_name","variableType":"SCALAR","displayName":"S3 Bucket Name","description":"(AWS Only) The name of an S3 bucket for temporary storage. Ensure your access credentials have S3 access and permission to write to the bucket. See this document for details on setting up access. The temporary objects created in this bucket will be removed again after the load completes, they are not kept.
\nThis property is available when using an Existing Amazon S3 Location for Staging.","defaultValue":[{"values":{"1":""}}],"defaultValueType":"TEXT","required":false},{"slot":18,"variableName":"encryption_method","variableType":"SCALAR","displayName":"Encryption","description":"(AWS Only) Decide on how the files are encrypted inside the S3 Bucket.This property is available when using an Existing Amazon S3 Location for Staging.
\n None: No encryption.
\n SSE KMS: Encrypt the data according to a key stored on KMS.
\n SSE S3: Encrypt the data according to a key stored on an S3 bucket","defaultValue":[{"values":{"1":"None"}}],"defaultValueType":"TEXT","required":false},{"slot":19,"variableName":"kms_key_id","variableType":"SCALAR","displayName":"KMS Key ID","description":"The ID of the KMS encryption key you have chosen to use in the 'Encryption' property.","defaultValue":[{"values":{"1":""}}],"defaultValueType":"TEXT","required":false},{"slot":20,"variableName":"blob_container","variableType":"SCALAR","displayName":"Azure Blob Container","description":"(Azure Only) Azure Blob Container to allow Matillion ETL to use the blob storage container object on Snowflake for staging data. ","defaultValue":[{"values":{"1":""}}],"defaultValueType":"TEXT","required":false},{"slot":21,"variableName":"storage_account","variableType":"SCALAR","displayName":"Azure Storage Account","description":"(Azure Only) Azure Storage Account to allow Matillion ETL to specify a blob container object on Snowflake for staging data. ","defaultValue":[{"values":{"1":""}}],"defaultValueType":"TEXT","required":false},{"slot":22,"variableName":"log_metrics","variableType":"SCALAR","displayName":"Log Metrics","description":"Option to switch off Metrics logging in the full product - default is TRUE which records the metrics for the batch run. ","defaultValue":[{"values":{"1":"TRUE"}}],"defaultValueType":"TEXT","required":false}]},"orchestrationJobs":["Google BigQuery - 1 - Iterate Objects","Google BigQuery - 3 - Stage Object","Google BigQuery - 2 - Stage Object","util - Query Source"],"transformationJobs":[],"imageMetadata":{"componentIcon":"iVBORw0KGgoAAAANSUhEUgAAACAAAAAgCAYAAABzenr0AAAD0ElEQVR42u2Xa2gUVxTHFbWCFBQEFfpJC/VLv4gfNQ+zMY9qGjQG1waKrRqFNgZE2zvjUqdmH3GTaBLU+qjQGkQIilHBfAgitglUfEU0IWpK6mZXk6Dxnc3eOzt/z8xmY4zZ2dkkaAUvHNgd7pz/755z7r1nJkz4OP7vI6MMs2weXpnm5sesGs2vsXlCq8cFwObmDWRI3EJY6hYpYxJPLw3ljk580K7n12LSqMSzqzGVHLSPEQDpbr5hlKEXP41VfMC600sxPSHxVC/m0IvPxgkAVJTlia3ew4+Mm3jEuM3d/4Ul8SUevpBeCJvkFMpJFX+1abj9QMOldg176lVk7oq7K87GVwcm0j5ujOUks5QbwiEB1N8IY3+DitpLYfS+AO4QTF5lnIJ0iUzz0LtCdjMHx5oiYt8dEm88z93N0eLXcLldIM0VjA3h4q0LD2LKiOI5CqbRJF+sl5eVcQQ5UHJKHXzmrFONqOi/C/YLhDVg/b4ecwg33zzyoeMS28xWX/SngEYC2V6OvCqBLMr50z4gp+L1HD0Nu0/3Ikn2I80ZjFVDvfpi3wKg3FebARTXRFaYQSu+/p+G4qPCAFhVxfH7hbAxpzWgofJMLxaze2YQmn6/vF39Jf3zI9tlZIBcWqkIAz8fV40CjAJ8s08YwiupALkKbPqtywDQLVXuwKqdzcPPhBqzi6fCLApnr4Xhewis2SuwYg9H423NKMD8aoG/6XeLL4SkAfEUdhc/SFX4Vj4xNBIv0px9n8U+ARXMoFT0xAJYXs5xs1PDo+cwwr69VjXOgPYuDSpFp6ObI8fpNwA2SgcgSRKYJGOLXIrvd9Tha6e/xMr1u9EsCnrVV597iVv3+vHoGYk/4Pjj/BOs8PjR3NE/ANGJLHYF2yQFG6TDyGfnsFkq0wioS5blL00B9OuThJrj3fXJjte5jtrSX3w433QTq70B478OsYbVReqB/VtAAKcYY22FhYVTzPsAj0i10nAMh/iK/UMh305idwafJbEOLGK+i7pfAphJ9pIg8uKnwiVOJAphZ2co1OXDIxNOZoEFUb8E0EAA3vi9YElwLokEE4GwU7iLpIo3ABbJnYeH+iWAerIKi01JyGW1/9MhclijkYIlrC0K8NQmd8+O+lMU5RMSf0wRKLDWmCj4lDqjgFWIFMd9FEteo/L13CdLga1U9WuHVj4BrCOQaQk0JyKLBB5ahch2tBjb70epUmyVd9r1cJP1xN1+8Ya+Pa0aY8o8Ej1O1qcfRgN2ldxMfKcfNRTqyST8K1mnw+H4/L18WVHo7e9N/IMYrwDqx/c6ukR6/wAAAABJRU5ErkJggg==","smallIcon":"iVBORw0KGgoAAAANSUhEUgAAABAAAAAQCAYAAAAf8/9hAAABxElEQVR42mNgoDZwbvup5dL+MxgDt/0Mcuv+L4ZXs0PPfxHnth/vndt//seKW38cZvj/nxGnAU5tP6bh1Aw35GcEVs0uHT91gbb/IWhA249Hln3/ObH4/cdemCKgn/8vOPT3/67Lf//vufrvf96iXyiGOLX/rEd1evvPQGQF3Vv//G/b9Pt/yMSf/907f/7fd+3Pf+/OL8iu+OrW8k0W2fZDyAZsu/j3f+7CX/+XH//zP2Hmr/9923//T5v64r9j8yeEK9p+NiO54EcOsgETd/7+P3v/n//zDv75X7b81/+dl/78d2949N+z4tR/v6ZbIBf8dW39ZYCIvob/LEDBKzAD3Dp+/l927Pf/7Rf+/N998ef/A5e//s+d9eJ/esX0/5mVU/5nVM+9XVJSwo0aiK2/XVFD/Md/+7pX/20qHvx3qrr1v3jCof/2Fbf/u1Rc+pBRNcu9vLy8EzMq235sxDTk5X+vihP/Qyu2gQ2zqXxUBFJbUVGxGDMltv9QAXrlJ7ohznWP/idXzAUZcLOgrFMTqJSxsrIyD3tqbPnhC8wPjSi45XtjYvWKzuKKpr1Ap98DarYnN68xAg2oKCws5KRa7gUAbYiS5dnaydkAAAAASUVORK5CYII="},"description":"","helpHtml":"
Property | Type | Description |
---|---|---|
OAuth | Variable | The name of the OAuth entry to be used from the Matillion OAuth Manager to connect to the source. These must be set up in advance, using Project → Manage OAuth. |
Tables and Columns | Grid | Contains the list of tables and columns (and in some cases an incremental_column to specify which column the load should be incremented on [accepts values of 0 or 1]) to be processed. |
Connection Options | Grid | A list of values and parameters. Parameters and their allowed values are database/driver specific. Referring to the data model will provide insight of what you could provide here.\n \nThey are usually not required as sensible defaults are assumed. |
Source Dataset | Variable | The dataset name where the source data is located. |
Source Project | Variable | The project name where the source data is located. |
Load Type | Variable | Sequential - Iterations are done in sequence, waiting for each to complete before starting the next. \nThis is the default.\n \nConcurrent - Iterations are run concurrently. This requires all \"Variables to Iterate\" to be defined as\nCopied variables, so that each iteration gets its own copy of the variable isolated from the same\nvariable being used by other concurrent executions.\n Note: The maximum concurrency is limited by the number of available threads (2x the number of virtual cpus on your cloud instance). |
Stage Warehouse | Variable | The warehouse name where the staging data will be stored. |
Stage Database | Variable | The database name where the staging data will be stored. |
Stage Schema | Variable | The schema name where the staging data will be stored. |
Stage Prefix | Variable | A prefix value that will be added to the start of the stage table names.\n \ne.g. If a Stage Prefix of 'stage_' is specified and the table being processed is named 'test_data' then the target table will be named 'stage_test_data'. |
Target Warehouse | Variable | The warehouse name where the target data will be stored. |
Target Database | Variable | The database name where the target data will be stored. |
Target Schema | Variable | The schema name where the target data will be stored. |
Target Prefix | Variable | A prefix value that will be added to the start of the target table names.\n \ne.g. If a Target Prefix of 'target_' is specified and the table being processed is named 'test_data' then the target table will be named 'target_test_data'. |
Staging | Variable | (AWS Only) Snowflake Managed: Allow Matillion ETL to create and use a temporary internal stage on Snowflake for staging the data. This stage, along with the staged data, will cease to exist after loading is complete. \n Existing Amazon S3 Location: Selecting this will avail the user of properties to specify a custom staging area on S3. |
S3 Bucket Name | Variable | (AWS Only) The name of an S3 bucket for temporary storage. Ensure your access credentials have S3 access and permission to write to the bucket. See this document for details on setting up access. The temporary objects created in this bucket will be removed again after the load completes, they are not kept. \nThis property is available when using an Existing Amazon S3 Location for Staging. |
Encryption | Variable | (AWS Only) Decide on how the files are encrypted inside the S3 Bucket.This property is available when using an Existing Amazon S3 Location for Staging. \n None: No encryption. \n SSE KMS: Encrypt the data according to a key stored on KMS. \n SSE S3: Encrypt the data according to a key stored on an S3 bucket |
KMS Key ID | Variable | The ID of the KMS encryption key you have chosen to use in the 'Encryption' property. |
Azure Blob Container | Variable | (Azure Only) Azure Blob Container to allow Matillion ETL to use the blob storage container object on Snowflake for staging data. |
Azure Storage Account | Variable | (Azure Only) Azure Storage Account to allow Matillion ETL to specify a blob container object on Snowflake for staging data. |
Log Metrics | Variable | Option to switch off Metrics logging in the full product - default is TRUE which records the metrics for the batch run. |