Toggle navigation
Home
com.yahoo.pulsar.discovery.service.web.ZookeeperCacheLoader to com.yahoo.pulsar.zookeeper.GlobalZooKeeperCache
No. of Instances - 1
No. of Commits - 1
No. of Projects - {'pulsar'}
Hierarchy/Composition: SIBLING
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Add or Remove Method invocation
globalZkCache.getLocalZkCache().getDataAsync(path,new Deserializer<PartitionedTopicMetadata>(){ @Override public PartitionedTopicMetadata deserialize( String key, byte[] content) throws Exception { return getThreadLocal().readValue(content,PartitionedTopicMetadata.class); } } ).thenAccept(metadata -> { if (metadata.isPresent()) { metadataFuture.complete(metadata.get()); } else { metadataFuture.complete(new PartitionedTopicMetadata()); } } )
to
globalZkCache.getDataAsync(path,new Deserializer<PartitionedTopicMetadata>(){ @Override public PartitionedTopicMetadata deserialize( String key, byte[] content) throws Exception { return getThreadLocal().readValue(content,PartitionedTopicMetadata.class); } } ).thenAccept(metadata -> { if (metadata.isPresent()) { metadataFuture.complete(metadata.get()); } else { metadataFuture.complete(new PartitionedTopicMetadata()); } } )