MCPcopy Create free account

hub / github.com/axiomhq/quantiles / functions

Functions92 in github.com/axiomhq/quantiles

↓ 18 callersMethodpush
(value, weight float64)
buffer.go:56
↓ 13 callersFunctiongetQuantileSpecs
* Helper method which, given the desired approximation error and an upper bound on the number of elements, computes the optimal number of levels and b
sketch.go:261
↓ 12 callersMethodPush
Push a value and a weight into the stream
sketch.go:73
↓ 12 callersMethodTotalWeight
TotalWeight returns the total weight of the summary
summary.go:331
↓ 11 callersMethodApproximationError
ApproximationError ...
summary.go:296
↓ 10 callersMethodbuildFromBufferEntries
(bes []bufEntry)
summary.go:65
↓ 10 callersMethodgenerateEntryList
generateEntryList returns a sorted vector view of the base buffer and clears the buffer. Callers should minimize how often this is called, ideally onl
buffer.go:72
↓ 10 callersFunctionnewBuffer
(blockSize, maxElements int64)
buffer.go:27
↓ 9 callersMethodFinalize
Finalize flushes approximator and finalizes state.
sketch.go:113
↓ 9 callersMethodcompress
(sizeHint int64, minEps float64)
summary.go:171
↓ 8 callersMethodMaxValue
MaxValue returns the max weight value of the summary
summary.go:323
↓ 8 callersMethodMinValue
MinValue returns the min weight value of the summary
summary.go:315
↓ 8 callersMethodSize
Size returns the size (num of entries) in the summary
summary.go:339
↓ 7 callersMethodnextMinRank
()
summary.go:37
↓ 6 callersFunctionNew
New returns a new Sketch for a given eps and maxElements
sketch.go:29
↓ 6 callersFunctionmaxFloat64
(a, b float64)
utils.go:10
↓ 6 callersFunctiontestSingleWorkerStreams
(t *testing.T, eps float64, maxElements int64, workerSummaryGenerator workerSummaryGeneratorFunc, expectedQu
sketch_test.go:96
↓ 5 callersMethodGenerateQuantiles
* GenerateQuantiles generates requested number of quantiles after finalizing stream. The returned quantiles can be queried using std::lower_bound to g
sketch.go:188
↓ 5 callersMethodMerge
Merge another summary into the this summary (great for esimating quantiles over several streams)
summary.go:85
↓ 5 callersFunctionNewWeightedQuantilesSummaryDummy
()
summary_test.go:25
↓ 5 callersMethodisFull
isFull ...
buffer.go:93
↓ 5 callersMethodprevMaxRank
()
summary.go:33
↓ 4 callersMethodFinalSummary
FinalSummary ...
sketch.go:249
↓ 4 callersFunctionmaxInt64
(a, b int64)
utils.go:3
↓ 4 callersFunctiontestDistributedStreams
Distributed tests.
sketch_test.go:214
↓ 3 callersMethodApproximationError
* ApproximationError calculates approximation error for the specified level. If the passed level is negative, the approximation error for the entire s
sketch.go:218
↓ 3 callersFunctionminFloat64
(a, b float64)
utils.go:17
↓ 3 callersFunctionpush
(n int)
buffer_test.go:81
↓ 2 callersMethodClear
Clear reset the summary
summary.go:344
↓ 2 callersMethodbuildFromSummaryEntries
(ses []SumEntry)
summary.go:80
↓ 2 callersFunctionnewSummary
newSummary ...
summary.go:49
↓ 2 callersMethodpropagateLocalSummary
* propagates local summary through summary levels while maintaining approximation error invariants. */
sketch.go:138
↓ 2 callersMethodpushBuffer
(buf *buffer)
sketch.go:91
↓ 1 callersMethodGenerateQuantiles
GenerateQuantiles returns a slice of float64 of size numQuantiles+1, the ith entry is the `i * 1/numQuantiles+1` quantile
summary.go:265
↓ 1 callersFunctionNewDefault
NewDefault returns a new Sketch with the eps = 0.01 and maxElements 1000
sketch.go:23
↓ 1 callersMethodPushSummary
PushSummary pushes full summary while maintaining approximation error invariants.
sketch.go:102
↓ 1 callersMethodQuantile
Quantile ...
sketch.go:176
↓ 1 callersFunctionaxiom
()
demo/main.go:25
↓ 1 callersFunctionprom
()
demo/main.go:36
↓ 1 callersMethodsetup
()
summary_test.go:44
↓ 1 callersFunctionveneur
()
demo/main.go:16
FunctionBenchmarkPush100
(b *testing.B)
buffer_test.go:91
FunctionBenchmarkPush1000
(b *testing.B)
buffer_test.go:101
FunctionBenchmarkPush10000
(b *testing.B)
buffer_test.go:111
MethodEntries
Entries returns all summary entries
summary.go:349
FunctionExample
()
stream_example_test.go:9
MethodGenerateBoundaries
* GenerateBoundaries generates requested number of boundaries after finalizing stream. The returned boundaries can be queried using std::lower_bound t
sketch.go:205
MethodGenerateBoundaries
GenerateBoundaries ...
summary.go:218
MethodLen
()
buffer.go:11
MethodLess
(i, j int)
buffer.go:12
MethodMaxDepth
MaxDepth ...
sketch.go:244
MethodMaxRank
MaxRank returns the entries maximum rank
summary.go:24
MethodMinRank
MinRank returns the entries minimum rank
summary.go:29
MethodQuantile
Quantile returns the value for quantile q
summary.go:245
MethodSwap
(i, j int)
buffer.go:13
FunctionTestBufferInvalid
(t *testing.T)
buffer_test.go:9
FunctionTestBufferPushEntryFull
(t *testing.T)
buffer_test.go:36
FunctionTestBufferPushEntryFullDeath
(t *testing.T)
buffer_test.go:58
FunctionTestBufferPushEntryNotFull
(t *testing.T)
buffer_test.go:18
FunctionTestInvalidEps
(t *testing.T)
sketch_test.go:13
FunctionTestNonZeroEps
(t *testing.T)
sketch_test.go:33
FunctionTestRandUniformFixedWeightsDistributed
(t *testing.T)
sketch_test.go:311
FunctionTestRandUniformRandWeightsDistributed
(t *testing.T)
sketch_test.go:321
FunctionTestSketchMedian
(t *testing.T)
sketch_test.go:331
FunctionTestStreamFixedNonUniform
(t *testing.T)
sketch_test.go:186
FunctionTestStreamFixedNonUniformDistributed
(t *testing.T)
sketch_test.go:300
FunctionTestStreamFixedUniform
(t *testing.T)
sketch_test.go:177
FunctionTestStreamFixedUniformDistributed
(t *testing.T)
sketch_test.go:290
FunctionTestStreamOneValue
(t *testing.T)
sketch_test.go:159
FunctionTestStreamOneZeroWeightValue
(t *testing.T)
sketch_test.go:168
FunctionTestStreamRandUniformFixedWeights
(t *testing.T)
sketch_test.go:195
FunctionTestStreamRandUniformRandWeights
(t *testing.T)
sketch_test.go:204
FunctionTestSummaryBuildFromBuffer
(t *testing.T)
summary_test.go:87
FunctionTestSummaryCompressRandomized
(t *testing.T)
summary_test.go:220
FunctionTestSummaryCompressSeparately
(t *testing.T)
summary_test.go:136
FunctionTestSummaryCompressSequentially
(t *testing.T)
summary_test.go:177
FunctionTestSummaryCompressThenMerge
(t *testing.T)
summary_test.go:300
FunctionTestSummaryMergeSymmetry
(t *testing.T)
summary_test.go:262
FunctionTestZeroEps
(t *testing.T)
sketch_test.go:20
MethodValue
Value returns the entries value
summary.go:14
MethodWeight
Weight returns the entries weight
summary.go:19
FunctionbToMb
(b uint64)
demo/main.go:12
Methodclone
()
sketch.go:56
Methodclone
()
summary.go:55
Methodclone
()
buffer.go:44
FunctiongenerateFixedNonUniformSummary
(workerID int32, maxElements int64, totalWeight *float64, stream *Sketch)
sketch_test.go:75
FunctiongenerateFixedUniformSummary
(workerID int32, maxElements int64, totalWeight *float64, stream *Sketch)
sketch_test.go:55
FunctiongenerateOneValue
Stream generators.
sketch_test.go:147
FunctiongenerateOneZeroWeightedValue
Stream generators.
sketch_test.go:154
FunctiongenerateRandUniformFixedWeightsSummary
(workerID int32, maxElements int64, totalWeight *float64, stream *Sketch)
sketch_test.go:66
FunctiongenerateRandUniformRandWeightsSummary
(workerID int32, maxElements int64, totalWeight *float64, stream *Sketch)
sketch_test.go:84
Functionmain
()
demo/main.go:45