phoenix git commit: PHOENIX-2364 timestamp type primary key desc error (freakyzoidberg)

2016-01-07 Thread ramkrishna 
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-0.98 94c3546f2 -> 8d679084f


PHOENIX-2364 timestamp type primary key desc error (freakyzoidberg)


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/8d679084
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/8d679084
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/8d679084

Branch: refs/heads/4.x-HBase-0.98
Commit: 8d679084f506e9298f32cb0078391813f1c3c287
Parents: 94c3546
Author: ramkrishna 
Authored: Thu Jan 7 21:52:19 2016 +0530
Committer: ramkrishna 
Committed: Thu Jan 7 21:55:49 2016 +0530

--
 .../phoenix/schema/types/PArrayDataType.java   |  2 ++
 .../org/apache/phoenix/schema/types/PDataType.java |  1 +
 .../phoenix/schema/types/PUnsignedDouble.java  |  1 +
 .../phoenix/schema/types/PUnsignedFloat.java   |  1 +
 .../apache/phoenix/schema/types/PUnsignedInt.java  |  1 +
 .../phoenix/schema/types/PUnsignedSmallint.java|  1 +
 .../java/org/apache/phoenix/query/OrderByTest.java | 17 +
 7 files changed, 24 insertions(+)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/8d679084/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PArrayDataType.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PArrayDataType.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PArrayDataType.java
index a1759a4..29af86e 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PArrayDataType.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PArrayDataType.java
@@ -1269,6 +1269,7 @@ public abstract class PArrayDataType extends 
PDataType {
 offsetPos.add(byteStream.size());
 if (sortOrder == SortOrder.DESC) {
 SortOrder.invert(bytes, offset, bytes, offset, 
len);
+offset = 0;
 }
 oStream.write(bytes, offset, len);
 oStream.write(getSeparatorByte(true, sortOrder));
@@ -1276,6 +1277,7 @@ public abstract class PArrayDataType extends 
PDataType {
 } else {
 if (sortOrder == SortOrder.DESC) {
 SortOrder.invert(bytes, offset, bytes, offset, len);
+offset = 0;
 }
 oStream.write(bytes, offset, len);
 }

http://git-wip-us.apache.org/repos/asf/phoenix/blob/8d679084/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDataType.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDataType.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDataType.java
index 5d8852c..7bf54ce 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDataType.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDataType.java
@@ -170,6 +170,7 @@ public abstract class PDataType implements DataType, 
Comparablehttp://git-wip-us.apache.org/repos/asf/phoenix/blob/8d679084/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedDouble.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedDouble.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedDouble.java
index 39e0d47..14e41e1 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedDouble.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedDouble.java
@@ -148,6 +148,7 @@ public class PUnsignedDouble extends PRealNumber {
   checkForSufficientLength(b, o, Bytes.SIZEOF_DOUBLE);
   if (sortOrder == SortOrder.DESC) {
 b = SortOrder.invert(b, o, new byte[Bytes.SIZEOF_DOUBLE], 0, 
Bytes.SIZEOF_DOUBLE);
+o = 0;
   }
   double v = Bytes.toDouble(b, o);
   if (v < 0) {

http://git-wip-us.apache.org/repos/asf/phoenix/blob/8d679084/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedFloat.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedFloat.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedFloat.java
index 489ebd0..980b538 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedFloat.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedFloat.java
@@ -142,6 +142,7 @@ public class PUnsignedFloat extends PRealNumber {
   checkForSufficientLength(b, o,

phoenix git commit: PHOENIX-2364 timestamp type primary key desc error (freakyzoidberg)

2016-01-07 Thread ramkrishna 
Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-1.0 db63efe30 -> 63830ef4e


PHOENIX-2364 timestamp type primary key desc error (freakyzoidberg)


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/63830ef4
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/63830ef4
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/63830ef4

Branch: refs/heads/4.x-HBase-1.0
Commit: 63830ef4e4c678da0c61b2449cfcbd00e17c856c
Parents: db63efe
Author: ramkrishna 
Authored: Thu Jan 7 21:52:19 2016 +0530
Committer: ramkrishna 
Committed: Thu Jan 7 21:55:13 2016 +0530

--
 .../phoenix/schema/types/PArrayDataType.java   |  2 ++
 .../org/apache/phoenix/schema/types/PDataType.java |  1 +
 .../phoenix/schema/types/PUnsignedDouble.java  |  1 +
 .../phoenix/schema/types/PUnsignedFloat.java   |  1 +
 .../apache/phoenix/schema/types/PUnsignedInt.java  |  1 +
 .../phoenix/schema/types/PUnsignedSmallint.java|  1 +
 .../java/org/apache/phoenix/query/OrderByTest.java | 17 +
 7 files changed, 24 insertions(+)
--


http://git-wip-us.apache.org/repos/asf/phoenix/blob/63830ef4/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PArrayDataType.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PArrayDataType.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PArrayDataType.java
index a1759a4..29af86e 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PArrayDataType.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PArrayDataType.java
@@ -1269,6 +1269,7 @@ public abstract class PArrayDataType extends 
PDataType {
 offsetPos.add(byteStream.size());
 if (sortOrder == SortOrder.DESC) {
 SortOrder.invert(bytes, offset, bytes, offset, 
len);
+offset = 0;
 }
 oStream.write(bytes, offset, len);
 oStream.write(getSeparatorByte(true, sortOrder));
@@ -1276,6 +1277,7 @@ public abstract class PArrayDataType extends 
PDataType {
 } else {
 if (sortOrder == SortOrder.DESC) {
 SortOrder.invert(bytes, offset, bytes, offset, len);
+offset = 0;
 }
 oStream.write(bytes, offset, len);
 }

http://git-wip-us.apache.org/repos/asf/phoenix/blob/63830ef4/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDataType.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDataType.java 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDataType.java
index 5d8852c..7bf54ce 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDataType.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PDataType.java
@@ -170,6 +170,7 @@ public abstract class PDataType implements DataType, 
Comparablehttp://git-wip-us.apache.org/repos/asf/phoenix/blob/63830ef4/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedDouble.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedDouble.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedDouble.java
index 39e0d47..14e41e1 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedDouble.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedDouble.java
@@ -148,6 +148,7 @@ public class PUnsignedDouble extends PRealNumber {
   checkForSufficientLength(b, o, Bytes.SIZEOF_DOUBLE);
   if (sortOrder == SortOrder.DESC) {
 b = SortOrder.invert(b, o, new byte[Bytes.SIZEOF_DOUBLE], 0, 
Bytes.SIZEOF_DOUBLE);
+o = 0;
   }
   double v = Bytes.toDouble(b, o);
   if (v < 0) {

http://git-wip-us.apache.org/repos/asf/phoenix/blob/63830ef4/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedFloat.java
--
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedFloat.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedFloat.java
index 489ebd0..980b538 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedFloat.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/schema/types/PUnsignedFloat.java
@@ -142,6 +142,7 @@ public class PUnsignedFloat extends PRealNumber {
   checkForSufficientLength(b, o, B