Skip to content

Commit

Permalink
fix lint and integration issue
Browse files Browse the repository at this point in the history
  • Loading branch information
zeroshade committed May 26, 2023
1 parent 3a96942 commit 2e81186
Show file tree
Hide file tree
Showing 3 changed files with 11 additions and 10 deletions.
1 change: 0 additions & 1 deletion dev/archery/archery/integration/datagen.py
Original file line number Diff line number Diff line change
Expand Up @@ -823,7 +823,6 @@ def _get_buffers(self):
]



class StringViewColumn(BinaryViewColumn):

def _encode_value(self, x):
Expand Down
12 changes: 7 additions & 5 deletions go/arrow/compute/executor.go
Original file line number Diff line number Diff line change
Expand Up @@ -88,11 +88,11 @@ var (
// then be modified to set into a context.
//
// The default exec context uses the following values:
// - ChunkSize = DefaultMaxChunkSize (MaxInt64)
// - PreallocContiguous = true
// - Registry = GetFunctionRegistry()
// - ExecChannelSize = 10
// - NumParallel = runtime.NumCPU()
// - ChunkSize = DefaultMaxChunkSize (MaxInt64)
// - PreallocContiguous = true
// - Registry = GetFunctionRegistry()
// - ExecChannelSize = 10
// - NumParallel = runtime.NumCPU()
func DefaultExecCtx() ExecCtx { return defaultExecCtx }

func init() {
Expand Down Expand Up @@ -171,6 +171,8 @@ func addComputeDataPrealloc(dt arrow.DataType, widths []bufferPrealloc) []buffer
return append(widths, bufferPrealloc{bitWidth: 32, addLen: 1})
case arrow.LARGE_BINARY, arrow.LARGE_STRING, arrow.LARGE_LIST:
return append(widths, bufferPrealloc{bitWidth: 64, addLen: 1})
case arrow.STRING_VIEW, arrow.BINARY_VIEW:
return append(widths, bufferPrealloc{bitWidth: arrow.StringHeaderSizeBytes * 8})
}
return widths
}
Expand Down
8 changes: 4 additions & 4 deletions go/arrow/internal/arrjson/arrjson.go
Original file line number Diff line number Diff line change
Expand Up @@ -159,9 +159,9 @@ func typeToJSON(arrowType arrow.DataType) (json.RawMessage, error) {
case *arrow.LargeStringType:
typ = nameJSON{"largeutf8"}
case *arrow.BinaryViewType:
typ = nameJSON{"binary_view"}
typ = nameJSON{"binaryview"}
case *arrow.StringViewType:
typ = nameJSON{"utf8_view"}
typ = nameJSON{"utf8view"}
case *arrow.Date32Type:
typ = unitZoneJSON{Name: "date", Unit: "DAY"}
case *arrow.Date64Type:
Expand Down Expand Up @@ -342,9 +342,9 @@ func typeFromJSON(typ json.RawMessage, children []FieldWrapper) (arrowType arrow
arrowType = arrow.BinaryTypes.String
case "largeutf8":
arrowType = arrow.BinaryTypes.LargeString
case "binary_view":
case "binaryview":
arrowType = arrow.BinaryTypes.BinaryView
case "utf8_view":
case "utf8view":
arrowType = arrow.BinaryTypes.StringView
case "date":
t := unitZoneJSON{}
Expand Down

0 comments on commit 2e81186

Please sign in to comment.