From f723bfa0f5c0a56e696776c4bfbdc6f62820d106 Mon Sep 17 00:00:00 2001 From: Moritz Hoffmann Date: Thu, 18 Apr 2024 16:54:09 -0400 Subject: [PATCH] Make arrange_core public (#475) Signed-off-by: Moritz Hoffmann --- src/operators/arrange/arrangement.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/operators/arrange/arrangement.rs b/src/operators/arrange/arrangement.rs index 9856e38e0..bffc2bdaa 100644 --- a/src/operators/arrange/arrangement.rs +++ b/src/operators/arrange/arrangement.rs @@ -557,7 +557,7 @@ where /// This operator arranges a stream of values into a shared trace, whose contents it maintains. /// It uses the supplied parallelization contract to distribute the data, which does not need to /// be consistently by key (though this is the most common). -fn arrange_core(stream: &StreamCore::Input>, pact: P, name: &str) -> Arranged> +pub fn arrange_core(stream: &StreamCore::Input>, pact: P, name: &str) -> Arranged> where G: Scope, G::Timestamp: Lattice,