Function NewClusterTableSession

client/tablesession.go:106–116

NewClusterTableSession creates a new TableSession instance for a cluster setup. Parameters: - clusterConfig: The configuration for the cluster session. - enableRPCCompression: A boolean indicating whether RPC compression is enabled. Returns: - An ITableSession instance if the session is successful

(clusterConfig *ClusterConfig, enableRPCCompression bool)

//   - An ITableSession instance if the session is successfully created.
//   - An error if there is an issue during session initialization.
func NewClusterTableSession(clusterConfig *ClusterConfig, enableRPCCompression bool) (ITableSession, error) {
	clusterConfig.sqlDialect = TableSqlDialect
	session, err := newClusterSessionWithSqlDialect(clusterConfig)
	if err != nil {
		return nil, err
	}
	if err = session.OpenCluster(enableRPCCompression); err != nil {
		return nil, err
	}
	return &TableSession{session: session}, nil
}

// Insert inserts a Tablet into the IoTDB.
//