Commit 6684ad68838e311a65fd386a720ba0a5ef692eee - golang-github-beorn7-perks

+1

-1

quantile/bench_test.go less more

5	5
6	6	func BenchmarkInsert(b *testing.B) {
7	7	b.StopTimer()
8		s := New(Targeted(0.01, 0.5, 0.9, 0.99))
	8	s := NewTargeted(0.01, 0.5, 0.9, 0.99)
9	9	b.StartTimer()
10	10	for i := float64(0); i < float64(b.N); i++ {
11	11	s.Insert(i)

+1

-1

quantile/example_test.go less more

14	14	go readFloats(ch)
15	15
16	16	// Compute the 50th, 90th, and 99th percentile for a stream within the set error epsilon of 0.01.
17		q := quantile.New(quantile.Targeted(0.01, 0.50, 0.90, 0.99))
	17	q := quantile.NewTargeted(0.01, 0.50, 0.90, 0.99)
18	18	for v := range ch {
19	19	q.Insert(v)
20	20	}

+14

-13

quantile/stream.go less more

40	40	a[i], a[j] = a[j], a[i]
41	41	}
42	42
43		type Invariant func(s *stream, r float64) float64
44
45		// Biased returns an Invariant for high-biased (>50th) quantiles not known a
	43	type invariant func(s *stream, r float64) float64
	44
	45	// Biased returns an Stream for high-biased (>50th) quantiles not known a
46	46	// priori with associated error bounds e (usually 0.01).
47	47	// See http://www.cs.rutgers.edu/~muthu/bquant.pdf for time, space, and error properties.
48		func Biased(e float64) Invariant {
49		return func(s *stream, r float64) float64 {
	48	func NewBiased(e float64) *Stream {
	49	f := func(s *stream, r float64) float64 {
50	50	return 2 * e * r
51	51	}
52		}
53
54		// Targeted returns an Invariant that is only concerned with a set
	52	return newStream(f)
	53	}
	54
	55	// Targeted returns an Stream that is only concerned with a set
55	56	// of quantile values with associated error bounds e (usually 0.01) that are supplied a priori.
56	57	// See http://www.cs.rutgers.edu/~muthu/bquant.pdf for time, space, and error properties.
57		func Targeted(e float64, quantiles ...float64) Invariant {
58		return func(s *stream, r float64) float64 {
	58	func NewTargeted(e float64, quantiles ...float64) *Stream {
	59	f := func(s *stream, r float64) float64 {
59	60	var m float64 = math.MaxFloat64
60	61	var f float64
61	62	for _, q := range quantiles {

68	69	}
69	70	return m
70	71	}
	72	return newStream(f)
71	73	}
72	74
73	75	// Stream calculates quantiles for a stream of float64s.

76	78	b Samples
77	79	}
78	80
79		// New returns an initialized Stream with the Invariant ƒ.
80		func New(ƒ Invariant) *Stream {
	81	func newStream(ƒ invariant) *Stream {
81	82	x := &stream{ƒ: ƒ, l: list.New()}
82	83	return &Stream{x, make(Samples, 0, 500)}
83	84	}

141	142	type stream struct {
142	143	n float64
143	144	l *list.List
144		ƒ Invariant
	145	ƒ invariant
145	146	}
146	147
147	148	func (s *stream) reset() {

+2

-2

quantile/stream_test.go less more

7	7	)
8	8
9	9	func TestQuantRandQuery(t *testing.T) {
10		s := New(Targeted(0.01, 0.5, 0.90, 0.99))
	10	s := NewTargeted(0.01, 0.5, 0.90, 0.99)
11	11	a := make([]float64, 0, 1e5)
12	12	rand.Seed(42)
13	13	for i := 0; i < cap(a); i++ {

39	39	done := make(chan *Stream)
40	40	for i := 0; i < 2; i++ {
41	41	go func() {
42		s := New(Targeted(0.01, 0.5, 0.90, 0.99))
	42	s := NewTargeted(0.01, 0.5, 0.90, 0.99)
43	43	for v := range ch {
44	44	s.Insert(v)
45	45	}