in example/session_example.go [493:537]
func createTablet(rowCount int) (*client.Tablet, error) {
tablet, err := client.NewTablet("root.ln.device1", []*client.MeasurementSchema{
{
Measurement: "restart_count",
DataType: client.INT32,
}, {
Measurement: "price",
DataType: client.DOUBLE,
}, {
Measurement: "tick_count",
DataType: client.INT64,
}, {
Measurement: "temperature",
DataType: client.FLOAT,
}, {
Measurement: "description",
DataType: client.TEXT,
},
{
Measurement: "status",
DataType: client.BOOLEAN,
},
}, rowCount)
if err != nil {
return nil, err
}
ts := time.Now().UTC().UnixNano() / 1000000
for row := 0; row < int(rowCount); row++ {
ts++
tablet.SetTimestamp(ts, row)
tablet.SetValueAt(rand.Int31(), 0, row)
if row%2 == 1 {
tablet.SetValueAt(rand.Float64(), 1, row)
} else {
tablet.SetValueAt(nil, 1, row)
}
tablet.SetValueAt(rand.Int63(), 2, row)
tablet.SetValueAt(rand.Float32(), 3, row)
tablet.SetValueAt(fmt.Sprintf("Test Device %d", row+1), 4, row)
tablet.SetValueAt(bool(ts%2 == 0), 5, row)
tablet.RowSize++
}
return tablet, nil
}