Function test_streaming_topk_stats

graphlite/src/exec/streaming_topk.rs:353–371

()

    #[test]
    fn test_streaming_topk_stats() {
        let mut topk = StreamingTopK::new(5);

        for i in 0..20 {
            topk.add(create_test_row(i, i as f64), i as f64);
        }

        let stats = topk.stats();

        assert_eq!(stats.processed_count, 20);
        assert_eq!(stats.kept_count, 5);
        assert_eq!(stats.k, 5);

        // Memory savings: kept 5 out of 20 = 25%
        assert!((stats.memory_savings_ratio() - 0.25).abs() < 0.01);

        // Discard ratio: discarded 15 out of 20 = 75%
        assert!((stats.discard_ratio() - 0.75).abs() < 0.01);
    }

    #[test]
    fn test_streaming_topk_empty() {