org.apache.pulsar.functions.utils

类 FunctionCommon

java.lang.Object

org.apache.pulsar.functions.utils.FunctionCommon

public class FunctionCommon
extends Object

Utils used for runtime.

构造器概要

构造器

构造器和说明
FunctionCommon()

方法概要

限定符和类型	方法和说明
static FunctionConfig.ProcessingGuarantees	convertProcessingGuarantee(Function.ProcessingGuarantees processingGuarantees)
static Function.ProcessingGuarantees	convertProcessingGuarantee(FunctionConfig.ProcessingGuarantees processingGuarantees)
static FunctionConfig.Runtime	convertRuntime(Function.FunctionDetails.Runtime runtime)
static Function.FunctionDetails.Runtime	convertRuntime(FunctionConfig.Runtime runtime)
static Object	createInstance(String userClassName, ClassLoader classLoader)
static File	createPkgTempFile()
static void	downloadFromHttpUrl(String destPkgUrl, File targetFile)
static ClassLoader	extractClassLoader(Path archivePath, File packageFile)
static ClassLoader	extractClassLoader(String destPkgUrl)
static File	extractFileFromPkgURL(String destPkgUrl)
static NarClassLoader	extractNarClassLoader(Path archivePath, File packageFile)
static int	findAvailablePort()
static String	getFullyQualifiedInstanceId(Function.Instance instance)
static String	getFullyQualifiedInstanceId(String tenant, String namespace, String functionName, int instanceId)
static String	getFullyQualifiedName(Function.FunctionDetails FunctionDetails)
static String	getFullyQualifiedName(String tenant, String namespace, String functionName)
static Class<?>[]	getFunctionTypes(Class userClass, boolean isWindowConfigPresent)
static Class<?>[]	getFunctionTypes(FunctionConfig functionConfig, ClassLoader classLoader)
static org.apache.pulsar.client.api.MessageId	getMessageId(long sequenceId)
static long	getSequenceId(org.apache.pulsar.client.api.MessageId messageId)
static Class<?>	getSinkType(String className, ClassLoader classLoader)
static Class<?>	getSourceType(String className, ClassLoader classLoader)
static String	getStateNamespace(String tenant, String namespace) Convert pulsar tenant and namespace to state storage namespace.
static Class<?>	getTypeArg(String className, Class<?> funClass, ClassLoader classLoader)
static String	getUniquePackageName(String packageName)
static void	implementsClass(String className, Class<?> klass, ClassLoader classLoader)
static Class<?>	loadClass(String className, ClassLoader classLoader)
static ClassLoader	loadJar(File jar) Load a jar.
static void	mergeJson(String json, com.google.protobuf.AbstractMessage.Builder builder)
static String	printJson(com.google.protobuf.MessageOrBuilder msg)
static byte[]	toByteArray(Object obj)

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

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

构造器详细资料

FunctionCommon

public FunctionCommon()

方法详细资料

printJson

public static String printJson(com.google.protobuf.MessageOrBuilder msg)
                        throws IOException

抛出:

IOException

mergeJson

public static void mergeJson(String json,
                             com.google.protobuf.AbstractMessage.Builder builder)
                      throws IOException

抛出:

IOException

findAvailablePort

public static int findAvailablePort()

getFunctionTypes

public static Class<?>[] getFunctionTypes(FunctionConfig functionConfig,
                                          ClassLoader classLoader)
                                   throws ClassNotFoundException

抛出:

ClassNotFoundException

getFunctionTypes

public static Class<?>[] getFunctionTypes(Class userClass,
                                          boolean isWindowConfigPresent)

createInstance

public static Object createInstance(String userClassName,
                                    ClassLoader classLoader)

convertRuntime

public static Function.FunctionDetails.Runtime convertRuntime(FunctionConfig.Runtime runtime)

convertRuntime

public static FunctionConfig.Runtime convertRuntime(Function.FunctionDetails.Runtime runtime)

convertProcessingGuarantee

public static Function.ProcessingGuarantees convertProcessingGuarantee(FunctionConfig.ProcessingGuarantees processingGuarantees)

convertProcessingGuarantee

public static FunctionConfig.ProcessingGuarantees convertProcessingGuarantee(Function.ProcessingGuarantees processingGuarantees)

getSourceType

public static Class<?> getSourceType(String className,
                                     ClassLoader classLoader)
                              throws ClassNotFoundException

抛出:

ClassNotFoundException

getSinkType

public static Class<?> getSinkType(String className,
                                   ClassLoader classLoader)
                            throws ClassNotFoundException

抛出:

ClassNotFoundException

extractClassLoader

public static ClassLoader extractClassLoader(Path archivePath,
                                             File packageFile)
                                      throws Exception

抛出:

Exception

downloadFromHttpUrl

public static void downloadFromHttpUrl(String destPkgUrl,
                                       File targetFile)
                                throws IOException

抛出:

IOException

loadJar

public static ClassLoader loadJar(File jar)
                           throws MalformedURLException

Load a jar.

参数:

jar - file of jar

返回:

classloader

抛出:

MalformedURLException

extractClassLoader

public static ClassLoader extractClassLoader(String destPkgUrl)
                                      throws IOException,
                                             URISyntaxException

抛出:

IOException

URISyntaxException

createPkgTempFile

public static File createPkgTempFile()
                              throws IOException

抛出:

IOException

extractFileFromPkgURL

public static File extractFileFromPkgURL(String destPkgUrl)
                                  throws IOException,
                                         URISyntaxException

抛出:

IOException

URISyntaxException

implementsClass

public static void implementsClass(String className,
                                   Class<?> klass,
                                   ClassLoader classLoader)

loadClass

public static Class<?> loadClass(String className,
                                 ClassLoader classLoader)
                          throws ClassNotFoundException

抛出:

ClassNotFoundException

extractNarClassLoader

public static NarClassLoader extractNarClassLoader(Path archivePath,
                                                   File packageFile)

getFullyQualifiedInstanceId

public static String getFullyQualifiedInstanceId(Function.Instance instance)

getFullyQualifiedInstanceId

public static String getFullyQualifiedInstanceId(String tenant,
                                                 String namespace,
                                                 String functionName,
                                                 int instanceId)

getSequenceId

public static final long getSequenceId(org.apache.pulsar.client.api.MessageId messageId)

getMessageId

public static final org.apache.pulsar.client.api.MessageId getMessageId(long sequenceId)

toByteArray

public static byte[] toByteArray(Object obj)
                          throws IOException

抛出:

IOException

getUniquePackageName

public static String getUniquePackageName(String packageName)

getStateNamespace

public static String getStateNamespace(String tenant,
                                       String namespace)

Convert pulsar tenant and namespace to state storage namespace.

参数:

tenant - pulsar tenant

namespace - pulsar namespace

返回:

state storage namespace

getFullyQualifiedName

public static String getFullyQualifiedName(Function.FunctionDetails FunctionDetails)

getFullyQualifiedName

public static String getFullyQualifiedName(String tenant,
                                           String namespace,
                                           String functionName)

getTypeArg

public static Class<?> getTypeArg(String className,
                                  Class<?> funClass,
                                  ClassLoader classLoader)
                           throws ClassNotFoundException

抛出:

ClassNotFoundException