org.apache.pulsar.functions.utils

类 SinkConfigUtils

java.lang.Object

org.apache.pulsar.functions.utils.SinkConfigUtils

public class SinkConfigUtils
extends Object

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	SinkConfigUtils.ExtractedSinkDetails

构造器概要

构造器

构造器和说明
SinkConfigUtils()

方法概要

限定符和类型	方法和说明
static Function.FunctionDetails	convert(SinkConfig sinkConfig, SinkConfigUtils.ExtractedSinkDetails sinkDetails)
static SinkConfig	convertFromDetails(Function.FunctionDetails functionDetails)
static SinkConfigUtils.ExtractedSinkDetails	validate(SinkConfig sinkConfig, Path archivePath, File uploadedInputStreamAsFile)
static SinkConfig	validateUpdate(SinkConfig existingConfig, SinkConfig newConfig)

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

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

构造器详细资料

SinkConfigUtils

public SinkConfigUtils()

方法详细资料

convert

public static Function.FunctionDetails convert(SinkConfig sinkConfig,
                                               SinkConfigUtils.ExtractedSinkDetails sinkDetails)
                                        throws IOException

抛出:

IOException

convertFromDetails

public static SinkConfig convertFromDetails(Function.FunctionDetails functionDetails)

validate

public static SinkConfigUtils.ExtractedSinkDetails validate(SinkConfig sinkConfig,
                                                            Path archivePath,
                                                            File uploadedInputStreamAsFile)

validateUpdate

public static SinkConfig validateUpdate(SinkConfig existingConfig,
                                        SinkConfig newConfig)