From eb9a77e2213f419af3a1979eb36f31b4835fd654 Mon Sep 17 00:00:00 2001 From: lvca Date: Sat, 13 Dec 2014 20:20:43 +0100 Subject: [PATCH] Fixed issue #32 --- .../orient/etl/transformer/OFlowTransformer.java | 2 +- .../orient/etl/transformer/OVertexTransformer.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/orientechnologies/orient/etl/transformer/OFlowTransformer.java b/src/main/java/com/orientechnologies/orient/etl/transformer/OFlowTransformer.java index 242526bcc90..2e95a20121c 100644 --- a/src/main/java/com/orientechnologies/orient/etl/transformer/OFlowTransformer.java +++ b/src/main/java/com/orientechnologies/orient/etl/transformer/OFlowTransformer.java @@ -42,7 +42,7 @@ public void configure(OETLProcessor iProcessor, final ODocument iConfiguration, operation = iConfiguration.field("operation"); if (operation == null) throw new OConfigurationException("Flow transformer has not mandatory 'operation' field"); - if (!operation.equalsIgnoreCase("halt") && !operation.equalsIgnoreCase("halt")) + if (!operation.equalsIgnoreCase("halt") && !operation.equalsIgnoreCase("skip")) throw new OConfigurationException("Flow transformer has invalid 'operation' field='" + operation + "', while supported are: 'skip' and 'halt'"); } diff --git a/src/main/java/com/orientechnologies/orient/etl/transformer/OVertexTransformer.java b/src/main/java/com/orientechnologies/orient/etl/transformer/OVertexTransformer.java index 13a257857e2..998d76efcc6 100644 --- a/src/main/java/com/orientechnologies/orient/etl/transformer/OVertexTransformer.java +++ b/src/main/java/com/orientechnologies/orient/etl/transformer/OVertexTransformer.java @@ -73,7 +73,7 @@ public Object executeTransform(final Object input) { if (v == null) return null; - if (vertexClass != null) + if (vertexClass != null && !vertexClass.equals(v.getRecord().getClassName())) v.setProperty("@class", vertexClass); return v; }