Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/axiomhq/quantiles
/ functions
Functions
92 in github.com/axiomhq/quantiles
⨍
Functions
92
◇
Types & classes
9
↓ 18 callers
Method
push
(value, weight float64)
buffer.go:56
↓ 13 callers
Function
getQuantileSpecs
* 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 callers
Method
Push
Push a value and a weight into the stream
sketch.go:73
↓ 12 callers
Method
TotalWeight
TotalWeight returns the total weight of the summary
summary.go:331
↓ 11 callers
Method
ApproximationError
ApproximationError ...
summary.go:296
↓ 10 callers
Method
buildFromBufferEntries
(bes []bufEntry)
summary.go:65
↓ 10 callers
Method
generateEntryList
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 callers
Function
newBuffer
(blockSize, maxElements int64)
buffer.go:27
↓ 9 callers
Method
Finalize
Finalize flushes approximator and finalizes state.
sketch.go:113
↓ 9 callers
Method
compress
(sizeHint int64, minEps float64)
summary.go:171
↓ 8 callers
Method
MaxValue
MaxValue returns the max weight value of the summary
summary.go:323
↓ 8 callers
Method
MinValue
MinValue returns the min weight value of the summary
summary.go:315
↓ 8 callers
Method
Size
Size returns the size (num of entries) in the summary
summary.go:339
↓ 7 callers
Method
nextMinRank
()
summary.go:37
↓ 6 callers
Function
New
New returns a new Sketch for a given eps and maxElements
sketch.go:29
↓ 6 callers
Function
maxFloat64
(a, b float64)
utils.go:10
↓ 6 callers
Function
testSingleWorkerStreams
(t *testing.T, eps float64, maxElements int64, workerSummaryGenerator workerSummaryGeneratorFunc, expectedQu
sketch_test.go:96
↓ 5 callers
Method
GenerateQuantiles
* 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 callers
Method
Merge
Merge another summary into the this summary (great for esimating quantiles over several streams)
summary.go:85
↓ 5 callers
Function
NewWeightedQuantilesSummaryDummy
()
summary_test.go:25
↓ 5 callers
Method
isFull
isFull ...
buffer.go:93
↓ 5 callers
Method
prevMaxRank
()
summary.go:33
↓ 4 callers
Method
FinalSummary
FinalSummary ...
sketch.go:249
↓ 4 callers
Function
maxInt64
(a, b int64)
utils.go:3
↓ 4 callers
Function
testDistributedStreams
Distributed tests.
sketch_test.go:214
↓ 3 callers
Method
ApproximationError
* 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 callers
Function
minFloat64
(a, b float64)
utils.go:17
↓ 3 callers
Function
push
(n int)
buffer_test.go:81
↓ 2 callers
Method
Clear
Clear reset the summary
summary.go:344
↓ 2 callers
Method
buildFromSummaryEntries
(ses []SumEntry)
summary.go:80
↓ 2 callers
Function
newSummary
newSummary ...
summary.go:49
↓ 2 callers
Method
propagateLocalSummary
* propagates local summary through summary levels while maintaining approximation error invariants. */
sketch.go:138
↓ 2 callers
Method
pushBuffer
(buf *buffer)
sketch.go:91
↓ 1 callers
Method
GenerateQuantiles
GenerateQuantiles returns a slice of float64 of size numQuantiles+1, the ith entry is the `i * 1/numQuantiles+1` quantile
summary.go:265
↓ 1 callers
Function
NewDefault
NewDefault returns a new Sketch with the eps = 0.01 and maxElements 1000
sketch.go:23
↓ 1 callers
Method
PushSummary
PushSummary pushes full summary while maintaining approximation error invariants.
sketch.go:102
↓ 1 callers
Method
Quantile
Quantile ...
sketch.go:176
↓ 1 callers
Function
axiom
()
demo/main.go:25
↓ 1 callers
Function
prom
()
demo/main.go:36
↓ 1 callers
Method
setup
()
summary_test.go:44
↓ 1 callers
Function
veneur
()
demo/main.go:16
Function
BenchmarkPush100
(b *testing.B)
buffer_test.go:91
Function
BenchmarkPush1000
(b *testing.B)
buffer_test.go:101
Function
BenchmarkPush10000
(b *testing.B)
buffer_test.go:111
Method
Entries
Entries returns all summary entries
summary.go:349
Function
Example
()
stream_example_test.go:9
Method
GenerateBoundaries
* GenerateBoundaries generates requested number of boundaries after finalizing stream. The returned boundaries can be queried using std::lower_bound t
sketch.go:205
Method
GenerateBoundaries
GenerateBoundaries ...
summary.go:218
Method
Len
()
buffer.go:11
Method
Less
(i, j int)
buffer.go:12
Method
MaxDepth
MaxDepth ...
sketch.go:244
Method
MaxRank
MaxRank returns the entries maximum rank
summary.go:24
Method
MinRank
MinRank returns the entries minimum rank
summary.go:29
Method
Quantile
Quantile returns the value for quantile q
summary.go:245
Method
Swap
(i, j int)
buffer.go:13
Function
TestBufferInvalid
(t *testing.T)
buffer_test.go:9
Function
TestBufferPushEntryFull
(t *testing.T)
buffer_test.go:36
Function
TestBufferPushEntryFullDeath
(t *testing.T)
buffer_test.go:58
Function
TestBufferPushEntryNotFull
(t *testing.T)
buffer_test.go:18
Function
TestInvalidEps
(t *testing.T)
sketch_test.go:13
Function
TestNonZeroEps
(t *testing.T)
sketch_test.go:33
Function
TestRandUniformFixedWeightsDistributed
(t *testing.T)
sketch_test.go:311
Function
TestRandUniformRandWeightsDistributed
(t *testing.T)
sketch_test.go:321
Function
TestSketchMedian
(t *testing.T)
sketch_test.go:331
Function
TestStreamFixedNonUniform
(t *testing.T)
sketch_test.go:186
Function
TestStreamFixedNonUniformDistributed
(t *testing.T)
sketch_test.go:300
Function
TestStreamFixedUniform
(t *testing.T)
sketch_test.go:177
Function
TestStreamFixedUniformDistributed
(t *testing.T)
sketch_test.go:290
Function
TestStreamOneValue
(t *testing.T)
sketch_test.go:159
Function
TestStreamOneZeroWeightValue
(t *testing.T)
sketch_test.go:168
Function
TestStreamRandUniformFixedWeights
(t *testing.T)
sketch_test.go:195
Function
TestStreamRandUniformRandWeights
(t *testing.T)
sketch_test.go:204
Function
TestSummaryBuildFromBuffer
(t *testing.T)
summary_test.go:87
Function
TestSummaryCompressRandomized
(t *testing.T)
summary_test.go:220
Function
TestSummaryCompressSeparately
(t *testing.T)
summary_test.go:136
Function
TestSummaryCompressSequentially
(t *testing.T)
summary_test.go:177
Function
TestSummaryCompressThenMerge
(t *testing.T)
summary_test.go:300
Function
TestSummaryMergeSymmetry
(t *testing.T)
summary_test.go:262
Function
TestZeroEps
(t *testing.T)
sketch_test.go:20
Method
Value
Value returns the entries value
summary.go:14
Method
Weight
Weight returns the entries weight
summary.go:19
Function
bToMb
(b uint64)
demo/main.go:12
Method
clone
()
sketch.go:56
Method
clone
()
summary.go:55
Method
clone
()
buffer.go:44
Function
generateFixedNonUniformSummary
(workerID int32, maxElements int64, totalWeight *float64, stream *Sketch)
sketch_test.go:75
Function
generateFixedUniformSummary
(workerID int32, maxElements int64, totalWeight *float64, stream *Sketch)
sketch_test.go:55
Function
generateOneValue
Stream generators.
sketch_test.go:147
Function
generateOneZeroWeightedValue
Stream generators.
sketch_test.go:154
Function
generateRandUniformFixedWeightsSummary
(workerID int32, maxElements int64, totalWeight *float64, stream *Sketch)
sketch_test.go:66
Function
generateRandUniformRandWeightsSummary
(workerID int32, maxElements int64, totalWeight *float64, stream *Sketch)
sketch_test.go:84
Function
main
()
demo/main.go:45