pub fn transform_generator<F>(
id: RString,
factory: F,
input_schema: SafeArrowSchema,
options: PluginOptions,
runtime: PluginAsyncRuntimeObj,
state_backend_config: PluginStateBackendConfig,
message_channels: PluginChannels,
) -> RResult<PluginResult, PluginInitializationError>where
F: FnOnce(SchemaRef, PluginAsyncRuntimeObj, PluginStateBackendFactory, PluginMetricsRecorder, HashMap<String, String>) -> Result<Arc<dyn TransformPlugin>, PluginInitializationError>,