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);