AJ-655: fix issue about deserialize decimal for cep;

Author: chengyitian

src/com/xxdb/data/BasicDecimal128.java

@@ -40,11 +40,18 @@ public BasicDecimal128(ExtendedDataInput in) throws IOException {
         unscaledValue = handleLittleEndianBigEndian(in);
     }
 
+    public BasicDecimal128(ExtendedDataInput in, int scale) throws IOException {
+        this.scale = scale;
+        unscaledValue = handleLittleEndianBigEndian(in);
+    }
+
     BasicDecimal128(int scale, BigInteger unscaledVal) {
         this.unscaledValue = unscaledVal;
         this.scale = scale;
     }
 
+
+
     private static BigInteger handleLittleEndianBigEndian(ExtendedDataInput in) throws IOException {
         byte[] buffer = new byte[16];
         BigInteger value;

src/com/xxdb/data/BasicDecimal32.java

@@ -17,6 +17,11 @@ public BasicDecimal32(ExtendedDataInput in) throws IOException{
         value_ = in.readInt();
     }
 
+    public BasicDecimal32(ExtendedDataInput in, int scale) throws IOException {
+        this.scale_ = scale;
+        value_ = in.readInt();
+    }
+
     public BasicDecimal32(int value, int scale){
         this(String.valueOf(value), scale);
     }

src/com/xxdb/data/BasicDecimal64.java

@@ -22,6 +22,10 @@ public BasicDecimal64(ExtendedDataInput in) throws IOException{
         scale_ = in.readInt();
         value_ = in.readLong();
     }
+    public BasicDecimal64(ExtendedDataInput in, int scale) throws IOException{
+        scale_ = scale;
+        value_ = in.readLong();
+    }
 
     public BasicDecimal64(long value, int scale){
         this(String.valueOf(value), scale);

src/com/xxdb/streaming/client/cep/EventHandler.java

@@ -388,7 +388,14 @@ private boolean checkSchema(List<EventScheme> eventSchemes, List<String> expandT
 
     private Entity deserializeScalar(Entity.DATA_TYPE type, int extraParam, ExtendedDataInput input) throws IOException {
         BasicEntityFactory factory = new BasicEntityFactory();
-        return factory.createEntity(Entity.DATA_FORM.DF_SCALAR, type, input, false);
+        if (type == Entity.DATA_TYPE.DT_DECIMAL32)
+            return new BasicDecimal32(input, extraParam);
+        else if (type == Entity.DATA_TYPE.DT_DECIMAL64)
+            return new BasicDecimal64(input, extraParam);
+        else if (type == Entity.DATA_TYPE.DT_DECIMAL128)
+            return new BasicDecimal128(input, extraParam);
+        else
+            return factory.createEntity(Entity.DATA_FORM.DF_SCALAR, type, input, false);
     }
 
     private Entity deserializeFastArray(Entity.DATA_TYPE type, int extraParam, ExtendedDataInput input) throws IOException {