Influxdb中Select查詢請(qǐng)求結(jié)果涉及到的一些數(shù)據(jù)結(jié)構(gòu)

女主宣言

數(shù)據(jù)結(jié)構(gòu)

Series其實(shí)就是measurement和tags的組合，tags是tag key和tag value的map.這個(gè)Tags的id是如何產(chǎn)生的呢，其實(shí)就是對(duì)tag key和tag value編碼到

具體實(shí)現(xiàn)定義在query/point.go中的encodeTags。

Row表示查詢結(jié)果集中的每一行, 其中的Values表示是返回的Fields的集合

bufFloatIterator相當(dāng)于c里面的鏈表元素，itr指向下一個(gè)元素的指針，buf表示當(dāng)前元素，即FloatPoint類型的鏈表的迭代器。

FloatPoint

FloatPoint定義在query/point.gen.go中， 表示一條field為float類型的數(shù)據(jù)

Next實(shí)現(xiàn)

當(dāng)前Iterator的值不為空，就返回當(dāng)前的buf, 當(dāng)前的值為空，就返回itr.itr.Next(),即指向的下一個(gè)元素

unread: iterator回退操作

floatMergeIterator組合了多個(gè)floatIterator

因?yàn)橐鱩erge, 這里需要對(duì)其管理的所有Interator元素作排序，這里用到了golang的container/heap作堆排。

因?yàn)橐胓olang的container/heap來(lái)管理，需要實(shí)現(xiàn)下面規(guī)定的接口，

floatMergeIterator定義中的floatMergeHeap即實(shí)現(xiàn)了上面的接口,我們主要來(lái)看一下比較函數(shù)的實(shí)現(xiàn)，比較的其實(shí)就是FloatPoint。

比較的優(yōu)先級(jí)先是FloatPoint的measurement名，然后是tagset id, 最后是time,將這個(gè)比較函數(shù)我們就可以知道.

結(jié)構(gòu)

Next函數(shù)的實(shí)現(xiàn)

一張長(zhǎng)圖

結(jié)合上面的Less函數(shù)可知，針對(duì)所有的FloatPoint, 排序的最小單位是Window(由measurement name, tagset id, time window組成)，屬性同一Window的FloatPoint不再排序。如果是按升級(jí)規(guī)則遍歷，則遍歷的結(jié)果是按Window從小到大排，但同一Window內(nèi)部的多條Point,時(shí)間不一定是從小到大的。

同樣它也借助了golang/container中的heap， 與floatMergeIterator相比它實(shí)現(xiàn)了全體Point的排序遍歷,我們來(lái)看一下是如何實(shí)現(xiàn)的;

pop函數(shù):

對(duì)所有Iterator包含的所在FloatPoint，都從排序，沒(méi)有Window的概念.

floatIteratorScanner將floatIterator的值掃描到map里。

ScanAt

在floatIterator中找滿足條件的Point, 條件是ts, name, tags均相等,實(shí)現(xiàn)比較簡(jiǎn)單

在一個(gè)單獨(dú)的goroutine里面循環(huán)調(diào)用floatIterator.Next獲取FloatPoint,然后寫入到chan中：

使用的時(shí)候，調(diào)用Next, 從上面的Chan中讀數(shù)據(jù):

限制在每個(gè)window中讀取的Point個(gè)數(shù)

next

運(yùn)行在select中的Group by time fill(...), 在當(dāng)前的interval的window中，如果沒(méi)有查詢到值，則使用相應(yīng)的添充規(guī)則生成相應(yīng)的值

具體可參見(jiàn)：

定義：

10  floatInterruptIterator

每遍歷N條數(shù)據(jù)后，檢測(cè)下遍歷是否需要中斷

定義:

Next

對(duì)每個(gè)interval內(nèi)的數(shù)據(jù)作reduce操作

定義:

reduce()

返回處理后的points, 函數(shù)較長(zhǎng)，但邏輯比較簡(jiǎn)單