|
Change Return Type long to CompletableFuture<Long> in method public getCounter(key String) : CompletableFuture<Long> in class org.apache.pulsar.functions.instance.state.StateContextImpl |
From |
To |
|
Change Return Type void to CompletableFuture<Void> in method public incrCounter(key String, amount long) : CompletableFuture<Void> in class org.apache.pulsar.functions.instance.state.StateContextImpl |
From |
To |
|
Change Return Type void to CompletableFuture<Void> in method public put(key String, value ByteBuffer) : CompletableFuture<Void> in class org.apache.pulsar.functions.instance.state.StateContext |
From |
To |
|
Change Return Type long to CompletableFuture<Long> in method public getCounter(key String) : CompletableFuture<Long> in class org.apache.pulsar.functions.instance.state.StateContext |
From |
To |
|
Change Return Type void to CompletableFuture<Void> in method public incrCounter(key String, amount long) : CompletableFuture<Void> in class org.apache.pulsar.functions.instance.state.StateContext |
From |
To |
|
Change Return Type void to CompletableFuture<Void> in method public put(key String, value ByteBuffer) : CompletableFuture<Void> in class org.apache.pulsar.functions.instance.state.StateContextImpl |
From |
To |