org.apache.pulsar.functions.utils.functioncache

类 FunctionCacheManagerImpl

java.lang.Object

org.apache.pulsar.functions.utils.functioncache.FunctionCacheManagerImpl

所有已实现的接口:

AutoCloseable, FunctionCacheManager

public class FunctionCacheManagerImpl
extends Object
implements FunctionCacheManager

An implementation of FunctionCacheManager.

构造器概要

构造器

构造器和说明
FunctionCacheManagerImpl()

方法概要

限定符和类型	方法和说明
void	close() Close the cache manager to release created class loaders.
ClassLoader	getClassLoader(String fid) Returns the function code class loader associated with id.
void	registerFunctionInstance(String fid, String eid, List<String> requiredJarFiles, List<URL> requiredClasspaths)
void	registerFunctionInstanceWithArchive(String fid, String eid, String narArchive)
void	unregisterFunctionInstance(String fid, String eid)

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

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

从接口继承的方法 org.apache.pulsar.functions.utils.functioncache.FunctionCacheManager

registerFunction, unregisterFunction

构造器详细资料

FunctionCacheManagerImpl

public FunctionCacheManagerImpl()

方法详细资料

getClassLoader

public ClassLoader getClassLoader(String fid)

从接口复制的说明: FunctionCacheManager

Returns the function code class loader associated with id.

指定者:

getClassLoader 在接口中 FunctionCacheManager

参数:

fid - function id

返回:

class loader which can load the function code.

registerFunctionInstance

public void registerFunctionInstance(String fid,
                                     String eid,
                                     List<String> requiredJarFiles,
                                     List<URL> requiredClasspaths)
                              throws IOException

指定者:

registerFunctionInstance 在接口中 FunctionCacheManager

抛出:

IOException

registerFunctionInstanceWithArchive

public void registerFunctionInstanceWithArchive(String fid,
                                                String eid,
                                                String narArchive)
                                         throws IOException

指定者:

registerFunctionInstanceWithArchive 在接口中 FunctionCacheManager

抛出:

IOException

unregisterFunctionInstance

public void unregisterFunctionInstance(String fid,
                                       String eid)

指定者:

unregisterFunctionInstance 在接口中 FunctionCacheManager

close

public void close()

从接口复制的说明: FunctionCacheManager

Close the cache manager to release created class loaders.

指定者:

close 在接口中 AutoCloseable

指定者:

close 在接口中 FunctionCacheManager