trait BuildBoxCoordinatorTrait = FnMut(DatabaseConnection, SinkParam, Option<UnboundedSender<IcebergSinkCompactionUpdate>>) -> BoxCoordinator
+ Send
+ 'static;trait BuildBoxCoordinatorTrait = FnMut(DatabaseConnection, SinkParam, Option<UnboundedSender<IcebergSinkCompactionUpdate>>) -> BoxCoordinator
+ Send
+ 'static;