pulsar 7530d64a679a0783122b18058c1148c89c0fee0a

7530d64a679a0783122b18058c1148c89c0fee0a

Files Diff

Added: 2
Removed: 4
Renamed: 0
Modified: 22

Link to commit

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Change Return Type	1
	Change Return Type KeyValue<String,String> to KeyValue<String,byte[]> in method public extractKeyValue(record Record<byte[]>) : KeyValue<String,byte[]> in class org.apache.pulsar.io.kafka.KafkaBytesSink	From	To
	Move And Rename Class	1
	Move And Rename Class org.apache.pulsar.io.elasticsearch.ElasticSearchStringSink moved and renamed to org.apache.pulsar.io.kafka.KafkaBytesSink	From	To
	Move And Rename Attribute	4
	Move And Rename Attribute private hdfsCluster : HdfsContainer renamed to protected serviceContainer : ServiceContainerT and moved from class org.apache.pulsar.tests.integration.io.HdfsSinkTester to class org.apache.pulsar.tests.integration.io.SinkTester	From	To
	Move And Rename Attribute private mySQLContainer : MySQLContainer renamed to protected serviceContainer : ServiceContainerT and moved from class org.apache.pulsar.tests.integration.io.JdbcSinkTester to class org.apache.pulsar.tests.integration.io.SinkTester	From	To
	Move And Rename Attribute private kafkaContainer : KafkaContainer renamed to protected serviceContainer : ServiceContainerT and moved from class org.apache.pulsar.tests.integration.io.KafkaSinkTester to class org.apache.pulsar.tests.integration.io.SinkTester	From	To
	Move And Rename Attribute private cassandraCluster : CassandraContainer renamed to protected serviceContainer : ServiceContainerT and moved from class org.apache.pulsar.tests.integration.io.CassandraSinkTester to class org.apache.pulsar.tests.integration.io.SinkTester	From	To
	Extract Method	1
	Extract Method private runSinkTester(tester SinkTester, builtin boolean) : void extracted from private testSink(tester SinkTester, builtin boolean) : void in class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest	From	To
	Change Attribute Type	1
	Change Attribute Type sink : ElasticSearchStringSink to sink : ElasticSearchSink in class org.apache.pulsar.io.elasticsearch.ElasticSearchSinkTests	From	To