|
Change Variable Type reader : Reader to reader : Reader<byte[]> in method public triggerFunction(tenant String, namespace String, functionName String, input String, uploadedInputStream InputStream, topic String) : Response in class org.apache.pulsar.functions.worker.rest.api.FunctionsImpl |
From |
To |
|
Change Variable Type autoSchema : AutoSchema to autoConsumeSchema : AutoConsumeSchema in method public TestOpenAndWriteSink() : void in class org.apache.pulsar.io.jdbc.JdbcSinkTest |
From |
To |
|
Change Variable Type producer : Producer to producer : Producer<byte[]> in method public triggerFunction(tenant String, namespace String, functionName String, input String, uploadedInputStream InputStream, topic String) : Response in class org.apache.pulsar.functions.worker.rest.api.FunctionsImpl |
From |
To |
|
Change Variable Type autoSchema : AutoSchema to autoConsumeSchema : AutoConsumeSchema in method public createReaderAsync(conf ReaderConfigurationData<T>, schema Schema<T>) : CompletableFuture<Reader<T>> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Variable Type decodeSchema : AutoSchema to decodeSchema : AutoConsumeSchema in method public testAutoAvroSchema() : void in class org.apache.pulsar.client.impl.schema.generic.GenericSchemaTest |
From |
To |
|
Change Variable Type autoSchema : AutoSchema to autoConsumeSchema : AutoConsumeSchema in method private singleTopicSubscribeAsync(conf ConsumerConfigurationData<T>, schema Schema<T>, interceptors ConsumerInterceptors<T>) : CompletableFuture<Consumer<T>> in class org.apache.pulsar.client.impl.PulsarClientImpl |
From |
To |
|
Change Variable Type decodeSchema : AutoSchema to decodeSchema : AutoConsumeSchema in method public testAutoJsonSchema() : void in class org.apache.pulsar.client.impl.schema.generic.GenericSchemaTest |
From |
To |