Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions Makefile
Original file line number Diff line number Diff line change
Expand Up @@ -63,9 +63,9 @@ generate:
curl -L -o thrift/iotdb-tools-thrift.zip https://repo1.maven.org/maven2/org/apache/iotdb/tools/iotdb-tools-thrift/0.14.1.0/iotdb-tools-thrift-0.14.1.0-$(OS_CLASSIFIER).zip; \
unzip -o thrift/iotdb-tools-thrift.zip -d thrift; \
curl -o common.thrift https://raw.githubusercontent.com/apache/iotdb/master/iotdb-protocol/thrift-commons/src/main/thrift/common.thrift; \
$(THRIFT_EXEC) -out . -gen go:package_prefix=github.com/apache/iotdb-client-go/ common.thrift; \
$(THRIFT_EXEC) -out . -gen go:package_prefix=github.com/apache/iotdb-client-go/v2/ common.thrift; \
curl -o client.thrift https://raw.githubusercontent.com/apache/iotdb/master/iotdb-protocol/thrift-datanode/src/main/thrift/client.thrift; \
$(THRIFT_EXEC) -out . -gen go:package_prefix=github.com/apache/iotdb-client-go/ client.thrift; \
$(THRIFT_EXEC) -out . -gen go:package_prefix=github.com/apache/iotdb-client-go/v2/ client.thrift; \
rm -f common.thrift; \
rm -f client.thrift; \
fi
Expand Down
3 changes: 2 additions & 1 deletion client/errors.go
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,8 @@ package client

import (
"bytes"
"github.com/apache/iotdb-client-go/common"

"github.com/apache/iotdb-client-go/v2/common"
)

type BatchError struct {
Expand Down
5 changes: 3 additions & 2 deletions client/rpcdataset.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,10 +3,11 @@ package client
import (
"context"
"fmt"
"github.com/apache/iotdb-client-go/common"
"github.com/apache/iotdb-client-go/rpc"
"strconv"
"time"

"github.com/apache/iotdb-client-go/v2/common"
"github.com/apache/iotdb-client-go/v2/rpc"
)

const startIndex = int32(2)
Expand Down
6 changes: 3 additions & 3 deletions client/session.go
Original file line number Diff line number Diff line change
Expand Up @@ -32,10 +32,10 @@ import (
"strings"
"time"

"github.com/apache/iotdb-client-go/common"

"github.com/apache/iotdb-client-go/rpc"
"github.com/apache/thrift/lib/go/thrift"

"github.com/apache/iotdb-client-go/v2/common"
"github.com/apache/iotdb-client-go/v2/rpc"
)

const (
Expand Down
3 changes: 2 additions & 1 deletion client/sessiondataset.go
Original file line number Diff line number Diff line change
@@ -1,8 +1,9 @@
package client

import (
"github.com/apache/iotdb-client-go/rpc"
"time"

"github.com/apache/iotdb-client-go/v2/rpc"
)

type SessionDataSet struct {
Expand Down
2 changes: 1 addition & 1 deletion client/tablesession.go
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@

package client

import "github.com/apache/iotdb-client-go/common"
import "github.com/apache/iotdb-client-go/v2/common"

// ITableSession defines an interface for interacting with IoTDB tables.
// It supports operations such as data insertion, executing queries, and closing the session.
Expand Down
3 changes: 2 additions & 1 deletion client/tablesessionpool.go
Original file line number Diff line number Diff line change
Expand Up @@ -20,9 +20,10 @@
package client

import (
"github.com/apache/iotdb-client-go/common"
"log"
"sync/atomic"

"github.com/apache/iotdb-client-go/v2/common"
)

// TableSessionPool manages a pool of ITableSession instances, enabling efficient
Expand Down
5 changes: 3 additions & 2 deletions client/utils.go
Original file line number Diff line number Diff line change
Expand Up @@ -24,10 +24,11 @@ import (
"encoding/binary"
"errors"
"fmt"
"github.com/apache/iotdb-client-go/common"
"github.com/apache/iotdb-client-go/rpc"
"strconv"
"time"

"github.com/apache/iotdb-client-go/v2/common"
"github.com/apache/iotdb-client-go/v2/rpc"
)

const (
Expand Down
3 changes: 2 additions & 1 deletion client/utils_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -20,8 +20,9 @@
package client

import (
"github.com/apache/iotdb-client-go/common"
"testing"

"github.com/apache/iotdb-client-go/v2/common"
)

func Test_bytesToInt32(t *testing.T) {
Expand Down
Loading