octosql: github.com/cube2222/octosql/storage/csv Index | Files

package csv

import "github.com/cube2222/octosql/storage/csv"

Index

Package Files

datasource.go

func NewDataSourceBuilderFactory Uses

func NewDataSourceBuilderFactory() physical.DataSourceBuilderFactory

func NewDataSourceBuilderFactoryFromConfig Uses

func NewDataSourceBuilderFactoryFromConfig(dbConfig map[string]interface{}) (physical.DataSourceBuilderFactory, error)

NewDataSourceBuilderFactoryFromConfig creates a data source builder factory using the configuration.

type DataSource Uses

type DataSource struct {
    // contains filtered or unexported fields
}

func (*DataSource) Get Uses

func (ds *DataSource) Get(ctx context.Context, variables octosql.Variables) (execution.RecordStream, error)

type RecordStream Uses

type RecordStream struct {
    // contains filtered or unexported fields
}

func (*RecordStream) Close Uses

func (rs *RecordStream) Close() error

func (*RecordStream) Next Uses

func (rs *RecordStream) Next(ctx context.Context) (*execution.Record, error)

Package csv imports 12 packages (graph) and is imported by 1 packages. Updated 2019-11-28. Refresh now. Tools for package owners.