代码题库

Credit-Based Backpressure — Replay Producer/Consumer Events into a State Trace

Compact a Ring-Buffer of Ticks into Evenly-Bucketed Time Slices

DAG Multi-Worker Topological Schedule

DAG Schedule on K Machines with Critical-Path Priority

Deduplicate a Replayed Tick Stream by (ts, exchange-seq), Latest-Ingest Wins

Divide-and-Conquer Sum Tree (Parallel Reduction Simulation)

Downsample a Tick Stream into OHLCV Bars (Right-Closed)

Weighted Edit Distance with Per-Character Cost Matrices

Fan-Out / Fan-In Coordination — Event Replay

Fork-Join Segment Stats (Welford Pairwise Merge)

Forward-Fill Missing Minutes Within a Trading Session

Greenwald-Khanna Streaming Quantile Summary

HDR Histogram Recorded-Value Bucket Index and Quantile Estimate

Leaky-Bucket Rate Limiter as Admission Control

MapReduce Group-By Count (Two-Phase Aggregation)

Merge Per-Day Bar Shards into a Sorted Timeseries

Parallel Pairwise Mean Merge with Kahan Compensation

Quantile Estimate from Pre-Bucketed Histogram Counts

Cache-Aware Pipeline Replay — Minimum Re-run Set with Input-Hash Chaining

Research Pipeline DAG — Cascade-Invalidate Downstream of a Failed Task

Research Pipeline DAG — Compute the Next-Runnable Set

Priority-Driven Task Scheduling with Deps on a Worker Pool

Session-Window Aggregation — Gap-Driven Boundaries

Sliding-Window Mean — Fixed-Count Window with O(1) Eviction

Sliding-Log Rate Limiter (Deque of Admitted Timestamps)

T-Digest Streaming Percentile Estimator (k_1 Scale Function)

Tick Buffer — Binary-Search Lookup and Range Scan by Timestamp

Token-Bucket Rate Limiter with Bounded Pending Queue

Tree Reduction with (min, max) Associative Combiner

Tumbling-Window Aggregation — Sparse Per-Bucket Stats

Watermark-Driven Tumbling Windows with Late-Event Handling

Tumbling Window Trigger Firing Policies (Early, On-Close, Speculative)