Versions in this module Expand all Collapse all v0 v0.1.1 Aug 31, 2024 v0.1.0 Aug 27, 2024 Changes in this version + func ArrowBatchToJSON(batch arrow.Record) (string, error) + func ArrowRecordToString(record arrow.Record) (string, error) + func CloneSourceStream(sourceChan <-chan arrow.Record, numClones int) ([]<-chan arrow.Record, error) + func ConvertSchemaSPB(schema *arrow.Schema) *storagepb.ProtoSchema + func DecodeToMap(s *pb.Struct) map[string]interface + func IpcReaderToChannel(reader *ipc.Reader) (<-chan arrow.Record, error) + func LoadEnv() + func MapArrowTypeToProtoType(dataType arrow.DataType) *descriptorpb.FieldDescriptorProto_Type + func PrintRecordBatch(record arrow.Record) error + func ProcessStreams(readErrChan <-chan error, writeErrChan <-chan error) error
Go to main page