73645631849ffce2f144f23d861763fe52a25af9
Files Diff
- Added: 1
- Removed: 1
- Renamed: 0
- Modified: 8
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 1 | ||
| Change Parameter Type schema : Schema to schema : Schema<Foo> in method protected produceSchemaMessagesToInputTopic(inputTopicName String, numMessages int, schema Schema<Foo>) : Map<String,String> in class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest | From | To | |
| Change Variable Type | 3 | ||
| Change Variable Type jdbcSink : JdbcAvroSchemaSink to jdbcSink : JdbcAutoSchemaSink in method public TestOpenAndWriteSink() : void in class org.apache.pulsar.io.jdbc.JdbcSinkTest | From | To | |
| Change Variable Type producer : Producer<String> to producer : Producer<Foo> in method protected produceSchemaMessagesToInputTopic(inputTopicName String, numMessages int, schema Schema<Foo>) : Map<String,String> in class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest | From | To | |
| Change Variable Type record : Record<byte[]> to record : Record<GenericRecord> in method public TestOpenAndWriteSink() : void in class org.apache.pulsar.io.jdbc.JdbcSinkTest | From | To | |
| Extract Method | 1 | ||
| Extract Method private ensureSubscriptionCreated(inputTopicName String, subscriptionName String, inputTopicSchema Schema<T>) : void extracted from private submitFunction(runtime Runtime, inputTopicName String, outputTopicName String, functionName String, functionClass String, inputTopicSchema Schema<T>) : void in class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest | From | To |