arrowtests

Documentation

Index

• Variables
• func NewTSRecord() (*arrow.Schema, arrow.Record)
• func PrintRecordColumns(rec arrow.Record)
• func PrintRecordRows(schema *arrow.Schema, recs []arrow.Record)
• type Event

Examples

• PrintRecordColumns
• PrintRecordRows

Variables

var (
	EventSchema = arrow.NewSchema(
		[]arrow.Field{
			{Name: "time", Type: arrow.FixedWidthTypes.Time32ms},
			{Name: "value", Type: arrow.PrimitiveTypes.Float64},
			{Name: "quality", Type: arrow.PrimitiveTypes.Int64},
		}, nil,
	)
)

Functions

func NewTSRecord

func NewTSRecord() (*arrow.Schema, arrow.Record)

NewTSRecord Create a new sample base on eventSchema

func PrintRecordColumns

func PrintRecordColumns(rec arrow.Record)

PrintRecordColumns Print a columns based output

Example

_, rec := NewTSRecord()
defer rec.Release()

PrintRecordColumns(rec)

Output:

column[0] "time": [1 2 3 4]
column[1] "value": [7 8 (null) 10]
column[2] "quality": [42 42 41 42]

func PrintRecordRows

func PrintRecordRows(schema *arrow.Schema, recs []arrow.Record)

PrintRecordRows Print a row based output

Example

s, rec := NewTSRecord()
defer rec.Release()

PrintRecordRows(s, []arrow.Record{rec})

Output:

time: 1 , value: 7 , quality: 42
time: 2 , value: 8 , quality: 42
time: 3 , value: <nil> , quality: 41
time: 4 , value: 10 , quality: 42

Types

type Event

type Event struct {
	Time  arrow.Time32
	Value interface{}
	// contains filtered or unexported fields
}