org.apache.pulsar.functions.utils.io

类 ConnectorUtils

java.lang.Object

org.apache.pulsar.functions.utils.io.ConnectorUtils

public class ConnectorUtils
extends Object

构造器概要

构造器

构造器和说明
ConnectorUtils()

方法概要

限定符和类型	方法和说明
static ConnectorDefinition	getConnectorDefinition(String narPath)
static String	getIOSinkClass(ClassLoader classLoader) Extract the Pulsar IO Sink class from a connector archive.
static String	getIOSourceClass(NarClassLoader ncl) Extract the Pulsar IO Source class from a connector archive.
static Connectors	searchForConnectors(String connectorsDirectory)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

ConnectorUtils

public ConnectorUtils()

方法详细资料

getIOSourceClass

public static String getIOSourceClass(NarClassLoader ncl)
                               throws IOException

Extract the Pulsar IO Source class from a connector archive.

抛出:

IOException

getIOSinkClass

public static String getIOSinkClass(ClassLoader classLoader)
                             throws IOException

Extract the Pulsar IO Sink class from a connector archive.

抛出:

IOException

getConnectorDefinition

public static ConnectorDefinition getConnectorDefinition(String narPath)
                                                  throws IOException

抛出:

IOException

searchForConnectors

public static Connectors searchForConnectors(String connectorsDirectory)
                                      throws IOException

抛出:

IOException