json

Documentation

Index

• Variables
• type JSONReader
  • func NewJSONReader(vrw types.ValueReadWriter, r io.ReadCloser, sch schema.Schema) (*JSONReader, error)
  • func OpenJSONReader(vrw types.ValueReadWriter, path string, fs filesys.ReadableFS, ...) (*JSONReader, error)
  • func (r *JSONReader) Close(ctx context.Context) error
  • func (r *JSONReader) GetSchema() schema.Schema
  • func (r *JSONReader) ReadRow(ctx context.Context) (row.Row, error)
  • func (r *JSONReader) ReadSqlRow(ctx context.Context) (sql.Row, error)
  • func (r *JSONReader) VerifySchema(sch schema.Schema) (bool, error)
• type JSONWriter
  • func NewJSONWriter(wr io.WriteCloser, outSch schema.Schema) (*JSONWriter, error)
  • func (jsonw *JSONWriter) Close(ctx context.Context) error
  • func (jsonw *JSONWriter) GetSchema() schema.Schema
  • func (jsonw *JSONWriter) WriteRow(ctx context.Context, r row.Row) error
  • func (jsonw *JSONWriter) WriteSqlRow(ctx context.Context, row sql.Row) error

Variables

var ReadBufSize = 256 * 1024

var WriteBufSize = 256 * 1024

Types

type JSONReader

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

func NewJSONReader

func NewJSONReader(vrw types.ValueReadWriter, r io.ReadCloser, sch schema.Schema) (*JSONReader, error)

func OpenJSONReader

func OpenJSONReader(vrw types.ValueReadWriter, path string, fs filesys.ReadableFS, sch schema.Schema) (*JSONReader, error)

func (*JSONReader) Close

func (r *JSONReader) Close(ctx context.Context) error

Close should release resources being held

func (*JSONReader) GetSchema

func (r *JSONReader) GetSchema() schema.Schema

GetSchema gets the schema of the rows that this reader will return

func (*JSONReader) ReadRow

func (r *JSONReader) ReadRow(ctx context.Context) (row.Row, error)

func (*JSONReader) ReadSqlRow

func (r *JSONReader) ReadSqlRow(ctx context.Context) (sql.Row, error)

func (*JSONReader) VerifySchema

func (r *JSONReader) VerifySchema(sch schema.Schema) (bool, error)

VerifySchema checks that the incoming schema matches the schema from the existing table

type JSONWriter

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

func NewJSONWriter

func NewJSONWriter(wr io.WriteCloser, outSch schema.Schema) (*JSONWriter, error)

func (*JSONWriter) Close

func (jsonw *JSONWriter) Close(ctx context.Context) error

Close should flush all writes, release resources being held

func (*JSONWriter) GetSchema

func (jsonw *JSONWriter) GetSchema() schema.Schema

func (*JSONWriter) WriteRow

func (jsonw *JSONWriter) WriteRow(ctx context.Context, r row.Row) error

WriteRow will write a row to a table

func (*JSONWriter) WriteSqlRow

func (jsonw *JSONWriter) WriteSqlRow(ctx context.Context, row sql.Row) error