357284aabe8f868ed7810f9b5a2c702de0a07df6
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 2
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 1 | ||
| Change Parameter Type record : Record<T> to record : Record<byte[]> in method public write(record Record<byte[]>) : void in class org.apache.pulsar.io.rabbitmq.RabbitMQSink | From | To | |
| Change Return Type | 1 | ||
| Change Return Type Record<String> to Record<byte[]> in method private build(topic String, key String, value String) : Record<byte[]> in class org.apache.pulsar.io.rabbitmq.sink.RabbitMQSinkTest | From | To | |
| Change Variable Type | 2 | ||
| Change Variable Type record : Record<String> to record : Record<byte[]> in method public TestOpenAndWriteSink() : void in class org.apache.pulsar.io.rabbitmq.sink.RabbitMQSinkTest | From | To | |
| Change Variable Type record : SinkRecord<String> to record : SinkRecord<byte[]> in method private build(topic String, key String, value String) : Record<byte[]> in class org.apache.pulsar.io.rabbitmq.sink.RabbitMQSinkTest | From | To |