You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by gu...@apache.org on 2024/07/03 10:51:37 UTC
(spark-connect-go) branch master updated: [SPARK-48777] Set version to v35 as only major versions are allowed in Go
This is an automated email from the ASF dual-hosted git repository.
gurwls223 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/spark-connect-go.git
The following commit(s) were added to refs/heads/master by this push:
new e9e142e [SPARK-48777] Set version to v35 as only major versions are allowed in Go
e9e142e is described below
commit e9e142e2532fdc9d71218078d86a2fb41a569e17
Author: Martin Grund <ma...@databricks.com>
AuthorDate: Wed Jul 3 19:51:29 2024 +0900
[SPARK-48777] Set version to v35 as only major versions are allowed in Go
### What changes were proposed in this pull request?
The last step from reverting the Bazel migration is to make sure that the module matches the Spark release version.
### Why are the changes needed?
Compatibility
### Does this PR introduce _any_ user-facing change?
No
### How was this patch tested?
Existing tests
Closes #28 from grundprinzip/SPARK-48777-4.
Authored-by: Martin Grund <ma...@databricks.com>
Signed-off-by: Hyukjin Kwon <gu...@apache.org>
---
client/channel/channel.go | 2 +-
client/channel/channel_test.go | 4 ++--
client/sql/dataframe.go | 4 ++--
client/sql/dataframe_test.go | 2 +-
client/sql/dataframereader.go | 2 +-
client/sql/dataframewriter.go | 4 ++--
client/sql/dataframewriter_test.go | 2 +-
client/sql/executeplanclient.go | 4 ++--
client/sql/mocks_test.go | 2 +-
client/sql/sparksession.go | 6 +++---
client/sql/sparksession_test.go | 4 ++--
cmd/spark-connect-example-raw-grpc-client/main.go | 2 +-
cmd/spark-connect-example-spark-session/main.go | 2 +-
go.mod | 2 +-
quick-start.md | 2 +-
15 files changed, 22 insertions(+), 22 deletions(-)
diff --git a/client/channel/channel.go b/client/channel/channel.go
index 2c83c1a..0a83401 100644
--- a/client/channel/channel.go
+++ b/client/channel/channel.go
@@ -27,7 +27,7 @@ import (
"strconv"
"strings"
- "github.com/apache/spark-connect-go/v3.5/client/sparkerrors"
+ "github.com/apache/spark-connect-go/v35/client/sparkerrors"
"golang.org/x/oauth2"
"google.golang.org/grpc"
"google.golang.org/grpc/credentials"
diff --git a/client/channel/channel_test.go b/client/channel/channel_test.go
index 6160a1c..04ea31c 100644
--- a/client/channel/channel_test.go
+++ b/client/channel/channel_test.go
@@ -21,8 +21,8 @@ import (
"strings"
"testing"
- "github.com/apache/spark-connect-go/v3.5/client/channel"
- "github.com/apache/spark-connect-go/v3.5/client/sparkerrors"
+ "github.com/apache/spark-connect-go/v35/client/channel"
+ "github.com/apache/spark-connect-go/v35/client/sparkerrors"
"github.com/stretchr/testify/assert"
)
diff --git a/client/sql/dataframe.go b/client/sql/dataframe.go
index a269b93..6870b49 100644
--- a/client/sql/dataframe.go
+++ b/client/sql/dataframe.go
@@ -26,8 +26,8 @@ import (
"github.com/apache/arrow/go/v12/arrow"
"github.com/apache/arrow/go/v12/arrow/array"
"github.com/apache/arrow/go/v12/arrow/ipc"
- "github.com/apache/spark-connect-go/v3.5/client/sparkerrors"
- proto "github.com/apache/spark-connect-go/v3.5/internal/generated"
+ "github.com/apache/spark-connect-go/v35/client/sparkerrors"
+ proto "github.com/apache/spark-connect-go/v35/internal/generated"
)
// ResultCollector receives a stream of result rows
diff --git a/client/sql/dataframe_test.go b/client/sql/dataframe_test.go
index d4bbec5..42500a1 100644
--- a/client/sql/dataframe_test.go
+++ b/client/sql/dataframe_test.go
@@ -28,7 +28,7 @@ import (
"github.com/apache/arrow/go/v12/arrow/float16"
"github.com/apache/arrow/go/v12/arrow/ipc"
"github.com/apache/arrow/go/v12/arrow/memory"
- proto "github.com/apache/spark-connect-go/v3.5/internal/generated"
+ proto "github.com/apache/spark-connect-go/v35/internal/generated"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
)
diff --git a/client/sql/dataframereader.go b/client/sql/dataframereader.go
index 61030a6..01f7748 100644
--- a/client/sql/dataframereader.go
+++ b/client/sql/dataframereader.go
@@ -1,6 +1,6 @@
package sql
-import proto "github.com/apache/spark-connect-go/v3.5/internal/generated"
+import proto "github.com/apache/spark-connect-go/v35/internal/generated"
// DataFrameReader supports reading data from storage and returning a data frame.
// TODO needs to implement other methods like Option(), Schema(), and also "strong typed"
diff --git a/client/sql/dataframewriter.go b/client/sql/dataframewriter.go
index 38ee85e..ae714c4 100644
--- a/client/sql/dataframewriter.go
+++ b/client/sql/dataframewriter.go
@@ -5,8 +5,8 @@ import (
"fmt"
"strings"
- "github.com/apache/spark-connect-go/v3.5/client/sparkerrors"
- proto "github.com/apache/spark-connect-go/v3.5/internal/generated"
+ "github.com/apache/spark-connect-go/v35/client/sparkerrors"
+ proto "github.com/apache/spark-connect-go/v35/internal/generated"
)
// DataFrameWriter supports writing data frame to storage.
diff --git a/client/sql/dataframewriter_test.go b/client/sql/dataframewriter_test.go
index cf92298..659a061 100644
--- a/client/sql/dataframewriter_test.go
+++ b/client/sql/dataframewriter_test.go
@@ -5,7 +5,7 @@ import (
"io"
"testing"
- proto "github.com/apache/spark-connect-go/v3.5/internal/generated"
+ proto "github.com/apache/spark-connect-go/v35/internal/generated"
"github.com/stretchr/testify/assert"
)
diff --git a/client/sql/executeplanclient.go b/client/sql/executeplanclient.go
index e69f489..d180e5b 100644
--- a/client/sql/executeplanclient.go
+++ b/client/sql/executeplanclient.go
@@ -5,8 +5,8 @@ import (
"fmt"
"io"
- "github.com/apache/spark-connect-go/v3.5/client/sparkerrors"
- proto "github.com/apache/spark-connect-go/v3.5/internal/generated"
+ "github.com/apache/spark-connect-go/v35/client/sparkerrors"
+ proto "github.com/apache/spark-connect-go/v35/internal/generated"
)
type executePlanClient struct {
diff --git a/client/sql/mocks_test.go b/client/sql/mocks_test.go
index aff6f0a..f0bdf3e 100644
--- a/client/sql/mocks_test.go
+++ b/client/sql/mocks_test.go
@@ -4,7 +4,7 @@ import (
"context"
"testing"
- proto "github.com/apache/spark-connect-go/v3.5/internal/generated"
+ proto "github.com/apache/spark-connect-go/v35/internal/generated"
"github.com/stretchr/testify/assert"
"google.golang.org/grpc"
"google.golang.org/grpc/metadata"
diff --git a/client/sql/sparksession.go b/client/sql/sparksession.go
index 24f8b34..8121e9a 100644
--- a/client/sql/sparksession.go
+++ b/client/sql/sparksession.go
@@ -20,9 +20,9 @@ import (
"context"
"fmt"
- "github.com/apache/spark-connect-go/v3.5/client/channel"
- "github.com/apache/spark-connect-go/v3.5/client/sparkerrors"
- proto "github.com/apache/spark-connect-go/v3.5/internal/generated"
+ "github.com/apache/spark-connect-go/v35/client/channel"
+ "github.com/apache/spark-connect-go/v35/client/sparkerrors"
+ proto "github.com/apache/spark-connect-go/v35/internal/generated"
"github.com/google/uuid"
"google.golang.org/grpc/metadata"
)
diff --git a/client/sql/sparksession_test.go b/client/sql/sparksession_test.go
index 01eee57..fee707d 100644
--- a/client/sql/sparksession_test.go
+++ b/client/sql/sparksession_test.go
@@ -4,8 +4,8 @@ import (
"context"
"testing"
- "github.com/apache/spark-connect-go/v3.5/client/sparkerrors"
- proto "github.com/apache/spark-connect-go/v3.5/internal/generated"
+ "github.com/apache/spark-connect-go/v35/client/sparkerrors"
+ proto "github.com/apache/spark-connect-go/v35/internal/generated"
"github.com/stretchr/testify/assert"
)
diff --git a/cmd/spark-connect-example-raw-grpc-client/main.go b/cmd/spark-connect-example-raw-grpc-client/main.go
index 08476b3..21e43ab 100644
--- a/cmd/spark-connect-example-raw-grpc-client/main.go
+++ b/cmd/spark-connect-example-raw-grpc-client/main.go
@@ -22,7 +22,7 @@ import (
"log"
"time"
- proto "github.com/apache/spark-connect-go/v3.5/internal/generated"
+ proto "github.com/apache/spark-connect-go/v35/internal/generated"
"github.com/google/uuid"
"google.golang.org/grpc"
"google.golang.org/grpc/credentials/insecure"
diff --git a/cmd/spark-connect-example-spark-session/main.go b/cmd/spark-connect-example-spark-session/main.go
index 4d06812..885a616 100644
--- a/cmd/spark-connect-example-spark-session/main.go
+++ b/cmd/spark-connect-example-spark-session/main.go
@@ -21,7 +21,7 @@ import (
"flag"
"log"
- "github.com/apache/spark-connect-go/v3.5/client/sql"
+ "github.com/apache/spark-connect-go/v35/client/sql"
)
var (
diff --git a/go.mod b/go.mod
index 96da869..8f8cd69 100644
--- a/go.mod
+++ b/go.mod
@@ -13,7 +13,7 @@
// See the License for the specific language governing permissions and
// limitations under the License.
-module github.com/apache/spark-connect-go/v3.5
+module github.com/apache/spark-connect-go/v35
go 1.21
diff --git a/quick-start.md b/quick-start.md
index 202be73..72bf139 100644
--- a/quick-start.md
+++ b/quick-start.md
@@ -22,7 +22,7 @@ import (
"flag"
"log"
- "github.com/apache/spark-connect-go/v3.5/client/sql"
+ "github.com/apache/spark-connect-go/v35/client/sql"
)
var (
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org