Function sink_generator 

pub fn sink_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 SinkPlugin>, PluginInitializationError>,