bigquery

Documentation

Index

• func GetBigQueryType(fd protoreflect.FieldDescriptor) bigquery.FieldType
• type RowConverter
  • func NewRowConverter(options ...transforms.Option) RowConverter
• type SchemaConverter
  • func NewSchemaConverter(options ...transforms.Option) SchemaConverter

Functions

func GetBigQueryType

func GetBigQueryType(fd protoreflect.FieldDescriptor) bigquery.FieldType

Types

type RowConverter

type RowConverter interface {
	Apply(proto.Message) map[string]interface{}
}

func NewRowConverter

func NewRowConverter(options ...transforms.Option) RowConverter

NewRowConverter will create a new SchemaConverter.

The following options can be used to override default behaviour: - transforms.OptionAddOverride - transforms.OptionAddScalarFunc - transforms.OptionMaxDepth

type SchemaConverter

type SchemaConverter interface {
	Apply(descriptor protoreflect.MessageDescriptor) []*bigquery.FieldSchema
}

func NewSchemaConverter

func NewSchemaConverter(options ...transforms.Option) SchemaConverter

NewSchemaConverter will create a new SchemaConverter.

The following options can be used to override default behaviour: - transforms.OptionAddOverride - transforms.OptionAddScalarFunc - transforms.OptionMaxDepth