file

package

v0.0.0-...-8ffd201 Latest Latest Go to latest Published: Apr 27, 2023 License: GPL-3.0 Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/gotodb/gotodb

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewFileMetadata(conf *config.FileConnector) (*metadata.Metadata, error)
type CSV
- func NewCSV(osFile *os.File, md *metadata.Metadata) *CSV
type File
- func NewFileConnector(catalog, schema, table string) (*File, error)
- func NewFileConnectorEmpty() *File
type Handler
- func NewHandler(file *partition.FileLocation, md *metadata.Metadata, readonly bool) (Handler, error)

Constants ¶

View Source

const (
	ReadRowsNumber = 10000
)

Variables ¶

This section is empty.

Functions ¶

func NewFileMetadata ¶

func NewFileMetadata(conf *config.FileConnector) (*metadata.Metadata, error)

Types ¶

type CSV ¶

type CSV struct {
	Closer      io.Closer
	Metadata    *metadata.Metadata
	Reader      *csv.Reader
	Writer      *csv.Writer
	Indexes     []int
	OutMetadata *metadata.Metadata
}

func NewCSV ¶

func NewCSV(osFile *os.File, md *metadata.Metadata) *CSV

func (*CSV) Read ¶

func (csv *CSV) Read(indexes []int) (*row.RowsGroup, error)

func (*CSV) SetColumns ¶

func (csv *CSV) SetColumns(indexes []int) error

func (*CSV) Write ¶

func (csv *CSV) Write(rb *row.RowsBuffer, indexes []int) (affectedRows int64, err error)

type File ¶

type File struct {
	Config    *config.FileConnector
	Metadata  *metadata.Metadata
	FileType  partition.FileType
	Partition *partition.Partition
}

func NewFileConnector ¶

func NewFileConnector(catalog, schema, table string) (*File, error)

func NewFileConnectorEmpty ¶

func NewFileConnectorEmpty() *File

func (*File) GetMetadata ¶

func (c *File) GetMetadata() (*metadata.Metadata, error)

func (*File) GetPartition ¶

func (c *File) GetPartition(_ int) (*partition.Partition, error)

func (*File) GetReader ¶

func (c *File) GetReader(file *partition.FileLocation, selectedMD *metadata.Metadata, _ []string) (row.GroupReader, error)

func (*File) Insert ¶

func (c *File) Insert(rb *row.RowsBuffer, columns []string) (affectedRows int64, err error)

func (*File) ShowColumns ¶

func (c *File) ShowColumns(catalog, schema, table string) row.Reader

func (*File) ShowPartitions ¶

func (c *File) ShowPartitions(_, _, _ string) row.Reader

func (*File) ShowSchemas ¶

func (c *File) ShowSchemas(catalog string, _, _ *string) row.Reader

func (*File) ShowTables ¶

func (c *File) ShowTables(catalog, schema string, _, _ *string) row.Reader

type Handler ¶

type Handler interface {
	Read(indexes []int) (rg *row.RowsGroup, err error)
	Write(rb *row.RowsBuffer, indexes []int) (affectedRows int64, err error)
}

func NewHandler ¶

func NewHandler(file *partition.FileLocation, md *metadata.Metadata, readonly bool) (Handler, error)

Source Files ¶

View all Source files

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