You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@unomi.apache.org by am...@apache.org on 2017/07/26 07:51:54 UTC
incubator-unomi git commit: UNOMI-101 : Allow partial mapping
Repository: incubator-unomi
Updated Branches:
refs/heads/master 4e49d5c4f -> 44b3e4a46
UNOMI-101 : Allow partial mapping
Project: http://git-wip-us.apache.org/repos/asf/incubator-unomi/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-unomi/commit/44b3e4a4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-unomi/tree/44b3e4a4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-unomi/diff/44b3e4a4
Branch: refs/heads/master
Commit: 44b3e4a46f05118f0bfb05561f81ba7ed102b8ae
Parents: 4e49d5c
Author: Abdelkader Midani <am...@apache.org>
Authored: Wed Jul 26 09:51:51 2017 +0200
Committer: Abdelkader Midani <am...@apache.org>
Committed: Wed Jul 26 09:51:51 2017 +0200
----------------------------------------------------------------------
.../org/apache/unomi/router/core/processor/LineSplitProcessor.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-unomi/blob/44b3e4a4/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/processor/LineSplitProcessor.java
----------------------------------------------------------------------
diff --git a/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/processor/LineSplitProcessor.java b/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/processor/LineSplitProcessor.java
index 3dbbf13..9e0fb66 100644
--- a/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/processor/LineSplitProcessor.java
+++ b/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/processor/LineSplitProcessor.java
@@ -86,7 +86,7 @@ public class LineSplitProcessor implements Processor {
profileToImport.setScope(RouterConstants.SYSTEM_SCOPE);
if (profileData.length > 0 && StringUtils.isNotBlank(profileData[0])) {
- if (hasDeleteColumn && (fieldsMapping.size() != (profileData.length - 1))) {
+ if (hasDeleteColumn && (fieldsMapping.size() > (profileData.length - 1))) {
throw new BadProfileDataFormatException("The mapping does not match the number of column : line [" + ((Integer) exchange.getProperty("CamelSplitIndex") + 1) + "]", new Throwable("MAPPING_COLUMN_MATCH"));
}
Map<String, Object> properties = new HashMap<>();