fix plain tag

xitongsys · Sep 23, 2019 · 492ed2d · 492ed2d
1 parent b4224db
commit 492ed2d
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/common/common.go b/common/common.go
@@ -157,6 +157,8 @@ func StringToTag(tag string) *Tag {
 			}
 		case "encoding":
 			switch strings.ToLower(val) {
+			 case "plain":
+			 	mp.Encoding = parquet.Encoding_PLAIN
 			case "rle":
 				mp.Encoding = parquet.Encoding_RLE
 			case "delta_binary_packed":

diff --git a/example/local_flat.go b/example/local_flat.go
@@ -12,7 +12,7 @@ import (
 
 type Student struct {
 	Name    string  `parquet:"name=name, type=UTF8, encoding=PLAIN_DICTIONARY"`
-	Age     int32   `parquet:"name=age, type=INT32"`
+	Age     int32   `parquet:"name=age, type=INT32, encoding=PLAIN"`
 	Id      int64   `parquet:"name=id, type=INT64"`
 	Weight  float32 `parquet:"name=weight, type=FLOAT"`
 	Sex     bool    `parquet:"name=sex, type=BOOLEAN"`