You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@asterixdb.apache.org by AsterixDB Code Review <do...@asterix-gerrit.ics.uci.edu> on 2021/05/04 11:35:34 UTC
Change in asterixdb[cheshire-cat]: dump index function
From Ali Alsuliman <al...@gmail.com>:
Ali Alsuliman has uploaded this change for review. ( https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/11323 )
Change subject: dump index function
......................................................................
dump index function
Change-Id: I63eedd5dd566c334e003031c13c30dc2b92081eb
---
M asterixdb/asterix-app/src/main/java/org/apache/asterix/app/function/DumpIndexFunction.java
M asterixdb/asterix-app/src/main/java/org/apache/asterix/app/function/DumpIndexReader.java
2 files changed, 5 insertions(+), 3 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb refs/changes/23/11323/1
diff --git a/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/function/DumpIndexFunction.java b/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/function/DumpIndexFunction.java
index 2fdbef3..85f77ed 100644
--- a/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/function/DumpIndexFunction.java
+++ b/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/function/DumpIndexFunction.java
@@ -50,6 +50,6 @@
throws HyracksDataException {
INCServiceContext serviceCtx = ctx.getJobletContext().getServiceContext();
final IIndexDataflowHelper indexDataflowHelper = indexDataflowHelperFactory.create(serviceCtx, partition);
- return new DumpIndexReader(indexDataflowHelper, recDesc, comparatorFactories);
+ return new DumpIndexReader(indexDataflowHelper, recDesc, comparatorFactories, partition);
}
}
diff --git a/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/function/DumpIndexReader.java b/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/function/DumpIndexReader.java
index 2a22ac6..dcf0952 100644
--- a/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/function/DumpIndexReader.java
+++ b/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/function/DumpIndexReader.java
@@ -47,11 +47,13 @@
private final DataInputStream dis = new DataInputStream(bbis);
private final IIndexDataflowHelper indexDataflowHelper;
private final IIndexAccessor accessor;
+ private final int partition;
public DumpIndexReader(IIndexDataflowHelper indexDataflowHelper, RecordDescriptor secondaryRecDesc,
- IBinaryComparatorFactory[] comparatorFactories) throws HyracksDataException {
+ IBinaryComparatorFactory[] comparatorFactories, int partition) throws HyracksDataException {
this.indexDataflowHelper = indexDataflowHelper;
this.secondaryRecDesc = secondaryRecDesc;
+ this.partition = partition;
indexDataflowHelper.open();
IIndex indexInstance = indexDataflowHelper.getIndexInstance();
accessor = indexInstance.createAccessor(NoOpIndexAccessParameters.INSTANCE);
@@ -102,6 +104,6 @@
recordBuilder.append(",");
}
recordBuilder.deleteCharAt(recordBuilder.length() - 1);
- recordBuilder.append("]}");
+ recordBuilder.append("], \"partition\":").append(partition).append('}');
}
}
--
To view, visit https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/11323
To unsubscribe, or for help writing mail filters, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-Project: asterixdb
Gerrit-Branch: cheshire-cat
Gerrit-Change-Id: I63eedd5dd566c334e003031c13c30dc2b92081eb
Gerrit-Change-Number: 11323
Gerrit-PatchSet: 1
Gerrit-Owner: Ali Alsuliman <al...@gmail.com>
Gerrit-MessageType: newchange
Change in asterixdb[cheshire-cat]: dump index function
Posted by AsterixDB Code Review <do...@asterix-gerrit.ics.uci.edu>.
From Jenkins <je...@fulliautomatix.ics.uci.edu>:
Jenkins has posted comments on this change. ( https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/11323 )
Change subject: dump index function
......................................................................
Patch Set 1: Integration-Tests-1
Integration Tests Failed
https://asterix-jenkins.ics.uci.edu/job/asterix-gerrit-integration-tests/11944/ : UNSTABLE
--
To view, visit https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/11323
To unsubscribe, or for help writing mail filters, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-Project: asterixdb
Gerrit-Branch: cheshire-cat
Gerrit-Change-Id: I63eedd5dd566c334e003031c13c30dc2b92081eb
Gerrit-Change-Number: 11323
Gerrit-PatchSet: 1
Gerrit-Owner: Ali Alsuliman <al...@gmail.com>
Gerrit-Reviewer: Jenkins <je...@fulliautomatix.ics.uci.edu>
Gerrit-Comment-Date: Tue, 04 May 2021 12:39:29 +0000
Gerrit-HasComments: No
Gerrit-Has-Labels: Yes
Gerrit-MessageType: comment
Change in asterixdb[cheshire-cat]: dump index function
Posted by AsterixDB Code Review <do...@asterix-gerrit.ics.uci.edu>.
From Ali Alsuliman <al...@gmail.com>:
Ali Alsuliman has uploaded this change for review. ( https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/11323 )
Change subject: dump index function
......................................................................
dump index function
Change-Id: I63eedd5dd566c334e003031c13c30dc2b92081eb
---
M asterixdb/asterix-app/src/main/java/org/apache/asterix/app/function/DumpIndexFunction.java
M asterixdb/asterix-app/src/main/java/org/apache/asterix/app/function/DumpIndexReader.java
2 files changed, 5 insertions(+), 3 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb refs/changes/23/11323/1
diff --git a/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/function/DumpIndexFunction.java b/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/function/DumpIndexFunction.java
index 2fdbef3..85f77ed 100644
--- a/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/function/DumpIndexFunction.java
+++ b/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/function/DumpIndexFunction.java
@@ -50,6 +50,6 @@
throws HyracksDataException {
INCServiceContext serviceCtx = ctx.getJobletContext().getServiceContext();
final IIndexDataflowHelper indexDataflowHelper = indexDataflowHelperFactory.create(serviceCtx, partition);
- return new DumpIndexReader(indexDataflowHelper, recDesc, comparatorFactories);
+ return new DumpIndexReader(indexDataflowHelper, recDesc, comparatorFactories, partition);
}
}
diff --git a/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/function/DumpIndexReader.java b/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/function/DumpIndexReader.java
index 2a22ac6..dcf0952 100644
--- a/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/function/DumpIndexReader.java
+++ b/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/function/DumpIndexReader.java
@@ -47,11 +47,13 @@
private final DataInputStream dis = new DataInputStream(bbis);
private final IIndexDataflowHelper indexDataflowHelper;
private final IIndexAccessor accessor;
+ private final int partition;
public DumpIndexReader(IIndexDataflowHelper indexDataflowHelper, RecordDescriptor secondaryRecDesc,
- IBinaryComparatorFactory[] comparatorFactories) throws HyracksDataException {
+ IBinaryComparatorFactory[] comparatorFactories, int partition) throws HyracksDataException {
this.indexDataflowHelper = indexDataflowHelper;
this.secondaryRecDesc = secondaryRecDesc;
+ this.partition = partition;
indexDataflowHelper.open();
IIndex indexInstance = indexDataflowHelper.getIndexInstance();
accessor = indexInstance.createAccessor(NoOpIndexAccessParameters.INSTANCE);
@@ -102,6 +104,6 @@
recordBuilder.append(",");
}
recordBuilder.deleteCharAt(recordBuilder.length() - 1);
- recordBuilder.append("]}");
+ recordBuilder.append("], \"partition\":").append(partition).append('}');
}
}
--
To view, visit https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/11323
To unsubscribe, or for help writing mail filters, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-Project: asterixdb
Gerrit-Branch: cheshire-cat
Gerrit-Change-Id: I63eedd5dd566c334e003031c13c30dc2b92081eb
Gerrit-Change-Number: 11323
Gerrit-PatchSet: 1
Gerrit-Owner: Ali Alsuliman <al...@gmail.com>
Gerrit-MessageType: newchange