[asterixdb] branch master updated: [NO ISSUE] Error codes + NCService getter + Record metadata getter

[htowaileb]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 65e1f5b  [NO ISSUE] Error codes + NCService getter + Record metadata 
getter
65e1f5b is described below

commit 65e1f5bae944c6bbbbaf984c58e12e509314344e
Author: Hussain Towaileb <hussain.towai...@couchbase.com>
AuthorDate: Mon Jul 15 01:51:48 2019 +0300

    [NO ISSUE] Error codes + NCService getter + Record metadata getter
    
    - user model changes: no
    - storage format changes: no
    - interface changes: no
    
    Details:
    - Task, added getter for NodeControllerService.
    - RecordWithMetadataAndPK, added getter for metaTypes.
    - Added extra error codes.
    
    Change-Id: Ic3fcc6b771b4393542988cd0aa6fd992ccb81028
    Reviewed-on: https://asterix-gerrit.ics.uci.edu/3423
    Contrib: Jenkins <jenk...@fulliautomatix.ics.uci.edu>
    Tested-by: Jenkins <jenk...@fulliautomatix.ics.uci.edu>
    Integration-Tests: Jenkins <jenk...@fulliautomatix.ics.uci.edu>
    Reviewed-by: Hussain Towaileb <hussai...@gmail.com>
    Reviewed-by: Michael Blow <mb...@apache.org>
---
 .../main/java/org/apache/asterix/common/exceptions/ErrorCode.java    | 5 +++++
 .../asterix-common/src/main/resources/asx_errormsg/en.properties     | 5 +++++
 .../asterix/external/input/record/RecordWithMetadataAndPK.java       | 4 ++++
 .../src/main/java/org/apache/hyracks/control/nc/Task.java            | 4 ++++
 4 files changed, 18 insertions(+)

diff --git 
a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/exceptions/ErrorCode.java
 
b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/exceptions/ErrorCode.java
index 67f0170..e172b38 100644
--- 
a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/exceptions/ErrorCode.java
+++ 
b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/exceptions/ErrorCode.java
@@ -296,6 +296,11 @@ public class ErrorCode {
     public static final int FEED_FAILED_WHILE_GETTING_A_NEW_RECORD = 3110;
     public static final int FEED_START_FEED_WITHOUT_CONNECTION = 3111;
     public static final int PARSER_COLLECTION_ITEM_CANNOT_BE_NULL = 3112;
+    public static final int FAILED_TO_PARSE_RECORD = 3113;
+    public static final int FAILED_TO_PARSE_RECORD_CONTENT = 3114;
+    public static final int FAILED_TO_PARSE_METADATA = 3115;
+    public static final int INPUT_DECODE_FAILURE = 3116;
+    public static final int FAILED_TO_PARSE_MALFORMED_LOG_RECORD = 3117;
 
     // Lifecycle management errors
     public static final int DUPLICATE_PARTITION_ID = 4000;
diff --git 
a/asterixdb/asterix-common/src/main/resources/asx_errormsg/en.properties 
b/asterixdb/asterix-common/src/main/resources/asx_errormsg/en.properties
index 8bac58c..f8262d9 100644
--- a/asterixdb/asterix-common/src/main/resources/asx_errormsg/en.properties
+++ b/asterixdb/asterix-common/src/main/resources/asx_errormsg/en.properties
@@ -294,6 +294,11 @@
 3110 = Feed failed while reading a new record
 3111 = Feed %1$s is not connected to any dataset
 3112 = Array/Multiset item cannot be null
+3113 = Failed to parse record
+3114 = Failed to parse record content
+3115 = Failed to parse record metadata
+3116 = Failed to decode input
+3117 = Failed to parse record, malformed log record
 
 # Lifecycle management errors
 4000 = Partition id %1$s for node %2$s already in use by node %3$s
diff --git 
a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/RecordWithMetadataAndPK.java
 
b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/RecordWithMetadataAndPK.java
index f9bc8b2..959e34d 100644
--- 
a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/RecordWithMetadataAndPK.java
+++ 
b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/RecordWithMetadataAndPK.java
@@ -100,6 +100,10 @@ public class RecordWithMetadataAndPK<T> extends 
RecordWithPK<T> {
         return record;
     }
 
+    public IAType[] getMetaTypes() {
+        return metaTypes;
+    }
+
     public ArrayBackedValueStorage getMetadata(final int index) {
         return fieldValueBuffers[index];
     }
diff --git 
a/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/Task.java
 
b/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/Task.java
index 8dd94f3..5bb713d 100644
--- 
a/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/Task.java
+++ 
b/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/Task.java
@@ -229,6 +229,10 @@ public class Task implements IHyracksTaskContext, 
ICounterContext, Runnable {
         return this;
     }
 
+    public NodeControllerService getNodeControllerService() {
+        return ncs;
+    }
+
     public Joblet getJoblet() {
         return joblet;
     }