Function initIndexVector

query/time_series_aggregate.go:334–336

(vector unsafe.Pointer, start, size int, stream unsafe.Pointer, device int)

}

func initIndexVector(vector unsafe.Pointer, start, size int, stream unsafe.Pointer, device int) {
	C.InitIndexVector((*C.uint32_t)(vector), (C.uint32_t)(start), (C.int)(size), stream, (C.int)(device))
}

func (bc *oopkBatchContext) filterAction(functorType uint32, stream unsafe.Pointer, device int, inputs []C.InputVector, exp expr.Expr) {
	numForeignTables := len(bc.foreignTableRecordIDsD)