NewTableSession creates a new TableSession instance using the provided configuration. Parameters: - config: The configuration for the session. - enableRPCCompression: A boolean indicating whether RPC compression is enabled. - connectionTimeoutInMs: The timeout in milliseconds for establishing a con
(config *Config, enableRPCCompression bool, connectionTimeoutInMs int)
| 85 | // - An ITableSession instance if the session is successfully created. |
| 86 | // - An error if there is an issue during session initialization. |
| 87 | func NewTableSession(config *Config, enableRPCCompression bool, connectionTimeoutInMs int) (ITableSession, error) { |
| 88 | config.sqlDialect = TableSqlDialect |
| 89 | session := newSessionWithSpecifiedSqlDialect(config) |
| 90 | |
| 91 | if err := session.Open(enableRPCCompression, connectionTimeoutInMs); err != nil { |
| 92 | return nil, err |
| 93 | } |
| 94 | return &TableSession{session: session}, nil |
| 95 | } |
| 96 | |
| 97 | // NewClusterTableSession creates a new TableSession instance for a cluster setup. |
| 98 | // |
searching dependent graphs…