fix the uint convertion

marshal/proto_test.go

@@ -87,6 +87,10 @@ func (t *TestInterfaceImpl2) foo() {
 
 type TestInterfaceStruct struct {
 	Val       TestInterface
+	UintVal32 uint32
+	UintVal64 uint64
+	UintVal   uint
+	Uint8     uint8
 	NestedVal TestInterface
 	Arr       []TestInterface
 	NestedArr [][]TestInterface
@@ -116,7 +120,7 @@ func TestInterfaceMarshal(t *testing.T) {
 	if err != nil {
 		t.Errorf("failed to marshal values: %v", err)
 	}
-	assert.Equal(t, 7, len(schemaHandler.ValueColumns))
+	assert.Equal(t, 11, len(schemaHandler.ValueColumns))
 	elementTestSchema := (*tableMap)["Parquet_go_root\x01Arr\x01List\x01Element\x01Test"]
 	elementBarSchema := (*tableMap)["Parquet_go_root\x01Arr\x01List\x01Element\x01NestedInterface\x01Bar"]
 	nestedElementTestSchema := (*tableMap)["Parquet_go_root\x01NestedArr\x01List\x01Element\x01List\x01Element\x01Test"]

types/types.go

@@ -203,6 +203,10 @@ func StrToParquetType(s string, pT *parquet.Type, cT *parquet.ConvertedType, len
 	}
 }
 
+func IsUint(kind reflect.Kind) bool {
+	return kind == reflect.Uint || kind == reflect.Uint16 || kind == reflect.Uint32 || kind == reflect.Uint8 || kind == reflect.Uint64
+}
+
 func InterfaceToParquetType(src interface{}, pT *parquet.Type) interface{} {
 	if src == nil {
 		return src
@@ -224,14 +228,24 @@ func InterfaceToParquetType(src interface{}, pT *parquet.Type) interface{} {
 		if _, ok := src.(int32); ok {
 			return src
 		} else {
-			return int32(reflect.ValueOf(src).Int())
+			v := reflect.ValueOf(src)
+			if IsUint(v.Kind()) {
+				return uint32(v.Uint())
+			} else {
+				return int32(v.Int())
+			}
 		}
 
 	case parquet.Type_INT64:
 		if _, ok := src.(int64); ok {
 			return src
 		} else {
-			return reflect.ValueOf(src).Int()
+			v := reflect.ValueOf(src)
+			if IsUint(v.Kind()) {
+				return uint64(v.Uint())
+			} else {
+				return int64(v.Int())
+			}
 		}
 
 	case parquet.Type_FLOAT: