Versions in this module Expand all Collapse all v1 v1.1.0 Jul 13, 2023 v1.0.1 Jul 13, 2023 Changes in this version + func ConvertArrowToParquetSchema(schema *arrow.Schema) ([]string, error) + type Item struct + GoType reflect.Type + Info *common.Tag + func NewItem() *Item + type JSONSchemaItemType struct + Fields []*JSONSchemaItemType + Tag string + func NewJSONSchemaItem() *JSONSchemaItemType + type PathMapType struct + Children map[string]*PathMapType + Path string + func NewPathMap(path string) *PathMapType + func (pmt *PathMapType) Add(path []string) + type SchemaHandler struct + ExPathToInPath map[string]string + InPathToExPath map[string]string + IndexMap map[int32]string + Infos []*common.Tag + MapIndex map[string]int32 + PathMap *PathMapType + SchemaElements []*parquet.SchemaElement + ValueColumns []string + func NewSchemaHandlerFromArrow(arrowSchema *arrow.Schema) (*SchemaHandler, error) + func NewSchemaHandlerFromJSON(str string) (sh *SchemaHandler, err error) + func NewSchemaHandlerFromMetadata(mds []string) (*SchemaHandler, error) + func NewSchemaHandlerFromSchemaHandler(sh *SchemaHandler) *SchemaHandler + func NewSchemaHandlerFromSchemaList(schemas []*parquet.SchemaElement) *SchemaHandler + func NewSchemaHandlerFromStruct(obj interface{}) (sh *SchemaHandler, err error) + func (sh *SchemaHandler) ConvertToInPathStr(pathStr string) (string, error) + func (sh *SchemaHandler) CreateInExMap() + func (sh *SchemaHandler) GetColumnNum() int64 + func (sh *SchemaHandler) GetExName(index int) string + func (sh *SchemaHandler) GetInName(index int) string + func (sh *SchemaHandler) GetRepetitionLevelIndex(path []string, rl int32) (int32, error) + func (sh *SchemaHandler) GetRepetitionType(path []string) (parquet.FieldRepetitionType, error) + func (sh *SchemaHandler) GetRootExName() string + func (sh *SchemaHandler) GetRootInName() string + func (sh *SchemaHandler) GetType(prefixPath string) (reflect.Type, error) + func (sh *SchemaHandler) GetTypes() []reflect.Type + func (sh *SchemaHandler) MaxDefinitionLevel(path []string) (int32, error) + func (sh *SchemaHandler) MaxRepetitionLevel(path []string) (int32, error)