Skip to content

Commit

Permalink
format
Browse files Browse the repository at this point in the history
  • Loading branch information
xitongsys committed Dec 5, 2021
1 parent 98acb50 commit 0fc1561
Show file tree
Hide file tree
Showing 6 changed files with 8 additions and 4 deletions.
1 change: 1 addition & 0 deletions compress/gzip.go
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
//go:build !no_gzip
// +build !no_gzip

package compress
Expand Down
1 change: 1 addition & 0 deletions compress/lz4.go
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
//go:build !no_lz4
// +build !no_lz4

package compress
Expand Down
1 change: 1 addition & 0 deletions compress/snappy.go
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
//go:build !no_snappy
// +build !no_snappy

package compress
Expand Down
1 change: 1 addition & 0 deletions compress/zstd.go
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
//go:build !no_zstd
// +build !no_zstd

package compress
Expand Down
6 changes: 3 additions & 3 deletions marshal/unmarshal.go
Original file line number Diff line number Diff line change
Expand Up @@ -115,7 +115,7 @@ func Unmarshal(tableMap *map[string]*layout.Table, bgn int, end int, dstInterfac
for i := bgn; i < end; i++ {
rl, dl, val := table.RepetitionLevels[i], table.DefinitionLevels[i], table.Values[i]
po, index := root, prefixIndex
OuterLoop:
OuterLoop:
for index < len(path) {
schemaIndex := schemaIndexs[index]
_, cT := schemaHandler.SchemaElements[schemaIndex].Type, schemaHandler.SchemaElements[schemaIndex].ConvertedType
Expand Down Expand Up @@ -173,7 +173,7 @@ OuterLoop:
po.Set(reflect.MakeMap(poType))
}

mapRec, ok := mapRecords[po];
mapRec, ok := mapRecords[po]
if !ok {
mapRec = &MapRecord{
KeyValues: []KeyValue{},
Expand Down Expand Up @@ -229,7 +229,7 @@ OuterLoop:
if prevType != poType || name != prevFieldName {
prevType = poType
prevFieldName = name
f, _ := prevType.FieldByName(name)
f, _ := prevType.FieldByName(name)
prevFieldIndex = f.Index
}
po = po.FieldByIndex(prevFieldIndex)
Expand Down
2 changes: 1 addition & 1 deletion tool/parquet-tools/parquet-tools.go
Original file line number Diff line number Diff line change
Expand Up @@ -113,7 +113,7 @@ func main() {
if cnt > 1000 {
cnt = 1000
}

err = pr.SkipRows(*skipCount)
if err != nil {
fmt.Fprintf(os.Stderr, "Can't skip[: %s\n", err)
Expand Down

0 comments on commit 0fc1561

Please sign in to comment.