This is an automated email from the ASF dual-hosted git repository.
mhubail 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 9203c2fe9e MB-61438: Supporting Plan for Id Extraction from Value
9203c2fe9e is described below
commit 9203c2fe9e55c0cb1f6496737bdc5c94375bf98b
Author: Ritik Raj <[email protected]>
AuthorDate: Sun Apr 7 20:18:48 2024 +0530
MB-61438: Supporting Plan for Id Extraction from Value
Change-Id: I2d4fd57af4f71a3b8cf45ed708a1500436565e6e
Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/18229
Integration-Tests: Jenkins <[email protected]>
Reviewed-by: Peeyush Gupta <[email protected]>
Tested-by: Murtadha Hubail <[email protected]>
---
.../apache/hyracks/data/std/util/ByteArrayAccessibleInputStream.java | 2 +-
.../dataflow/LSMTreeIndexInsertUpdateDeleteOperatorDescriptor.java | 4 ++++
2 files changed, 5 insertions(+), 1 deletion(-)
diff --git
a/hyracks-fullstack/hyracks/hyracks-data/hyracks-data-std/src/main/java/org/apache/hyracks/data/std/util/ByteArrayAccessibleInputStream.java
b/hyracks-fullstack/hyracks/hyracks-data/hyracks-data-std/src/main/java/org/apache/hyracks/data/std/util/ByteArrayAccessibleInputStream.java
index 7f1d451988..c1b4d9e1e2 100644
---
a/hyracks-fullstack/hyracks/hyracks-data/hyracks-data-std/src/main/java/org/apache/hyracks/data/std/util/ByteArrayAccessibleInputStream.java
+++
b/hyracks-fullstack/hyracks/hyracks-data/hyracks-data-std/src/main/java/org/apache/hyracks/data/std/util/ByteArrayAccessibleInputStream.java
@@ -29,7 +29,7 @@ public class ByteArrayAccessibleInputStream extends
ByteArrayInputStream {
public void setContent(byte[] buf, int offset, int length) {
this.buf = buf;
this.pos = offset;
- this.count = Math.min(offset + length, buf.length);
+ this.count = Math.min(offset + length, buf == null ? 0 : buf.length);
this.mark = offset;
}
diff --git
a/hyracks-fullstack/hyracks/hyracks-storage-am-lsm-common/src/main/java/org/apache/hyracks/storage/am/lsm/common/dataflow/LSMTreeIndexInsertUpdateDeleteOperatorDescriptor.java
b/hyracks-fullstack/hyracks/hyracks-storage-am-lsm-common/src/main/java/org/apache/hyracks/storage/am/lsm/common/dataflow/LSMTreeIndexInsertUpdateDeleteOperatorDescriptor.java
index 26ce56af96..92813199b5 100644
---
a/hyracks-fullstack/hyracks/hyracks-storage-am-lsm-common/src/main/java/org/apache/hyracks/storage/am/lsm/common/dataflow/LSMTreeIndexInsertUpdateDeleteOperatorDescriptor.java
+++
b/hyracks-fullstack/hyracks/hyracks-storage-am-lsm-common/src/main/java/org/apache/hyracks/storage/am/lsm/common/dataflow/LSMTreeIndexInsertUpdateDeleteOperatorDescriptor.java
@@ -67,4 +67,8 @@ public class LSMTreeIndexInsertUpdateDeleteOperatorDescriptor
extends AbstractSi
recordDescProvider.getInputRecordDescriptor(getActivityId(),
0), op, modCallbackFactory,
tupleFilterFactory, tuplePartitionerFactory, partitionsMap);
}
+
+ public int[] getFieldPermutation() {
+ return fieldPermutation;
+ }
}
