This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 631e9c892257ac66bbd9df69a916f7922e8242b2
Author: Jon Chase <jch...@agari.com>
AuthorDate: Sat Jun 6 06:12:17 2020 -0400
CAMEL-14992: adding producer label to configuration parameters
---
.../camel/component/aws2/athena/aws2-athena.json | 74 +++++++++++-----------
.../aws2/athena/Athena2Configuration.java | 60 +++++++++++-------
2 files changed, 75 insertions(+), 59 deletions(-)
diff --git
a/components/camel-aws2-athena/src/generated/resources/org/apache/camel/component/aws2/athena/aws2-athena.json
b/components/camel-aws2-athena/src/generated/resources/org/apache/camel/component/aws2/athena/aws2-athena.json
index 325f2bf..c01bd59 100644
---
a/components/camel-aws2-athena/src/generated/resources/org/apache/camel/component/aws2/athena/aws2-athena.json
+++
b/components/camel-aws2-athena/src/generated/resources/org/apache/camel/component/aws2/athena/aws2-athena.json
@@ -24,61 +24,61 @@
"accessKey": { "kind": "property", "displayName": "Access Key", "group":
"producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": true,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Amazon AWS Access Key."
},
"amazonAthenaClient": { "kind": "property", "displayName": "Amazon Athena
Client", "group": "producer", "label": "", "required": false, "type": "object",
"javaType": "software.amazon.awssdk.services.athena.AthenaClient",
"deprecated": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "The AmazonAthena
instance to use as the client." },
"configuration": { "kind": "property", "displayName": "Configuration",
"group": "producer", "label": "", "required": false, "type": "object",
"javaType": "org.apache.camel.component.aws2.athena.Athena2Configuration",
"deprecated": false, "secret": false, "description": "The component
configuration." },
- "database": { "kind": "property", "displayName": "Database", "group":
"producer", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "The Athena database to
use." },
- "delay": { "kind": "property", "displayName": "Delay", "group":
"producer", "label": "", "required": false, "type": "integer", "javaType":
"long", "deprecated": false, "secret": false, "defaultValue": "2000",
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Milliseconds before the
next poll for query execution status. See the section 'Waiting for Query
Completion and Retrying Failed Queries' to [...]
- "encryptionOption": { "kind": "property", "displayName": "Encryption
Option", "group": "producer", "label": "", "required": false, "type": "object",
"javaType": "software.amazon.awssdk.services.athena.model.EncryptionOption",
"enum": [ "SSE_S3", "SSE_KMS", "CSE_KMS", "null" ], "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "The encryption type to
use when [...]
- "includeTrace": { "kind": "property", "displayName": "Include Trace",
"group": "producer", "label": "", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "secret": false, "defaultValue":
"false", "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Include useful trace
information at the beginning of queries as an SQL comment (prefixed with --)."
},
- "initialDelay": { "kind": "property", "displayName": "Initial Delay",
"group": "producer", "label": "", "required": false, "type": "integer",
"javaType": "long", "deprecated": false, "secret": false, "defaultValue":
"1000", "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Milliseconds before the
first poll for query execution status. See the section 'Waiting for Query
Completion and Retrying Fa [...]
- "kmsKey": { "kind": "property", "displayName": "Kms Key", "group":
"producer", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "For SSE-KMS and CSE-KMS,
this is the KMS key ARN or ID." },
+ "database": { "kind": "property", "displayName": "Database", "group":
"producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "The Athena database to
use." },
+ "delay": { "kind": "property", "displayName": "Delay", "group":
"producer", "label": "producer", "required": false, "type": "integer",
"javaType": "long", "deprecated": false, "secret": false, "defaultValue":
"2000", "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Milliseconds before the
next poll for query execution status. See the section 'Waiting for Query
Completion and Retrying Failed Que [...]
+ "encryptionOption": { "kind": "property", "displayName": "Encryption
Option", "group": "producer", "label": "producer", "required": false, "type":
"object", "javaType":
"software.amazon.awssdk.services.athena.model.EncryptionOption", "enum": [
"SSE_S3", "SSE_KMS", "CSE_KMS", "null" ], "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "The encryption type to u
[...]
+ "includeTrace": { "kind": "property", "displayName": "Include Trace",
"group": "producer", "label": "producer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "secret": false, "defaultValue":
"false", "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Include useful trace
information at the beginning of queries as an SQL comment (prefixed with --)."
},
+ "initialDelay": { "kind": "property", "displayName": "Initial Delay",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "long", "deprecated": false, "secret": false, "defaultValue":
"1000", "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Milliseconds before the
first poll for query execution status. See the section 'Waiting for Query
Completion and Ret [...]
+ "kmsKey": { "kind": "property", "displayName": "Kms Key", "group":
"producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "For SSE-KMS and CSE-KMS,
this is the KMS key ARN or ID." },
"lazyStartProducer": { "kind": "property", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the r [...]
- "maxAttempts": { "kind": "property", "displayName": "Max Attempts",
"group": "producer", "label": "", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "secret": false, "defaultValue": "1",
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Maximum number of times
to attempt a query. Set to 1 to disable retries. See the section 'Waiting for
Query Completion and Retryin [...]
- "maxResults": { "kind": "property", "displayName": "Max Results", "group":
"producer", "label": "", "required": false, "type": "integer", "javaType":
"java.lang.Integer", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Max number of results to
return for the given operation (if supported by the Athena API endpoint). If
not set, will use the Athena API defa [...]
- "nextToken": { "kind": "property", "displayName": "Next Token", "group":
"producer", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Pagination token to use
in the case where the response from the previous request was truncated." },
- "operation": { "kind": "property", "displayName": "Operation", "group":
"producer", "label": "", "required": false, "type": "object", "javaType":
"org.apache.camel.component.aws2.athena.Athena2Operations", "enum": [
"getQueryExecution", "getQueryResults", "listQueryExecutions",
"startQueryExecution" ], "deprecated": false, "secret": false, "defaultValue":
"startQueryExecution", "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": [...]
- "outputLocation": { "kind": "property", "displayName": "Output Location",
"group": "producer", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "The location in Amazon
S3 where query results are stored, such as s3:\/\/path\/to\/query\/bucket\/.
Ensure this value ends with a for [...]
- "outputType": { "kind": "property", "displayName": "Output Type", "group":
"producer", "label": "", "required": false, "type": "object", "javaType":
"org.apache.camel.component.aws2.athena.Athena2OutputType", "enum": [
"StreamList", "SelectList", "S3Pointer" ], "deprecated": false, "secret":
false, "defaultValue": "StreamList", "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "How query results [...]
+ "maxAttempts": { "kind": "property", "displayName": "Max Attempts",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "secret": false, "defaultValue": "1",
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Maximum number of times
to attempt a query. Set to 1 to disable retries. See the section 'Waiting for
Query Completion and [...]
+ "maxResults": { "kind": "property", "displayName": "Max Results", "group":
"producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Max number of results to
return for the given operation (if supported by the Athena API endpoint). If
not set, will use the Athena [...]
+ "nextToken": { "kind": "property", "displayName": "Next Token", "group":
"producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Pagination token to use
in the case where the response from the previous request was truncated." },
+ "operation": { "kind": "property", "displayName": "Operation", "group":
"producer", "label": "producer", "required": false, "type": "object",
"javaType": "org.apache.camel.component.aws2.athena.Athena2Operations", "enum":
[ "getQueryExecution", "getQueryResults", "listQueryExecutions",
"startQueryExecution" ], "deprecated": false, "secret": false, "defaultValue":
"startQueryExecution", "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration", "configuration
[...]
+ "outputLocation": { "kind": "property", "displayName": "Output Location",
"group": "producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "The location in Amazon
S3 where query results are stored, such as s3:\/\/path\/to\/query\/bucket\/.
Ensure this value ends wi [...]
+ "outputType": { "kind": "property", "displayName": "Output Type", "group":
"producer", "label": "producer", "required": false, "type": "object",
"javaType": "org.apache.camel.component.aws2.athena.Athena2OutputType", "enum":
[ "StreamList", "SelectList", "S3Pointer" ], "deprecated": false, "secret":
false, "defaultValue": "StreamList", "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "How query [...]
"proxyHost": { "kind": "property", "displayName": "Proxy Host", "group":
"producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "To define a proxy host
when instantiating the Athena client." },
"proxyPort": { "kind": "property", "displayName": "Proxy Port", "group":
"producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "To define a proxy port
when instantiating the Athena client." },
"proxyProtocol": { "kind": "property", "displayName": "Proxy Protocol",
"group": "producer", "label": "", "required": false, "type": "object",
"javaType": "software.amazon.awssdk.core.Protocol", "enum": [ "HTTP", "HTTPS"
], "deprecated": false, "secret": false, "defaultValue": "HTTPS",
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "To define a proxy
protocol when instantiating the Athena client." },
- "queryExecutionId": { "kind": "property", "displayName": "Query Execution
Id", "group": "producer", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "The unique ID
identifying the query execution." },
- "queryString": { "kind": "property", "displayName": "Query String",
"group": "producer", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "The SQL query to run.
Except for simple queries, prefer setting this as the body of the Exchange or
as a header using Athena2Constants.QUER [...]
+ "queryExecutionId": { "kind": "property", "displayName": "Query Execution
Id", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "The unique ID
identifying the query execution." },
+ "queryString": { "kind": "property", "displayName": "Query String",
"group": "producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "The SQL query to run.
Except for simple queries, prefer setting this as the body of the Exchange or
as a header using Athena2Consta [...]
"region": { "kind": "property", "displayName": "Region", "group":
"producer", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "The region in which
Athena client needs to work. When using this parameter, the configuration will
expect the lowercase name of the region (for exampl [...]
- "resetWaitTimeoutOnRetry": { "kind": "property", "displayName": "Reset
Wait Timeout On Retry", "group": "producer", "label": "", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": "true", "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Reset the waitTimeout
countdown in the event of a query retry. If set to true, potential max tim [...]
- "retry": { "kind": "property", "displayName": "Retry", "group":
"producer", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "enum": [ "never", "always", "retryable", "exhausted",
"generic" ], "deprecated": false, "secret": false, "defaultValue": "never",
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Optional comma separated
list of error types to retry the q [...]
+ "resetWaitTimeoutOnRetry": { "kind": "property", "displayName": "Reset
Wait Timeout On Retry", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret":
false, "defaultValue": "true", "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Reset the waitTimeout
countdown in the event of a query retry. If set to true, potential [...]
+ "retry": { "kind": "property", "displayName": "Retry", "group":
"producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "never", "always", "retryable",
"exhausted", "generic" ], "deprecated": false, "secret": false, "defaultValue":
"never", "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Optional comma separated
list of error types to ret [...]
"secretKey": { "kind": "property", "displayName": "Secret Key", "group":
"producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": true,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Amazon AWS Secret Key."
},
- "waitTimeout": { "kind": "property", "displayName": "Wait Timeout",
"group": "producer", "label": "", "required": false, "type": "integer",
"javaType": "long", "deprecated": false, "secret": false, "defaultValue": "0",
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Optional max wait time
in millis to wait for a successful query completion. See the section 'Waiting
for Query Completion and Ret [...]
- "workGroup": { "kind": "property", "displayName": "Work Group", "group":
"producer", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "The workgroup to use for
running the query." },
+ "waitTimeout": { "kind": "property", "displayName": "Wait Timeout",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "long", "deprecated": false, "secret": false, "defaultValue": "0",
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Optional max wait time
in millis to wait for a successful query completion. See the section 'Waiting
for Query Completion [...]
+ "workGroup": { "kind": "property", "displayName": "Work Group", "group":
"producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "The workgroup to use for
running the query." },
"basicPropertyBinding": { "kind": "property", "displayName": "Basic
Property Binding", "group": "advanced", "label": "advanced", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": false, "description": "Whether the component should use basic
property binding (Camel 2.x) or the newer property binding with additional
capabilities" },
"clientRequestToken": { "kind": "property", "displayName": "Client Request
Token", "group": "advanced", "label": "advanced", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "A unique string to
ensure issues queries are idempotent. It is unlikely you will need to set
this." }
},
"properties": {
- "label": { "kind": "path", "displayName": "Label", "group": "producer",
"label": "", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "secret":
false, "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Logical name" },
+ "label": { "kind": "path", "displayName": "Label", "group": "producer",
"label": "producer", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "secret":
false, "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Logical name" },
"accessKey": { "kind": "parameter", "displayName": "Access Key", "group":
"producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": true,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Amazon AWS Access Key."
},
"amazonAthenaClient": { "kind": "parameter", "displayName": "Amazon Athena
Client", "group": "producer", "label": "", "required": false, "type": "object",
"javaType": "software.amazon.awssdk.services.athena.AthenaClient",
"deprecated": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "The AmazonAthena
instance to use as the client." },
- "database": { "kind": "parameter", "displayName": "Database", "group":
"producer", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "The Athena database to
use." },
- "delay": { "kind": "parameter", "displayName": "Delay", "group":
"producer", "label": "", "required": false, "type": "integer", "javaType":
"long", "deprecated": false, "secret": false, "defaultValue": "2000",
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Milliseconds before the
next poll for query execution status. See the section 'Waiting for Query
Completion and Retrying Failed Queries' t [...]
- "encryptionOption": { "kind": "parameter", "displayName": "Encryption
Option", "group": "producer", "label": "", "required": false, "type": "object",
"javaType": "software.amazon.awssdk.services.athena.model.EncryptionOption",
"enum": [ "SSE_S3", "SSE_KMS", "CSE_KMS", "null" ], "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "The encryption type to
use when [...]
- "includeTrace": { "kind": "parameter", "displayName": "Include Trace",
"group": "producer", "label": "", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "secret": false, "defaultValue":
"false", "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Include useful trace
information at the beginning of queries as an SQL comment (prefixed with --)."
},
- "initialDelay": { "kind": "parameter", "displayName": "Initial Delay",
"group": "producer", "label": "", "required": false, "type": "integer",
"javaType": "long", "deprecated": false, "secret": false, "defaultValue":
"1000", "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Milliseconds before the
first poll for query execution status. See the section 'Waiting for Query
Completion and Retrying F [...]
- "kmsKey": { "kind": "parameter", "displayName": "Kms Key", "group":
"producer", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "For SSE-KMS and CSE-KMS,
this is the KMS key ARN or ID." },
+ "database": { "kind": "parameter", "displayName": "Database", "group":
"producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "The Athena database to
use." },
+ "delay": { "kind": "parameter", "displayName": "Delay", "group":
"producer", "label": "producer", "required": false, "type": "integer",
"javaType": "long", "deprecated": false, "secret": false, "defaultValue":
"2000", "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Milliseconds before the
next poll for query execution status. See the section 'Waiting for Query
Completion and Retrying Failed Qu [...]
+ "encryptionOption": { "kind": "parameter", "displayName": "Encryption
Option", "group": "producer", "label": "producer", "required": false, "type":
"object", "javaType":
"software.amazon.awssdk.services.athena.model.EncryptionOption", "enum": [
"SSE_S3", "SSE_KMS", "CSE_KMS", "null" ], "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "The encryption type to
[...]
+ "includeTrace": { "kind": "parameter", "displayName": "Include Trace",
"group": "producer", "label": "producer", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "secret": false, "defaultValue":
"false", "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Include useful trace
information at the beginning of queries as an SQL comment (prefixed with --)."
},
+ "initialDelay": { "kind": "parameter", "displayName": "Initial Delay",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "long", "deprecated": false, "secret": false, "defaultValue":
"1000", "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Milliseconds before the
first poll for query execution status. See the section 'Waiting for Query
Completion and Re [...]
+ "kmsKey": { "kind": "parameter", "displayName": "Kms Key", "group":
"producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "For SSE-KMS and CSE-KMS,
this is the KMS key ARN or ID." },
"lazyStartProducer": { "kind": "parameter", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the [...]
- "maxAttempts": { "kind": "parameter", "displayName": "Max Attempts",
"group": "producer", "label": "", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "secret": false, "defaultValue": "1",
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Maximum number of times
to attempt a query. Set to 1 to disable retries. See the section 'Waiting for
Query Completion and Retryi [...]
- "maxResults": { "kind": "parameter", "displayName": "Max Results",
"group": "producer", "label": "", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Max number of results to
return for the given operation (if supported by the Athena API endpoint). If
not set, will use the Athena API def [...]
- "nextToken": { "kind": "parameter", "displayName": "Next Token", "group":
"producer", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Pagination token to use
in the case where the response from the previous request was truncated." },
- "operation": { "kind": "parameter", "displayName": "Operation", "group":
"producer", "label": "", "required": false, "type": "object", "javaType":
"org.apache.camel.component.aws2.athena.Athena2Operations", "enum": [
"getQueryExecution", "getQueryResults", "listQueryExecutions",
"startQueryExecution" ], "deprecated": false, "secret": false, "defaultValue":
"startQueryExecution", "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": [...]
- "outputLocation": { "kind": "parameter", "displayName": "Output Location",
"group": "producer", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "The location in Amazon
S3 where query results are stored, such as s3:\/\/path\/to\/query\/bucket\/.
Ensure this value ends with a fo [...]
- "outputType": { "kind": "parameter", "displayName": "Output Type",
"group": "producer", "label": "", "required": false, "type": "object",
"javaType": "org.apache.camel.component.aws2.athena.Athena2OutputType", "enum":
[ "StreamList", "SelectList", "S3Pointer" ], "deprecated": false, "secret":
false, "defaultValue": "StreamList", "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "How query results [...]
+ "maxAttempts": { "kind": "parameter", "displayName": "Max Attempts",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "int", "deprecated": false, "secret": false, "defaultValue": "1",
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Maximum number of times
to attempt a query. Set to 1 to disable retries. See the section 'Waiting for
Query Completion an [...]
+ "maxResults": { "kind": "parameter", "displayName": "Max Results",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Max number of results to
return for the given operation (if supported by the Athena API endpoint). If
not set, will use the Athena [...]
+ "nextToken": { "kind": "parameter", "displayName": "Next Token", "group":
"producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Pagination token to use
in the case where the response from the previous request was truncated." },
+ "operation": { "kind": "parameter", "displayName": "Operation", "group":
"producer", "label": "producer", "required": false, "type": "object",
"javaType": "org.apache.camel.component.aws2.athena.Athena2Operations", "enum":
[ "getQueryExecution", "getQueryResults", "listQueryExecutions",
"startQueryExecution" ], "deprecated": false, "secret": false, "defaultValue":
"startQueryExecution", "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration", "configuratio
[...]
+ "outputLocation": { "kind": "parameter", "displayName": "Output Location",
"group": "producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "The location in Amazon
S3 where query results are stored, such as s3:\/\/path\/to\/query\/bucket\/.
Ensure this value ends w [...]
+ "outputType": { "kind": "parameter", "displayName": "Output Type",
"group": "producer", "label": "producer", "required": false, "type": "object",
"javaType": "org.apache.camel.component.aws2.athena.Athena2OutputType", "enum":
[ "StreamList", "SelectList", "S3Pointer" ], "deprecated": false, "secret":
false, "defaultValue": "StreamList", "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "How query [...]
"proxyHost": { "kind": "parameter", "displayName": "Proxy Host", "group":
"producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "To define a proxy host
when instantiating the Athena client." },
"proxyPort": { "kind": "parameter", "displayName": "Proxy Port", "group":
"producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "To define a proxy port
when instantiating the Athena client." },
"proxyProtocol": { "kind": "parameter", "displayName": "Proxy Protocol",
"group": "producer", "label": "", "required": false, "type": "object",
"javaType": "software.amazon.awssdk.core.Protocol", "enum": [ "HTTP", "HTTPS"
], "deprecated": false, "secret": false, "defaultValue": "HTTPS",
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "To define a proxy
protocol when instantiating the Athena cli [...]
- "queryExecutionId": { "kind": "parameter", "displayName": "Query Execution
Id", "group": "producer", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "The unique ID
identifying the query execution." },
- "queryString": { "kind": "parameter", "displayName": "Query String",
"group": "producer", "label": "", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "The SQL query to run.
Except for simple queries, prefer setting this as the body of the Exchange or
as a header using Athena2Constants.QUE [...]
+ "queryExecutionId": { "kind": "parameter", "displayName": "Query Execution
Id", "group": "producer", "label": "producer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "The unique ID
identifying the query execution." },
+ "queryString": { "kind": "parameter", "displayName": "Query String",
"group": "producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "The SQL query to run.
Except for simple queries, prefer setting this as the body of the Exchange or
as a header using Athena2Const [...]
"region": { "kind": "parameter", "displayName": "Region", "group":
"producer", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "The region in which
Athena client needs to work. When using this parameter, the configuration will
expect the lowercase name of the region (for examp [...]
- "resetWaitTimeoutOnRetry": { "kind": "parameter", "displayName": "Reset
Wait Timeout On Retry", "group": "producer", "label": "", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": "true", "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Reset the waitTimeout
countdown in the event of a query retry. If set to true, potential max ti [...]
- "retry": { "kind": "parameter", "displayName": "Retry", "group":
"producer", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "enum": [ "never", "always", "retryable", "exhausted",
"generic" ], "deprecated": false, "secret": false, "defaultValue": "never",
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Optional comma separated
list of error types to retry the [...]
+ "resetWaitTimeoutOnRetry": { "kind": "parameter", "displayName": "Reset
Wait Timeout On Retry", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret":
false, "defaultValue": "true", "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Reset the waitTimeout
countdown in the event of a query retry. If set to true, potentia [...]
+ "retry": { "kind": "parameter", "displayName": "Retry", "group":
"producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "enum": [ "never", "always", "retryable",
"exhausted", "generic" ], "deprecated": false, "secret": false, "defaultValue":
"never", "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Optional comma separated
list of error types to re [...]
"secretKey": { "kind": "parameter", "displayName": "Secret Key", "group":
"producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": true,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Amazon AWS Secret Key."
},
- "waitTimeout": { "kind": "parameter", "displayName": "Wait Timeout",
"group": "producer", "label": "", "required": false, "type": "integer",
"javaType": "long", "deprecated": false, "secret": false, "defaultValue": "0",
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Optional max wait time
in millis to wait for a successful query completion. See the section 'Waiting
for Query Completion and Re [...]
- "workGroup": { "kind": "parameter", "displayName": "Work Group", "group":
"producer", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "The workgroup to use for
running the query." },
+ "waitTimeout": { "kind": "parameter", "displayName": "Wait Timeout",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "long", "deprecated": false, "secret": false, "defaultValue": "0",
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "Optional max wait time
in millis to wait for a successful query completion. See the section 'Waiting
for Query Completio [...]
+ "workGroup": { "kind": "parameter", "displayName": "Work Group", "group":
"producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "The workgroup to use for
running the query." },
"basicPropertyBinding": { "kind": "parameter", "displayName": "Basic
Property Binding", "group": "advanced", "label": "advanced", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": false, "description": "Whether the endpoint should use basic
property binding (Camel 2.x) or the newer property binding with additional
capabilities" },
"clientRequestToken": { "kind": "parameter", "displayName": "Client
Request Token", "group": "advanced", "label": "advanced", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws2.athena.Athena2Configuration",
"configurationField": "configuration", "description": "A unique string to
ensure issues queries are idempotent. It is unlikely you will need to set
this." },
"synchronous": { "kind": "parameter", "displayName": "Synchronous",
"group": "advanced", "label": "advanced", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "secret": false, "defaultValue":
"false", "description": "Sets whether synchronous processing should be strictly
used, or Camel is allowed to use asynchronous processing (if supported)." }
diff --git
a/components/camel-aws2-athena/src/main/java/org/apache/camel/component/aws2/athena/Athena2Configuration.java
b/components/camel-aws2-athena/src/main/java/org/apache/camel/component/aws2/athena/Athena2Configuration.java
index e0c2eb0..c18b62e 100644
---
a/components/camel-aws2-athena/src/main/java/org/apache/camel/component/aws2/athena/Athena2Configuration.java
+++
b/components/camel-aws2-athena/src/main/java/org/apache/camel/component/aws2/athena/Athena2Configuration.java
@@ -29,67 +29,82 @@ import
software.amazon.awssdk.services.athena.paginators.GetQueryResultsIterable
@UriParams
public class Athena2Configuration implements Cloneable {
- @UriPath(description = "Logical name")
+ @UriPath(label = "producer",
+ description = "Logical name")
@Metadata(required = true)
private String label;
- // common
- @UriParam(defaultValue = "startQueryExecution",
+ @UriParam(label = "producer",
+ defaultValue = "startQueryExecution",
description = "The Athena API function to call.")
private Athena2Operations operation =
Athena2Operations.startQueryExecution;
- @UriParam(description = "The Athena database to use.")
+ @UriParam(label = "producer",
+ description = "The Athena database to use.")
private String database;
- @UriParam(description = "The unique ID identifying the query execution.")
+ @UriParam(label = "producer",
+ description = "The unique ID identifying the query execution.")
private String queryExecutionId;
- @UriParam(description = "The workgroup to use for running the query.")
+ @UriParam(label = "producer",
+ description = "The workgroup to use for running the query.")
private String workGroup;
- @UriParam(description = "Pagination token to use in the case where the
response from the previous request was truncated.")
+ @UriParam(label = "producer",
+ description = "Pagination token to use in the case where the response
from the previous request was truncated.")
private String nextToken;
- @UriParam(description = "Max number of results to return for the given
operation (if supported by the Athena API endpoint). If not set, will use the
Athena API default for the given operation.")
+ @UriParam(label = "producer",
+ description = "Max number of results to return for the given operation
(if supported by the Athena API endpoint). If not set, will use the Athena API
default for the given operation.")
private Integer maxResults;
- @UriParam(defaultValue = "false",
+ @UriParam(label = "producer",
+ defaultValue = "false",
description = "Include useful trace information at the beginning of
queries as an SQL comment (prefixed with \"--\").")
private boolean includeTrace;
- @UriParam(description = "The location in Amazon S3 where query results are
stored, such as s3://path/to/query/bucket/. Ensure this value ends with a
forward slash ('/').")
+ @UriParam(label = "producer",
+ description = "The location in Amazon S3 where query results are
stored, such as s3://path/to/query/bucket/. Ensure this value ends with a
forward slash ('/').")
private String outputLocation;
- @UriParam(defaultValue = "StreamList",
+ @UriParam(label = "producer",
+ defaultValue = "StreamList",
description = "How query results should be returned. One of "
+ "StreamList (default - return a GetQueryResultsIterable that can
page through all results), "
+ "SelectList (returns at most 1,000 rows at a time, plus a
NextToken value as a header than can be used for manual pagination of results),
"
+ "S3Pointer (return an S3 path pointing to the results).")
private Athena2OutputType outputType = Athena2OutputType.StreamList;
- // startQueryExecution
@UriParam(label = "advanced",
description = "A unique string to ensure issues queries are
idempotent. It is unlikely you will need to set this.")
private String clientRequestToken;
- @UriParam(description =
- "The SQL query to run. Except for simple queries, prefer setting this
as the {@code body} of the "
+ @UriParam(label = "producer",
+ description = "The SQL query to run. Except for simple queries,
prefer setting this as the {@code body} of the "
+ "Exchange or as a header using Athena2Constants.QUERY_STRING to
avoid having to deal with URL encoding issues.")
private String queryString;
- @UriParam(description = "The encryption type to use when storing query
results in S3. One of SSE_S3, SSE_KMS, or CSE_KMS.")
+ @UriParam(label = "producer",
+ description = "The encryption type to use when storing query results
in S3. One of SSE_S3, SSE_KMS, or CSE_KMS.")
private EncryptionOption encryptionOption;
- @UriParam(description = "For SSE-KMS and CSE-KMS, this is the KMS key ARN
or ID.")
+ @UriParam(label = "producer",
+ description = "For SSE-KMS and CSE-KMS, this is the KMS key ARN or
ID.")
private String kmsKey;
- @UriParam(defaultValue = "0",
+ @UriParam(label = "producer",
+ defaultValue = "0",
description = "Optional max wait time in millis to wait for a
successful query completion. "
+ "See the section 'Waiting for Query Completion and Retrying
Failed Queries' to learn more.")
private long waitTimeout;
- @UriParam(defaultValue = "1000",
+ @UriParam(label = "producer",
+ defaultValue = "1000",
description = "Milliseconds before the first poll for query execution
status. "
+ "See the section 'Waiting for Query Completion and Retrying
Failed Queries' to learn more.")
private long initialDelay = 1_000;
- @UriParam(defaultValue = "2000",
+ @UriParam(label = "producer",
+ defaultValue = "2000",
description = "Milliseconds before the next poll for query execution
status. "
+ "See the section 'Waiting for Query Completion and Retrying
Failed Queries' to learn more.")
private long delay = 2_000;
- @UriParam(defaultValue = "1",
+ @UriParam(label = "producer",
+ defaultValue = "1",
description = "Maximum number of times to attempt a query. Set to 1
to disable retries. "
+ "See the section 'Waiting for Query Completion and Retrying
Failed Queries' to learn more.")
private int maxAttempts = 1;
- @UriParam(defaultValue = "never",
+ @UriParam(label = "producer",
+ defaultValue = "never",
description = "Optional comma separated list of error types to retry
the query for. Use "
+ "'retryable' to retry all retryable failure conditions (e.g.
generic errors and resources exhausted), "
+ "'generic' to retry 'GENERIC_INTERNAL_ERROR' failures, "
@@ -99,7 +114,8 @@ public class Athena2Configuration implements Cloneable {
+ "See the section 'Waiting for Query Completion and Retrying
Failed Queries' to learn more.",
enums = "never,always,retryable,exhausted,generic")
private String retry;
- @UriParam(defaultValue = "true",
+ @UriParam(label = "producer",
+ defaultValue = "true",
description = "Reset the waitTimeout countdown in the event of a query
retry. "
+ "If set to true, potential max time spent waiting for queries is
equal to waitTimeout x maxAttempts. "
+ "See the section 'Waiting for Query Completion and Retrying
Failed Queries' to learn more.")
