release 3.00.2.1

Author: dolphindb-jffu

src/Properties/AssemblyInfo.cs

@@ -32,5 +32,5 @@
 // 可以指定所有值，也可以使用以下所示的 "*" 预置版本号和修订号
 //通过使用 "*"，如下所示:
 // [assembly: AssemblyVersion("1.0.*")]
-[assembly: AssemblyVersion("3.00.2.0")]
-[assembly: AssemblyFileVersion("3.00.2.0")]
+[assembly: AssemblyVersion("3.00.2.1")]
+[assembly: AssemblyFileVersion("3.00.2.1")]

src/data/AbstractVector.cs

@@ -194,6 +194,7 @@ public static void checkCompressedMethod(DATA_TYPE type, int method){
                             case DATA_TYPE.DT_NANOTIMESTAMP:
 
                             case DATA_TYPE.DT_INT128:
+                            case DATA_TYPE.DT_COMPLEX:
                             case DATA_TYPE.DT_UUID:
                             case DATA_TYPE.DT_IPADDR:
                             case DATA_TYPE.DT_FLOAT:
@@ -264,6 +265,7 @@ public static int getUnitLength(DATA_TYPE type)
                     unitLength = 8;
                     break;
                 case DATA_TYPE.DT_INT128:
+                case DATA_TYPE.DT_COMPLEX:
                 case DATA_TYPE.DT_UUID:
                 case DATA_TYPE.DT_IPADDR:
                 case DATA_TYPE.DT_DECIMAL128:

src/data/BasicComplex.cs

@@ -0,0 +1,127 @@
+using System;
+using System.Collections.Generic;
+using dolphindb.io;
+
+namespace dolphindb.data
+{
+    public class BasicComplex : AbstractScalar
+    {
+
+        protected Double2 value;
+
+        public BasicComplex(double real, double image)
+        {
+            value = new Double2(real, image);
+        }
+
+        public BasicComplex(ExtendedDataInput @in)
+        {
+            value = @in.readDouble2();
+        }
+
+        public Double2 getDouble2()
+        {
+            return value;
+        }
+
+
+        public override bool isNull()
+        {
+            return value.isNull();
+        }
+
+
+        public override void setNull()
+        {
+            value = new Double2(-double.MaxValue, -double.MaxValue);
+        }
+
+        public double getReal() { 
+            return value.x;
+        }
+
+        public double getImage(){
+            return value.y;
+        }
+
+        public override Number getNumber()
+        {
+            throw new Exception("Imcompatible data type");
+        }
+
+        public override object getObject()
+        {
+            throw new NotImplementedException();
+        }
+
+        public override void setObject(object value)
+        {
+            throw new NotImplementedException();
+        }
+        public override Object getTemporal()
+        {
+            throw new Exception("Imcompatible data type");
+        }
+
+        public override DATA_CATEGORY getDataCategory()
+        {
+            return DATA_CATEGORY.BINARY;
+        }
+        public override DATA_TYPE getDataType()
+        {
+            return DATA_TYPE.DT_COMPLEX;
+        }
+
+        public override String getString()
+        {
+            if (isNull())
+            {
+                return "";
+            }
+            else
+            {
+                return value.x.ToString() + (value.y >= 0 ? "+" : "") + value.y.ToString() + "i";
+            }
+        }
+
+        public bool equals(Object o)
+        {
+            if (!(o is BasicComplex) || o == null)
+                return false;
+            else
+                return value.equals(((BasicComplex)o).value);
+        }
+
+        public override void writeScalarToOutputStream(ExtendedDataOutput @out)
+        {
+            @out.writeDouble2(value);
+        }
+
+        public Double2 getValue()
+        {
+            return value;
+        }
+
+        public override int hashBucket(int buckets)
+        {
+            return value.hashBucket(buckets);
+        }
+
+        public override bool Equals(object o)
+        {
+            if (!(o is BasicComplex) || o == null)
+            {
+                return false;
+            }
+            else
+            {
+                return getValue().equals(((BasicComplex)o).getValue());
+            }
+        }
+
+        public override int GetHashCode()
+        {
+            return value.GetHashCode();
+        }
+    }
+}

src/data/BasicComplexMatrix.cs

@@ -0,0 +1,82 @@
+using dolphindb.io;
+using System;
+using System.Collections.Generic;
+
+namespace dolphindb.data
+{
+
+    public class BasicComplexMatrix : AbstractMatrix
+    {
+        private BasicComplexVector value;
+
+        public BasicComplexMatrix(int rows, int columns) : base(rows, columns)
+        {
+            this.value = new BasicComplexVector(rows * columns);
+        }
+
+        public BasicComplexMatrix(int rows, int columns, IList<Double2[]> list) : base(rows, columns)
+        {
+            List<Double2> tmp = new List<Double2>();
+            foreach (Double2[] data in list)
+            {
+                tmp.AddRange(data);
+            }
+            if (tmp.Count != rows * columns)
+            {
+                throw new Exception("the total size of list must be equal to rows * columns");
+            }
+            value = new BasicComplexVector(tmp);
+        }
+
+        public BasicComplexMatrix(ExtendedDataInput @in) : base(@in)
+        {
+        }
+
+        public override bool isNull(int row, int column)
+        {
+            return value.isNull(getIndex(row, column));
+        }
+
+        public override void setNull(int row, int column)
+        {
+            value.setNull(getIndex(row, column));
+        }
+
+        public override IScalar get(int row, int column)
+        {
+            return this.value.get(getIndex(row, column));
+        }
+
+        public void set(int row, int column, IScalar value)
+        {
+            this.value.set(getIndex(row, column), value);
+        }
+
+        public override DATA_CATEGORY getDataCategory()
+        {
+            return DATA_CATEGORY.BINARY;
+        }
+
+        public override DATA_TYPE getDataType()
+        {
+            return DATA_TYPE.DT_COMPLEX;
+        }
+
+        public override Type getElementClass()
+        {
+            return typeof(BasicComplex);
+        }
+
+        protected internal override void readMatrixFromInputStream(int rows, int columns, ExtendedDataInput @in)
+        {
+            this.value = new BasicComplexVector(rows * columns);
+            value.deserialize(0, rows * columns, @in);
+        }
+
+        protected internal override void writeVectorToOutputStream(ExtendedDataOutput @out)
+        {
+            this.value.writeVectorToOutputStream(@out);
+        }
+    }
+
+}