delta_sharing

package module
v0.0.0-...-18245c9 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 16, 2023 License: Apache-2.0 Imports: 20 Imported by: 0

README

go_delta_sharing_client

Community developed Delta Sharing Client to provide access delta Shares to applications written in Golang

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func LoadArrowTable

func LoadArrowTable(client interface{}, table Table, fileId string) (arrow.Table, error)

func LoadAsArrowTable

func LoadAsArrowTable(url string, fileno int) (arrow.Table, error)

func LoadAsDataFrame

func LoadAsDataFrame(url string) (*dataframe.DataFrame, error)

func NewSharingClient

func NewSharingClient(Ctx context.Context, ProfileFile string, cacheDir string) (*sharingClient, error)

func NewSharingClientFromString

func NewSharingClientFromString(Ctx context.Context, ProfileString string, cacheDir string) (*sharingClient, error)

Types

type CDFFile

type CDFFile struct {
	File
}

type CdfOptions

type CdfOptions struct {
	StartingVersion   *int    `json:"starting_version,omitempty"`
	EndingVersion     *int    `json:"ending_version,omitempty"`
	StartingTimestamp *string `json:"starting_timestamp,omitempty"`
	EndingTimestamp   *string `json:"ending_timestamp,omitempty"`
}

type DSErr

type DSErr struct {
	Mod  string
	Func string
	Call string
	Msg  string
}

func (*DSErr) Error

func (e *DSErr) Error() string

type DataChangeFile

type DataChangeFile struct {
	File
}

type File

type File struct {
	Url                 string            `json:"url"`
	Id                  string            `json:"id"`
	PartitionValues     map[string]string `json:"partitionValues"`
	Size                float32           `json:"size"`
	Stats               string            `json:"stats,omitempty"`
	Timestamp           float32           `json:"timestamp,omitempty"`
	Version             int32             `json:"version,omitempty"`
	ExpirationTimestamp int32             `json:"expirationTimestamp,omitempty"`
}

func (*File) GetStats

func (F *File) GetStats() (*stats, error)

type RemoveFile

type RemoveFile struct {
	File
}

type Table

type Table struct {
	Name   string `json:"name"`
	Share  string `json:"share"`
	Schema string `json:"schema"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL