MCPcopy Create free account

hub / github.com/cloudflare/parquet-tsdb-poc / functions

Functions341 in github.com/cloudflare/parquet-tsdb-poc

⨍ Functions 341◇ Types & classes 94
↓ 1 callersFunctionEqualWithPageCheck
(path string, value parquet.Value)
search/constraint.go:35
↓ 1 callersMethodErr
()
db/iterator.go:122
↓ 1 callersMethodExtlabels
()
db/db.go:66
↓ 1 callersMethodGetColumns
()
proto/metapb/meta.pb.go:130
↓ 1 callersMethodGetColumnsForName
()
proto/metapb/meta.pb.go:85
↓ 1 callersMethodGetMaxt
()
proto/metapb/meta.pb.go:71
↓ 1 callersMethodGetMint
()
proto/metapb/meta.pb.go:64
↓ 1 callersMethodGetShards
()
proto/metapb/meta.pb.go:78
↓ 1 callersMethodIndex
()
convert/convert.go:27
↓ 1 callersFunctionIntersection
Intersection gives the intersection of [a, b] and [c, d]. It should first be checked if both intersect using Intersects
internal/util/interval.go:19
↓ 1 callersMethodIterator
(_ chunkenc.Iterator)
db/iterator.go:26
↓ 1 callersMethodLabelNames
(context.Context, *storage.LabelHints, ...*labels.Matcher)
db/db.go:151
↓ 1 callersMethodLabelValues
(ctx context.Context, name string, hints *storage.LabelHints, ms ...*labels.Matcher)
db/db.go:134
↓ 1 callersFunctionLabelsProjection
(s *parquet.Schema)
schema/schema.go:92
↓ 1 callersMethodLen
()
db/db_test.go:1062
↓ 1 callersMethodNameLabelMapping
()
convert/tsdb.go:115
↓ 1 callersFunctionNewDB
(syncer syncer, opts ...DBOption)
db/db.go:44
↓ 1 callersMethodNext
()
db/iterator.go:102
↓ 1 callersFunctionOr
(cs ...Constraint)
search/constraint.go:250
↓ 1 callersMethodPop
()
convert/sort.go:212
↓ 1 callersMethodReadRows
(rows []parquet.Row)
convert/sort.go:164
↓ 1 callersFunctionRegisterMetrics
(reg prometheus.Registerer)
search/metrics.go:25
↓ 1 callersFunctionRegisterMetrics
(reg prometheus.Registerer)
db/metrics.go:19
↓ 1 callersFunctionRegisterQueryV1
(r *route.Router, queryable storage.Queryable, engine promql.QueryEngine, opts ...QueryAPIOption)
api/http/query.go:68
↓ 1 callersMethodSeek
(t int64)
db/iterator.go:70
↓ 1 callersMethodSeek
(t int64)
db/iterator.go:136
↓ 1 callersMethodSeries
()
db/shard.go:319
↓ 1 callersFunctionSet
(path string, values []parquet.Value)
search/constraint.go:254
↓ 1 callersFunctionSortBufSize
(sbs int)
convert/convert.go:72
↓ 1 callersFunctionSortBy
(labels []string)
convert/convert.go:78
↓ 1 callersFunctionSplitBlockPath
(name string)
schema/block.go:20
↓ 1 callersMethodTombstones
()
convert/convert.go:29
↓ 1 callersFunctionTracer
()
internal/tracing/tracer.go:15
↓ 1 callersFunctionallChunksEmpty
(chkBytes [schema.ChunkColumnsPerDay][]byte)
convert/chunks.go:19
↓ 1 callersMethodbuffer
(i int)
search/search.go:277
↓ 1 callersMethodbuildBloomfilterColumns
()
convert/convert.go:44
↓ 1 callersMethodbuildSortingColumns
()
convert/convert.go:54
↓ 1 callersFunctionchunkProjections
(blkStart, mint, maxt int64)
db/shard.go:211
↓ 1 callersMethodclose
()
convert/sort.go:251
↓ 1 callersFunctioncollectChunks
(it chunks.Iterator)
convert/chunks.go:28
↓ 1 callersFunctionconstraintForMatchers
(matchers []*labels.Matcher, columnsForName []string)
db/shard.go:154
↓ 1 callersMethodconvert
(ctx context.Context)
convert/convert.go:192
↓ 1 callersMethodconvertShard
(ctx context.Context)
convert/convert.go:239
↓ 1 callersMethodconvertShards
(ctx context.Context)
convert/convert.go:228
↓ 1 callersFunctiondownloadBlocks
(ctx context.Context, bkt objstore.BucketReader, metas []tsdb.BlockMeta, blkDir string)
cmd/convert.go:187
↓ 1 callersFunctionequalRow
(l, r parquet.Row)
search/search_test.go:144
↓ 1 callersFunctionfetchTSDBMetas
(ctx context.Context, bkt objstore.BucketReader, from, to time.Time)
cmd/convert.go:130
↓ 1 callersFunctionfile_meta_proto_init
()
proto/metapb/meta.pb.go:194
↓ 1 callersMethodfilterBlocks
(blks []*Block)
db/syncer.go:177
↓ 1 callersMethodfilterBlocks
([]*Block)
db/syncer.go:183
↓ 1 callersMethodfilterMetas
(metas map[string]Meta)
db/syncer.go:173
↓ 1 callersMethodfilterMetas
(map[string]Meta)
db/syncer.go:182
↓ 1 callersFunctionfromStorageHints
(h *storage.SelectHints)
db/seriesset.go:23
↓ 1 callersFunctiongetStartEnd
(opts conversionOpts)
cmd/convert.go:118
↓ 1 callersMethodinit
()
db/seriesset.go:67
↓ 1 callersMethodinitialize
()
convert/sort.go:127
↓ 1 callersFunctionlabelProjections
(columnsForName []string)
db/shard.go:207
↓ 1 callersFunctionmakeBufferedRowReaders
(numReaders int, readerAt func(int) parquet.RowReader)
convert/sort.go:116
↓ 1 callersFunctionmergeRowReaders
(readers []parquet.RowReader, compare func(parquet.Row, parquet.Row) int)
convert/sort.go:109
↓ 1 callersFunctionmetricNameFromMatchers
(matchers []*labels.Matcher)
db/shard.go:145
↓ 1 callersFunctionnewBoundedSeriesIterator
(it chunkenc.Iterator, mint, maxt int64)
db/iterator.go:132
↓ 1 callersFunctionnewBucketReaderAt
(bkt objstore.Bucket, name string, timeout time.Duration)
db/util.go:24
↓ 1 callersFunctionnewChunkSeriesIterator
(cs []chunkenc.Iterator)
db/iterator.go:63
↓ 1 callersFunctionnewConcatSeriesSet
(series ...storage.Series)
db/seriesset.go:141
↓ 1 callersFunctionnewConverter
( name string, mint int64, maxt int64, rr *indexRowReader, bkt objstore.Bucket, p parquet.BufferPool, s
convert/convert.go:162
↓ 1 callersFunctionnewFilterRowReader
(rr RowReaderCloser, accept func(r parquet.Row) bool)
search/search.go:172
↓ 1 callersFunctionnewIndexRowReader
(ctx context.Context, mint, maxt int64, blks []Convertible)
convert/tsdb.go:42
↓ 1 callersFunctionnewLimitReader
(r parquet.RowReader, limit int)
convert/convert.go:385
↓ 1 callersFunctionnewRangesRowReader
(ranges []rowRange, rows parquet.Rows)
search/search.go:91
↓ 1 callersFunctionnewReaderAt
(r io.ReadSeeker)
convert/sort.go:295
↓ 1 callersFunctionnewRowGroupRows
(schema *parquet.Schema, columns []parquet.ColumnChunk)
search/search.go:283
↓ 1 callersFunctionnewSortingWriter
(in io.ReadWriteSeeker, p parquet.BufferPool, schema *parquet.Schema, flushThreshold int, cols ...parquet.Sort
convert/sort.go:29
↓ 1 callersFunctionnewVerticalSeriesSet
(sets ...storage.SeriesSet)
db/seriesset.go:99
↓ 1 callersMethodnext
()
search/search.go:95
↓ 1 callersMethodnext
()
convert/sort.go:230
↓ 1 callersFunctionoverlappingBlocks
(blocks []*tsdb.Block, date time.Time)
cmd/convert.go:173
↓ 1 callersFunctionparseDuration
(s string)
api/http/query.go:207
↓ 1 callersFunctionparseMatchersParam
(r *http.Request)
api/http/query.go:225
↓ 1 callersFunctionparseTime
(s string)
api/http/query.go:171
↓ 1 callersFunctionreadShard
(ctx context.Context, bkt objstore.Bucket, m Meta, i int, cfg blockConfig)
db/syncer.go:284
↓ 1 callersFunctionreadShards
(ctx context.Context, bkt objstore.Bucket, m Meta, cfg blockConfig)
db/syncer.go:272
↓ 1 callersFunctionregisterConvertApp
(app *kingpin.Application)
cmd/convert.go:41
↓ 1 callersMethodregisterFlags
(cmd *kingpin.CmdClause)
cmd/convert.go:35
↓ 1 callersMethodregisterFlags
(cmd *kingpin.CmdClause)
cmd/serve.go:51
↓ 1 callersMethodregisterParquetFlags
(cmd *kingpin.CmdClause)
cmd/config.go:56
↓ 1 callersFunctionregisterServeApp
(app *kingpin.Application)
cmd/serve.go:61
↓ 1 callersMethodregisterTSDBFlags
(cmd *kingpin.CmdClause)
cmd/config.go:68
↓ 1 callersFunctionsamplesFromModel
(samples []promql.FPoint)
api/grpc/thanos.go:203
↓ 1 callersFunctionsetupDiscovery
(ctx context.Context, g *run.Group, log *slog.Logger, bkt objstore.Bucket, opts blockOpts)
cmd/serve.go:181
↓ 1 callersFunctionsetupInternalAPI
(g *run.Group, log *slog.Logger, reg *prometheus.Registry, opts internalAPIOpts)
cmd/serve.go:384
↓ 1 callersFunctionsetupInterrupt
(ctx context.Context, g *run.Group, log *slog.Logger)
cmd/serve.go:109
↓ 1 callersFunctionsetupMetaFilter
(ctx context.Context, g *run.Group, log *slog.Logger, opts blockOpts)
cmd/serve.go:211
↓ 1 callersFunctionsetupPromAPI
(g *run.Group, log *slog.Logger, db *cfdb.DB, opts promAPIOpts, qOpts queryOpts)
cmd/serve.go:347
↓ 1 callersFunctionsetupPrometheusRegistry
()
cmd/cmd.go:87
↓ 1 callersFunctionsetupSyncer
(ctx context.Context, g *run.Group, log *slog.Logger, bkt objstore.Bucket, discoverer *cfdb.Discoverer, metaFi
cmd/serve.go:248
↓ 1 callersFunctionsetupThanosAPI
(g *run.Group, log *slog.Logger, db *cfdb.DB, opts thanosAPIOpts, qOpts queryOpts)
cmd/serve.go:296
↓ 1 callersFunctionsetupTracing
(ctx context.Context, opts tracingOpts)
cmd/config.go:154
↓ 1 callersFunctionsizeFromSeeker
(seek io.Seeker)
convert/sort.go:257
↓ 1 callersMethodskipByBloomfilter
(cc parquet.ColumnChunk)
search/constraint.go:145
↓ 1 callersFunctiontoStorageHints
(h hints)
db/seriesset.go:33
← previousnext →101–200 of 341, ranked by callers