管道把所有行跑完之后,最后还得把结果以某种形式“交出去”。
一个查询的入口长这样:
Copy
internal static class QueryProgram<TRow, TPipeline, TRuntimeResult, TPublicResult>
where TPipeline : IQueryNode<TRow, TRuntimeResult, TRow>
{
public static IReadOnlyList Execute(ReadOnlySpan rows)
{
var run…
2026/7/23 10:50:09