schema

package

v0.0.0-...-8f686df Latest Latest Go to latest Published: May 31, 2025 License: Apache-2.0 Imports: 9 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/devrev/columnify

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func NewSchemaHandlerFromArrow(s IntermediateSchema) (*schema.SchemaHandler, error)
type IntermediateSchema

Constants ¶

View Source

const (
	SchemaTypeAvro     = "avro"
	SchemaTypeBigquery = "bigquery"
)

Variables ¶

View Source

var (
	ErrUnsupportedSchema   = errors.New("unsupported schema")
	ErrInvalidSchema       = errors.New("invalid schema")
	ErrUnconvertibleSchema = errors.New("input schema is unable to convert")
)

Functions ¶

func NewSchemaHandlerFromArrow ¶

func NewSchemaHandlerFromArrow(s IntermediateSchema) (*schema.SchemaHandler, error)

NewSchemaHandlerFromArrow converts intermediate schema to parquet-go schema handler.

Types ¶

type IntermediateSchema ¶

type IntermediateSchema struct {
	ArrowSchema *arrow.Schema
	Name        string
}

func GetSchema ¶

func GetSchema(content []byte, schemaType string) (*IntermediateSchema, error)

GetSchema converts input schema intermediate schema.

func NewIntermediateSchema ¶

func NewIntermediateSchema(s *arrow.Schema, name string) *IntermediateSchema

func NewSchemaFromAvroSchema ¶

func NewSchemaFromAvroSchema(schemaContent []byte) (*IntermediateSchema, error)

func NewSchemaFromBigQuerySchema ¶

func NewSchemaFromBigQuerySchema(schemaContent []byte) (*IntermediateSchema, error)

Source Files ¶

View all Source files

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