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:28:44 UTC
(spark-connect-go) branch master updated: [SPARK-48777] Adjusting the version identifier to v3.5 to match Spark
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 9dc64df [SPARK-48777] Adjusting the version identifier to v3.5 to match Spark
9dc64df is described below
commit 9dc64df152039f4edaa1c3fae070804c7256741a
Author: Martin Grund <ma...@databricks.com>
AuthorDate: Wed Jul 3 19:28:38 2024 +0900
[SPARK-48777] Adjusting the version identifier to v3.5 to match Spark
### 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 #26 from grundprinzip/SPARK-48777-3.
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 b5d459d..2c83c1a 100644
--- a/client/channel/channel.go
+++ b/client/channel/channel.go
@@ -27,7 +27,7 @@ import (
"strconv"
"strings"
- "github.com/apache/spark-connect-go/v1/client/sparkerrors"
+ "github.com/apache/spark-connect-go/v3.5/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 1395d99..6160a1c 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/v1/client/channel"
- "github.com/apache/spark-connect-go/v1/client/sparkerrors"
+ "github.com/apache/spark-connect-go/v3.5/client/channel"
+ "github.com/apache/spark-connect-go/v3.5/client/sparkerrors"
"github.com/stretchr/testify/assert"
)
diff --git a/client/sql/dataframe.go b/client/sql/dataframe.go
index a7f5f51..a269b93 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/v1/client/sparkerrors"
- proto "github.com/apache/spark-connect-go/v1/internal/generated"
+ "github.com/apache/spark-connect-go/v3.5/client/sparkerrors"
+ proto "github.com/apache/spark-connect-go/v3.5/internal/generated"
)
// ResultCollector receives a stream of result rows
diff --git a/client/sql/dataframe_test.go b/client/sql/dataframe_test.go
index 98675fd..d4bbec5 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/v1/internal/generated"
+ proto "github.com/apache/spark-connect-go/v3.5/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 59f21ff..61030a6 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/v1/internal/generated"
+import proto "github.com/apache/spark-connect-go/v3.5/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 dee74e8..38ee85e 100644
--- a/client/sql/dataframewriter.go
+++ b/client/sql/dataframewriter.go
@@ -5,8 +5,8 @@ import (
"fmt"
"strings"
- "github.com/apache/spark-connect-go/v1/client/sparkerrors"
- proto "github.com/apache/spark-connect-go/v1/internal/generated"
+ "github.com/apache/spark-connect-go/v3.5/client/sparkerrors"
+ proto "github.com/apache/spark-connect-go/v3.5/internal/generated"
)
// DataFrameWriter supports writing data frame to storage.
diff --git a/client/sql/dataframewriter_test.go b/client/sql/dataframewriter_test.go
index 649e013..cf92298 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/v1/internal/generated"
+ proto "github.com/apache/spark-connect-go/v3.5/internal/generated"
"github.com/stretchr/testify/assert"
)
diff --git a/client/sql/executeplanclient.go b/client/sql/executeplanclient.go
index ece0a20..e69f489 100644
--- a/client/sql/executeplanclient.go
+++ b/client/sql/executeplanclient.go
@@ -5,8 +5,8 @@ import (
"fmt"
"io"
- "github.com/apache/spark-connect-go/v1/client/sparkerrors"
- proto "github.com/apache/spark-connect-go/v1/internal/generated"
+ "github.com/apache/spark-connect-go/v3.5/client/sparkerrors"
+ proto "github.com/apache/spark-connect-go/v3.5/internal/generated"
)
type executePlanClient struct {
diff --git a/client/sql/mocks_test.go b/client/sql/mocks_test.go
index 9d87d50..aff6f0a 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/v1/internal/generated"
+ proto "github.com/apache/spark-connect-go/v3.5/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 e1ecef8..24f8b34 100644
--- a/client/sql/sparksession.go
+++ b/client/sql/sparksession.go
@@ -20,9 +20,9 @@ import (
"context"
"fmt"
- "github.com/apache/spark-connect-go/v1/client/channel"
- "github.com/apache/spark-connect-go/v1/client/sparkerrors"
- proto "github.com/apache/spark-connect-go/v1/internal/generated"
+ "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/google/uuid"
"google.golang.org/grpc/metadata"
)
diff --git a/client/sql/sparksession_test.go b/client/sql/sparksession_test.go
index 0a3b105..01eee57 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/v1/client/sparkerrors"
- proto "github.com/apache/spark-connect-go/v1/internal/generated"
+ "github.com/apache/spark-connect-go/v3.5/client/sparkerrors"
+ proto "github.com/apache/spark-connect-go/v3.5/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 25e48d9..08476b3 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/v1/internal/generated"
+ proto "github.com/apache/spark-connect-go/v3.5/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 f19a199..4d06812 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/v1/client/sql"
+ "github.com/apache/spark-connect-go/v3.5/client/sql"
)
var (
diff --git a/go.mod b/go.mod
index 6d12e7a..96da869 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/v1
+module github.com/apache/spark-connect-go/v3.5
go 1.21
diff --git a/quick-start.md b/quick-start.md
index 2cf83a4..202be73 100644
--- a/quick-start.md
+++ b/quick-start.md
@@ -22,7 +22,7 @@ import (
"flag"
"log"
- "github.com/apache/spark-connect-go/v1/client/sql"
+ "github.com/apache/spark-connect-go/v3.5/client/sql"
)
var (
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org