new code_data_ConnectorDefinition( name, // java.lang.String config, // code.data.O uniqueness, // scala.Option[Any] factory, // code.data.StreamProcessorFactory )