|
Change Parameter Type executor : OrderedSafeExecutor to executor : OrderedScheduler in method public MetaStoreImplZookeeper(zk ZooKeeper, executor OrderedScheduler) in class org.apache.bookkeeper.mledger.impl.MetaStoreImplZookeeper |
From |
To |
|
Change Parameter Type bookieAddressList : List<BookieSocketAddress> to bookieAddressList : List<String> in method public resolve(bookieAddressList List<String>) : List<String> in class org.apache.pulsar.zookeeper.ZkBookieRackAffinityMapping |
From |
To |
|
Change Parameter Type executor : OrderedSafeExecutor to executor : OrderedScheduler in method public LocalZooKeeperCache(zk ZooKeeper, executor OrderedScheduler, scheduledExecutor ScheduledExecutorService) in class org.apache.pulsar.zookeeper.LocalZooKeeperCache |
From |
To |
|
Change Parameter Type orderedExecutor : OrderedSafeExecutor to orderedExecutor : OrderedScheduler in method public GlobalZooKeeperCache(zkClientFactory ZooKeeperClientFactory, zkSessionTimeoutMillis int, globalZkConnect String, orderedExecutor OrderedScheduler, scheduledExecutor ScheduledExecutorService) in class org.apache.pulsar.zookeeper.GlobalZooKeeperCache |
From |
To |
|
Change Parameter Type orderedExecutor : OrderedSafeExecutor to orderedExecutor : OrderedScheduler in method public ManagedLedgerImpl(factory ManagedLedgerFactoryImpl, bookKeeper BookKeeper, store MetaStore, config ManagedLedgerConfig, scheduledExecutor ScheduledExecutorService, orderedExecutor OrderedScheduler, name String) in class org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl |
From |
To |
|
Change Parameter Type conf : Configuration to conf : ClientConfiguration in method public initialize(conf ClientConfiguration, optionalDnsResolver Optional<DNSToSwitchMapping>, timer HashedWheelTimer, featureProvider FeatureProvider, statsLogger StatsLogger) : RackawareEnsemblePlacementPolicyImpl in class org.apache.pulsar.zookeeper.ZkIsolatedBookieEnsemblePlacementPolicy |
From |
To |
|
Change Parameter Type rackawarePolicy : RackawareEnsemblePlacementPolicy to rackawarePolicy : RackawareEnsemblePlacementPolicyImpl in method public registerRackChangeListener(rackawarePolicy RackawareEnsemblePlacementPolicyImpl) : void in class org.apache.pulsar.zookeeper.ZkBookieRackAffinityMapping |
From |
To |
|
Change Parameter Type executor : OrderedSafeExecutor to executor : OrderedScheduler in method public ZooKeeperCache(zkSession ZooKeeper, executor OrderedScheduler, scheduledExecutor ScheduledExecutorService) in class org.apache.pulsar.zookeeper.ZooKeeperCache |
From |
To |
|
Change Parameter Type bookieAddress : BookieSocketAddress to bookieAddress : String in method private getRack(bookieAddress String) : String in class org.apache.pulsar.zookeeper.ZkBookieRackAffinityMapping |
From |
To |
|
Change Return Type OrderedSafeExecutor to OrderedScheduler in method public getOrderedExecutor() : OrderedScheduler in class org.apache.pulsar.broker.PulsarService |
From |
To |
|
Change Return Type ZooKeeperDataCache<Map<String,Map<BookieSocketAddress,BookieInfo>>> to ZooKeeperDataCache<Map<String,Map<String,BookieInfo>>> in method private getAndSetZkCache(conf Configuration) : ZooKeeperDataCache<Map<String,Map<String,BookieInfo>>> in class org.apache.pulsar.zookeeper.ZkBookieRackAffinityMapping |
From |
To |
|
Change Return Type EnsemblePlacementPolicy to RackawareEnsemblePlacementPolicyImpl in method public initialize(conf ClientConfiguration, optionalDnsResolver Optional<DNSToSwitchMapping>, timer HashedWheelTimer, featureProvider FeatureProvider, statsLogger StatsLogger) : RackawareEnsemblePlacementPolicyImpl in class org.apache.pulsar.zookeeper.ZkIsolatedBookieEnsemblePlacementPolicy |
From |
To |
|
Change Return Type OrderedSafeExecutor to OrderedScheduler in method public getTopicOrderedExecutor() : OrderedScheduler in class org.apache.pulsar.broker.service.BrokerService |
From |
To |
|
Change Return Type OrderedSafeExecutor to OrderedScheduler in method package getExecutor() : OrderedScheduler in class org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl |
From |
To |
|
Change Return Type ZooKeeperDataCache<Map<String,Map<BookieSocketAddress,BookieInfo>>> to ZooKeeperDataCache<Map<String,Map<String,BookieInfo>>> in method public getZkBookieRackMappingCache(zkCache ZooKeeperCache) : ZooKeeperDataCache<Map<String,Map<String,BookieInfo>>> in class org.apache.pulsar.zookeeper.ZkBookieRackAffinityMapping |
From |
To |
|
Change Variable Type bookieMapping : Map<BookieSocketAddress,BookieInfo> to bookieMapping : Map<String,BookieInfo> in method private getRack(bookieAddress String) : String in class org.apache.pulsar.zookeeper.ZkBookieRackAffinityMapping |
From |
To |
|
Change Variable Type bookieAddress : BookieSocketAddress to bookieAddress : String in method public resolve(bookieAddressList List<String>) : List<String> in class org.apache.pulsar.zookeeper.ZkBookieRackAffinityMapping |
From |
To |
|
Change Variable Type bkConf : ClientConfiguration to bkConf : ServerConfiguration in method public main(args String[]) : void in class org.apache.pulsar.PulsarClusterMetadataSetup |
From |
To |
|
Change Variable Type zkDataCache : ZooKeeperDataCache<Map<String,Map<BookieSocketAddress,BookieInfo>>> to zkDataCache : ZooKeeperDataCache<Map<String,Map<String,BookieInfo>>> in method public getZkBookieRackMappingCache(zkCache ZooKeeperCache) : ZooKeeperDataCache<Map<String,Map<String,BookieInfo>>> in class org.apache.pulsar.zookeeper.ZkBookieRackAffinityMapping |
From |
To |
|
Change Variable Type allGroupsBookieMapping : Map<String,Map<BookieSocketAddress,BookieInfo>> to allGroupsBookieMapping : Map<String,Map<String,BookieInfo>> in method private getRack(bookieAddress String) : String in class org.apache.pulsar.zookeeper.ZkBookieRackAffinityMapping |
From |
To |
|
Change Variable Type zkDataCache : ZooKeeperDataCache<Map<String,Map<BookieSocketAddress,BookieInfo>>> to zkDataCache : ZooKeeperDataCache<Map<String,Map<String,BookieInfo>>> in method private getAndSetZkCache(conf Configuration) : ZooKeeperDataCache<Map<String,Map<String,BookieInfo>>> in class org.apache.pulsar.zookeeper.ZkBookieRackAffinityMapping |
From |
To |
|
Change Attribute Type orderedExecutor : OrderedSafeExecutor to orderedExecutor : OrderedScheduler in class org.apache.pulsar.discovery.service.BrokerDiscoveryProvider |
From |
To |
|
Change Attribute Type bookieMappingCache : ZooKeeperDataCache<Map<String,Map<BookieSocketAddress,BookieInfo>>> to bookieMappingCache : ZooKeeperDataCache<Map<String,Map<String,BookieInfo>>> in class org.apache.pulsar.zookeeper.ZkBookieRackAffinityMapping |
From |
To |
|
Change Attribute Type orderedExecutor : OrderedSafeExecutor to orderedExecutor : OrderedScheduler in class org.apache.pulsar.broker.PulsarService |
From |
To |
|
Change Attribute Type executor : OrderedSafeExecutor to executor : OrderedScheduler in class org.apache.pulsar.zookeeper.ZooKeeperCache |
From |
To |
|
Change Attribute Type orderedExecutor : OrderedSafeExecutor to orderedExecutor : OrderedScheduler in class org.apache.pulsar.discovery.service.web.ZookeeperCacheLoader |
From |
To |
|
Change Attribute Type rackawarePolicy : RackawareEnsemblePlacementPolicy to rackawarePolicy : RackawareEnsemblePlacementPolicyImpl in class org.apache.pulsar.zookeeper.ZkBookieRackAffinityMapping |
From |
To |
|
Change Attribute Type pendingAddEntries : Queue<OpAddEntry> to pendingAddEntries : GrowableArrayBlockingQueue<OpAddEntry> in class org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl |
From |
To |
|
Change Attribute Type topicOrderedExecutor : OrderedSafeExecutor to topicOrderedExecutor : OrderedScheduler in class org.apache.pulsar.broker.service.BrokerService |
From |
To |
|
Change Attribute Type executor : OrderedSafeExecutor to executor : OrderedScheduler in class org.apache.bookkeeper.mledger.impl.MetaStoreImplZookeeper |
From |
To |
|
Change Attribute Type executor : OrderedSafeExecutor to executor : OrderedScheduler in class org.apache.pulsar.broker.namespace.OwnershipCacheTest |
From |
To |
|
Change Attribute Type executor : OrderedSafeExecutor to executor : OrderedScheduler in class org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl |
From |
To |
|
Change Attribute Type orderedExecutor : OrderedSafeExecutor to orderedExecutor : OrderedScheduler in class org.apache.pulsar.proxy.server.util.ZookeeperCacheLoader |
From |
To |
|
Change Attribute Type executor : OrderedSafeExecutor to executor : OrderedScheduler in class org.apache.pulsar.broker.cache.ResourceQuotaCacheTest |
From |
To |
|
Change Attribute Type orderedExecutor : OrderedSafeExecutor to orderedExecutor : OrderedScheduler in class org.apache.pulsar.websocket.WebSocketService |
From |
To |
|
Change Attribute Type orderedExecutor : OrderedSafeExecutor to orderedExecutor : OrderedScheduler in class org.apache.bookkeeper.mledger.impl.ManagedLedgerFactoryImpl |
From |
To |
|
Change Attribute Type executor : OrderedSafeExecutor to executor : OrderedScheduler in class org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic |
From |
To |
|
Change Attribute Type typeRef : TypeReference<Map<String,Map<BookieSocketAddress,BookieInfo>>> to typeRef : TypeReference<Map<String,Map<String,BookieInfo>>> in class org.apache.pulsar.zookeeper.ZkBookieRackAffinityMapping |
From |
To |
|
Change Attribute Type orderedExecutor : OrderedSafeExecutor to orderedExecutor : OrderedScheduler in class org.apache.pulsar.proxy.server.BrokerDiscoveryProvider |
From |
To |
|
Change Attribute Type executor : OrderedSafeExecutor to executor : OrderedScheduler in class org.apache.bookkeeper.test.MockedBookKeeperTestCase |
From |
To |