A C D E F G I J L M N O P R S T U V W

A

Action() - 类 的构造器org.apache.pulsar.functions.utils.Actions.Action

ActionResult() - 类 的构造器org.apache.pulsar.functions.utils.Actions.ActionResult

Actions - org.apache.pulsar.functions.utils中的类

Actions.Action - org.apache.pulsar.functions.utils中的类

Actions.ActionResult - org.apache.pulsar.functions.utils中的类

addAction(Actions.Action) - 类 中的方法org.apache.pulsar.functions.utils.Actions

C

classExists(String) - 类 中的静态方法org.apache.pulsar.functions.utils.Reflections

Check if class exists.

classExistsInJar(File, String) - 类 中的静态方法org.apache.pulsar.functions.utils.Reflections

Check if a class is in a jar.

classImplementsIface(String, Class) - 类 中的静态方法org.apache.pulsar.functions.utils.Reflections

check if class implements interface.

classInJarImplementsIface(File, String, Class) - 类 中的静态方法org.apache.pulsar.functions.utils.Reflections

check if a class implements an interface.

close() - 类 中的方法org.apache.pulsar.functions.utils.functioncache.FunctionCacheEntry

close() - 接口 中的方法org.apache.pulsar.functions.utils.functioncache.FunctionCacheManager

Close the cache manager to release created class loaders.

close() - 类 中的方法org.apache.pulsar.functions.utils.functioncache.FunctionCacheManagerImpl

ComponentTypeUtils - org.apache.pulsar.functions.utils中的类

ComponentTypeUtils() - 类 的构造器org.apache.pulsar.functions.utils.ComponentTypeUtils

Connectors - org.apache.pulsar.functions.utils.io中的类

Connectors() - 类 的构造器org.apache.pulsar.functions.utils.io.Connectors

ConnectorUtils - org.apache.pulsar.functions.utils.io中的类

ConnectorUtils() - 类 的构造器org.apache.pulsar.functions.utils.io.ConnectorUtils

convert(FunctionConfig, ClassLoader) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionConfigUtils

convert(SinkConfig, SinkConfigUtils.ExtractedSinkDetails) - 类 中的静态方法org.apache.pulsar.functions.utils.SinkConfigUtils

convert(SourceConfig, SourceConfigUtils.ExtractedSourceDetails) - 类 中的静态方法org.apache.pulsar.functions.utils.SourceConfigUtils

convertFromDetails(Function.FunctionDetails) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionConfigUtils

convertFromDetails(Function.FunctionDetails) - 类 中的静态方法org.apache.pulsar.functions.utils.SinkConfigUtils

convertFromDetails(Function.FunctionDetails) - 类 中的静态方法org.apache.pulsar.functions.utils.SourceConfigUtils

convertProcessingGuarantee(FunctionConfig.ProcessingGuarantees) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

convertProcessingGuarantee(Function.ProcessingGuarantees) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

convertRuntime(FunctionConfig.Runtime) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

convertRuntime(Function.FunctionDetails.Runtime) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

create(URL[], ClassLoader) - 类 中的静态方法org.apache.pulsar.functions.utils.functioncache.FunctionClassLoaders

createInstance(String, ClassLoader) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

createInstance(String, Class<T>, ClassLoader) - 类 中的静态方法org.apache.pulsar.functions.utils.Reflections

Create an instance of userClassName using provided classLoader.

createInstance(String, ClassLoader) - 类 中的静态方法org.apache.pulsar.functions.utils.Reflections

Create an instance of userClassName using provided classLoader.

createInstance(String, ClassLoader, Object[], Class[]) - 类 中的静态方法org.apache.pulsar.functions.utils.Reflections

createInstance(String, File) - 类 中的静态方法org.apache.pulsar.functions.utils.Reflections

createPkgTempFile() - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

D

DEFAULT_MAX_LAG_MS - 类 中的静态变量org.apache.pulsar.functions.utils.WindowConfigUtils

DEFAULT_WATERMARK_EVENT_INTERVAL_MS - 类 中的静态变量org.apache.pulsar.functions.utils.WindowConfigUtils

downloadFromHttpUrl(String, File) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

E

Exceptions - org.apache.pulsar.functions.utils中的类

Util to handle exceptions.

Exceptions() - 类 的构造器org.apache.pulsar.functions.utils.Exceptions

extractClassLoader(Path, File) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

extractClassLoader(String) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

ExtractedSinkDetails() - 类 的构造器org.apache.pulsar.functions.utils.SinkConfigUtils.ExtractedSinkDetails

ExtractedSourceDetails() - 类 的构造器org.apache.pulsar.functions.utils.SourceConfigUtils.ExtractedSourceDetails

extractFileFromPkgURL(String) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

extractNarClassLoader(Path, File) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

F

findAvailablePort() - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

FunctionCacheEntry - org.apache.pulsar.functions.utils.functioncache中的类

A cache entry in the function cache.

FunctionCacheManager - org.apache.pulsar.functions.utils.functioncache中的接口

A cache manager for caching function code and its dependencies.

FunctionCacheManagerImpl - org.apache.pulsar.functions.utils.functioncache中的类

An implementation of FunctionCacheManager.

FunctionCacheManagerImpl() - 类 的构造器org.apache.pulsar.functions.utils.functioncache.FunctionCacheManagerImpl

FunctionClassLoaders - org.apache.pulsar.functions.utils.functioncache中的类

Class loaders for loading function code.

FunctionClassLoaders() - 类 的构造器org.apache.pulsar.functions.utils.functioncache.FunctionClassLoaders

FunctionCommon - org.apache.pulsar.functions.utils中的类

Utils used for runtime.

FunctionCommon() - 类 的构造器org.apache.pulsar.functions.utils.FunctionCommon

FunctionConfigUtils - org.apache.pulsar.functions.utils中的类

FunctionConfigUtils() - 类 的构造器org.apache.pulsar.functions.utils.FunctionConfigUtils

FunctionInstanceId - org.apache.pulsar.functions.utils中的类

FunctionInstanceId(String) - 类 的构造器org.apache.pulsar.functions.utils.FunctionInstanceId

G

getClassLoader(String) - 接口 中的方法org.apache.pulsar.functions.utils.functioncache.FunctionCacheManager

Returns the function code class loader associated with id.

getClassLoader(String) - 类 中的方法org.apache.pulsar.functions.utils.functioncache.FunctionCacheManagerImpl

getConnectorDefinition(String) - 类 中的静态方法org.apache.pulsar.functions.utils.io.ConnectorUtils

getFullyQualifiedInstanceId(Function.Instance) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

getFullyQualifiedInstanceId(String, String, String, int) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

getFullyQualifiedName(Function.FunctionDetails) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

getFullyQualifiedName(String, String, String) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

getFunctionTypes(FunctionConfig, ClassLoader) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

getFunctionTypes(Class, boolean) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

getIOSinkClass(ClassLoader) - 类 中的静态方法org.apache.pulsar.functions.utils.io.ConnectorUtils

Extract the Pulsar IO Sink class from a connector archive.

getIOSourceClass(NarClassLoader) - 类 中的静态方法org.apache.pulsar.functions.utils.io.ConnectorUtils

Extract the Pulsar IO Source class from a connector archive.

getMessageId(long) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

getSequenceId(MessageId) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

getSinkType(String, ClassLoader) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

getSourceType(String, ClassLoader) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

getStateNamespace(String, String) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

Convert pulsar tenant and namespace to state storage namespace.

getTypeArg(String, Class<?>, ClassLoader) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

getUniquePackageName(String) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

I

implementsClass(String, Class<?>, ClassLoader) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

inferMissingArguments(FunctionConfig) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionConfigUtils

inferMissingArguments(WindowConfig) - 类 中的静态方法org.apache.pulsar.functions.utils.WindowConfigUtils

J

JAVA_INSTANCE_JAR_PROPERTY - 类 中的静态变量org.apache.pulsar.functions.utils.functioncache.FunctionCacheEntry

L

loadClass(String, ClassLoader) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

loadClass(String, ClassLoader) - 类 中的静态方法org.apache.pulsar.functions.utils.Reflections

Load class to resolve array types.

loadJar(File) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

Load a jar.

M

merge(Resources, Resources) - 类 中的静态方法org.apache.pulsar.functions.utils.ResourceConfigUtils

mergeJson(String, AbstractMessage.Builder) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

N

newBuilder() - 类 中的静态方法org.apache.pulsar.functions.utils.Actions

numActions() - 类 中的方法org.apache.pulsar.functions.utils.Actions

O

org.apache.pulsar.functions.utils - 程序包 org.apache.pulsar.functions.utils

org.apache.pulsar.functions.utils.functioncache - 程序包 org.apache.pulsar.functions.utils.functioncache

org.apache.pulsar.functions.utils.io - 程序包 org.apache.pulsar.functions.utils.io

P

printJson(MessageOrBuilder) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

R

Reflections - org.apache.pulsar.functions.utils中的类

Utils related to reflections.

Reflections() - 类 的构造器org.apache.pulsar.functions.utils.Reflections

register(String, Collection<String>, Collection<URL>) - 类 中的方法org.apache.pulsar.functions.utils.functioncache.FunctionCacheEntry

registerFunction(String, List<String>, List<URL>) - 接口 中的方法org.apache.pulsar.functions.utils.functioncache.FunctionCacheManager

Registers a function with its required jar files and classpaths.

registerFunctionInstance(String, String, List<String>, List<URL>) - 接口 中的方法org.apache.pulsar.functions.utils.functioncache.FunctionCacheManager

registerFunctionInstance(String, String, List<String>, List<URL>) - 类 中的方法org.apache.pulsar.functions.utils.functioncache.FunctionCacheManagerImpl

registerFunctionInstanceWithArchive(String, String, String) - 接口 中的方法org.apache.pulsar.functions.utils.functioncache.FunctionCacheManager

registerFunctionInstanceWithArchive(String, String, String) - 类 中的方法org.apache.pulsar.functions.utils.functioncache.FunctionCacheManagerImpl

ResourceConfigUtils - org.apache.pulsar.functions.utils中的类

ResourceConfigUtils() - 类 的构造器org.apache.pulsar.functions.utils.ResourceConfigUtils

rethrowIOException(Throwable) - 类 中的静态方法org.apache.pulsar.functions.utils.Exceptions

run() - 类 中的方法org.apache.pulsar.functions.utils.Actions

S

searchForConnectors(String) - 类 中的静态方法org.apache.pulsar.functions.utils.io.ConnectorUtils

SinkConfigUtils - org.apache.pulsar.functions.utils中的类

SinkConfigUtils() - 类 的构造器org.apache.pulsar.functions.utils.SinkConfigUtils

SinkConfigUtils.ExtractedSinkDetails - org.apache.pulsar.functions.utils中的类

SourceConfigUtils - org.apache.pulsar.functions.utils中的类

SourceConfigUtils() - 类 的构造器org.apache.pulsar.functions.utils.SourceConfigUtils

SourceConfigUtils.ExtractedSourceDetails - org.apache.pulsar.functions.utils中的类

T

toByteArray(Object) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionCommon

toString(Function.FunctionDetails.ComponentType) - 类 中的静态方法org.apache.pulsar.functions.utils.ComponentTypeUtils

toString(Exception) - 类 中的静态方法org.apache.pulsar.functions.utils.Exceptions

U

unregister(String) - 类 中的方法org.apache.pulsar.functions.utils.functioncache.FunctionCacheEntry

unregisterFunction(String) - 接口 中的方法org.apache.pulsar.functions.utils.functioncache.FunctionCacheManager

Unregisters a job from the function cache manager.

unregisterFunctionInstance(String, String) - 接口 中的方法org.apache.pulsar.functions.utils.functioncache.FunctionCacheManager

unregisterFunctionInstance(String, String) - 类 中的方法org.apache.pulsar.functions.utils.functioncache.FunctionCacheManagerImpl

V

validate(FunctionConfig, File) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionConfigUtils

validate(Resources) - 类 中的静态方法org.apache.pulsar.functions.utils.ResourceConfigUtils

validate(SinkConfig, Path, File) - 类 中的静态方法org.apache.pulsar.functions.utils.SinkConfigUtils

validate(SourceConfig, Path, File) - 类 中的静态方法org.apache.pulsar.functions.utils.SourceConfigUtils

validate(WindowConfig) - 类 中的静态方法org.apache.pulsar.functions.utils.WindowConfigUtils

validateFunctionClassTypes(ClassLoader, Function.FunctionDetails.Builder) - 类 中的静态方法org.apache.pulsar.functions.utils.ValidatorUtils

validateSchema(String, Class<?>, ClassLoader, boolean) - 类 中的静态方法org.apache.pulsar.functions.utils.ValidatorUtils

validateSerde(String, Class<?>, ClassLoader, boolean) - 类 中的静态方法org.apache.pulsar.functions.utils.ValidatorUtils

validateUpdate(FunctionConfig, FunctionConfig) - 类 中的静态方法org.apache.pulsar.functions.utils.FunctionConfigUtils

validateUpdate(SinkConfig, SinkConfig) - 类 中的静态方法org.apache.pulsar.functions.utils.SinkConfigUtils

validateUpdate(SourceConfig, SourceConfig) - 类 中的静态方法org.apache.pulsar.functions.utils.SourceConfigUtils

ValidatorUtils - org.apache.pulsar.functions.utils中的类

ValidatorUtils() - 类 的构造器org.apache.pulsar.functions.utils.ValidatorUtils

verifyAction() - 类 中的方法org.apache.pulsar.functions.utils.Actions.Action

W

WindowConfigUtils - org.apache.pulsar.functions.utils中的类

WindowConfigUtils() - 类 的构造器org.apache.pulsar.functions.utils.WindowConfigUtils

A C D E F G I J L M N O P R S T U V W