|
Pull Up Method private isProducersExceeded() : boolean from class org.apache.pulsar.broker.service.persistent.PersistentTopic to protected isProducersExceeded() : boolean from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Method private hasLocalProducers() : boolean from class org.apache.pulsar.broker.service.persistent.PersistentTopic to protected hasLocalProducers() : boolean from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Method public toString() : String from class org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic to public toString() : String from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Method public isSchemaCompatible(schema SchemaData) : CompletableFuture<Boolean> from class org.apache.pulsar.broker.service.persistent.PersistentTopic to public isSchemaCompatible(schema SchemaData) : CompletableFuture<Boolean> from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Method public getName() : String from class org.apache.pulsar.broker.service.persistent.PersistentTopic to public getName() : String from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Method public recordAddLatency(latencyUSec long) : void from class org.apache.pulsar.broker.service.persistent.PersistentTopic to public recordAddLatency(latencyUSec long) : void from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Method public getName() : String from class org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic to public getName() : String from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Method public hasSchema() : CompletableFuture<Boolean> from class org.apache.pulsar.broker.service.persistent.PersistentTopic to public hasSchema() : CompletableFuture<Boolean> from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Method private isProducersExceeded() : boolean from class org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic to protected isProducersExceeded() : boolean from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Method public isEncryptionRequired() : boolean from class org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic to public isEncryptionRequired() : boolean from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Method public deleteSchema() : CompletableFuture<SchemaVersion> from class org.apache.pulsar.broker.service.persistent.PersistentTopic to public deleteSchema() : CompletableFuture<SchemaVersion> from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Method public getBrokerService() : BrokerService from class org.apache.pulsar.broker.service.persistent.PersistentTopic to public getBrokerService() : BrokerService from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Method public markBatchMessagePublished() : void from class org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic to public markBatchMessagePublished() : void from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Method private hasLocalProducers() : boolean from class org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic to protected hasLocalProducers() : boolean from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Method public isEncryptionRequired() : boolean from class org.apache.pulsar.broker.service.persistent.PersistentTopic to public isEncryptionRequired() : boolean from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Method public addSchema(schema SchemaData) : CompletableFuture<SchemaVersion> from class org.apache.pulsar.broker.service.persistent.PersistentTopic to public addSchema(schema SchemaData) : CompletableFuture<SchemaVersion> from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Method public getProducers() : ConcurrentOpenHashSet<Producer> from class org.apache.pulsar.broker.service.persistent.PersistentTopic to public getProducers() : ConcurrentOpenHashSet<Producer> from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Method public getProducers() : ConcurrentOpenHashSet<Producer> from class org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic to public getProducers() : ConcurrentOpenHashSet<Producer> from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Method public toString() : String from class org.apache.pulsar.broker.service.persistent.PersistentTopic to public toString() : String from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Method public recordAddLatency(latencyUSec long) : void from class org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic to public recordAddLatency(latencyUSec long) : void from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Method public isSchemaCompatible(schema SchemaData) : CompletableFuture<Boolean> from class org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic to public isSchemaCompatible(schema SchemaData) : CompletableFuture<Boolean> from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Method public hasSchema() : CompletableFuture<Boolean> from class org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic to public hasSchema() : CompletableFuture<Boolean> from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Method public deleteSchema() : CompletableFuture<SchemaVersion> from class org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic to public deleteSchema() : CompletableFuture<SchemaVersion> from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Method public getSchemaValidationEnforced() : boolean from class org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic to public getSchemaValidationEnforced() : boolean from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Method public markBatchMessagePublished() : void from class org.apache.pulsar.broker.service.persistent.PersistentTopic to public markBatchMessagePublished() : void from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Method public getSchemaValidationEnforced() : boolean from class org.apache.pulsar.broker.service.persistent.PersistentTopic to public getSchemaValidationEnforced() : boolean from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Method public getBrokerService() : BrokerService from class org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic to public getBrokerService() : BrokerService from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Method public addSchema(schema SchemaData) : CompletableFuture<SchemaVersion> from class org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic to public addSchema(schema SchemaData) : CompletableFuture<SchemaVersion> from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Attribute private POLICY_UPDATE_FAILURE_RETRY_TIME_SECONDS : long from class org.apache.pulsar.broker.service.persistent.PersistentTopic to protected POLICY_UPDATE_FAILURE_RETRY_TIME_SECONDS : long from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Attribute private lastActive : long from class org.apache.pulsar.broker.service.persistent.PersistentTopic to protected lastActive : long from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Attribute private lastActive : long from class org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic to protected lastActive : long from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Attribute private isFenced : boolean from class org.apache.pulsar.broker.service.persistent.PersistentTopic to protected isFenced : boolean from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Attribute private addEntryLatencyStatsUsec : StatsBuckets from class org.apache.pulsar.broker.service.persistent.PersistentTopic to protected addEntryLatencyStatsUsec : StatsBuckets from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Attribute private isEncryptionRequired : boolean from class org.apache.pulsar.broker.service.persistent.PersistentTopic to protected isEncryptionRequired : boolean from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Attribute private addEntryLatencyStatsUsec : StatsBuckets from class org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic to protected addEntryLatencyStatsUsec : StatsBuckets from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Attribute private topic : String from class org.apache.pulsar.broker.service.persistent.PersistentTopic to protected topic : String from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Attribute public replicatorPrefix : String from class org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic to protected replicatorPrefix : String from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Attribute private schemaValidationEnforced : boolean from class org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic to protected schemaValidationEnforced : boolean from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Attribute private producers : ConcurrentOpenHashSet<Producer> from class org.apache.pulsar.broker.service.persistent.PersistentTopic to protected producers : ConcurrentOpenHashSet<Producer> from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Attribute private lock : ReentrantReadWriteLock from class org.apache.pulsar.broker.service.persistent.PersistentTopic to protected lock : ReentrantReadWriteLock from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Attribute private schemaValidationEnforced : boolean from class org.apache.pulsar.broker.service.persistent.PersistentTopic to protected schemaValidationEnforced : boolean from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Attribute private lock : ReentrantReadWriteLock from class org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic to protected lock : ReentrantReadWriteLock from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Attribute private schemaCompatibilityStrategy : SchemaCompatibilityStrategy from class org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic to protected schemaCompatibilityStrategy : SchemaCompatibilityStrategy from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Attribute private POLICY_UPDATE_FAILURE_RETRY_TIME_SECONDS : long from class org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic to protected POLICY_UPDATE_FAILURE_RETRY_TIME_SECONDS : long from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Attribute private topic : String from class org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic to protected topic : String from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Attribute private hasBatchMessagePublished : boolean from class org.apache.pulsar.broker.service.persistent.PersistentTopic to protected hasBatchMessagePublished : boolean from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Attribute private isEncryptionRequired : boolean from class org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic to protected isEncryptionRequired : boolean from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Attribute private hasBatchMessagePublished : boolean from class org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic to protected hasBatchMessagePublished : boolean from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Attribute private isFenced : boolean from class org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic to protected isFenced : boolean from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Attribute private producers : ConcurrentOpenHashSet<Producer> from class org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic to protected producers : ConcurrentOpenHashSet<Producer> from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Attribute private schemaCompatibilityStrategy : SchemaCompatibilityStrategy from class org.apache.pulsar.broker.service.persistent.PersistentTopic to protected schemaCompatibilityStrategy : SchemaCompatibilityStrategy from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Attribute public replicatorPrefix : String from class org.apache.pulsar.broker.service.persistent.PersistentTopic to protected replicatorPrefix : String from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Attribute private brokerService : BrokerService from class org.apache.pulsar.broker.service.persistent.PersistentTopic to protected brokerService : BrokerService from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |
|
Pull Up Attribute private brokerService : BrokerService from class org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic to protected brokerService : BrokerService from class org.apache.pulsar.broker.service.AbstractTopic |
From |
To |