This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git
The following commit(s) were added to refs/heads/main by this push: new b2c23b8515e Regen b2c23b8515e is described below commit b2c23b8515e1e9ff6f9528c3620ae3a8479009c4 Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Sun Dec 10 18:51:43 2023 +0100 Regen --- .../camel/springboot/catalog/dataformats/parquetAvro.json | 3 ++- .../src/main/docs/parquet-avro.json | 7 +++++++ .../avro/springboot/ParquetAvroDataFormatConfiguration.java | 13 +++++++++++++ 3 files changed, 22 insertions(+), 1 deletion(-) diff --git a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/dataformats/parquetAvro.json b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/dataformats/parquetAvro.json index b5a6c6026af..dd5ef33fef0 100644 --- a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/dataformats/parquetAvro.json +++ b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/dataformats/parquetAvro.json @@ -18,6 +18,7 @@ "properties": { "id": { "index": 0, "kind": "attribute", "displayName": "Id", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "The id of this node" }, "compressionCodecName": { "index": 1, "kind": "attribute", "displayName": "Compression Codec Name", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "GZIP", "description": "Compression codec to use when marshalling." }, - "unmarshalType": { "index": 2, "kind": "attribute", "displayName": "Unmarshal Type", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Class to use when (un)marshalling. If omitted, parquet files are converted into Avro's GenericRecords for unmarshalling and input objects are assumed as GenericRecords for marshalling." } + "unmarshalType": { "index": 2, "kind": "attribute", "displayName": "Unmarshal Type", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Class to use when (un)marshalling. If omitted, parquet files are converted into Avro's GenericRecords for unmarshalling and input objects are assumed as GenericRecords for marshalling." }, + "lazyLoad": { "index": 3, "kind": "attribute", "displayName": "Lazy Load", "required": false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Whether the unmarshalling should produce an iterator of records or read all the records at once." } } } diff --git a/components-starter/camel-parquet-avro-starter/src/main/docs/parquet-avro.json b/components-starter/camel-parquet-avro-starter/src/main/docs/parquet-avro.json index 4c907e3eab8..3e185ea11cc 100644 --- a/components-starter/camel-parquet-avro-starter/src/main/docs/parquet-avro.json +++ b/components-starter/camel-parquet-avro-starter/src/main/docs/parquet-avro.json @@ -31,6 +31,13 @@ "description": "Whether to enable auto configuration of the parquetAvro data format. This is enabled by default.", "sourceType": "org.apache.camel.dataformat.parquet.avro.springboot.ParquetAvroDataFormatConfiguration" }, + { + "name": "camel.dataformat.parquet-avro.lazy-load", + "type": "java.lang.Boolean", + "description": "Whether the unmarshalling should produce an iterator of records or read all the records at once.", + "sourceType": "org.apache.camel.dataformat.parquet.avro.springboot.ParquetAvroDataFormatConfiguration", + "defaultValue": false + }, { "name": "camel.dataformat.parquet-avro.unmarshal-type", "type": "java.lang.String", diff --git a/components-starter/camel-parquet-avro-starter/src/main/java/org/apache/camel/dataformat/parquet/avro/springboot/ParquetAvroDataFormatConfiguration.java b/components-starter/camel-parquet-avro-starter/src/main/java/org/apache/camel/dataformat/parquet/avro/springboot/ParquetAvroDataFormatConfiguration.java index 5310a80ac59..933e70c21d9 100644 --- a/components-starter/camel-parquet-avro-starter/src/main/java/org/apache/camel/dataformat/parquet/avro/springboot/ParquetAvroDataFormatConfiguration.java +++ b/components-starter/camel-parquet-avro-starter/src/main/java/org/apache/camel/dataformat/parquet/avro/springboot/ParquetAvroDataFormatConfiguration.java @@ -44,6 +44,11 @@ public class ParquetAvroDataFormatConfiguration * are assumed as GenericRecords for marshalling. */ private String unmarshalType; + /** + * Whether the unmarshalling should produce an iterator of records or read + * all the records at once. + */ + private Boolean lazyLoad = false; public String getCompressionCodecName() { return compressionCodecName; @@ -60,4 +65,12 @@ public class ParquetAvroDataFormatConfiguration public void setUnmarshalType(String unmarshalType) { this.unmarshalType = unmarshalType; } + + public Boolean getLazyLoad() { + return lazyLoad; + } + + public void setLazyLoad(Boolean lazyLoad) { + this.lazyLoad = lazyLoad; + } } \ No newline at end of file