You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2023/01/12 15:09:08 UTC
[camel] branch main updated: Fix camel-hdfs in endpointdsl
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.git
The following commit(s) were added to refs/heads/main by this push:
new c061ff8d16b Fix camel-hdfs in endpointdsl
c061ff8d16b is described below
commit c061ff8d16b7c9c6a41d2aa8c62878d0dce2e352
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Thu Jan 12 16:08:45 2023 +0100
Fix camel-hdfs in endpointdsl
---
.../org/apache/camel/catalog/components/hdfs.json | 2 +-
.../component/hdfs/HdfsEndpointConfigurer.java | 4 +--
.../org/apache/camel/component/hdfs/hdfs.json | 2 +-
.../component/hdfs/HdfsArrayFileTypeHandler.java | 4 ++-
.../component/hdfs/HdfsBloomMapFileHandler.java | 4 ++-
.../camel/component/hdfs/HdfsCompressionType.java | 24 ++++++++++++++++++
.../camel/component/hdfs/HdfsConfiguration.java | 13 +++++-----
.../apache/camel/component/hdfs/HdfsConstants.java | 3 +--
.../apache/camel/component/hdfs/HdfsHelper.java | 29 ++++++++++++++++++++++
.../camel/component/hdfs/HdfsMapFileHandler.java | 4 ++-
.../component/hdfs/HdfsSequenceFileHandler.java | 4 ++-
.../endpoint/dsl/HdfsEndpointBuilderFactory.java | 18 +++++++-------
12 files changed, 85 insertions(+), 26 deletions(-)
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/hdfs.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/hdfs.json
index 3adb77edeb0..32fee66a91f 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/hdfs.json
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/hdfs.json
@@ -62,7 +62,7 @@
"checkIdleInterval": { "kind": "parameter", "displayName": "Check Idle Interval", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 500, "configurationClass": "org.apache.camel.component.hdfs.HdfsConfiguration", "configurationField": "config", "description": "How often (time in millis) in to run the idle checker background task. This option is only in use if the [...]
"chunkSize": { "kind": "parameter", "displayName": "Chunk Size", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 4096, "configurationClass": "org.apache.camel.component.hdfs.HdfsConfiguration", "configurationField": "config", "description": "When reading a normal file, this is split into chunks producing a message per chunk." },
"compressionCodec": { "kind": "parameter", "displayName": "Compression Codec", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "org.apache.camel.component.hdfs.HdfsCompressionCodec", "enum": [ "DEFAULT", "GZIP", "BZIP2", "SNAPPY", "LZ4", "ZSTANDARD" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "DEFAULT", "configurationClass": "org.apache.camel.component.hdfs.HdfsConfiguration", "configurationField": "config", [...]
- "compressionType": { "kind": "parameter", "displayName": "Compression Type", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "org.apache.hadoop.io.SequenceFile.CompressionType", "enum": [ "NONE", "RECORD", "BLOCK" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "NONE", "configurationClass": "org.apache.camel.component.hdfs.HdfsConfiguration", "configurationField": "config", "description": "The compression type to [...]
+ "compressionType": { "kind": "parameter", "displayName": "Compression Type", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "org.apache.camel.component.hdfs.HdfsCompressionType", "enum": [ "NONE", "RECORD", "BLOCK" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "NONE", "configurationClass": "org.apache.camel.component.hdfs.HdfsConfiguration", "configurationField": "config", "description": "The compression type [...]
"openedSuffix": { "kind": "parameter", "displayName": "Opened Suffix", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "opened", "configurationClass": "org.apache.camel.component.hdfs.HdfsConfiguration", "configurationField": "config", "description": "When a file is opened for reading\/writing the file is renamed with this suffix to avoid to read it [...]
"readSuffix": { "kind": "parameter", "displayName": "Read Suffix", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "read", "configurationClass": "org.apache.camel.component.hdfs.HdfsConfiguration", "configurationField": "config", "description": "Once the file has been read is renamed with this suffix to avoid to read it again." },
"replication": { "kind": "parameter", "displayName": "Replication", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "short", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "3", "configurationClass": "org.apache.camel.component.hdfs.HdfsConfiguration", "configurationField": "config", "description": "The HDFS replication factor" },
diff --git a/components/camel-hdfs/src/generated/java/org/apache/camel/component/hdfs/HdfsEndpointConfigurer.java b/components/camel-hdfs/src/generated/java/org/apache/camel/component/hdfs/HdfsEndpointConfigurer.java
index a3277930bf5..1a22df10193 100644
--- a/components/camel-hdfs/src/generated/java/org/apache/camel/component/hdfs/HdfsEndpointConfigurer.java
+++ b/components/camel-hdfs/src/generated/java/org/apache/camel/component/hdfs/HdfsEndpointConfigurer.java
@@ -41,7 +41,7 @@ public class HdfsEndpointConfigurer extends PropertyConfigurerSupport implements
case "compressioncodec":
case "compressionCodec": target.getConfig().setCompressionCodec(property(camelContext, org.apache.camel.component.hdfs.HdfsCompressionCodec.class, value)); return true;
case "compressiontype":
- case "compressionType": target.getConfig().setCompressionType(property(camelContext, org.apache.hadoop.io.SequenceFile.CompressionType.class, value)); return true;
+ case "compressionType": target.getConfig().setCompressionType(property(camelContext, org.apache.camel.component.hdfs.HdfsCompressionType.class, value)); return true;
case "connectonstartup":
case "connectOnStartup": target.getConfig().setConnectOnStartup(property(camelContext, boolean.class, value)); return true;
case "delay": target.setDelay(property(camelContext, long.class, value)); return true;
@@ -130,7 +130,7 @@ public class HdfsEndpointConfigurer extends PropertyConfigurerSupport implements
case "compressioncodec":
case "compressionCodec": return org.apache.camel.component.hdfs.HdfsCompressionCodec.class;
case "compressiontype":
- case "compressionType": return org.apache.hadoop.io.SequenceFile.CompressionType.class;
+ case "compressionType": return org.apache.camel.component.hdfs.HdfsCompressionType.class;
case "connectonstartup":
case "connectOnStartup": return boolean.class;
case "delay": return long.class;
diff --git a/components/camel-hdfs/src/generated/resources/org/apache/camel/component/hdfs/hdfs.json b/components/camel-hdfs/src/generated/resources/org/apache/camel/component/hdfs/hdfs.json
index 3adb77edeb0..32fee66a91f 100644
--- a/components/camel-hdfs/src/generated/resources/org/apache/camel/component/hdfs/hdfs.json
+++ b/components/camel-hdfs/src/generated/resources/org/apache/camel/component/hdfs/hdfs.json
@@ -62,7 +62,7 @@
"checkIdleInterval": { "kind": "parameter", "displayName": "Check Idle Interval", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 500, "configurationClass": "org.apache.camel.component.hdfs.HdfsConfiguration", "configurationField": "config", "description": "How often (time in millis) in to run the idle checker background task. This option is only in use if the [...]
"chunkSize": { "kind": "parameter", "displayName": "Chunk Size", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 4096, "configurationClass": "org.apache.camel.component.hdfs.HdfsConfiguration", "configurationField": "config", "description": "When reading a normal file, this is split into chunks producing a message per chunk." },
"compressionCodec": { "kind": "parameter", "displayName": "Compression Codec", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "org.apache.camel.component.hdfs.HdfsCompressionCodec", "enum": [ "DEFAULT", "GZIP", "BZIP2", "SNAPPY", "LZ4", "ZSTANDARD" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "DEFAULT", "configurationClass": "org.apache.camel.component.hdfs.HdfsConfiguration", "configurationField": "config", [...]
- "compressionType": { "kind": "parameter", "displayName": "Compression Type", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "org.apache.hadoop.io.SequenceFile.CompressionType", "enum": [ "NONE", "RECORD", "BLOCK" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "NONE", "configurationClass": "org.apache.camel.component.hdfs.HdfsConfiguration", "configurationField": "config", "description": "The compression type to [...]
+ "compressionType": { "kind": "parameter", "displayName": "Compression Type", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "org.apache.camel.component.hdfs.HdfsCompressionType", "enum": [ "NONE", "RECORD", "BLOCK" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "NONE", "configurationClass": "org.apache.camel.component.hdfs.HdfsConfiguration", "configurationField": "config", "description": "The compression type [...]
"openedSuffix": { "kind": "parameter", "displayName": "Opened Suffix", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "opened", "configurationClass": "org.apache.camel.component.hdfs.HdfsConfiguration", "configurationField": "config", "description": "When a file is opened for reading\/writing the file is renamed with this suffix to avoid to read it [...]
"readSuffix": { "kind": "parameter", "displayName": "Read Suffix", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "read", "configurationClass": "org.apache.camel.component.hdfs.HdfsConfiguration", "configurationField": "config", "description": "Once the file has been read is renamed with this suffix to avoid to read it again." },
"replication": { "kind": "parameter", "displayName": "Replication", "group": "advanced", "label": "advanced", "required": false, "type": "integer", "javaType": "short", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "3", "configurationClass": "org.apache.camel.component.hdfs.HdfsConfiguration", "configurationField": "config", "description": "The HDFS replication factor" },
diff --git a/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsArrayFileTypeHandler.java b/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsArrayFileTypeHandler.java
index 3d465125bf9..3d5702a619c 100644
--- a/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsArrayFileTypeHandler.java
+++ b/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsArrayFileTypeHandler.java
@@ -26,6 +26,8 @@ import org.apache.hadoop.io.Writable;
import org.apache.hadoop.io.WritableComparable;
import org.apache.hadoop.util.ReflectionUtils;
+import static org.apache.camel.component.hdfs.HdfsHelper.asCompressionType;
+
class HdfsArrayFileTypeHandler extends DefaultHdfsFile<ArrayFile.Writer, ArrayFile.Reader> {
@SuppressWarnings("rawtypes")
@@ -41,7 +43,7 @@ class HdfsArrayFileTypeHandler extends DefaultHdfsFile<ArrayFile.Writer, ArrayFi
hdfsInfo.getFileSystem(),
hdfsPath,
valueWritableClass,
- endpointConfig.getCompressionType(),
+ asCompressionType(endpointConfig.getCompressionType()),
() -> {
});
return rout;
diff --git a/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsBloomMapFileHandler.java b/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsBloomMapFileHandler.java
index 7139e38bd7a..d553d01da50 100644
--- a/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsBloomMapFileHandler.java
+++ b/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsBloomMapFileHandler.java
@@ -28,6 +28,8 @@ import org.apache.hadoop.io.Writable;
import org.apache.hadoop.io.WritableComparable;
import org.apache.hadoop.util.ReflectionUtils;
+import static org.apache.camel.component.hdfs.HdfsHelper.asCompressionType;
+
class HdfsBloomMapFileHandler extends DefaultHdfsFile<BloomMapFile.Writer, BloomMapFile.Reader> {
@SuppressWarnings("rawtypes")
@@ -44,7 +46,7 @@ class HdfsBloomMapFileHandler extends DefaultHdfsFile<BloomMapFile.Writer, Bloom
new Path(hdfsPath),
MapFile.Writer.keyClass(keyWritableClass),
MapFile.Writer.valueClass(valueWritableClass),
- MapFile.Writer.compression(endpointConfig.getCompressionType(),
+ MapFile.Writer.compression(asCompressionType(endpointConfig.getCompressionType()),
endpointConfig.getCompressionCodec().getCodec()),
MapFile.Writer.progressable(() -> {
}));
diff --git a/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsCompressionType.java b/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsCompressionType.java
new file mode 100644
index 00000000000..68991427c4d
--- /dev/null
+++ b/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsCompressionType.java
@@ -0,0 +1,24 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.hdfs;
+
+public enum HdfsCompressionType {
+
+ NONE,
+ RECORD,
+ BLOCK;
+}
diff --git a/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsConfiguration.java b/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsConfiguration.java
index 60d688fe2d3..2b4b004f305 100644
--- a/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsConfiguration.java
+++ b/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsConfiguration.java
@@ -30,7 +30,6 @@ import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriParams;
import org.apache.camel.spi.UriPath;
import org.apache.camel.util.URISupport;
-import org.apache.hadoop.io.SequenceFile;
import static org.apache.camel.util.ObjectHelper.isNotEmpty;
@@ -62,7 +61,7 @@ public class HdfsConfiguration {
@UriParam(label = "advanced", defaultValue = "" + HdfsConstants.DEFAULT_BLOCKSIZE)
private long blockSize = HdfsConstants.DEFAULT_BLOCKSIZE;
@UriParam(label = "advanced", defaultValue = "NONE")
- private SequenceFile.CompressionType compressionType = HdfsConstants.DEFAULT_COMPRESSIONTYPE;
+ private HdfsCompressionType compressionType = HdfsConstants.DEFAULT_COMPRESSIONTYPE;
@UriParam(label = "advanced", defaultValue = "DEFAULT")
private HdfsCompressionCodec compressionCodec = HdfsConstants.DEFAULT_CODEC;
@UriParam(defaultValue = "NORMAL_FILE")
@@ -167,11 +166,11 @@ public class HdfsConfiguration {
}
}
- private SequenceFile.CompressionType getCompressionType(
- Map<String, Object> hdfsSettings, String param, SequenceFile.CompressionType ct) {
+ private HdfsCompressionType getCompressionType(
+ Map<String, Object> hdfsSettings, String param, HdfsCompressionType ct) {
String eit = (String) hdfsSettings.get(param);
if (eit != null) {
- return SequenceFile.CompressionType.valueOf(eit);
+ return HdfsCompressionType.valueOf(eit);
} else {
return ct;
}
@@ -387,14 +386,14 @@ public class HdfsConfiguration {
this.fileType = fileType;
}
- public SequenceFile.CompressionType getCompressionType() {
+ public HdfsCompressionType getCompressionType() {
return compressionType;
}
/**
* The compression type to use (is default not in use)
*/
- public void setCompressionType(SequenceFile.CompressionType compressionType) {
+ public void setCompressionType(HdfsCompressionType compressionType) {
this.compressionType = compressionType;
}
diff --git a/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsConstants.java b/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsConstants.java
index a2a4e30edc6..c1c68d37060 100644
--- a/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsConstants.java
+++ b/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsConstants.java
@@ -18,7 +18,6 @@ package org.apache.camel.component.hdfs;
import org.apache.camel.Exchange;
import org.apache.camel.spi.Metadata;
-import org.apache.hadoop.io.SequenceFile;
public final class HdfsConstants {
@@ -30,7 +29,7 @@ public final class HdfsConstants {
public static final long DEFAULT_BLOCKSIZE = 64 * 1024 * 1024L;
- public static final SequenceFile.CompressionType DEFAULT_COMPRESSIONTYPE = SequenceFile.CompressionType.NONE;
+ public static final HdfsCompressionType DEFAULT_COMPRESSIONTYPE = HdfsCompressionType.NONE;
public static final HdfsCompressionCodec DEFAULT_CODEC = HdfsCompressionCodec.DEFAULT;
diff --git a/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsHelper.java b/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsHelper.java
new file mode 100644
index 00000000000..f01c2bf511d
--- /dev/null
+++ b/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsHelper.java
@@ -0,0 +1,29 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.hdfs;
+
+import org.apache.hadoop.io.SequenceFile;
+
+public final class HdfsHelper {
+
+ private HdfsHelper() {
+ }
+
+ public static SequenceFile.CompressionType asCompressionType(HdfsCompressionType type) {
+ return SequenceFile.CompressionType.valueOf(type.name());
+ }
+}
diff --git a/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsMapFileHandler.java b/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsMapFileHandler.java
index 2425dd1baa4..0d0fcf820c0 100644
--- a/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsMapFileHandler.java
+++ b/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsMapFileHandler.java
@@ -27,6 +27,8 @@ import org.apache.hadoop.io.Writable;
import org.apache.hadoop.io.WritableComparable;
import org.apache.hadoop.util.ReflectionUtils;
+import static org.apache.camel.component.hdfs.HdfsHelper.asCompressionType;
+
class HdfsMapFileHandler extends DefaultHdfsFile<MapFile.Writer, MapFile.Reader> {
@Override
@@ -43,7 +45,7 @@ class HdfsMapFileHandler extends DefaultHdfsFile<MapFile.Writer, MapFile.Reader>
new Path(hdfsPath),
MapFile.Writer.keyClass(keyWritableClass),
MapFile.Writer.valueClass(valueWritableClass),
- MapFile.Writer.compression(endpointConfig.getCompressionType(),
+ MapFile.Writer.compression(asCompressionType(endpointConfig.getCompressionType()),
endpointConfig.getCompressionCodec().getCodec()),
MapFile.Writer.progressable(() -> {
}));
diff --git a/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsSequenceFileHandler.java b/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsSequenceFileHandler.java
index 59a58439e2a..efc14a882c2 100644
--- a/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsSequenceFileHandler.java
+++ b/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsSequenceFileHandler.java
@@ -25,6 +25,8 @@ import org.apache.hadoop.io.SequenceFile;
import org.apache.hadoop.io.Writable;
import org.apache.hadoop.util.ReflectionUtils;
+import static org.apache.camel.component.hdfs.HdfsHelper.asCompressionType;
+
class HdfsSequenceFileHandler extends DefaultHdfsFile<SequenceFile.Writer, SequenceFile.Reader> {
@Override
@@ -43,7 +45,7 @@ class HdfsSequenceFileHandler extends DefaultHdfsFile<SequenceFile.Writer, Seque
SequenceFile.Writer.bufferSize(endpointConfig.getBufferSize()),
SequenceFile.Writer.replication(endpointConfig.getReplication()),
SequenceFile.Writer.blockSize(endpointConfig.getBlockSize()),
- SequenceFile.Writer.compression(endpointConfig.getCompressionType(),
+ SequenceFile.Writer.compression(asCompressionType(endpointConfig.getCompressionType()),
endpointConfig.getCompressionCodec().getCodec()),
SequenceFile.Writer.progressable(() -> {
}),
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/HdfsEndpointBuilderFactory.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/HdfsEndpointBuilderFactory.java
index 1fb105c271f..65eb58a03e4 100644
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/HdfsEndpointBuilderFactory.java
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/HdfsEndpointBuilderFactory.java
@@ -1239,7 +1239,7 @@ public interface HdfsEndpointBuilderFactory {
* The compression type to use (is default not in use).
*
* The option is a:
- * <code>org.apache.hadoop.io.SequenceFile.CompressionType</code> type.
+ * <code>org.apache.camel.component.hdfs.HdfsCompressionType</code> type.
*
* Default: NONE
* Group: advanced
@@ -1248,7 +1248,7 @@ public interface HdfsEndpointBuilderFactory {
* @return the dsl builder
*/
default AdvancedHdfsEndpointConsumerBuilder compressionType(
- org.apache.hadoop.io.SequenceFile.CompressionType compressionType) {
+ org.apache.camel.component.hdfs.HdfsCompressionType compressionType) {
doSetProperty("compressionType", compressionType);
return this;
}
@@ -1256,7 +1256,7 @@ public interface HdfsEndpointBuilderFactory {
* The compression type to use (is default not in use).
*
* The option will be converted to a
- * <code>org.apache.hadoop.io.SequenceFile.CompressionType</code> type.
+ * <code>org.apache.camel.component.hdfs.HdfsCompressionType</code> type.
*
* Default: NONE
* Group: advanced
@@ -1923,7 +1923,7 @@ public interface HdfsEndpointBuilderFactory {
* The compression type to use (is default not in use).
*
* The option is a:
- * <code>org.apache.hadoop.io.SequenceFile.CompressionType</code> type.
+ * <code>org.apache.camel.component.hdfs.HdfsCompressionType</code> type.
*
* Default: NONE
* Group: advanced
@@ -1932,7 +1932,7 @@ public interface HdfsEndpointBuilderFactory {
* @return the dsl builder
*/
default AdvancedHdfsEndpointProducerBuilder compressionType(
- org.apache.hadoop.io.SequenceFile.CompressionType compressionType) {
+ org.apache.camel.component.hdfs.HdfsCompressionType compressionType) {
doSetProperty("compressionType", compressionType);
return this;
}
@@ -1940,7 +1940,7 @@ public interface HdfsEndpointBuilderFactory {
* The compression type to use (is default not in use).
*
* The option will be converted to a
- * <code>org.apache.hadoop.io.SequenceFile.CompressionType</code> type.
+ * <code>org.apache.camel.component.hdfs.HdfsCompressionType</code> type.
*
* Default: NONE
* Group: advanced
@@ -2493,7 +2493,7 @@ public interface HdfsEndpointBuilderFactory {
* The compression type to use (is default not in use).
*
* The option is a:
- * <code>org.apache.hadoop.io.SequenceFile.CompressionType</code> type.
+ * <code>org.apache.camel.component.hdfs.HdfsCompressionType</code> type.
*
* Default: NONE
* Group: advanced
@@ -2502,7 +2502,7 @@ public interface HdfsEndpointBuilderFactory {
* @return the dsl builder
*/
default AdvancedHdfsEndpointBuilder compressionType(
- org.apache.hadoop.io.SequenceFile.CompressionType compressionType) {
+ org.apache.camel.component.hdfs.HdfsCompressionType compressionType) {
doSetProperty("compressionType", compressionType);
return this;
}
@@ -2510,7 +2510,7 @@ public interface HdfsEndpointBuilderFactory {
* The compression type to use (is default not in use).
*
* The option will be converted to a
- * <code>org.apache.hadoop.io.SequenceFile.CompressionType</code> type.
+ * <code>org.apache.camel.component.hdfs.HdfsCompressionType</code> type.
*
* Default: NONE
* Group: advanced