>From Shahrzad Shirazi <[email protected]>:
Shahrzad Shirazi has uploaded this change for review. (
https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/20964?usp=email )
Change subject: WIP:Fixing Null for update statement
......................................................................
WIP:Fixing Null for update statement
Change-Id: I0b06e37893590c0f4fff8adede55672993ca94d5
---
M
asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/RecordMergeEvaluator.java
1 file changed, 5 insertions(+), 5 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/64/20964/1
diff --git
a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/RecordMergeEvaluator.java
b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/RecordMergeEvaluator.java
index adbf310..7cf2f58 100644
---
a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/RecordMergeEvaluator.java
+++
b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/evaluators/functions/records/RecordMergeEvaluator.java
@@ -87,7 +87,7 @@
private final DataOutput out = resultStorage.getDataOutput();
RecordMergeEvaluator(IEvaluatorContext ctx, IScalarEvaluatorFactory[]
args, IAType[] argTypes,
- SourceLocation sourceLocation, FunctionIdentifier identifier,
boolean isIgnoreDuplicates)
+ SourceLocation sourceLocation, FunctionIdentifier
identifier, boolean isIgnoreDuplicates)
throws HyracksDataException {
super(sourceLocation, identifier);
@@ -135,7 +135,7 @@
}
private void mergeFields(ARecordType combinedType,
ARecordVisitablePointable leftRecord,
- ARecordVisitablePointable rightRecord, int nestedLevel) throws
IOException {
+ ARecordVisitablePointable rightRecord, int
nestedLevel) throws IOException {
if (rbStack.size() < (nestedLevel + 1)) {
rbStack.add(new RecordBuilder());
}
@@ -149,8 +149,8 @@
IVisitablePointable leftValue = leftRecord.getFieldValues().get(i);
ATypeTag leftType = PointableHelper.getTypeTag(leftValue);
- // Skip NULL or MISSING values from the transform record
- if (leftType == ATypeTag.NULL || leftType == ATypeTag.MISSING) {
+ // Skip MISSING values from the transform record
+ if (leftType == ATypeTag.MISSING) {
continue;
}
@@ -225,7 +225,7 @@
*
*/
private void addFieldToSubRecord(ARecordType combinedType,
IVisitablePointable fieldNamePointable,
- IVisitablePointable leftValue, IVisitablePointable rightValue, int
nestedLevel) throws IOException {
+ IVisitablePointable leftValue,
IVisitablePointable rightValue, int nestedLevel) throws IOException {
runtimeRecordTypeInfo.reset(combinedType);
int pos =
runtimeRecordTypeInfo.getFieldIndex(fieldNamePointable.getByteArray(),
--
To view, visit https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/20964?usp=email
To unsubscribe, or for help writing mail filters, visit
https://asterix-gerrit.ics.uci.edu/settings?usp=email
Gerrit-MessageType: newchange
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Change-Id: I0b06e37893590c0f4fff8adede55672993ca94d5
Gerrit-Change-Number: 20964
Gerrit-PatchSet: 1
Gerrit-Owner: Shahrzad Shirazi <[email protected]>
