AJ-627: fix issue about cep vector deserialize;

Author: chengyitian

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

@@ -393,6 +393,7 @@ private Entity deserializeScalar(Entity.DATA_TYPE type, int extraParam, Extended
 
     private Entity deserializeFastArray(Entity.DATA_TYPE type, int extraParam, ExtendedDataInput input) throws IOException {
         BasicEntityFactory factory = new BasicEntityFactory();
+        input.readShort();
         return factory.createEntity(Entity.DATA_FORM.DF_VECTOR, type, input, false);
     }
 

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

@@ -12,30 +12,6 @@ public FastArrayAttributeSerializer(int unitLen) {
 
     @Override
     public void serialize(Entity attribute, ExtendedDataOutput out) throws IOException {
-        int curCount = attribute.rows();
-        short arrayRows = 1;
-        byte curCountBytes = 1;
-        byte reserved = 0;
-        int maxCount = 255;
-        while (curCount > maxCount) {
-            curCountBytes *= 2;
-            maxCount = (1 << (8 * curCountBytes)) - 1;
-        }
-        out.writeShort(arrayRows);
-        out.writeByte(curCountBytes);
-        out.writeByte(reserved);
-        switch (curCountBytes) {
-            case 1:
-                out.writeByte(curCount);
-                break;
-            case 2:
-                out.writeShort(curCount);
-                break;
-            default:
-                out.writeInt(curCount);
-                break;
-        }
-
         attribute.write(out);
     }