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 <[email protected]>
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
