pulsar d248cee810c311c201035c6b2ae4d255ea3a54b4

d248cee810c311c201035c6b2ae4d255ea3a54b4

Files Diff

Added: 9
Removed: 4
Renamed: 0
Modified: 23

Link to commit

Dependency Action

Refactorings reported:

Refactoring Name	Occurences
Pull Up Method	1
Pull Up Method public setupCluster() : void from class org.apache.pulsar.tests.integration.offload.TestS3Offload to public setupCluster() : void from class org.apache.pulsar.tests.integration.suites.PulsarTieredStorageTestSuite	From	To
Move And Rename Method	3
Move And Rename Method protected waitForProcessingMessages(tenant String, namespace String, sourceName String, numMessages int) : void from class org.apache.pulsar.tests.integration.io.PulsarIOSourceTest to protected waitForProcessingSourceMessages(tenant String, namespace String, sourceName String, numMessages int) : void from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest	From	To
Move And Rename Method package PulsarFunctionsRuntimeTest(functionRuntimeType FunctionRuntimeType) from class org.apache.pulsar.tests.integration.functions.runtime.PulsarFunctionsRuntimeTest to package PulsarFunctionsTest(functionRuntimeType FunctionRuntimeType) from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest	From	To
Move And Rename Method public testPublishAndConsume(serviceUrl String) : void from class org.apache.pulsar.tests.integration.smoke.SmokeTest to private publishAndConsumeMessages(inputTopic String, outputTopic String, numMessages int) : void from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest	From	To
Move Method	26
Move Method protected getSinkInfoNotFound(tenant String, namespace String, sinkName String) : void from class org.apache.pulsar.tests.integration.io.PulsarIOSinkTest to protected getSinkInfoNotFound(tenant String, namespace String, sinkName String) : void from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest	From	To
Move Method private deleteFunction(functionName String) : void from class org.apache.pulsar.tests.integration.functions.runtime.PulsarFunctionsRuntimeTest to private deleteFunction(functionName String) : void from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest	From	To
Move Method public testSource() : void from class org.apache.pulsar.tests.integration.io.PulsarIOSourceTest to private testSource(tester SourceTester) : void from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest	From	To
Move Method public checkUpload() : String from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest to public checkUpload() : String from class org.apache.pulsar.tests.integration.functions.FunctionsCLITest	From	To
Move Method protected produceMessagesToInputTopic(inputTopicName String, numMessages int) : Map<String,String> from class org.apache.pulsar.tests.integration.io.PulsarIOSinkTest to protected produceMessagesToInputTopic(inputTopicName String, numMessages int) : Map<String,String> from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest	From	To
Move Method protected getSourceInfoNotFound(tenant String, namespace String, sourceName String) : void from class org.apache.pulsar.tests.integration.io.PulsarIOSourceTest to protected getSourceInfoNotFound(tenant String, namespace String, sourceName String) : void from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest	From	To
Move Method private publishAndConsumeMessages(inputTopic String, outputTopic String, numMessages int) : void from class org.apache.pulsar.tests.integration.functions.runtime.PulsarFunctionsRuntimeTest to private publishAndConsumeMessages(inputTopic String, outputTopic String, numMessages int) : void from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest	From	To
Move Method protected getSourceStatus(tenant String, namespace String, sourceName String) : void from class org.apache.pulsar.tests.integration.io.PulsarIOSourceTest to protected getSourceStatus(tenant String, namespace String, sourceName String) : void from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest	From	To
Move Method protected getSourceInfoSuccess(tenant String, namespace String, sourceName String) : void from class org.apache.pulsar.tests.integration.io.PulsarIOSourceTest to protected getSourceInfoSuccess(tester SourceTester, tenant String, namespace String, sourceName String) : void from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest	From	To
Move Method protected getSinkStatus(tenant String, namespace String, sinkName String) : void from class org.apache.pulsar.tests.integration.io.PulsarIOSinkTest to protected getSinkStatus(tenant String, namespace String, sinkName String) : void from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest	From	To
Move Method public testExclamationFunction(runtime Runtime) : void from class org.apache.pulsar.tests.integration.functions.runtime.PulsarFunctionsRuntimeTest to private testExclamationFunction(runtime Runtime) : void from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest	From	To
Move Method private submitExclamationFunction(runtime Runtime, inputTopicName String, outputTopicName String, functionName String) : void from class org.apache.pulsar.tests.integration.functions.runtime.PulsarFunctionsRuntimeTest to private submitExclamationFunction(runtime Runtime, inputTopicName String, outputTopicName String, functionName String) : void from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest	From	To
Move Method public checkDownload() : void from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest to public checkDownload() : void from class org.apache.pulsar.tests.integration.functions.FunctionsCLITest	From	To
Move Method protected submitSinkConnector(tenant String, namespace String, sinkName String, inputTopicName String) : void from class org.apache.pulsar.tests.integration.io.PulsarIOSinkTest to protected submitSinkConnector(tester SinkTester, tenant String, namespace String, sinkName String, inputTopicName String) : void from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest	From	To
Move Method private getFunctionInfoNotFound(functionName String) : void from class org.apache.pulsar.tests.integration.functions.runtime.PulsarFunctionsRuntimeTest to private getFunctionInfoNotFound(functionName String) : void from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest	From	To
Move Method public testSink() : void from class org.apache.pulsar.tests.integration.io.PulsarIOSinkTest to private testSink(tester SinkTester) : void from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest	From	To
Move Method private getFunctionStatus(functionName String, numMessages int) : void from class org.apache.pulsar.tests.integration.functions.runtime.PulsarFunctionsRuntimeTest to private getFunctionStatus(functionName String, numMessages int) : void from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest	From	To
Move Method protected waitForProcessingMessages(tenant String, namespace String, sinkName String, numMessages int) : void from class org.apache.pulsar.tests.integration.io.PulsarIOSinkTest to protected waitForProcessingMessages(tenant String, namespace String, sinkName String, numMessages int) : void from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest	From	To
Move Method private getFunctionInfoSuccess(functionName String) : void from class org.apache.pulsar.tests.integration.functions.runtime.PulsarFunctionsRuntimeTest to private getFunctionInfoSuccess(functionName String) : void from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest	From	To
Move Method protected prepareSource() : void from class org.apache.pulsar.tests.integration.io.PulsarIOSourceTest to protected prepareSource(tester SourceTester) : void from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest	From	To
Move Method protected deleteSink(tenant String, namespace String, sinkName String) : void from class org.apache.pulsar.tests.integration.io.PulsarIOSinkTest to protected deleteSink(tenant String, namespace String, sinkName String) : void from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest	From	To
Move Method protected getSinkInfoSuccess(tenant String, namespace String, sinkName String) : void from class org.apache.pulsar.tests.integration.io.PulsarIOSinkTest to protected getSinkInfoSuccess(tester SinkTester, tenant String, namespace String, sinkName String) : void from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest	From	To
Move Method protected deleteSource(tenant String, namespace String, sourceName String) : void from class org.apache.pulsar.tests.integration.io.PulsarIOSourceTest to protected deleteSource(tenant String, namespace String, sourceName String) : void from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest	From	To
Move Method protected validateSourceResult(consumer Consumer<String>, kvs Map<String,String>) : void from class org.apache.pulsar.tests.integration.io.PulsarIOSourceTest to protected validateSourceResult(consumer Consumer<String>, kvs Map<String,String>) : void from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest	From	To
Move Method protected prepareSink() : void from class org.apache.pulsar.tests.integration.io.PulsarIOSinkTest to protected prepareSink(tester SinkTester) : void from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest	From	To
Move Method protected submitSourceConnector(tenant String, namespace String, sourceName String, outputTopicName String) : void from class org.apache.pulsar.tests.integration.io.PulsarIOSourceTest to protected submitSourceConnector(tester SourceTester, tenant String, namespace String, sourceName String, outputTopicName String) : void from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest	From	To
Pull Up Attribute	1
Pull Up Attribute private ENTRIES_PER_LEDGER : int from class org.apache.pulsar.tests.integration.offload.TestS3Offload to protected ENTRIES_PER_LEDGER : int from class org.apache.pulsar.tests.integration.suites.PulsarTieredStorageTestSuite	From	To
Extract Class	1
Extract Class org.apache.pulsar.tests.integration.functions.FunctionsCLITest from class org.apache.pulsar.tests.integration.functions.PulsarFunctionsTest	From	To
Extract Superclass	2
Extract Superclass org.apache.pulsar.tests.integration.suites.PulsarTieredStorageTestSuite from classes [org.apache.pulsar.tests.integration.offload.TestS3Offload]	From	To
Extract Superclass org.apache.pulsar.tests.integration.suites.PulsarTestSuite from classes [org.apache.pulsar.tests.integration.cli.CLITest, org.apache.pulsar.tests.integration.compaction.TestCompaction, org.apache.pulsar.tests.integration.functions.PulsarFunctionsTestBase]	From	To
Change Variable Type	12
Change Variable Type m : Message<byte[]> to m : Message<String> in method public testPublishCompactAndConsumeCLI(serviceUrl String) : void in class org.apache.pulsar.tests.integration.compaction.TestCompaction	From	To
Change Variable Type consumer : Consumer<byte[]> to consumer : Consumer<String> in method public testPublishCompactAndConsumeRest(serviceUrl String) : void in class org.apache.pulsar.tests.integration.compaction.TestCompaction	From	To
Change Variable Type consumer : Consumer<byte[]> to consumer : Consumer<String> in method private waitAndVerifyCompacted(client PulsarClient, topic String, sub String, expectedKey String, expectedValue String) : void in class org.apache.pulsar.tests.integration.compaction.TestCompaction	From	To
Change Variable Type consumer : Consumer<byte[]> to consumer : Consumer<String> in method public testPublishCompactAndConsumeCLI(serviceUrl String) : void in class org.apache.pulsar.tests.integration.compaction.TestCompaction	From	To
Change Variable Type m : Message<byte[]> to m : Message<String> in method public testPublishCompactAndConsumeRest(serviceUrl String) : void in class org.apache.pulsar.tests.integration.compaction.TestCompaction	From	To
Change Variable Type m : Message<byte[]> to m : Message<String> in method private waitAndVerifyCompacted(client PulsarClient, topic String, sub String, expectedKey String, expectedValue String) : void in class org.apache.pulsar.tests.integration.compaction.TestCompaction	From	To

d248cee810c311c201035c6b2ae4d255ea3a54b4

Files Diff

Link to commit

Third party dependencies:

Refactorings reported: