sybil

package

Go to main page

Versions in this module

v0

v0.5.0

Dec 5, 2017

Changes in this version

+ var DISTINCT_STR = "distinct"

+ var GOB_GZIP_EXT = ".db.gz"

+ var HIST_FACTOR_POW = uint(1)

+ var HIST_STR = "hist"

+ var MISSING_VALUE = uint64(math.MaxUint64)

+ var NULL_BLOCK = "NULL_BLOCK"

+ func DecodeFlags()

+ func EncodeFlags()

+ func ListTables() []string

+ func Max(x, y int64) int64

+ func Min(x, y int64) int64

+ func NewFalseFlag() *bool

+ func NewTrueFlag() *bool

+ func PrintBytes(obj interface{})

type Aggregation

+ HistType string

+ Name string

+ Op string

+ type BasicHist struct

+ func (h *BasicHist) AddValue(value int64)

+ func (h *BasicHist) AddWeightedValue(value int64, weight int64)

+ func (h *BasicHist) Combine(oh interface{})

+ func (h *BasicHist) GetPercentiles() []int64

+ func (h *BasicHist) GetSparseBuckets() map[int64]int64

+ func (h *BasicHist) GetStdDev() float64

+ func (h *BasicHist) GetStrBuckets() map[string]int64

+ func (h *BasicHist) GetVariance() float64

+ func (h *BasicHist) Print()

+ func (h *BasicHist) SetupBuckets(buckets int, min, max int64)

+ func (h *BasicHist) Sum() int64

+ func (h *BasicHist) TrackPercentiles()

+ type BasicHistCachedInfo struct

+ Averages []float64

+ Avg float64

+ BucketSize int

+ Count int64

+ Info IntInfo

+ Max int64

+ Min int64

+ NumBuckets int

+ Outliers []int64

+ PercentileMode bool

+ Samples int

+ Underliers []int64

+ Values []int64

+ type FileDecoder interface

+ CloseFile func() bool

+ Decode func(interface{}) error

+ type FileEncoder interface

+ CloseFile func() bool

+ Encode func(interface{}) error

+ func GetFileEncoder(filename string) FileEncoder

type FlagDefs

+ CACHED_QUERIES *bool

+ DECODE_FLAGS *bool

+ DISTINCT *string

+ ENCODE_FLAGS *bool

+ ENCODE_RESULTS *bool

+ HDR_HIST *bool

+ LIST_TABLES *bool

+ LOG_HIST *bool

+ type GobFileDecoder struct

+ File *os.File

+ func (gfd GobFileDecoder) CloseFile() bool

+ type GobFileEncoder struct

+ File *os.File

+ func (pb GobFileEncoder) CloseFile() bool

type Grouping

+ Name string

+ type HistCompat struct

+ func (h *HistCompat) GetIntBuckets() map[int64]int64

+ func (h *HistCompat) GetMeanVariance() float64

+ func (h *HistCompat) Mean() float64

+ func (h *HistCompat) Range() (int64, int64)

+ func (h *HistCompat) StdDev() float64

+ func (h *HistCompat) TotalCount() int64

+ func (hc *HistCompat) Max() int64

+ func (hc *HistCompat) Min() int64

+ func (hc *HistCompat) NewHist() Histogram

+ type Histogram interface

+ AddWeightedValue func(int64, int64)

+ Combine func(interface{})

+ GetIntBuckets func() map[int64]int64

+ GetPercentiles func() []int64

+ GetStrBuckets func() map[string]int64

+ Max func() int64

+ Mean func() float64

+ Min func() int64

+ NewHist func() Histogram

+ Range func() (int64, int64)

+ StdDev func() float64

+ TotalCount func() int64

+ type MultiHist struct

+ Avg float64

+ Count int64

+ Info *IntInfo

+ Max int64

+ Min int64

+ PercentileMode bool

+ Samples int

+ Subhists []*HistCompat

+ func (h *MultiHist) AddValue(value int64)

+ func (h *MultiHist) AddWeightedValue(value int64, weight int64)

+ func (h *MultiHist) Combine(oh interface{})

+ func (h *MultiHist) GetMeanVariance() float64

+ func (h *MultiHist) GetNonZeroBuckets() map[string]int64

+ func (h *MultiHist) GetPercentiles() []int64

+ func (h *MultiHist) GetSparseBuckets() map[int64]int64

+ func (h *MultiHist) GetStdDev() float64

+ func (h *MultiHist) GetStrBuckets() map[string]int64

+ func (h *MultiHist) GetVariance() float64

+ func (h *MultiHist) Print()

+ func (h *MultiHist) Sum() int64

+ func (h *MultiHist) TrackPercentiles()

+ type MultiHistCompat struct

+ Histogram *MultiHist

+ func (h *MultiHistCompat) GetIntBuckets() map[int64]int64

+ func (h *MultiHistCompat) GetMeanVariance() float64

+ func (h *MultiHistCompat) Mean() float64

+ func (h *MultiHistCompat) Range() (int64, int64)

+ func (h *MultiHistCompat) StdDev() float64

+ func (h *MultiHistCompat) TotalCount() int64

+ func (hc *MultiHistCompat) Max() int64

+ func (hc *MultiHistCompat) Min() int64

+ func (hc *MultiHistCompat) NewHist() Histogram

+ type NodeResults struct

+ QuerySpec QuerySpec

+ Samples []*Sample

+ Table Table

+ Tables []string

type OptionDefs

+ DISTINCT []string

+ MERGE_TABLE *Table

+ type QueryParams savedQueryParams

+ type QueryResults savedQueryResults

type QuerySpec

+ func CombineAndPrune(querySpec *QuerySpec, block_specs map[string]*QuerySpec) *QuerySpec

+ func MultiCombineResults(querySpec *QuerySpec, block_specs map[string]*QuerySpec) *QuerySpec

+ func (qs *QuerySpec) GetCacheKey(blockname string) string

+ func (qs *QuerySpec) GetCacheStruct(blockname string) QueryParams

+ func (qs *QuerySpec) LoadCachedResults(blockname string) bool

+ func (qs *QuerySpec) NewResult() *Result

+ func (qs *QuerySpec) PruneResults(limit int)

+ func (qs *QuerySpec) SaveCachedResults(blockname string)

+ func (qs *QuerySpec) SortResults()

+ func (querySpec *QuerySpec) GetCacheRelevantFilters(blockname string) []Filter

type Result

+ Distinct *hll.LogLogBeta

type StrReplace

+ Pattern string

+ Replace string

type Table

+ func (t *Table) WriteQueryCache(to_cache_specs map[string]*QuerySpec)

+ type VTable struct

+ Columns map[string]*IntInfo

+ func (vt *VTable) AggregateInfo(dirs []string)

+ func (vt *VTable) AggregateSamples(dirs []string)

+ func (vt *VTable) AggregateSpecs(dirs []string)

+ func (vt *VTable) AggregateTables(dirs []string)

+ func (vt *VTable) StitchResults(dirs []string)

v0.2.0

Sep 10, 2017

Changes in this version

+ var BLOCKS_PER_CACHE_FILE = 64

+ var BREAK_MAP = make(map[string]int, 0)

+ var CACHE_DIR = "cache"

+ var DEBUG_OUTLIERS = false

+ var EMPTY = ""

+ var ENABLE_LUA = false

+ var ENV_FLAG = os.Getenv("DEBUG")

+ var FILE_DIGEST_THRESHOLD = 256

+ var GZIP_EXT = ".gz"

+ var KB = int64(1024)

+ var MAX_LOCK_BREAKS = 5

+ var MAX_ROW_STORE_TRIES = 20

+ var MIN_CUTOFF = 5

+ var MIN_FILES_TO_DIGEST = 0

+ var SIZE_DIGEST_THRESHOLD = int64(1024) * 2

+ var STD_CUTOFF = 1000.0

+ var VERSION_STRING = "0.2.0"

+ func Debug(args ...interface{})

+ func Error(args ...interface{})

+ func GetFileDecoder(filename string) *gob.Decoder

+ func GetVersionInfo() map[string]interface

+ func Print(args ...interface{})

+ func PrintVersionInfo()

+ func RenameAndMod(src, dst string) error

+ func SetLuaScript(filename string)

+ func Warn(args ...interface{})

+ type CacheLock struct

+ func (l *CacheLock) Recover() bool

type FlagDefs

+ DEBUG *bool

+ EXPORT *bool

+ FIELD_SEPARATOR *string

+ FILTER_SEPARATOR *string

+ LUA *bool

+ LUAFILE *string

+ RECYCLE_MEM *bool

+ SKIP_COMPACT *bool

+ SKIP_OUTLIERS *bool

type IntInfo

+ M2 float64

+ type LuaKey interface

+ type LuaTable map[string]interface

type QuerySpec

+ LuaResult LuaTable

+ LuaState *C.struct_lua_State

type RecordList

+ func (rl RecordList) ResetRecords(tb *TableBlock)

+ type SavedBlockCache map[string]*SavedColumnInfo

type SessionStats

+ NumBounces Hist

type Table

+ BlockInfoCache map[string]*SavedColumnInfo

+ NewBlockInfos []string

+ func (t *Table) CompactRecords()

+ func (t *Table) GrabCacheLock() bool

+ func (t *Table) IsNotExist() bool

+ func (t *Table) LoadBlockCache()

+ func (t *Table) LoadBlockInfo(dirname string) *SavedColumnInfo

+ func (t *Table) MakeDir()

+ func (t *Table) ReleaseCacheLock() bool

+ func (t *Table) ResetBlockCache()

+ func (t *Table) ShouldCompactRowStore(digest string) bool

+ func (t *Table) WriteBlockCache()

type TableBlock

+ func (b *TableBlock) ExportBlockData()

+ func (tb *TableBlock) RecycleSlab(loadSpec *LoadSpec)

v0.0.6

Jun 19, 2016

Changes in this version

+ const INT_VAL

+ const NO_OP

+ const OP_AVG

+ const OP_DISTINCT

+ const OP_HIST

+ const SET_VAL

+ const STR_VAL

+ var BLOCKS_BEFORE_GC = 8

+ var BLOCK_VERSION = int32(1)

+ var CARDINALITY_THRESHOLD = 4

+ var CHUNKS_BEFORE_GC = 16

+ var CHUNK_SIZE = 1024 * 8 * 8

+ var CHUNK_THRESHOLD = CHUNK_SIZE / 8

+ var COPY_RECORD_INTERNS = false

+ var DEBUG_RECORD_CONSISTENCY = false

+ var DEBUG_TIMING = false

+ var DELETE_BLOCKS = make([]string, 0)

+ var DELETE_BLOCKS_AFTER_QUERY = true

+ var FALSE = false

+ var FLAGS = FlagDefs

+ var FORMATS = map[string]string

+ var GROUP_BY_WIDTH = 8

+ var GROUP_DELIMITER = "\t"

+ var HOLD_MATCHES = false

+ var INGEST_DIR = "ingest"

+ var INTERNAL_RESULT_LIMIT = 100000

+ var LOADED_TABLES = make(map[string]*Table)

+ var LOCK_TRIES = 50

+ var LOCK_US = time.Millisecond * 3

+ var NO_MORE_BLOCKS = GROUP_DELIMITER

+ var NUM_BUCKETS = 1000

+ var OPTS = OptionDefs

+ var PROFILE *bool = &PROFILER_ENABLED

+ var PROFILER_ENABLED bool

+ var READ_ROWS_ONLY = false

+ var REGEX_CACHE_SIZE = 100000

+ var ROW_STORE_BLOCK = "ROW_STORE"

+ var RUN_PROFILER = func() ProfilerStop

+ var SINGLE_EVENT_DURATION = int64(30)

+ var STOMACHE_DIR = "stomache"

+ var STOP_PROFILER = func()

+ var TEMP_INGEST_DIR = ".ingest.temp"

+ var TEST_MODE = false

+ var TOP_STRING_COUNT = 20

+ var TRUE = true

+ func FilterAndAggRecords(querySpec *QuerySpec, recordsPtr *RecordList) int

+ func GetTimeFormat(time_fmt string) string

+ func LoadAndSessionize(tables []*Table, querySpec *QuerySpec, sessionSpec *SessionSpec) int

+ func LoadRowBlockCB(digestname string, records RecordList)

+ func PrintResults(querySpec *QuerySpec)

+ func PrintTables()

+ func RecoverLock(lock RecoverableLock) bool

+ func SearchBlocks(querySpec *QuerySpec, block_list map[string]*TableBlock) map[string]*QuerySpec

+ func SessionizeRecords(querySpec *QuerySpec, sessionSpec *SessionSpec, recordsptr *RecordList)

+ func SetDefaults()

+ func SortResults(querySpec *QuerySpec)

+ type ActiveSession struct

+ Path []string

+ PathKey bytes.Buffer

+ PathLength int

+ PathStats map[string]int

+ Records RecordList

+ Stats *SessionStats

+ func (as *ActiveSession) AddRecord(r *Record)

+ func (as *ActiveSession) CombineSession(session *ActiveSession)

+ func (as *ActiveSession) ExpireRecords(timestamp int) []RecordList

+ func (as *ActiveSession) IsExpired() bool

+ type Activity struct

+ Count int

+ type ActivityMap map[int]Activity

+ type AfterLoadQueryCB struct

+ func (cb *AfterLoadQueryCB) CB(digestname string, records RecordList)

+ type AfterRowBlockLoad func(string, RecordList)

+ type Aggregation struct

+ type BlockLock struct

+ func (l *BlockLock) Recover() bool

+ type Calendar struct

+ Daily ActivityMap

+ Max int64

+ Min int64

+ Monthly ActivityMap

+ Weekly ActivityMap

+ func NewCalendar() *Calendar

+ func (c *Calendar) AddActivity(timestamp int)

+ func (c *Calendar) CombineCalendar(cc *Calendar)

+ type DigestLock struct

+ func (l *DigestLock) Recover() bool

+ type Filter interface

+ Filter func(*Record) bool

+ func BuildFilters(t *Table, loadSpec *LoadSpec, filterSpec FilterSpec) []Filter

+ type FilterSpec struct

+ Int string

+ Set string

+ Str string

+ type FlagDefs struct

+ ADD_RECORDS *int

+ ANOVA_ICC *bool

+ DIR *string

+ GC *bool

+ GROUPS *string

+ HIST_BUCKET *int

+ INTS *string

+ INT_FILTERS *string

+ JOIN_GROUP *string

+ JOIN_KEY *string

+ JOIN_TABLE *string

+ JSON *bool

+ LIMIT *int

+ LOAD_AND_QUERY *bool

+ LOAD_THEN_QUERY *bool

+ OP *string

+ PATH_KEY *string

+ PATH_LENGTH *int

+ PRINT *bool

+ PRINT_INFO *bool

+ PRINT_KEYS *bool

+ PROFILE *bool

+ PROFILE_MEM *bool

+ READ_INGESTION_LOG *bool

+ READ_ROWSTORE *bool

+ RETENTION *bool

+ SAMPLES *bool

+ SESSION_COL *string

+ SESSION_CUTOFF *int

+ SET_FILTERS *string

+ SORT *string

+ STRS *string

+ STR_FILTERS *string

+ STR_REPLACE *string

+ TABLE *string

+ TIME *bool

+ TIME_BUCKET *int

+ TIME_COL *string

+ UPDATE_TABLE_INFO *bool

+ WEIGHT_COL *string

+ type Grouping struct

+ type Hist struct

+ Avg float64

+ Count int64

+ Max int64

+ Min int64

+ Samples int

+ func (h *Hist) Combine(next_hist *Hist)

+ func (h *Hist) GetBuckets() map[string]int64

+ func (h *Hist) GetMeanVariance() float64

+ func (h *Hist) GetPercentiles() []int64

+ func (h *Hist) GetStdDev() float64

+ func (h *Hist) GetVariance() float64

+ func (h *Hist) Print()

+ func (h *Hist) SetupBuckets(buckets int, min, max int64)

+ func (h *Hist) Sum() int64

+ func (h *Hist) TrackPercentiles()

+ type InfoLock struct

+ func (l *InfoLock) Recover() bool

+ type IntArr []IntField

+ type IntField int64

+ type IntFilter struct

+ Field string

+ FieldId int16

+ Op string

+ Value int

+ func (filter IntFilter) Filter(r *Record) bool

+ type IntInfo struct

+ Avg float64

+ Count int

+ Max int64

+ Min int64

+ type IntInfoTable map[int16]*IntInfo

+ type LoadSpec struct

+ LoadAllColumns bool

+ func NewLoadSpec() LoadSpec

+ func (l *LoadSpec) Int(name string)

+ func (l *LoadSpec) Set(name string)

+ func (l *LoadSpec) Str(name string)

+ type Lock struct

+ Name string

+ Table *Table

+ func (l *Lock) ForceDeleteFile()

+ func (l *Lock) ForceMakeFile(pid int64)

+ func (l *Lock) Grab() bool

+ func (l *Lock) Recover() bool

+ func (l *Lock) Release() bool

+ type NoFilter struct

+ func (f NoFilter) Filter(r *Record) bool

+ type NoProfile struct

+ func (p NoProfile) Start() ProfilerStart

+ func (p NoProfile) Stop()

+ type OptionDefs struct

+ DELTA_ENCODE_INT_VALUES bool

+ DELTA_ENCODE_RECORD_IDS bool

+ GROUP_BY []string

+ SAMPLES bool

+ SORT_COUNT string

+ STR_REPLACEMENTS map[string]StrReplace

+ TIMESERIES bool

+ TIME_COL_ID int16

+ TIME_FORMAT string

+ WEIGHT_COL bool

+ WEIGHT_COL_ID int16

+ WRITE_BLOCK_INFO bool

+ type ProfilerStart interface

+ Stop func()

+ type ProfilerStop interface

+ Start func() ProfilerStart

+ type QuerySpec struct

+ Aggregations []Aggregation

+ BlockList map[string]TableBlock

+ Cumulative *Result

+ Filters []Filter

+ Groups []Grouping

+ Limit int16

+ Matched RecordList

+ OrderBy string

+ Results ResultMap

+ Sessions SessionList

+ Sorted []*Result

+ Table *Table

+ TimeBucket int

+ TimeResults map[int]ResultMap

+ func CombineResults(querySpec *QuerySpec, block_specs map[string]*QuerySpec) *QuerySpec

+ func CopyQuerySpec(querySpec *QuerySpec) *QuerySpec

+ func (qs *QuerySpec) PrintResults()

+ func (querySpec *QuerySpec) CalculateICC() map[string]float64

+ func (querySpec *QuerySpec) Punctuate()

+ func (querySpec *QuerySpec) ResetResults()

+ type Record struct

+ Ints []IntField

+ Path string

+ Populated []int8

+ SetMap map[int16]SetField

+ Strs []StrField

+ Timestamp int64

+ func (r *Record) AddIntField(name string, val int64)

+ func (r *Record) AddSetField(name string, val []string)

+ func (r *Record) AddStrField(name string, val string)

+ func (r *Record) CopyRecord() *Record

+ func (r *Record) GetIntVal(name string) (int, bool)

+ func (r *Record) GetSetVal(name string) ([]string, bool)

+ func (r *Record) GetStrVal(name string) (string, bool)

+ func (r *Record) ResizeFields(length int16)

+ type RecordList []*Record

+ func CombineMatches(block_specs map[string]*QuerySpec) RecordList

+ func (a RecordList) Len() int

+ func (a RecordList) Swap(i, j int)

+ type RecoverableLock interface

+ Grab func() bool

+ Recover func() bool

+ Release func() bool

+ type Result struct

+ BinaryByKey string

+ Count int64

+ GroupByKey string

+ Hists map[string]*Hist

+ Samples int64

+ func NewResult() *Result

+ func (rs *Result) Combine(next_result *Result)

+ type ResultJSON map[string]interface

+ type ResultMap map[string]*Result

+ func (master_result *ResultMap) Combine(results *ResultMap)

+ type RowSavedInt struct

+ Name int16

+ Value int64

+ type RowSavedSet struct

+ Name int16

+ Value []string

+ type RowSavedStr struct

+ Name int16

+ Value string

+ type Sample map[string]interface

+ type SaveBlockChunkCB struct

+ func (cb *SaveBlockChunkCB) CB(digestname string, records RecordList)

+ type SavedColumnInfo struct

+ IntInfoMap SavedIntInfo

+ NumRecords int32

+ StrInfoMap SavedStrInfo

+ type SavedIntBucket struct

+ Records []uint32

+ Value int64

+ type SavedIntColumn struct

+ Bins []SavedIntBucket

+ BucketEncoded bool

+ DeltaEncodedIDs bool

+ Name string

+ VERSION int32

+ ValueEncoded bool

+ Values []int64

+ func NewSavedIntColumn() SavedIntColumn

+ type SavedIntInfo map[string]*IntInfo

+ type SavedRecord struct

+ Ints []RowSavedInt

+ Sets []RowSavedSet

+ Strs []RowSavedStr

+ type SavedRecords struct

+ RecordList []*SavedRecord

+ type SavedSetBucket struct

+ Records []uint32

+ Value int32

+ type SavedSetColumn struct

+ Bins []SavedSetBucket

+ BucketEncoded bool

+ DeltaEncodedIDs bool

+ Name string

+ StringTable []string

+ VERSION int32

+ Values [][]int32

+ func NewSavedSetColumn() SavedSetColumn

+ type SavedStrBucket struct

+ Records []uint32

+ Value int32

+ type SavedStrColumn struct

+ Bins []SavedStrBucket

+ BucketEncoded bool

+ DeltaEncodedIDs bool

+ Name string

+ StringTable []string

+ VERSION int32

+ Values []int32

+ func NewSavedStrColumn() SavedStrColumn

+ type SavedStrInfo map[string]*StrInfo

+ type SeparatedColumns struct

+ type SessionList struct

+ Expiration int

+ JoinTable *Table

+ LastExpiration int

+ List Sessions

+ PathCounts map[string]int

+ PathUniques map[string]int

+ Results map[string]*SessionStats

+ func (as *SessionList) NoMoreRecordsBefore(timestamp int)

+ func (sl *SessionList) AddRecord(group_key string, r *Record)

+ func (sl *SessionList) ExpireRecords() int

+ type SessionSpec struct

+ Count int

+ ExpireAfter int

+ Sessions SessionList

+ func NewSessionSpec() SessionSpec

+ func (ss *SessionSpec) CombineSessions(sessionspec *SessionSpec)

+ func (ss *SessionSpec) ExpireRecords()

+ func (ss *SessionSpec) Finalize()

+ func (ss *SessionSpec) PrintResults()

+ type SessionStats struct

+ Calendar *Calendar

+ LastSessionEnd int64

+ NumEvents Hist

+ NumSessions Hist

+ Retention Hist

+ SessionDelta Hist

+ SessionDuration Hist

+ func NewSessionStats() *SessionStats

+ func (ss *SessionStats) CombineStats(stats *SessionStats)

+ func (ss *SessionStats) PrintStats(key string)

+ func (ss *SessionStats) SummarizeSession(records RecordList)

+ type Sessions map[string]*ActiveSession

+ type SetArr []SetField

+ type SetField []int32

+ type SetFilter struct

+ Field string

+ FieldId int16

+ Op string

+ Value string

+ func (filter SetFilter) Filter(r *Record) bool

+ type SetMap map[int16]SetField

+ type SortBlocksByEndTime []*TableBlock

+ func (a SortBlocksByEndTime) Len() int

+ func (a SortBlocksByEndTime) Less(i, j int) bool

+ func (a SortBlocksByEndTime) Swap(i, j int)

+ type SortBlocksByTime []*TableBlock

+ func (a SortBlocksByTime) Len() int

+ func (a SortBlocksByTime) Less(i, j int) bool

+ func (a SortBlocksByTime) Swap(i, j int)

+ type SortRecordsByTime struct

+ func (a SortRecordsByTime) Less(i, j int) bool

+ type SortResultsByCol struct

+ Col string

+ Results []*Result

+ func (a SortResultsByCol) Len() int

+ func (a SortResultsByCol) Less(i, j int) bool

+ func (a SortResultsByCol) Swap(i, j int)

+ type SortStrsByCount []StrInfoCol

+ func (a SortStrsByCount) Len() int

+ func (a SortStrsByCount) Less(i, j int) bool

+ func (a SortStrsByCount) Swap(i, j int)

+ type StrArr []StrField

+ type StrField int32

+ type StrFilter struct

+ Field string

+ FieldId int16

+ Op string

+ Regex *regexp.Regexp

+ Value string

+ func (filter StrFilter) Filter(r *Record) bool

+ type StrInfo struct

+ Cardinality int

+ TopStringCount map[int32]int

+ type StrInfoCol struct

+ Name int32

+ Value int

+ type StrInfoTable map[int16]*StrInfo

+ type StrReplace struct

+ type Table struct

+ BlockList map[string]*TableBlock

+ IntInfo IntInfoTable

+ KeyTable map[string]int16

+ KeyTypes map[int16]int8

+ LastBlock TableBlock

+ Name string

+ RowBlock *TableBlock

+ StrInfo StrInfoTable

+ func GetTable(name string) *Table

+ func (t *Table) Aggregation(name string, op string) Aggregation

+ func (t *Table) AppendRecordsToLog(records RecordList, blockname string)

+ func (t *Table) BuildJoinMap()

+ func (t *Table) ChunkAndSave()

+ func (t *Table) DeduceTableInfoFromBlocks()

+ func (t *Table) DigestRecords()

+ func (t *Table) FillPartialBlock() bool

+ func (t *Table) FindPartialBlocks() []*TableBlock

+ func (t *Table) GetColumnType(v string) int8

+ func (t *Table) GetRecordById(id string) *Record

+ func (t *Table) GrabBlockLock(name string) bool

+ func (t *Table) GrabDigestLock() bool

+ func (t *Table) GrabInfoLock() bool

+ func (t *Table) Grouping(name string) Grouping

+ func (t *Table) HasFlagFile() bool

+ func (t *Table) IngestRecords(blockname string)

+ func (t *Table) IntFilter(name string, op string, value int) IntFilter

+ func (t *Table) LoadAndQueryRecords(loadSpec *LoadSpec, querySpec *QuerySpec) int

+ func (t *Table) LoadBlockFromDir(dirname string, loadSpec *LoadSpec, load_records bool) *TableBlock

+ func (t *Table) LoadRecords(loadSpec *LoadSpec) int

+ func (t *Table) LoadRecordsFromLog(filename string) RecordList

+ func (t *Table) LoadRowStoreRecords(digest string, after_block_load_cb AfterRowBlockLoad)

+ func (t *Table) LoadSavedRecordsFromLog(filename string) []*SavedRecord

+ func (t *Table) LoadTableInfo() bool

+ func (t *Table) LoadTableInfoFrom(filename string) bool

+ func (t *Table) MatchAndAggregate(querySpec *QuerySpec)

+ func (t *Table) MaybeCompactRecords()

+ func (t *Table) NewHist(info *IntInfo) *Hist

+ func (t *Table) NewLoadSpec() LoadSpec

+ func (t *Table) NewRecord() *Record

+ func (t *Table) PrintColInfo()

+ func (t *Table) PrintRecord(r *Record)

+ func (t *Table) PrintRecords(records RecordList)

+ func (t *Table) PrintSamples()

+ func (t *Table) ReadBlockInfoFromDir(dirname string) *SavedColumnInfo

+ func (t *Table) ReleaseBlockLock(name string) bool

+ func (t *Table) ReleaseDigestLock() bool

+ func (t *Table) ReleaseInfoLock() bool

+ func (t *Table) ReleaseRecords()

+ func (t *Table) RestoreUningestedFiles()

+ func (t *Table) SaveRecordsToBlock(records RecordList, filename string)

+ func (t *Table) SaveRecordsToColumns() bool

+ func (t *Table) SaveTableInfo(fname string)

+ func (t *Table) SetFilter(name string, op string, value string) SetFilter

+ func (t *Table) ShouldLoadBlockFromDir(dirname string, querySpec *QuerySpec) bool

+ func (t *Table) StrFilter(name string, op string, value string) StrFilter

+ func (t *Table) TrimTable(trimSpec *TrimSpec) []*TableBlock

+ type TableBlock struct

+ Info *SavedColumnInfo

+ IntInfo IntInfoTable

+ Matched RecordList

+ Name string

+ RecordList RecordList

+ Size int64

+ StrInfo StrInfoTable

+ func (tb *TableBlock) GetColumnInfo(name_id int16) *TableColumn

+ func (tb *TableBlock) SaveInfoToColumns(dirname string)

+ func (tb *TableBlock) SaveIntsToColumns(dirname string, same_ints map[int16]ValueMap)

+ func (tb *TableBlock) SaveSetsToColumns(dirname string, same_sets map[int16]ValueMap)

+ func (tb *TableBlock) SaveStrsToColumns(dirname string, same_strs map[int16]ValueMap)

+ func (tb *TableBlock) SaveToColumns(filename string)

+ func (tb *TableBlock) SeparateRecordsIntoColumns() SeparatedColumns

+ type TableColumn struct

+ RCache map[int]bool

+ StringTable map[string]int32

+ Type int8

+ type TrimSpec struct

+ DeleteBefore int64

+ MBLimit int64

+ type ValueMap map[int64][]uint32

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL