Repository: polarsignals/frostdb
Pull request #506 (2023-08-29 12:52:35)

Update arrow


Patch:
diff --git a/db.go b/db.go
index 2e92bf5..9cf32da 100644
--- a/db.go
+++ b/db.go
@@ -14,7 +14,7 @@ import (
 	"sync/atomic"
 	"time"
 
-	"github.com/apache/arrow/go/v13/arrow/ipc"
+	"github.com/apache/arrow/go/v14/arrow/ipc"
 	"github.com/go-kit/log"
 	"github.com/go-kit/log/level"
 	"github.com/google/btree"
diff --git a/dynparquet/example.go b/dynparquet/example.go
index 8648067..0579233 100644
--- a/dynparquet/example.go
+++ b/dynparquet/example.go
@@ -5,9 +5,9 @@ import (
 	"sort"
 	"testing"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 	"github.com/google/uuid"
 	"github.com/parquet-go/parquet-go"
 	"google.golang.org/protobuf/proto"
diff --git a/examples/aggregations/aggregations.go b/examples/aggregations/aggregations.go
index fa87ce2..3dc63d1 100644
--- a/examples/aggregations/aggregations.go
+++ b/examples/aggregations/aggregations.go
@@ -4,8 +4,8 @@ import (
 	"context"
 	"fmt"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 
 	"github.com/polarsignals/frostdb"
 	schemapb "github.com/polarsignals/frostdb/gen/proto/go/frostdb/schema/v1alpha1"
diff --git a/examples/simple/simple.go b/examples/simple/simple.go
index cb5635a..79e3723 100644
--- a/examples/simple/simple.go
+++ b/examples/simple/simple.go
@@ -4,8 +4,8 @@ import (
 	"context"
 	"fmt"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 	"google.golang.org/protobuf/proto"
 
 	"github.com/polarsignals/frostdb"
diff --git a/go.mod b/go.mod
index 351c6d1..b0ad5de 100644
--- a/go.mod
+++ b/go.mod
@@ -4,7 +4,7 @@ go 1.19
 
 require (
 	github.com/RoaringBitmap/roaring v0.9.4
-	github.com/apache/arrow/go/v13 v13.0.0-20230725201451-5a9240fd28e1
+	github.com/apache/arrow/go/v14 v14.0.0-20230829105931-29819425f428
 	github.com/cespare/xxhash/v2 v2.2.0
 	github.com/cockroachdb/datadriven v1.0.2
 	github.com/dgryski/go-metro v0.0.0-20211217172704-adc40b04c140
diff --git a/go.sum b/go.sum
index 5c1d8ed..490e126 100644
--- a/go.sum
+++ b/go.sum
@@ -4,8 +4,8 @@ github.com/RoaringBitmap/roaring v0.9.4 h1:ckvZSX5gwCRaJYBNe7syNawCU5oruY9gQmjXl
 github.com/RoaringBitmap/roaring v0.9.4/go.mod h1:icnadbWcNyfEHlYdr+tDlOTih1Bf/h+rzPpv4sbomAA=
 github.com/andybalholm/brotli v1.0.5 h1:8uQZIdzKmjc/iuPu7O2ioW48L81FgatrcpfFmiq/cCs=
 github.com/andybalholm/brotli v1.0.5/go.mod h1:fO7iG3H7G2nSZ7m0zPUDn85XEX2GTukHGRSepvi9Eig=
-github.com/apache/arrow/go/v13 v13.0.0-20230725201451-5a9240fd28e1 h1:fRZe9ew77QcD7d00X1ZgvAreRJF3yzBflEUEMBv2+rM=
-github.com/apache/arrow/go/v13 v13.0.0-20230725201451-5a9240fd28e1/go.mod h1:W69eByFNO0ZR30q1/7Sr9d83zcVZmF2MiP3fFYAWJOc=
+github.com/apache/arrow/go/v14 v14.0.0-20230829105931-29819425f428 h1:sBac6Mt0xdDR6Ekbq6PKuMShpSuyyoqfdYJ0PsQRtds=
+github.com/apache/arrow/go/v14 v14.0.0-20230829105931-29819425f428/go.mod h1:QQ18IZU2Y3BFqHtF2HyvrjEEmk8TyzzmXgUVjep3bCw=
 github.com/benbjohnson/clock v1.1.0 h1:Q92kusRqC1XV2MjkWETPvjJVqKetz1OzxZB7mHJLju8=
 github.com/benbjohnson/clock v1.1.0/go.mod h1:J11/hYXuz8f4ySSvYwY0FKfm+ezbsZBKZxNJlLklBHA=
 github.com/benbjohnson/immutable v0.4.0 h1:CTqXbEerYso8YzVPxmWxh2gnoRQbbB9X1quUC8+vGZA=
diff --git a/granule.go b/granule.go
index 4641c25..91e190b 100644
--- a/granule.go
+++ b/granule.go
@@ -5,7 +5,7 @@ import (
 	"fmt"
 	"sync/atomic"
 
-	"github.com/apache/arrow/go/v13/arrow"
+	"github.com/apache/arrow/go/v14/arrow"
 	"github.com/google/btree"
 
 	"github.com/polarsignals/frostdb/dynparquet"
diff --git a/parts/part.go b/parts/part.go
index 1b90151..029bba5 100644
--- a/parts/part.go
+++ b/parts/part.go
@@ -5,7 +5,7 @@ import (
 	"fmt"
 	"math"
 
-	"github.com/apache/arrow/go/v13/arrow"
+	"github.com/apache/arrow/go/v14/arrow"
 	"github.com/parquet-go/parquet-go"
 
 	"github.com/polarsignals/frostdb/dynparquet"
diff --git a/pqarrow/arrow.go b/pqarrow/arrow.go
index 6fc9716..68e6f8a 100644
--- a/pqarrow/arrow.go
+++ b/pqarrow/arrow.go
@@ -7,9 +7,9 @@ import (
 	"sort"
 	"sync"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 	"github.com/parquet-go/parquet-go"
 
 	"github.com/polarsignals/frostdb/dynparquet"
diff --git a/pqarrow/arrowutils/arrow.go b/pqarrow/arrowutils/arrow.go
index 77556f6..2665881 100644
--- a/pqarrow/arrowutils/arrow.go
+++ b/pqarrow/arrowutils/arrow.go
@@ -3,7 +3,7 @@ package arrowutils
 import (
 	"fmt"
 
-	"github.com/apache/arrow/go/v13/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/array"
 )
 
 func ForEachValueInList(index int, arr *array.List, iterator func(int, any)) error {
diff --git a/pqarrow/arrowutils/groupranges.go b/pqarrow/arrowutils/groupranges.go
index 24bf98d..f469352 100644
--- a/pqarrow/arrowutils/groupranges.go
+++ b/pqarrow/arrowutils/groupranges.go
@@ -6,8 +6,8 @@ import (
 	"fmt"
 	"strings"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
 )
 
 // GetGroupsAndOrderedSetRanges returns a min-heap of group ranges and ordered
diff --git a/pqarrow/arrowutils/merge.go b/pqarrow/arrowutils/merge.go
index 03621f8..3d40246 100644
--- a/pqarrow/arrowutils/merge.go
+++ b/pqarrow/arrowutils/merge.go
@@ -5,9 +5,9 @@ import (
 	"container/heap"
 	"fmt"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 
 	"github.com/polarsignals/frostdb/pqarrow/builder"
 )
diff --git a/pqarrow/arrowutils/nullarray.go b/pqarrow/arrowutils/nullarray.go
index 692868b..ff5a9c6 100644
--- a/pqarrow/arrowutils/nullarray.go
+++ b/pqarrow/arrowutils/nullarray.go
@@ -1,8 +1,8 @@
 package arrowutils
 
 import (
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 
 	"github.com/polarsignals/frostdb/pqarrow/builder"
 )
diff --git a/pqarrow/arrowutils/utils.go b/pqarrow/arrowutils/utils.go
index c966feb..f648620 100644
--- a/pqarrow/arrowutils/utils.go
+++ b/pqarrow/arrowutils/utils.go
@@ -1,9 +1,9 @@
 package arrowutils
 
 import (
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 )
 
 // ArrayConcatenator is an object that helps callers keep track of a slice of
diff --git a/pqarrow/builder/listbuilder.go b/pqarrow/builder/listbuilder.go
index 585ca93..d58ee82 100644
--- a/pqarrow/builder/listbuilder.go
+++ b/pqarrow/builder/listbuilder.go
@@ -21,10 +21,10 @@ package builder
 import (
 	"sync/atomic"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
-	"github.com/apache/arrow/go/v13/arrow/bitutil"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/bitutil"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 )
 
 const (
diff --git a/pqarrow/builder/optbuilders.go b/pqarrow/builder/optbuilders.go
index c174979..2fc789c 100644
--- a/pqarrow/builder/optbuilders.go
+++ b/pqarrow/builder/optbuilders.go
@@ -7,10 +7,10 @@ import (
 	"sync/atomic"
 	"unsafe"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
-	"github.com/apache/arrow/go/v13/arrow/bitutil"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/bitutil"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 	"github.com/parquet-go/parquet-go"
 )
 
diff --git a/pqarrow/builder/recordbuilder.go b/pqarrow/builder/recordbuilder.go
index ba06097..4cea2a4 100644
--- a/pqarrow/builder/recordbuilder.go
+++ b/pqarrow/builder/recordbuilder.go
@@ -4,9 +4,9 @@ import (
 	"fmt"
 	"sync/atomic"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 )
 
 // The code in this file is based heavily on Apache arrow's array.RecordBuilder,
diff --git a/pqarrow/builder/utils.go b/pqarrow/builder/utils.go
index 20c181f..197bd23 100644
--- a/pqarrow/builder/utils.go
+++ b/pqarrow/builder/utils.go
@@ -4,9 +4,9 @@ import (
 	"fmt"
 	"unsafe"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 )
 
 func NewBuilder(mem memory.Allocator, t arrow.DataType) ColumnBuilder {
diff --git a/pqarrow/convert/convert.go b/pqarrow/convert/convert.go
index 7881992..0b52da4 100644
--- a/pqarrow/convert/convert.go
+++ b/pqarrow/convert/convert.go
@@ -3,7 +3,7 @@ package convert
 import (
 	"errors"
 
-	"github.com/apache/arrow/go/v13/arrow"
+	"github.com/apache/arrow/go/v14/arrow"
 	"github.com/parquet-go/parquet-go"
 	"github.com/parquet-go/parquet-go/format"
 
diff --git a/pqarrow/parquet.go b/pqarrow/parquet.go
index 66517ff..0f35099 100644
--- a/pqarrow/parquet.go
+++ b/pqarrow/parquet.go
@@ -5,9 +5,9 @@ import (
 	"io"
 	"strings"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
-	"github.com/apache/arrow/go/v13/arrow/scalar"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/scalar"
 	"github.com/parquet-go/parquet-go"
 
 	"github.com/polarsignals/frostdb/bufutils"
diff --git a/pqarrow/writer/writer.go b/pqarrow/writer/writer.go
index 56894b8..f030639 100644
--- a/pqarrow/writer/writer.go
+++ b/pqarrow/writer/writer.go
@@ -4,7 +4,7 @@ import (
 	"fmt"
 	"io"
 
-	"github.com/apache/arrow/go/v13/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/array"
 	"github.com/parquet-go/parquet-go"
 
 	"github.com/polarsignals/frostdb/pqarrow/builder"
diff --git a/query/engine.go b/query/engine.go
index 018bd42..a972555 100644
--- a/query/engine.go
+++ b/query/engine.go
@@ -3,8 +3,8 @@ package query
 import (
 	"context"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 	"go.opentelemetry.io/otel/trace"
 
 	"github.com/polarsignals/frostdb/query/logicalplan"
diff --git a/query/logicalplan/builder.go b/query/logicalplan/builder.go
index a003c7d..26b0b30 100644
--- a/query/logicalplan/builder.go
+++ b/query/logicalplan/builder.go
@@ -1,7 +1,7 @@
 package logicalplan
 
 import (
-	"github.com/apache/arrow/go/v13/arrow"
+	"github.com/apache/arrow/go/v14/arrow"
 	"github.com/parquet-go/parquet-go"
 )
 
diff --git a/query/logicalplan/expr.go b/query/logicalplan/expr.go
index e1f0dcb..972be00 100644
--- a/query/logicalplan/expr.go
+++ b/query/logicalplan/expr.go
@@ -5,8 +5,8 @@ import (
 	"strings"
 	"time"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/scalar"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/scalar"
 	"github.com/parquet-go/parquet-go"
 
 	"github.com/polarsignals/frostdb/pqarrow/convert"
diff --git a/query/logicalplan/logicalplan.go b/query/logicalplan/logicalplan.go
index fc82356..5586bb8 100644
--- a/query/logicalplan/logicalplan.go
+++ b/query/logicalplan/logicalplan.go
@@ -5,8 +5,8 @@ import (
 	"fmt"
 	"strings"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 
 	"github.com/polarsignals/frostdb/dynparquet"
 )
diff --git a/query/logicalplan/validate.go b/query/logicalplan/validate.go
index 83e3a67..fc35132 100644
--- a/query/logicalplan/validate.go
+++ b/query/logicalplan/validate.go
@@ -5,7 +5,7 @@ import (
 	"reflect"
 	"strings"
 
-	"github.com/apache/arrow/go/v13/arrow/scalar"
+	"github.com/apache/arrow/go/v14/arrow/scalar"
 	"github.com/parquet-go/parquet-go/format"
 )
 
diff --git a/query/memory.go b/query/memory.go
index 658625b..9d197d8 100644
--- a/query/memory.go
+++ b/query/memory.go
@@ -6,7 +6,7 @@ import (
 	"sync"
 	"sync/atomic"
 
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 	"github.com/prometheus/client_golang/prometheus"
 	"github.com/prometheus/client_golang/prometheus/promauto"
 )
diff --git a/query/physicalplan/aggregate.go b/query/physicalplan/aggregate.go
index 635f9fe..89849c3 100644
--- a/query/physicalplan/aggregate.go
+++ b/query/physicalplan/aggregate.go
@@ -7,11 +7,11 @@ import (
 	"hash/maphash"
 	"strings"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
-	"github.com/apache/arrow/go/v13/arrow/math"
-	"github.com/apache/arrow/go/v13/arrow/memory"
-	"github.com/apache/arrow/go/v13/arrow/scalar"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/math"
+	"github.com/apache/arrow/go/v14/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow/scalar"
 	"github.com/cespare/xxhash/v2"
 	"github.com/dgryski/go-metro"
 	"go.opentelemetry.io/otel/attribute"
diff --git a/query/physicalplan/binaryscalarexpr.go b/query/physicalplan/binaryscalarexpr.go
index 95c24c8..46109ae 100644
--- a/query/physicalplan/binaryscalarexpr.go
+++ b/query/physicalplan/binaryscalarexpr.go
@@ -5,9 +5,9 @@ import (
 	"errors"
 	"fmt"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
-	"github.com/apache/arrow/go/v13/arrow/scalar"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/scalar"
 
 	"github.com/polarsignals/frostdb/query/logicalplan"
 )
diff --git a/query/physicalplan/distinct.go b/query/physicalplan/distinct.go
index 738e592..33f08cb 100644
--- a/query/physicalplan/distinct.go
+++ b/query/physicalplan/distinct.go
@@ -7,10 +7,10 @@ import (
 	"strings"
 	"sync"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
-	"github.com/apache/arrow/go/v13/arrow/memory"
-	"github.com/apache/arrow/go/v13/arrow/scalar"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow/scalar"
 	"go.opentelemetry.io/otel/trace"
 
 	"github.com/polarsignals/frostdb/pqarrow/builder"
diff --git a/query/physicalplan/filter.go b/query/physicalplan/filter.go
index 59de5b4..2a9a8fb 100644
--- a/query/physicalplan/filter.go
+++ b/query/physicalplan/filter.go
@@ -7,10 +7,10 @@ import (
 	"regexp"
 
 	"github.com/RoaringBitmap/roaring"
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
-	"github.com/apache/arrow/go/v13/arrow/memory"
-	"github.com/apache/arrow/go/v13/arrow/scalar"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow/scalar"
 	"go.opentelemetry.io/otel/trace"
 
 	"github.com/polarsignals/frostdb/query/logicalplan"
diff --git a/query/physicalplan/ordered_aggregate.go b/query/physicalplan/ordered_aggregate.go
index b03e0e5..47e30fe 100644
--- a/query/physicalplan/ordered_aggregate.go
+++ b/query/physicalplan/ordered_aggregate.go
@@ -6,9 +6,9 @@ import (
 	"fmt"
 	"strings"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 	"go.opentelemetry.io/otel/trace"
 
 	"github.com/polarsignals/frostdb/pqarrow/arrowutils"
diff --git a/query/physicalplan/ordered_synchronizer.go b/query/physicalplan/ordered_synchronizer.go
index 050ee97..10e1f43 100644
--- a/query/physicalplan/ordered_synchronizer.go
+++ b/query/physicalplan/ordered_synchronizer.go
@@ -6,9 +6,9 @@ import (
 	"fmt"
 	"sync"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 
 	"github.com/polarsignals/frostdb/dynparquet"
 	"github.com/polarsignals/frostdb/pqarrow/arrowutils"
diff --git a/query/physicalplan/physicalplan.go b/query/physicalplan/physicalplan.go
index 805ddb3..4c54955 100644
--- a/query/physicalplan/physicalplan.go
+++ b/query/physicalplan/physicalplan.go
@@ -5,8 +5,8 @@ import (
 	"fmt"
 	"runtime"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 	"go.opentelemetry.io/otel/attribute"
 	"go.opentelemetry.io/otel/trace"
 	"golang.org/x/sync/errgroup"
diff --git a/query/physicalplan/project.go b/query/physicalplan/project.go
index bbffabf..09b1a96 100644
--- a/query/physicalplan/project.go
+++ b/query/physicalplan/project.go
@@ -5,9 +5,9 @@ import (
 	"fmt"
 	"strings"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 	"go.opentelemetry.io/otel/trace"
 
 	"github.com/polarsignals/frostdb/query/logicalplan"
diff --git a/query/physicalplan/regexpfilter.go b/query/physicalplan/regexpfilter.go
index f28d61b..ab9989b 100644
--- a/query/physicalplan/regexpfilter.go
+++ b/query/physicalplan/regexpfilter.go
@@ -4,8 +4,8 @@ import (
 	"fmt"
 	"regexp"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
 )
 
 type RegExpFilter struct {
diff --git a/query/physicalplan/synchronize.go b/query/physicalplan/synchronize.go
index 21c043e..35f1894 100644
--- a/query/physicalplan/synchronize.go
+++ b/query/physicalplan/synchronize.go
@@ -6,7 +6,7 @@ import (
 	"sync"
 	"sync/atomic"
 
-	"github.com/apache/arrow/go/v13/arrow"
+	"github.com/apache/arrow/go/v14/arrow"
 )
 
 // Synchronizer is used to combine the results of multiple parallel streams
diff --git a/snapshot.go b/snapshot.go
index cc7d0bc..844dbdb 100644
--- a/snapshot.go
+++ b/snapshot.go
@@ -16,8 +16,8 @@ import (
 	"github.com/prometheus/client_golang/prometheus"
 	"github.com/prometheus/client_golang/prometheus/promauto"
 
-	"github.com/apache/arrow/go/v13/arrow/ipc"
-	"github.com/apache/arrow/go/v13/arrow/util"
+	"github.com/apache/arrow/go/v14/arrow/ipc"
+	"github.com/apache/arrow/go/v14/arrow/util"
 	"github.com/go-kit/log/level"
 	"github.com/google/btree"
 	"github.com/oklog/ulid"
diff --git a/sqlparse/visitor.go b/sqlparse/visitor.go
index 0cda569..462a138 100644
--- a/sqlparse/visitor.go
+++ b/sqlparse/visitor.go
@@ -5,7 +5,7 @@ import (
 	"strings"
 	"time"
 
-	"github.com/apache/arrow/go/v13/arrow/scalar"
+	"github.com/apache/arrow/go/v14/arrow/scalar"
 	"github.com/pingcap/tidb/parser/ast"
 	"github.com/pingcap/tidb/parser/opcode"
 	"github.com/pingcap/tidb/parser/test_driver"
diff --git a/table.go b/table.go
index 03e01da..390abeb 100644
--- a/table.go
+++ b/table.go
@@ -18,10 +18,10 @@ import (
 	"sync/atomic"
 	"time"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
-	"github.com/apache/arrow/go/v13/arrow/memory"
-	"github.com/apache/arrow/go/v13/arrow/util"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow/util"
 	"github.com/dustin/go-humanize"
 	"github.com/go-kit/log"
 	"github.com/go-kit/log/level"
diff --git a/wal/wal.go b/wal/wal.go
index ce5db01..97b4d45 100644
--- a/wal/wal.go
+++ b/wal/wal.go
@@ -10,8 +10,8 @@ import (
 	"sync"
 	"time"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/ipc"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/ipc"
 	"github.com/go-kit/log"
 	"github.com/go-kit/log/level"
 	"github.com/polarsignals/wal"


Test patch:
diff --git a/aggregate_test.go b/aggregate_test.go
index 9400e0c..5c2b712 100644
--- a/aggregate_test.go
+++ b/aggregate_test.go
@@ -7,9 +7,9 @@ import (
 	"strconv"
 	"testing"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 	"github.com/google/uuid"
 	"github.com/stretchr/testify/require"
 
diff --git a/bench_test.go b/bench_test.go
index 01e79fd..f115d60 100644
--- a/bench_test.go
+++ b/bench_test.go
@@ -10,9 +10,9 @@ import (
 	"testing"
 	"time"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 	"github.com/google/uuid"
 	"github.com/stretchr/testify/require"
 
diff --git a/db_test.go b/db_test.go
index 973ba74..cd5a09d 100644
--- a/db_test.go
+++ b/db_test.go
@@ -11,8 +11,8 @@ import (
 	"testing"
 	"time"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 	"github.com/go-kit/log/level"
 	"github.com/google/uuid"
 	"github.com/parquet-go/parquet-go"
diff --git a/logictest/logic_test.go b/logictest/logic_test.go
index 28047e0..e0235bb 100644
--- a/logictest/logic_test.go
+++ b/logictest/logic_test.go
@@ -4,7 +4,7 @@ import (
 	"context"
 	"testing"
 
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 	"github.com/cockroachdb/datadriven"
 	"github.com/stretchr/testify/require"
 
diff --git a/logictest/runner.go b/logictest/runner.go
index dd82695..6f755de 100644
--- a/logictest/runner.go
+++ b/logictest/runner.go
@@ -9,9 +9,9 @@ import (
 	"strings"
 	"text/tabwriter"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 	"github.com/cockroachdb/datadriven"
 	"github.com/google/uuid"
 	"github.com/parquet-go/parquet-go"
diff --git a/pqarrow/arrow_test.go b/pqarrow/arrow_test.go
index 0c9c02a..d39a88d 100644
--- a/pqarrow/arrow_test.go
+++ b/pqarrow/arrow_test.go
@@ -5,9 +5,9 @@ import (
 	"fmt"
 	"testing"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 	"github.com/google/uuid"
 	"github.com/parquet-go/parquet-go"
 	"github.com/stretchr/testify/require"
diff --git a/pqarrow/arrowutils/merge_test.go b/pqarrow/arrowutils/merge_test.go
index 4c9cf84..082f85a 100644
--- a/pqarrow/arrowutils/merge_test.go
+++ b/pqarrow/arrowutils/merge_test.go
@@ -3,9 +3,9 @@ package arrowutils_test
 import (
 	"testing"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 	"github.com/stretchr/testify/require"
 
 	"github.com/polarsignals/frostdb/pqarrow/arrowutils"
diff --git a/pqarrow/builder/optbuilders_test.go b/pqarrow/builder/optbuilders_test.go
index ef39446..8f524ed 100644
--- a/pqarrow/builder/optbuilders_test.go
+++ b/pqarrow/builder/optbuilders_test.go
@@ -6,9 +6,9 @@ import (
 	"math/rand"
 	"testing"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 	"github.com/stretchr/testify/require"
 
 	"github.com/polarsignals/frostdb/pqarrow/builder"
diff --git a/pqarrow/convert/convert_test.go b/pqarrow/convert/convert_test.go
index 6334809..2e1d5ae 100644
--- a/pqarrow/convert/convert_test.go
+++ b/pqarrow/convert/convert_test.go
@@ -4,7 +4,7 @@ import (
 	"fmt"
 	"testing"
 
-	"github.com/apache/arrow/go/v13/arrow"
+	"github.com/apache/arrow/go/v14/arrow"
 	"github.com/parquet-go/parquet-go"
 	"github.com/stretchr/testify/require"
 )
diff --git a/query/logicalplan/builder_test.go b/query/logicalplan/builder_test.go
index 30021c1..5fd3c22 100644
--- a/query/logicalplan/builder_test.go
+++ b/query/logicalplan/builder_test.go
@@ -3,7 +3,7 @@ package logicalplan
 import (
 	"testing"
 
-	"github.com/apache/arrow/go/v13/arrow/scalar"
+	"github.com/apache/arrow/go/v14/arrow/scalar"
 	"github.com/stretchr/testify/require"
 
 	"github.com/polarsignals/frostdb/dynparquet"
diff --git a/query/logicalplan/logicalplan_test.go b/query/logicalplan/logicalplan_test.go
index 5315dd7..0986381 100644
--- a/query/logicalplan/logicalplan_test.go
+++ b/query/logicalplan/logicalplan_test.go
@@ -4,7 +4,7 @@ import (
 	"context"
 	"testing"
 
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 	"github.com/stretchr/testify/require"
 
 	"github.com/polarsignals/frostdb/dynparquet"
diff --git a/query/logicalplan/optimize_test.go b/query/logicalplan/optimize_test.go
index 1ca9993..fd9c3bb 100644
--- a/query/logicalplan/optimize_test.go
+++ b/query/logicalplan/optimize_test.go
@@ -5,7 +5,7 @@ import (
 
 	"github.com/polarsignals/frostdb/dynparquet"
 
-	"github.com/apache/arrow/go/v13/arrow/scalar"
+	"github.com/apache/arrow/go/v14/arrow/scalar"
 	"github.com/stretchr/testify/require"
 )
 
diff --git a/query/physicalplan/aggregate_test.go b/query/physicalplan/aggregate_test.go
index d273577..2e18fb8 100644
--- a/query/physicalplan/aggregate_test.go
+++ b/query/physicalplan/aggregate_test.go
@@ -6,9 +6,9 @@ import (
 	"math/rand"
 	"testing"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 	"github.com/stretchr/testify/require"
 	"go.opentelemetry.io/otel/trace"
 
diff --git a/query/physicalplan/ordered_aggregate_test.go b/query/physicalplan/ordered_aggregate_test.go
index 3bfa686..9973685 100644
--- a/query/physicalplan/ordered_aggregate_test.go
+++ b/query/physicalplan/ordered_aggregate_test.go
@@ -5,9 +5,9 @@ import (
 	"fmt"
 	"testing"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 	"github.com/stretchr/testify/require"
 	"go.opentelemetry.io/otel/trace"
 
diff --git a/query/physicalplan/ordered_synchronizer_test.go b/query/physicalplan/ordered_synchronizer_test.go
index 5850007..95ef61e 100644
--- a/query/physicalplan/ordered_synchronizer_test.go
+++ b/query/physicalplan/ordered_synchronizer_test.go
@@ -6,9 +6,9 @@ import (
 	"sync/atomic"
 	"testing"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 	"github.com/stretchr/testify/require"
 	"golang.org/x/sync/errgroup"
 
diff --git a/query/physicalplan/physicalplan_test.go b/query/physicalplan/physicalplan_test.go
index fdfb5d5..23f3b18 100644
--- a/query/physicalplan/physicalplan_test.go
+++ b/query/physicalplan/physicalplan_test.go
@@ -4,8 +4,8 @@ import (
 	"context"
 	"testing"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 	"github.com/stretchr/testify/require"
 	"go.opentelemetry.io/otel/trace"
 
diff --git a/query/physicalplan/synchronize_test.go b/query/physicalplan/synchronize_test.go
index ece2030..f27ba61 100644
--- a/query/physicalplan/synchronize_test.go
+++ b/query/physicalplan/synchronize_test.go
@@ -5,9 +5,9 @@ import (
 	"sync"
 	"testing"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 	"github.com/stretchr/testify/require"
 )
 
diff --git a/snapshot_test.go b/snapshot_test.go
index b360cb7..823ec48 100644
--- a/snapshot_test.go
+++ b/snapshot_test.go
@@ -9,9 +9,9 @@ import (
 	"testing"
 	"time"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
-	"github.com/apache/arrow/go/v13/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/memory"
 	"github.com/stretchr/testify/require"
 	"golang.org/x/sync/errgroup"
 
diff --git a/table_test.go b/table_test.go
index e3f6934..875b937 100644
--- a/table_test.go
+++ b/table_test.go
@@ -11,10 +11,10 @@ import (
 	"sync/atomic"
 	"testing"
 
-	"github.com/apache/arrow/go/v13/arrow"
-	"github.com/apache/arrow/go/v13/arrow/array"
-	"github.com/apache/arrow/go/v13/arrow/memory"
-	"github.com/apache/arrow/go/v13/arrow/util"
+	"github.com/apache/arrow/go/v14/arrow"
+	"github.com/apache/arrow/go/v14/arrow/array"
+	"github.com/apache/arrow/go/v14/arrow/memory"
+	"github.com/apache/arrow/go/v14/arrow/util"
 	"github.com/go-kit/log"
 	"github.com/go-kit/log/level"
 	"github.com/google/uuid"