|
Rename Method private createRecordContext(algo String, keyNames String[], keyValues byte[][], param byte[], metadata1 Map<String,String>, metadata2 Map<String,String>, batchSize int, compressionMsgSize int, properties Map<String,String>, isEncryption boolean) : RecordContext renamed to private createRecord(data byte[], algo String, keyNames String[], keyValues byte[][], param byte[], metadata1 Map<String,String>, metadata2 Map<String,String>, batchSize int, compressionMsgSize int, properties Map<String,String>, isEncryption boolean) : Record<byte[]> in class org.apache.pulsar.io.kinesis.UtilsTest |
From |
To |
|
Change Parameter Type record : ConsumerRecord<byte[],byte[]> to record : ConsumerRecord<String,byte[]> in method public KafkaRecord(record ConsumerRecord<String,byte[]>, value V) in class org.apache.pulsar.io.kafka.KafkaAbstractSource.KafkaRecord |
From |
To |
|
Change Parameter Type inputRecordContext : RecordContext to record : Record<byte[]> in method public serializeRecordToFlatBuffer(record Record<byte[]>) : ByteBuffer in class org.apache.pulsar.io.kinesis.Utils |
From |
To |
|
Change Parameter Type message : byte[] to sourceRecord : Record<byte[]> in method public write(sourceRecord Record<byte[]>) : void in class org.apache.pulsar.io.kafka.KafkaAbstractSink |
From |
To |
|
Change Parameter Type record : byte[] to record : Record<byte[]> in method public write(record Record<byte[]>) : void in class org.apache.pulsar.io.cassandra.CassandraAbstractSink |
From |
To |
|
Change Parameter Type recordContext : RecordContext to recordContext : Record<T> in method public sendOutputMessage(outputMsgBuilder MessageBuilder, recordContext Record<T>) : void in class org.apache.pulsar.functions.sink.PulsarSink.PulsarSinkAtLeastOnceProcessor |
From |
To |
|
Change Parameter Type recordCtx : RecordContext to record : Record<byte[]> in method public createKinesisMessage(msgFormat MessageFormat, record Record<byte[]>) : ByteBuffer in class org.apache.pulsar.io.kinesis.KinesisSink |
From |
To |
|
Change Parameter Type recordContext : RecordContext to recordContext : Record<T> in method public sendOutputMessage(outputMsgBuilder MessageBuilder, recordContext Record<T>) : void in class org.apache.pulsar.functions.sink.PulsarSink.PulsarSinkEffectivelyOnceProcessor |
From |
To |
|
Change Parameter Type record : byte[] to record : Record<byte[]> in method public write(record Record<byte[]>) : void in class org.apache.pulsar.io.aerospike.AerospikeAbstractSink |
From |
To |
|
Change Parameter Type inputRecordContext : RecordContext to record : Record<byte[]> in method public serializeRecordToFlatBuffer(builder FlatBufferBuilder, record Record<byte[]>) : ByteBuffer in class org.apache.pulsar.io.kinesis.Utils |
From |
To |
|
Change Parameter Type result : RecordContext to resultContext : Record<byte[]> in method package create(streamName String, resultContext Record<byte[]>, startTime long) : ProducerSendCallback in class org.apache.pulsar.io.kinesis.KinesisSink.ProducerSendCallback |
From |
To |
|
Change Parameter Type message : byte[] to record : Record<byte[]> in method public extractKeyValue(record Record<byte[]>) : KeyValue<String,String> in class org.apache.pulsar.io.aerospike.AerospikeStringSink |
From |
To |
|
Change Parameter Type recordContext : RecordContext to recordContext : Record<T> in method public sendOutputMessage(outputMsgBuilder MessageBuilder, recordContext Record<T>) : void in class org.apache.pulsar.functions.sink.PulsarSink.PulsarSinkProcessor |
From |
To |
|
Change Parameter Type record : ConsumerRecord<byte[],byte[]> to record : ConsumerRecord<String,byte[]> in method public extractValue(record ConsumerRecord<String,byte[]>) : String in class org.apache.pulsar.io.kafka.KafkaStringSource |
From |
To |
|
Change Parameter Type message : byte[] to record : Record<byte[]> in method public extractKeyValue(record Record<byte[]>) : KeyValue<String,String> in class org.apache.pulsar.io.cassandra.CassandraStringSink |
From |
To |
|
Change Parameter Type recordContext : RecordContext to recordContext : Record<T> in method public sendOutputMessage(outputMsgBuilder MessageBuilder, recordContext Record<T>) : void in class org.apache.pulsar.functions.sink.PulsarSink.PulsarSinkAtMostOnceProcessor |
From |
To |
|
Change Return Type CompletableFuture<Void> to void in method public write(sourceRecord Record<byte[]>) : void in class org.apache.pulsar.io.kafka.KafkaAbstractSink |
From |
To |
|
Change Return Type CompletableFuture<Void> to void in method public write(record Record<byte[]>) : void in class org.apache.pulsar.io.aerospike.AerospikeAbstractSink |
From |
To |
|
Change Return Type long to Optional<Long> in method public getRecordSequence() : Optional<Long> in class org.apache.pulsar.io.kafka.KafkaAbstractSource.KafkaRecord |
From |
To |
|
Change Return Type String to Optional<String> in method public getPartitionId() : Optional<String> in class org.apache.pulsar.io.kafka.KafkaAbstractSource.KafkaRecord |
From |
To |
|
Change Return Type CompletableFuture<Void> to void in method public write(record Record<byte[]>) : void in class org.apache.pulsar.io.cassandra.CassandraAbstractSink |
From |
To |
|
Change Return Type RecordContext to Record<byte[]> in method private createRecord(data byte[], algo String, keyNames String[], keyValues byte[][], param byte[], metadata1 Map<String,String>, metadata2 Map<String,String>, batchSize int, compressionMsgSize int, properties Map<String,String>, isEncryption boolean) : Record<byte[]> in class org.apache.pulsar.io.kinesis.UtilsTest |
From |
To |
|
Rename Parameter inputRecordContext : RecordContext to record : Record<byte[]> in method public serializeRecordToFlatBuffer(record Record<byte[]>) : ByteBuffer in class org.apache.pulsar.io.kinesis.Utils |
From |
To |
|
Rename Parameter message : byte[] to sourceRecord : Record<byte[]> in method public write(sourceRecord Record<byte[]>) : void in class org.apache.pulsar.io.kafka.KafkaAbstractSink |
From |
To |
|
Rename Parameter recordCtx : RecordContext to record : Record<byte[]> in method public createKinesisMessage(msgFormat MessageFormat, record Record<byte[]>) : ByteBuffer in class org.apache.pulsar.io.kinesis.KinesisSink |
From |
To |
|
Rename Parameter inputRecordContext : RecordContext to record : Record<byte[]> in method public serializeRecordToFlatBuffer(builder FlatBufferBuilder, record Record<byte[]>) : ByteBuffer in class org.apache.pulsar.io.kinesis.Utils |
From |
To |
|
Rename Parameter result : RecordContext to resultContext : Record<byte[]> in method package create(streamName String, resultContext Record<byte[]>, startTime long) : ProducerSendCallback in class org.apache.pulsar.io.kinesis.KinesisSink.ProducerSendCallback |
From |
To |
|
Rename Parameter message : byte[] to record : Record<byte[]> in method public extractKeyValue(record Record<byte[]>) : KeyValue<String,String> in class org.apache.pulsar.io.cassandra.CassandraStringSink |
From |
To |
|
Rename Parameter message : byte[] to record : Record<byte[]> in method public extractKeyValue(record Record<byte[]>) : KeyValue<String,String> in class org.apache.pulsar.io.aerospike.AerospikeStringSink |
From |
To |