Function TestReducerMinMaxSum

functional/functional_test.go:237–300

(t *testing.T)

}

func TestReducerMinMaxSum(t *testing.T) {
	tests := []struct {
		rows    [][]ast.Constant
		wantMin ast.Constant
		wantMax ast.Constant
		wantSum ast.Constant
		wantAvg ast.Constant
	}{
		{
			rows: [][]ast.Constant{
				{ast.Number(1)},
				{ast.Number(1)},
				{ast.Number(3)},
			},
			wantMin: ast.Number(1),
			wantMax: ast.Number(3),
			wantSum: ast.Number(5),
			wantAvg: ast.Float64((float64(1) + float64(1) + float64(3)) / float64(3)),
		},
		// Note that EvalReducerFn is never called with empty list of rows.
		// The reducer functions may be called in user code though.
		{
			rows:    nil,
			wantMin: ast.Number(math.MaxInt64),
			wantMax: ast.Number(math.MinInt64),
			wantSum: ast.Number(0),
			wantAvg: ast.Float64(math.NaN()),
		},
	}
	for _, test := range tests {
		var rows []ast.ConstSubstList
		for _, row := range test.rows {
			rows = append(rows, makeConstSubstList([]ast.Variable{ast.Variable{"X"}}, row))
		}
		gotMax, err := EvalReduceFn(ast.ApplyFn{symbols.Max, []ast.BaseTerm{ast.Variable{"X"}}}, rows)
		if err != nil {
			t.Fatalf("EvalReduceFn(Max,%v) failed with %v", rows, err)
		}
		if test.wantMax != gotMax {
			t.Errorf("EvalReduceFn(Max, %v)=%v want %v", rows, gotMax, test.wantMax)
		}
		gotMin, err := EvalReduceFn(ast.ApplyFn{symbols.Min, []ast.BaseTerm{ast.Variable{"X"}}}, rows)
		if err != nil {
			t.Fatalf("EvalReduceFn(Min,%v) failed with %v", rows, err)
		}
		if test.wantMin != gotMin {
			t.Errorf("EvalReduceFn(Min, %v)=%v want %v", rows, gotMin, test.wantMin)
		}
		gotSum, err := EvalReduceFn(ast.ApplyFn{symbols.Sum, []ast.BaseTerm{ast.Variable{"X"}}}, rows)
		if err != nil {
			t.Fatalf("EvalReduceFn(Sum, %v) failed with %v", rows, err)
		}
		if test.wantSum != gotSum {
			t.Errorf("EvalReduceFn(Sum, %v)=%v want %v", rows, gotSum, test.wantSum)
		}
		gotAvg, err := EvalReduceFn(ast.ApplyFn{symbols.Avg, []ast.BaseTerm{ast.Variable{"X"}}}, rows)
		if err != nil {
			t.Fatalf("EvalReduceFn(Avg, %v) failed with %v", rows, err)