|
Pull Up Method public writeRecord(t T) : void from class org.apache.flink.batch.connectors.pulsar.PulsarOutputFormat to public writeRecord(t T) : void from class org.apache.flink.batch.connectors.pulsar.BasePulsarOutputFormat |
From |
To |
|
Pull Up Method public configure(configuration Configuration) : void from class org.apache.flink.batch.connectors.pulsar.PulsarOutputFormat to public configure(configuration Configuration) : void from class org.apache.flink.batch.connectors.pulsar.BasePulsarOutputFormat |
From |
To |
|
Pull Up Method private getProducerInstance() : Producer<byte[]> from class org.apache.flink.batch.connectors.pulsar.PulsarOutputFormat to private getProducerInstance() : Producer<byte[]> from class org.apache.flink.batch.connectors.pulsar.BasePulsarOutputFormat |
From |
To |
|
Pull Up Method private createPulsarProducer() : Producer<byte[]> from class org.apache.flink.batch.connectors.pulsar.PulsarOutputFormat to private createPulsarProducer() : Producer<byte[]> from class org.apache.flink.batch.connectors.pulsar.BasePulsarOutputFormat |
From |
To |
|
Pull Up Method public open(taskNumber int, numTasks int) : void from class org.apache.flink.batch.connectors.pulsar.PulsarOutputFormat to public open(taskNumber int, numTasks int) : void from class org.apache.flink.batch.connectors.pulsar.BasePulsarOutputFormat |
From |
To |
|
Pull Up Method public close() : void from class org.apache.flink.batch.connectors.pulsar.PulsarOutputFormat to public close() : void from class org.apache.flink.batch.connectors.pulsar.BasePulsarOutputFormat |
From |
To |
|
Pull Up Attribute private producer : Producer<byte[]> from class org.apache.flink.batch.connectors.pulsar.PulsarOutputFormat to private producer : Producer<byte[]> from class org.apache.flink.batch.connectors.pulsar.BasePulsarOutputFormat |
From |
To |
|
Pull Up Attribute private LOG : Logger from class org.apache.flink.batch.connectors.pulsar.PulsarOutputFormat to private LOG : Logger from class org.apache.flink.batch.connectors.pulsar.BasePulsarOutputFormat |
From |
To |
|
Pull Up Attribute private failureCallback : Function<Throwable,MessageId> from class org.apache.flink.batch.connectors.pulsar.PulsarOutputFormat to private failureCallback : Function<Throwable,MessageId> from class org.apache.flink.batch.connectors.pulsar.BasePulsarOutputFormat |
From |
To |
|
Pull Up Attribute private serviceUrl : String from class org.apache.flink.batch.connectors.pulsar.PulsarOutputFormat to protected serviceUrl : String from class org.apache.flink.batch.connectors.pulsar.BasePulsarOutputFormat |
From |
To |
|
Pull Up Attribute private topicName : String from class org.apache.flink.batch.connectors.pulsar.PulsarOutputFormat to protected topicName : String from class org.apache.flink.batch.connectors.pulsar.BasePulsarOutputFormat |
From |
To |
|
Pull Up Attribute private serializationSchema : SerializationSchema<T> from class org.apache.flink.batch.connectors.pulsar.PulsarOutputFormat to protected serializationSchema : SerializationSchema<T> from class org.apache.flink.batch.connectors.pulsar.BasePulsarOutputFormat |
From |
To |