Repository: asterixdb Updated Branches: refs/heads/master 622496642 -> e0c232d27
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/e0c232d2/hyracks-fullstack/hyracks/hyracks-examples/btree-example/btreehelper/src/main/java/org/apache/hyracks/examples/btree/helper/NCApplicationEntryPoint.java ---------------------------------------------------------------------- diff --git a/hyracks-fullstack/hyracks/hyracks-examples/btree-example/btreehelper/src/main/java/org/apache/hyracks/examples/btree/helper/NCApplicationEntryPoint.java b/hyracks-fullstack/hyracks/hyracks-examples/btree-example/btreehelper/src/main/java/org/apache/hyracks/examples/btree/helper/NCApplicationEntryPoint.java index 66ec854..5180f23 100644 --- a/hyracks-fullstack/hyracks/hyracks-examples/btree-example/btreehelper/src/main/java/org/apache/hyracks/examples/btree/helper/NCApplicationEntryPoint.java +++ b/hyracks-fullstack/hyracks/hyracks-examples/btree-example/btreehelper/src/main/java/org/apache/hyracks/examples/btree/helper/NCApplicationEntryPoint.java @@ -20,8 +20,10 @@ package org.apache.hyracks.examples.btree.helper; import org.apache.hyracks.api.application.INCApplicationContext; import org.apache.hyracks.api.application.INCApplicationEntryPoint; +import org.apache.hyracks.api.job.resource.NodeCapacity; public class NCApplicationEntryPoint implements INCApplicationEntryPoint { + @Override public void start(INCApplicationContext ncAppCtx, String[] args) throws Exception { RuntimeContext rCtx = new RuntimeContext(ncAppCtx); @@ -37,4 +39,9 @@ public class NCApplicationEntryPoint implements INCApplicationEntryPoint { public void stop() throws Exception { } + + @Override + public NodeCapacity getCapacity() { + return new NodeCapacity(Runtime.getRuntime().maxMemory(), Runtime.getRuntime().availableProcessors() - 1); + } } http://git-wip-us.apache.org/repos/asf/asterixdb/blob/e0c232d2/hyracks-fullstack/hyracks/hyracks-storage-am-lsm-invertedindex/src/main/java/org/apache/hyracks/storage/am/lsm/invertedindex/search/AbstractTOccurrenceSearcher.java ---------------------------------------------------------------------- diff --git a/hyracks-fullstack/hyracks/hyracks-storage-am-lsm-invertedindex/src/main/java/org/apache/hyracks/storage/am/lsm/invertedindex/search/AbstractTOccurrenceSearcher.java b/hyracks-fullstack/hyracks/hyracks-storage-am-lsm-invertedindex/src/main/java/org/apache/hyracks/storage/am/lsm/invertedindex/search/AbstractTOccurrenceSearcher.java index 9e6afa7..e4b220b 100644 --- a/hyracks-fullstack/hyracks/hyracks-storage-am-lsm-invertedindex/src/main/java/org/apache/hyracks/storage/am/lsm/invertedindex/search/AbstractTOccurrenceSearcher.java +++ b/hyracks-fullstack/hyracks/hyracks-storage-am-lsm-invertedindex/src/main/java/org/apache/hyracks/storage/am/lsm/invertedindex/search/AbstractTOccurrenceSearcher.java @@ -122,12 +122,12 @@ public abstract class AbstractTOccurrenceSearcher implements IInvertedIndexSearc // If it's a list, it can have multiple keywords in it. But, each keyword should not be a phrase. if (isFullTextSearchQuery) { if (queryTokenizerType == TokenizerType.STRING && tokenCountInOneField > 1) { - throw HyracksDataException.create(ErrorCode.RUNTIME_FULLTEXT_PHRASE_FOUND); + throw HyracksDataException.create(ErrorCode.FULLTEXT_PHRASE_FOUND); } else if (queryTokenizerType == TokenizerType.LIST) { for (int j = 1; j < token.getTokenLength(); j++) { if (DelimitedUTF8StringBinaryTokenizer .isSeparator((char) token.getData()[token.getStartOffset() + j])) { - throw HyracksDataException.create(ErrorCode.RUNTIME_FULLTEXT_PHRASE_FOUND); + throw HyracksDataException.create(ErrorCode.FULLTEXT_PHRASE_FOUND); } } }
