Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

goclickzetta

package module

Go to main page

Versions in this module

v0

v0.0.5

Feb 17, 2025

v0.0.4

Feb 14, 2025

v0.0.3

Feb 13, 2025

v0.0.2

Feb 13, 2025

Changes in this version

+ const JSON

v0.0.1

Sep 6, 2023

Changes in this version

+ const ARRAY

+ const BIGINT

+ const BOOLEAN

+ const CHAR

+ const COS

+ const CancelJobPath

+ const ClickzettaGoDriverVersion

+ const DATE

+ const DECIMAL

+ const DOUBLE

+ const DateType

+ const FLOAT

+ const File

+ const GETWAYPATH

+ const GetJobResultPath

+ const GetTokenPath

+ const INT

+ const INTERVAL

+ const MAP

+ const Memory

+ const NOT_SUPPORTED

+ const OSS

+ const QueryFailed

+ const QueryStatusComplete

+ const QueryStatusInProgress

+ const SFSessionIDKey

+ const SFSessionUserKey

+ const SMALLINT

+ const STRING

+ const STRUCT

+ const SubmitJobRequestPath

+ const TIMESTAMP_LTZ

+ const TINYINT

+ const TimestampLTZType

+ const VARCHAR

+ var ASYNC jobRequestMode = "ASYNC"

+ var COMPACTION_JOB jobType = "COMPACTION_JOB"

+ var HTTPTransport = &http.Transport

+ var HYBRID jobRequestMode = "HYBRID"

+ var LogKeys = [...]contextKey

+ var SQL_JOB jobType = "SQL_JOB"

+ var SYNC jobRequestMode = "SYNC"

+ var UNKNOWN jobRequestMode = "UNKNOWN"

+ func AppendValueToArrowField(field array.Builder, value interface{}, tpe *util.DataType) error

+ func ConvertToArrowDataType(tpe *util.DataType) (arrow.DataType, error)

+ func ConvertToArrowValue(value interface{}, tpe *util.DataType) (string, error)

+ func DSN(cfg *Config) (dsn string)

+ func GetHttpResponseMsgToJson(headers map[string]string, path string, connection *ClickzettaConn, ...) (*fastjson.Value, []byte, error)

+ func SFCallerPrettyfier(frame *runtime.Frame) (string, string)

+ func SetLogger(inLogger *SFLogger)

+ type BulkLoadCommitMode string

+ var ABORT_STREAM BulkLoadCommitMode

+ var COMMIT_STREAM BulkLoadCommitMode

+ type BulkLoadConfig struct

+ BLConfig *ingestion.BulkLoadStreamWriterConfig

+ func (bc *BulkLoadConfig) GetBulkLoadConfig() (StagingConfig, error)

+ func (bc *BulkLoadConfig) GetFileFormat() FileFormat

+ func (bc *BulkLoadConfig) GetMaxBytesPerFile() int64

+ func (bc *BulkLoadConfig) GetMaxRowsPerFile() int64

+ type BulkLoadOperation string

+ var APPEND BulkLoadOperation = "APPEND"

+ var OVERWRITE BulkLoadOperation = "OVERWRITE"

+ var UPSERT BulkLoadOperation = "UPSERT"

+ type BulkLoadState string

+ var ABORTED BulkLoadState = "ABORTED"

+ var COMMIT_FAILED BulkLoadState = "COMMIT_FAILED"

+ var COMMIT_SUBMITTED BulkLoadState = "COMMIT_SUBMITTED"

+ var COMMIT_SUCCESS BulkLoadState = "COMMIT_SUCCESS"

+ var CREATED BulkLoadState = "CREATED"

+ var SEALED BulkLoadState = "SEALED"

+ type BulkloadCommitOptions struct

+ VirtualCluster string

+ Workspace string

+ type BulkloadMetadata struct

+ InstanceId int64

+ StreamInfo *ingestion.BulkLoadStreamInfo

+ Table CZTable

+ func (bm *BulkloadMetadata) GetOperation() BulkLoadOperation

+ func (bm *BulkloadMetadata) GetPartitionSpec() string

+ func (bm *BulkloadMetadata) GetRecordKeys() []string

+ func (bm *BulkloadMetadata) GetSQLErrorMsg() string

+ func (bm *BulkloadMetadata) GetState() BulkLoadState

+ type BulkloadOptions struct

+ Operation BulkLoadOperation

+ PartitionSpec string

+ RecordKeys []string

+ Table string

+ type BulkloadStream struct

+ Closed bool

+ CommitOptions *BulkloadCommitOptions

+ Connection *ClickzettaConn

+ MetaData *BulkloadMetadata

+ StreamOptions *BulkloadOptions

+ func (stream *BulkloadStream) Abort() error

+ func (stream *BulkloadStream) Close() error

+ func (stream *BulkloadStream) Commit() error

+ func (stream *BulkloadStream) GetStreamId() string

+ func (stream *BulkloadStream) OpenWriter(partitionId int64) (*BulkloadWriter, error)

+ type BulkloadWriter struct

+ ArrowSchema *arrow.Schema

+ BLConfig *BulkLoadConfig

+ COSClient *cos.Client

+ Closed bool

+ Connection *ClickzettaConn

+ CurrentRecordBatch map[string][]interface{}

+ CurrentRecordBatchRows int

+ CurrentRecordBatchSize int

+ CurrentTotalBytes int

+ CurrentTotalRows int

+ EstimateRowStaticSize int

+ FileId int

+ FileNameUUID string

+ FileSystem fs.FS

+ FinishedFileSizes []int

+ FinishedFiles []string

+ LocalLocation string

+ MetaData *BulkloadMetadata

+ OSSBucket *oss.Bucket

+ PartitionId int64

+ PartitionSpec map[string]string

+ StageConfig *StagingConfig

+ StreamOptions *BulkloadOptions

+ Writer *pqarrow.FileWriter

+ func (bw *BulkloadWriter) Abort() error

+ func (bw *BulkloadWriter) CheckFileStatus() error

+ func (bw *BulkloadWriter) Close() error

+ func (bw *BulkloadWriter) CloseCurrentFile() error

+ func (bw *BulkloadWriter) ConstructArrowSchema() error

+ func (bw *BulkloadWriter) CreateNextFileWriter() (*pqarrow.FileWriter, error)

+ func (bw *BulkloadWriter) CreateRow() *Row

+ func (bw *BulkloadWriter) CurrentFileName() string

+ func (bw *BulkloadWriter) EstimateRowSize() int

+ func (bw *BulkloadWriter) Finish() error

+ func (bw *BulkloadWriter) FlushRecordBatch() (int, error)

+ func (bw *BulkloadWriter) Init() error

+ func (bw *BulkloadWriter) ParsePartitionSpec() (map[string]string, error)

+ func (bw *BulkloadWriter) ProcessStagingType() error

+ func (bw *BulkloadWriter) UploadLocalFile() (string, error)

+ func (bw *BulkloadWriter) WriteRow(row *Row) error

+ type CZTable struct

+ Schema map[string]*util.DataType

+ SchemaName string

+ TableMeta *ingestion.StreamSchema

+ TableName string

+ type ClickzettaConn struct

+ func (conn *ClickzettaConn) Begin() (driver.Tx, error)

+ func (conn *ClickzettaConn) BeginTx(ctx context.Context, opts driver.TxOptions) (driver.Tx, error)

+ func (conn *ClickzettaConn) Close() (err error)

+ func (conn *ClickzettaConn) CommitBulkloadStream(streamId string, commitMode BulkLoadCommitMode, option BulkloadOptions) (*BulkloadMetadata, error)

+ func (conn *ClickzettaConn) CreateBulkloadStream(option BulkloadOptions) (*BulkloadStream, error)

+ func (conn *ClickzettaConn) Exec(query string, args []driver.Value) (driver.Result, error)

+ func (conn *ClickzettaConn) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Result, error)

+ func (conn *ClickzettaConn) FinishBulkloadStreamWriter(streamId string, option BulkloadOptions, partitionId uint32, ...) (*ingestion.ResponseStatus, error)

+ func (conn *ClickzettaConn) GateWayCall(message proto.Message, method ingestion.MethodEnum) (*fastjson.Value, error)

+ func (conn *ClickzettaConn) GetBulkloadStream(streamId string, option BulkloadOptions) (*BulkloadMetadata, error)

+ func (conn *ClickzettaConn) GetDistributeBulkloadStream(streamId string, option BulkloadOptions) (*BulkloadStream, error)

+ func (conn *ClickzettaConn) OpenBulkloadStreamWriter(streamId string, option BulkloadOptions, partitionId uint32) (*BulkLoadConfig, error)

+ func (conn *ClickzettaConn) Ping(ctx context.Context) error

+ func (conn *ClickzettaConn) Prepare(query string) (driver.Stmt, error)

+ func (conn *ClickzettaConn) PrepareContext(ctx context.Context, query string) (driver.Stmt, error)

+ func (conn *ClickzettaConn) Query(query string, args []driver.Value) (driver.Rows, error)

+ func (conn *ClickzettaConn) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Rows, error)

+ type ClickzettaDriver struct

+ func (d ClickzettaDriver) Open(dsn string) (driver.Conn, error)

+ func (d ClickzettaDriver) OpenWithConfig(ctx context.Context, config Config) (driver.Conn, error)

+ type ClickzettaError struct

+ IncludeQueryID bool

+ Message string

+ MessageArgs []interface{}

+ Number int

+ QueryID string

+ SQLState string

+ func (ce *ClickzettaError) Error() string

+ type ClickzettaResult interface

+ GetError func() error

+ GetQueryID func() string

+ GetStatus func() queryStatus

+ type ClickzettaRows interface

+ GetQueryID func() string

+ GetResultRows func() ([]interface{}, error)

+ GetStatus func() queryStatus

+ type ClickzettaStmt struct

+ func (stmt *ClickzettaStmt) Close() error

+ func (stmt *ClickzettaStmt) Exec(args []driver.Value) (driver.Result, error)

+ func (stmt *ClickzettaStmt) ExecContext(ctx context.Context, args []driver.NamedValue) (driver.Result, error)

+ func (stmt *ClickzettaStmt) NumInput() int

+ func (stmt *ClickzettaStmt) Query(args []driver.Value) (driver.Rows, error)

+ func (stmt *ClickzettaStmt) QueryContext(ctx context.Context, args []driver.NamedValue) (driver.Rows, error)

+ type Config struct

+ Instance string

+ InstanceId int64

+ Params map[string]*string

+ Password string

+ Protocol string

+ Schema string

+ Service string

+ Token string

+ UserName string

+ VirtualCluster string

+ Workspace string

+ func ParseDSN(dsn string) (cfg *Config, err error)

+ type ConfigBool uint8

+ type Connector struct

+ func NewConnector(driver InternalClickzettaDriver, config Config) Connector

+ func (t Connector) Connect(ctx context.Context) (driver.Conn, error)

+ func (t Connector) Driver() driver.Driver

+ type FileFormat string

+ var ARROW FileFormat = "arrow"

+ var AVRO FileFormat = "avro"

+ var CSV FileFormat = "csv"

+ var DUMMY FileFormat = "dummy"

+ var HIVE_RESULT FileFormat = "hive_result"

+ var ICEBERG FileFormat = "iceberg"

+ var MEMORY FileFormat = "memory"

+ var ORC FileFormat = "orc"

+ var PARQUET FileFormat = "parquet"

+ var TEXT FileFormat = "text"

+ type InternalClickzettaDriver interface

+ Open func(dsn string) (driver.Conn, error)

+ OpenWithConfig func(ctx context.Context, config Config) (driver.Conn, error)

+ type InternalClient interface

+ Close func() error

+ Get func(context.Context, *url.URL, map[string]string, time.Duration) (*http.Response, error)

+ Post func(context.Context, *url.URL, map[string]string, []byte, time.Duration) (*http.Response, error)

+ type Row struct

+ ColumnNameValues map[string]interface{}

+ Columns map[string]*util.DataType

+ TableName string

+ func (row *Row) SetBigint(columnName string, value interface{}) error

+ func (row *Row) SetBoolean(columnName string, value interface{}) error

+ func (row *Row) SetDate(columnName string, value interface{}) error

+ func (row *Row) SetDecimal(columnName string, value interface{}) error

+ func (row *Row) SetDouble(columnName string, value interface{}) error

+ func (row *Row) SetFloat(columnName string, value interface{}) error

+ func (row *Row) SetInt(columnName string, value interface{}) error

+ func (row *Row) SetSmallInt(columnName string, value interface{}) error

+ func (row *Row) SetString(columnName string, value interface{}) error

+ func (row *Row) SetTimestamp(columnName string, value interface{}) error

+ func (row *Row) SetTinyInt(columnName string, value interface{}) error

+ type SFLogger interface

+ SetLogLevel func(level string) error

+ SetOutput func(output io.Writer)

+ WithContext func(ctx context.Context) *rlog.Entry

+ func CreateDefaultLogger() SFLogger

+ func GetLogger() SFLogger

+ type StagingConfig struct

+ Endpoint string

+ ID string

+ Path string

+ Secret string

+ Token string

+ Type string

+ type TypedNullTime struct

+ Time sql.NullTime

+ TzType timezoneType

+ type UUID [16]byte

+ func NewUUID() UUID

+ func ParseUUID(str string) UUID

+ func (u UUID) String() string