| 程序包 | 说明 |
|---|---|
| org.apache.pulsar.functions.utils |
| 限定符和类型 | 方法和说明 |
|---|---|
static SinkConfigUtils.ExtractedSinkDetails |
SinkConfigUtils.validate(SinkConfig sinkConfig,
Path archivePath,
File uploadedInputStreamAsFile) |
| 限定符和类型 | 方法和说明 |
|---|---|
static Function.FunctionDetails |
SinkConfigUtils.convert(SinkConfig sinkConfig,
SinkConfigUtils.ExtractedSinkDetails sinkDetails) |
Copyright © 2017–2019 Apache Software Foundation. All rights reserved.