Skip to content

Commit

Permalink
hsearch federated 1.2 version upgrade with bug Fixes.
Browse files Browse the repository at this point in the history 
Partition index hits only a specific column as required when the value
is exact.
Lots of test cases to ensure the federated search is proper.
  • Loading branch information
@abhinashak
abhinashak committed Mar 28, 2013
1 parent f1ba4a9 commit 3a456d4
Show file tree
Hide file tree
Showing 29 changed files with 1,475 additions and 43 deletions.
106 changes: 104 additions & 2 deletions .classpath
View file
Original file line number Diff line number Diff line change
Expand Up @@ -11,12 +11,114 @@
<classpathentry kind="lib" path="lib/commons-logging-1.1.1.jar"/>
<classpathentry kind="lib" path="lib/gson-2.2.2-sources.jar"/>
<classpathentry kind="lib" path="lib/gson-2.2.2.jar"/>
<classpathentry kind="lib" path="lib/hsearch-federated.jar" sourcepath="lib/src-hsearch-federated.jar"/>
<classpathentry kind="lib" path="lib/lucene-core.jar"/>
<classpathentry kind="lib" path="lib/src-hsearch-federated.jar"/>
<classpathentry kind="lib" path="lib/hadoop-client-2.0.0-cdh4.2.0.jar"/>
<classpathentry kind="lib" path="lib/hadoop-common-2.0.0-cdh4.2.0.jar"/>
<classpathentry kind="lib" path="lib/hadoop-gpl-compression-0.1.0.jar"/>
<classpathentry kind="lib" path="lib/hbase-0.94.2-cdh4.2.0-security.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/zookeeper-3.4.5-cdh4.2.0.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/commons-collections-3.2.1.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/protobuf-java-2.4.0a.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/activation-1.1.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/aopalliance-1.0.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/asm-3.2.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/avro-1.7.3.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/commons-beanutils-1.7.0.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/commons-beanutils-core-1.8.0.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/commons-cli-1.2.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/commons-codec-1.4.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/commons-configuration-1.6.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/commons-daemon-1.0.3.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/commons-digester-1.8.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/commons-el-1.0.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/commons-httpclient-3.1.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/commons-io-2.1.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/commons-lang-2.5.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/commons-logging-1.1.1.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/commons-net-3.1.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/core-3.1.1.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/gmbal-api-only-3.0.0-b023.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/grizzly-framework-2.1.1-tests.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/grizzly-framework-2.1.1.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/grizzly-http-2.1.1.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/grizzly-http-server-2.1.1.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/grizzly-http-servlet-2.1.1.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/grizzly-rcm-2.1.1.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/guava-11.0.2.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/guice-3.0.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/guice-servlet-3.0.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/hadoop-annotations-2.0.0-cdh4.2.0.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/hadoop-auth-2.0.0-cdh4.2.0.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/hadoop-client-2.0.0-cdh4.2.0.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/hadoop-common-2.0.0-cdh4.2.0-tests.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/hadoop-common-2.0.0-cdh4.2.0.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/hadoop-hdfs-2.0.0-cdh4.2.0-tests.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/hadoop-hdfs-2.0.0-cdh4.2.0.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/hadoop-mapreduce-client-app-2.0.0-cdh4.2.0.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/hadoop-mapreduce-client-common-2.0.0-cdh4.2.0.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/hadoop-mapreduce-client-core-2.0.0-cdh4.2.0.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/hadoop-mapreduce-client-hs-2.0.0-cdh4.2.0.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/hadoop-mapreduce-client-jobclient-2.0.0-cdh4.2.0-tests.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/hadoop-mapreduce-client-jobclient-2.0.0-cdh4.2.0.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/hadoop-mapreduce-client-shuffle-2.0.0-cdh4.2.0.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/hadoop-minicluster-2.0.0-cdh4.2.0.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/hadoop-yarn-api-2.0.0-cdh4.2.0.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/hadoop-yarn-client-2.0.0-cdh4.2.0.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/hadoop-yarn-common-2.0.0-cdh4.2.0.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/hadoop-yarn-server-common-2.0.0-cdh4.2.0.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/hadoop-yarn-server-nodemanager-2.0.0-cdh4.2.0.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/hadoop-yarn-server-resourcemanager-2.0.0-cdh4.2.0.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/hadoop-yarn-server-tests-2.0.0-cdh4.2.0-tests.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/hadoop-yarn-server-web-proxy-2.0.0-cdh4.2.0.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/hbase-0.94.2-cdh4.2.0-security.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/high-scale-lib-1.1.1.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/httpclient-4.1.3.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/httpcore-4.1.3.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/jackson-core-asl-1.8.8.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/jackson-jaxrs-1.8.8.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/jackson-mapper-asl-1.8.8.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/jackson-xc-1.8.8.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/jamon-runtime-2.3.1.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/jasper-compiler-5.5.23.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/jasper-runtime-5.5.23.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/javax.inject-1.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/javax.servlet-3.0.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/jaxb-api-2.1.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/jaxb-impl-2.2.3-1.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/jersey-client-1.8.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/jersey-core-1.8.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/jersey-grizzly2-1.8.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/jersey-guice-1.8.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/jersey-json-1.8.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/jersey-server-1.8.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/jersey-test-framework-core-1.8.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/jersey-test-framework-grizzly2-1.8.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/jets3t-0.6.1.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/jettison-1.1.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/jetty-6.1.26.cloudera.2.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/jetty-util-6.1.26.cloudera.2.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/jruby-complete-1.6.5.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/jsch-0.1.42.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/jsp-2.1-6.1.14.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/jsp-api-2.1-6.1.14.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/jsp-api-2.1.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/jsr305-1.3.9.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/junit-4.10-HBASE-1.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/kfs-0.3.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/libthrift-0.9.0.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/log4j-1.2.17.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/management-api-3.0.0-b012.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/metrics-core-2.1.2.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/netty-3.2.4.Final.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/paranamer-2.3.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/servlet-api-2.5-6.1.14.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/servlet-api-2.5.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/slf4j-api-1.6.1.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/slf4j-log4j12-1.6.1.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/snappy-java-1.0.4.1.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/stax-api-1.0.1.jar"/>
<classpathentry kind="lib" path="/hsearch-hbase/hbase-cdh4/lib/xmlenc-0.52.jar"/>
<classpathentry kind="lib" path="lib/hsearch-federated_1.2.jar"/>
<classpathentry kind="lib" path="lib/src-hsearch-federated_1.2.jar"/>
<classpathentry kind="output" path="classes"/>
</classpath>
2 changes: 1 addition & 1 deletion build.properties
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
name=hsearch-core
version=0.94.2.207
version=0.94.2.208

company=Bizosys Technologies Pvt Ltd.

Expand Down
21 changes: 5 additions & 16 deletions classes/com/bizosys/hsearch/treetable/compiler/schema.txt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,26 +2,15 @@
"module" : "com.delme.generated",
"table": "htable",
"columns": [
{
"name": "Resumes",
{
"name": "ExamResult",

"mergeId": {
"name": "mergeId",
"datatype": "Integer"
},

"indexes": "unstructured"
},

{
"name": "EmpDetail",

"mergeId": {
"name": "mergeId",
"datatype": "Integer"
},

"indexes": [
"indexes": [
{
"name": "age",
"datatype": "Integer"
Expand All @@ -48,8 +37,8 @@
},

"partitions": {
"names": "a,b,c,d,e,f,g,h,i",
"ranges": "[*:-123],[-123:-11],[-11:23],[23:45],[45:134],[134:10012],[10012:213923],[213923:1111111],[1111111:*]",
"names": "a,b,c,d,e,f,g,h,i,j",
"ranges": "[0:10],[10:20],[20:30],[30:40],[40:50],[50:60],[60:70],[70:80],[80:90][90:100]",
"column" : 4 ,
"type" : "numeric"
}
Expand Down
47 changes: 47 additions & 0 deletions classes/com/bizosys/hsearch/treetable/storage/examresult.json
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,47 @@
{
"module" : "com.bizosys.hsearch.treetable.storage.sampleImpl",
"table": "htable-test",
"columns": [
{
"name": "ExamResult",

"mergeId": {
"name": "mergeId",
"datatype": "Integer"
},

"indexes": [
{
"name": "age",
"datatype": "Integer"
},
{
"name": "role",
"datatype": "String"
},
{
"name": "location",
"datatype": "String"
}
],

"key": {
"name": "empid",
"datatype": "Integer"
},

"value":
{
"name": "mark",
"datatype": "Float"
},

"partitions": {
"names": "a,b,c,d,e,f,g,h,i,j",
"ranges": "[*:1],[1:2],[2:3],[3:4],[4:5],[5:6],[6:7],[7:8],[8:9],[9:*]",
"column" : 4 ,
"type" : "numeric"
}
}
]
}
Binary file modified hsearch-core.jar
View file
Binary file not shown.
Binary file removed lib/hsearch-federated.jar
View file
Binary file not shown.
Binary file added lib/hsearch-federated_1.2.jar
View file
Binary file not shown.
Binary file removed lib/src-hsearch-federated.jar
View file
Binary file not shown.
Binary file added lib/src-hsearch-federated_1.2.jar
View file
Binary file not shown.
Empty file added logs/perf.xml
View file
Empty file.
Binary file modified src-hsearch-core.jar
View file
Binary file not shown.
22 changes: 22 additions & 0 deletions src/java/com/bizosys/hsearch/treetable/Cell2.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -168,6 +168,11 @@ public void getMap(V exactValue, V minimumValue, V maximumValue,
public void populate(Map<K1,V> map) throws IOException {
ISortedByte<byte[]> kvB = SortedBytesArray.getInstance().parse(data.data, data.offset, data.length);

if ( kvB.getSize() == 0 ) {
System.err.println("Null Values to pipulate in Cell2");
return;
}

byte[] allKeysB = kvB.getValueAt(0);
if ( null == allKeysB ) return;

Expand Down Expand Up @@ -207,6 +212,23 @@ public byte[] toBytesOnSortedData() throws IOException {
return cellB;
}

public byte[] toBytesOnSortedData(Map<K1, V> customMap) throws IOException {

if ( null == customMap) return null;
if ( customMap.size() == 0 ) return null;

Collection<K1> keys = customMap.keySet();
Collection<V> values = customMap.values();

List<byte[]> bytesElems = new ArrayList<byte[]>();
bytesElems.add(k1Sorter.toBytes(keys));
bytesElems.add(vSorter.toBytes(values));

byte[] cellB = SortedBytesArray.getInstance().toBytes(bytesElems);
bytesElems.clear();
return cellB;
}

public byte[] toBytes(V minValue, V maximumValue, boolean leftInclusize, boolean rightInclusize, Comparator<V> vComp) throws IOException {

if ( sortedList.size() == 0 ) return null;
Expand Down
1 change: 1 addition & 0 deletions src/java/com/bizosys/hsearch/treetable/client/HSearchProcessingInstruction.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -127,6 +127,7 @@ public static String ser(FunctionExpr[] functions) {
public static void main(String[] args) throws ParseException {
FunctionExpr count = new FunctionExpr(1, FunctionRepos.COUNT);
FunctionExpr min = new FunctionExpr(21, FunctionRepos.COUNT);

HSearchProcessingInstruction o =
new HSearchProcessingInstruction(PLUGIN_CALLBACK_COLS, OUTPUT_COLS,
new FunctionExpr[]{count, min});
Expand Down
18 changes: 13 additions & 5 deletions src/java/com/bizosys/hsearch/treetable/client/partition/PartitionNumeric.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -78,13 +78,12 @@ public void setPartitionsAndRange(String colName, String familyNames, String ran
public void getMatchingFamilies(HSearchQuery query, Set<String> uniqueFamilies) throws IOException {

if ( query.filterCells[this.partitionIndex]) {
if ( null == query.exactValCellsO) {
if ( null == query.exactValCells[this.partitionIndex]) {
double min = query.minValCells[this.partitionIndex];
double max = query.maxValCells[this.partitionIndex];
getColumnFamilies(min, max, uniqueFamilies);
} else {
Object exact = query.exactValCellsO[this.partitionIndex];
uniqueFamilies.add(getColumnFamily(new Double(exact.toString()) ));
uniqueFamilies.add(getColumnFamily(new Double(query.exactValCells[this.partitionIndex]) ));
}
} else {
getColumnFamilies(HSearchQuery.DOUBLE_MIN_VALUE, HSearchQuery.DOUBLE_MAX_VALUE, uniqueFamilies);
Expand Down Expand Up @@ -121,8 +120,13 @@ public void getColumnFamilies(Double startVal, Double endVal, Set<String> famili

}

if ( !isStart )
throw new IOException("No matching columns found for value = " + startVal + ":" + endVal +"\n" + families.toString());
if ( !isStart ) {
System.err.println("Start is not found. Adding All : " + startVal + "\t-\t" + endVal);
for (NumericRange aRange : rangeL) {
families.add(colName + "_" + aRange.ext);
}
}
//throw new IOException("No matching columns found for value = " + startVal + ":" + endVal +"\n" + families.toString());

}

Expand All @@ -131,11 +135,15 @@ public String getColumnFamily(Double exactVal) throws IOException {

if ( rangeL.size() == 0 ) return colName;

NumericRange lastRange = null;
for (NumericRange aRange : rangeL) {
if ( aRange.start <= exactVal && aRange.end > exactVal)
return colName + "_" + aRange.ext;
lastRange = aRange;
}

if ( lastRange.end == exactVal) return colName + "_" + lastRange.ext;

throw new IOException("No matching columns found for value :" + exactVal);
}

Expand Down
21 changes: 5 additions & 16 deletions src/java/com/bizosys/hsearch/treetable/compiler/schema.txt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,26 +2,15 @@
"module" : "com.delme.generated",
"table": "htable",
"columns": [
{
"name": "Resumes",
{
"name": "ExamResult",

"mergeId": {
"name": "mergeId",
"datatype": "Integer"
},

"indexes": "unstructured"
},

{
"name": "EmpDetail",

"mergeId": {
"name": "mergeId",
"datatype": "Integer"
},

"indexes": [
"indexes": [
{
"name": "age",
"datatype": "Integer"
Expand All @@ -48,8 +37,8 @@
},

"partitions": {
"names": "a,b,c,d,e,f,g,h,i",
"ranges": "[*:-123],[-123:-11],[-11:23],[23:45],[45:134],[134:10012],[10012:213923],[213923:1111111],[1111111:*]",
"names": "a,b,c,d,e,f,g,h,i,j",
"ranges": "[0:10],[10:20],[20:30],[30:40],[40:50],[50:60],[60:70],[70:80],[80:90][90:100]",
"column" : 4 ,
"type" : "numeric"
}
Expand Down
3 changes: 2 additions & 1 deletion src/java/com/bizosys/hsearch/treetable/storage/HSearchTableReader.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -39,6 +39,7 @@
public abstract class HSearchTableReader implements IScanCallBack {

public static boolean DEBUG_ENABLED = HbaseLog.l.isDebugEnabled();
public static boolean INFO_ENABLED = HbaseLog.l.isInfoEnabled();

//public static ParallelHReader parallelReader = new ParallelHReader(10);

Expand Down Expand Up @@ -91,7 +92,7 @@ public void read( String multiQuery, Map<String, String> multiQueryParts,

List<ColumnFamName> families = new ArrayList<ColumnFamName>();
for (String family : uniqueFamilies) {
if ( DEBUG_ENABLED ) HbaseLog.l.debug("HSearchTableReader > Adding Family: " + family);
if ( INFO_ENABLED ) HbaseLog.l.info("HSearchTableReader > Adding Family: " + family);
families.add(new ColumnFamName(family.getBytes(), HBaseTableSchemaDefn.COL_NAME_BYTES));
}

Expand Down
Loading

0 comments on commit 3a456d4

Please sign in to comment.