record

Documentation

Index

• func GetJsonFromAllRrc(allrrc []*utils.RecordResultContainer, esResponse bool, qid uint64, ...) ([]map[string]interface{}, []string, error)
• func GetOrCreateNodeRes(qid uint64) *structs.NodeResult
• func GetRecordsFromSegment(segKey string, vTable string, blkRecIndexes map[uint16]map[uint16]uint64, ...) (map[string]map[string]interface{}, map[string]bool, error)

Functions

func GetJsonFromAllRrc

func GetJsonFromAllRrc(allrrc []*utils.RecordResultContainer, esResponse bool, qid uint64,
	segEncToKey map[uint16]string, aggs *structs.QueryAggregators) ([]map[string]interface{}, []string, error)

Gets all raw json records from RRCs. If esResponse is false, _id and _type will not be added to any record

func GetOrCreateNodeRes

func GetOrCreateNodeRes(qid uint64) *structs.NodeResult

func GetRecordsFromSegment

func GetRecordsFromSegment(segKey string, vTable string, blkRecIndexes map[uint16]map[uint16]uint64,
	tsKey string, esQuery bool, qid uint64,
	aggs *structs.QueryAggregators, colsIndexMap map[string]int) (map[string]map[string]interface{}, map[string]bool, error)

returns a map of record identifiers to record maps, and all columns seen record identifiers is segfilename + blockNum + recordNum If esResponse is false, _id and _type will not be added to any record