You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hop.apache.org by ha...@apache.org on 2022/06/03 06:12:19 UTC
[hop] branch master updated: HOP-3972 added import support for KettleKafkaConsumerInput, added variablemapper import for TransformationExecutor
This is an automated email from the ASF dual-hosted git repository.
hansva pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hop.git
The following commit(s) were added to refs/heads/master by this push:
new 2aa5b4bf16 HOP-3972 added import support for KettleKafkaConsumerInput, added variablemapper import for TransformationExecutor
new 0b20b0d729 Merge pull request #1519 from bamaer/HOP-3972
2aa5b4bf16 is described below
commit 2aa5b4bf1617e30c8119b8838a83cc2bde220232
Author: Bart Maertens <ba...@know.bi>
AuthorDate: Thu Jun 2 16:53:26 2022 +0200
HOP-3972 added import support for KettleKafkaConsumerInput, added variablemapper import for TransformationExecutor
---
.../src/main/java/org/apache/hop/imports/kettle/KettleConst.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/plugins/misc/import/src/main/java/org/apache/hop/imports/kettle/KettleConst.java b/plugins/misc/import/src/main/java/org/apache/hop/imports/kettle/KettleConst.java
index 2048de8b90..2591eae639 100644
--- a/plugins/misc/import/src/main/java/org/apache/hop/imports/kettle/KettleConst.java
+++ b/plugins/misc/import/src/main/java/org/apache/hop/imports/kettle/KettleConst.java
@@ -43,6 +43,9 @@ public class KettleConst {
},
{"target_step_name", "target_transform_name"},
{"step_performance_capturing_delay", "transform_performance_capturing_delay"},
+ {"transformationPath", "pipelinePath"},
+ {"SUB_STEP", "subTransform"},
+ {"variablemapping", "variable_mapping"},
// jobs
{"job", "workflow"},
{"job_version", "workflow_version"},
@@ -145,6 +148,7 @@ public class KettleConst {
{"Mapping", "SimpleMapping"},
// Text File Input deprecated
{"TextFileInput", "TextFileInput2"},
+ {"KettleKafkaConsumerInput", "KafkaConsumer"}
})
.collect(Collectors.toMap(data -> (String) data[0], data -> (String) data[1]));