This is an automated email from the ASF dual-hosted git repository.

dlych pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/asterixdb-bad.git


The following commit(s) were added to refs/heads/master by this push:
     new 802964b  Coordinated change for non-deterministic udf support
802964b is described below

commit 802964b15cc9e70d6bd50e7613c40b096e5fa19e
Author: Dmitry Lychagin <[email protected]>
AuthorDate: Mon Mar 2 21:39:40 2020 -0800

    Coordinated change for non-deterministic udf support
    
    Change-Id: If67c9303aa67a5b20f6609df97dc797cc7ad38a5
---
 .../org/apache/asterix/bad/metadata/ProcedureTupleTranslator.java | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git 
a/asterix-bad/src/main/java/org/apache/asterix/bad/metadata/ProcedureTupleTranslator.java
 
b/asterix-bad/src/main/java/org/apache/asterix/bad/metadata/ProcedureTupleTranslator.java
index dfcca97..ed42dd6 100644
--- 
a/asterix-bad/src/main/java/org/apache/asterix/bad/metadata/ProcedureTupleTranslator.java
+++ 
b/asterix-bad/src/main/java/org/apache/asterix/bad/metadata/ProcedureTupleTranslator.java
@@ -95,8 +95,10 @@ public class ProcedureTupleTranslator extends 
AbstractTupleTranslator<Procedure>
         String languageValue = ((AString) procedureRecord
                 
.getValueByPos(BADMetadataRecordTypes.PROCEDURE_ARECORD_PROCEDURE_LANGUAGE_FIELD_INDEX))
                         .getStringValue();
-        Function.FunctionLanguage language = 
Function.FunctionLanguage.findByName(languageValue);
-        if (language == null) {
+        Function.FunctionLanguage language;
+        try {
+            language = Function.FunctionLanguage.valueOf(languageValue);
+        } catch (IllegalArgumentException e) {
             throw new AsterixException(ErrorCode.METADATA_ERROR, 
languageValue);
         }
 
@@ -204,7 +206,7 @@ public class ProcedureTupleTranslator extends 
AbstractTupleTranslator<Procedure>
 
         // write field 6
         fieldValue.reset();
-        aString.setValue(procedure.getLanguage().getName());
+        aString.setValue(procedure.getLanguage().name());
         stringSerde.serialize(aString, fieldValue.getDataOutput());
         
recordBuilder.addField(BADMetadataRecordTypes.PROCEDURE_ARECORD_PROCEDURE_LANGUAGE_FIELD_INDEX,
 fieldValue);
 

Reply via email to