| Type Before | Type After | No. of Instances | No. of Commits | No. of Projects | Hierarchy Relation | Primitive Info | Namespace |
|---|---|---|---|---|---|---|---|
| java.util.concurrent.ScheduledExecutorService | java.util.concurrent.ExecutorService | 1 | 1 | 1 | R_SUPER_T | - | Jdk -> Jdk |
| io.netty.buffer.ByteBuf | void | 1 | 1 | 1 | - | - | External -> Jdk |
| java.lang.String | com.yahoo.pulsar.common.policies.data.loadbalancer.LoadReport | 2 | 1 | 1 | Composition | - | Jdk -> Internal |
| long | int | 12 | 5 | 1 | - | Narrowing | Jdk -> Jdk |
| com.yahoo.pulsar.discovery.service.DiscoveryService | com.yahoo.pulsar.discovery.service.DiscoveryServiceServlet | 3 | 1 | 1 | - | - | Internal -> Internal |
| com.yahoo.pulsar.common.policies.data.BundlesData | java.lang.reflect.AccessibleObject | 1 | 1 | 1 | - | - | Internal -> Jdk |
| org.json.JSONObject | java.lang.String | 1 | 1 | 1 | - | - | External -> Jdk |
| void | java.util.Set<? extendsorg.apache.bookkeeper.mledger.Position> | 2 | 1 | 1 | - | - | Jdk -> Jdk |
| com.yahoo.pulsar.common.util.collections.ConcurrentOpenHashSet | com.yahoo.pulsar.common.util.collections.ConcurrentOpenHashMap | 2 | 1 | 1 | - | - | Internal -> Internal |
| java.text.SimpleDateFormat | java.time.format.DateTimeFormatter | 4 | 1 | 1 | - | - | Jdk -> Jdk |
| void | int | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| io.netty.channel.ChannelPromise | org.apache.commons.lang3.tuple.Pair<io.netty.channel.ChannelPromise, java.lang.Integer> | 1 | 1 | 1 | SIBLING | - | External -> External |
| com.yahoo.pulsar.client.impl.ConsumerBase | com.yahoo.pulsar.client.impl.ConsumerImpl | 1 | 1 | 1 | R_SUPER_T | - | Internal -> Internal |
| com.yahoo.pulsar.broker.lookup.LookupResult | java.util.concurrent.CompletableFuture<com.yahoo.pulsar.broker.lookup.LookupResult> | 1 | 1 | 1 | - | - | Internal -> Jdk |
| com.yahoo.pulsar.common.naming.ServiceUnitId | com.yahoo.pulsar.common.naming.NamespaceBundle | 23 | 1 | 1 | T_SUPER_R | - | Internal -> Internal |
| java.util.Map.Entry | java.util.Optional | 3 | 1 | 1 | - | - | Jdk -> Jdk |
| com.google.common.cache.LoadingCache | com.github.benmanes.caffeine.cache.AsyncLoadingCache | 2 | 1 | 1 | SIBLING | - | External -> External |
| com.google.common.cache.Cache | com.github.benmanes.caffeine.cache.AsyncLoadingCache | 1 | 1 | 1 | SIBLING | - | External -> External |
| com.yahoo.pulsar.broker.namespace.NamespaceEphemeralData | java.util.Optional<com.yahoo.pulsar.broker.namespace.NamespaceEphemeralData> | 1 | 1 | 1 | - | - | Internal -> Jdk |
| void | java.util.concurrent.CompletableFuture<java.util.Optional<com.yahoo.pulsar.common.policies.data.LocalPolicies>> | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| com.yahoo.pulsar.common.naming.NamespaceName | com.yahoo.pulsar.common.naming.NamespaceBundle | 2 | 1 | 1 | Composition | - | Internal -> Internal |
| com.yahoo.pulsar.common.lookup.data.LookupData | void | 1 | 1 | 1 | - | - | Internal -> Jdk |
| com.yahoo.pulsar.common.policies.impl.NamespaceIsolationPolicies | java.util.Optional<com.yahoo.pulsar.common.policies.impl.NamespaceIsolationPolicies> | 1 | 1 | 1 | - | - | Internal -> Jdk |
| com.yahoo.pulsar.common.policies.data.Policies | java.util.Optional<com.yahoo.pulsar.common.policies.data.Policies> | 1 | 1 | 1 | - | - | Internal -> Jdk |
| java.util.concurrent.ExecutorService | io.netty.channel.EventLoopGroup | 2 | 1 | 1 | - | - | Jdk -> External |
| com.ning.http.client.AsyncHttpClientConfig.Builder | org.asynchttpclient.DefaultAsyncHttpClientConfig.Builder | 1 | 1 | 1 | SIBLING | - | External -> External |
| javax.net.ssl.SSLContext | io.netty.handler.ssl.SslContext | 1 | 1 | 1 | - | - | Jdk -> External |
| boolean | java.util.concurrent.CompletableFuture<java.lang.Boolean> | 5 | 1 | 1 | - | - | Jdk -> Jdk |
| java.util.List | java.util.Set | 19 | 4 | 1 | SIBLING | - | Jdk -> Jdk |
| java.util.List | java.lang.Iterable | 1 | 1 | 1 | R_SUPER_T | - | Jdk -> Jdk |
| com.yahoo.pulsar.client.impl.ConnectionPool | com.yahoo.pulsar.client.impl.PulsarClientImpl | 2 | 1 | 1 | SIBLING | - | Internal -> Internal |
| org.json.JSONObject | com.google.gson.JsonObject | 13 | 1 | 1 | SIBLING | - | External -> External |
| int | java.lang.String | 8 | 3 | 1 | - | - | Jdk -> Jdk |
| org.json.JSONArray | com.google.gson.JsonArray | 7 | 1 | 1 | SIBLING | - | External -> External |
| com.yahoo.pulsar.discovery.service.BrokerDiscoveryProvider | com.yahoo.pulsar.discovery.service.DiscoveryService | 2 | 1 | 1 | Composition | - | Internal -> Internal |
| com.yahoo.pulsar.common.policies.data.PersistentTopicStats | com.yahoo.pulsar.common.policies.data.PartitionedTopicStats | 1 | 1 | 1 | R_SUPER_T | - | Internal -> Internal |
| java.util.List<java.lang.String> | com.yahoo.pulsar.common.policies.data.PersistentTopicInternalStats | 1 | 1 | 1 | - | - | Jdk -> Internal |
| com.yahoo.pulsar.common.policies.data.PartitionedTopicStats | com.yahoo.pulsar.common.policies.data.PersistentTopicStats | 1 | 1 | 1 | R_SUPER_T | - | Internal -> Internal |
| com.yahoo.pulsar.common.policies.data.PersistentTopicInternalStats | java.util.List<java.lang.String> | 1 | 1 | 1 | - | - | Internal -> Jdk |
| void | java.util.concurrent.CompletableFuture<java.lang.Void> | 16 | 6 | 1 | - | - | Jdk -> Jdk |
| com.yahoo.pulsar.broker.ServiceConfiguration | com.yahoo.pulsar.websocket.service.WebSocketProxyConfiguration | 6 | 1 | 1 | - | - | Internal -> Internal |
| com.yahoo.pulsar.client.api.Producer | com.yahoo.pulsar.client.impl.ProducerImpl | 2 | 1 | 1 | - | - | Internal -> Internal |
| java.util.concurrent.atomic.AtomicLong | long | 5 | 2 | 1 | - | - | Jdk -> Jdk |
| java.util.concurrent.atomic.AtomicReference<org.apache.bookkeeper.mledger.impl.OpReadEntry> | org.apache.bookkeeper.mledger.impl.OpReadEntry | 1 | 1 | 1 | - | - | Jdk -> Internal |
| java.util.concurrent.atomic.AtomicReference<com.yahoo.pulsar.client.impl.ClientCnx> | com.yahoo.pulsar.client.impl.ClientCnx | 1 | 1 | 1 | - | - | Jdk -> Internal |
| java.util.concurrent.atomic.AtomicInteger | int | 8 | 1 | 1 | - | - | Jdk -> Jdk |
| java.util.concurrent.atomic.AtomicBoolean | int | 3 | 1 | 1 | - | - | Jdk -> Jdk |
| java.util.concurrent.atomic.AtomicReference<com.yahoo.pulsar.broker.service.Consumer> | com.yahoo.pulsar.broker.service.Consumer | 1 | 1 | 1 | - | - | Jdk -> Internal |
| java.util.concurrent.atomic.AtomicReference<org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl.State> | org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl.State | 4 | 1 | 1 | - | - | Jdk -> Internal |
| com.yahoo.pulsar.discovery.service.web.ZookeeperCacheLoader | com.yahoo.pulsar.zookeeper.GlobalZooKeeperCache | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| java.util.List<java.lang.Double> | java.lang.Double | 2 | 1 | 1 | - | - | Jdk -> Jdk |
| org.apache.bookkeeper.mledger.impl.MetaStore.Version | org.apache.bookkeeper.mledger.impl.MetaStore.Stat | 22 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.bookkeeper.mledger.impl.MetaStoreImplZookeeper.ZKVersion | org.apache.bookkeeper.mledger.impl.MetaStoreImplZookeeper.ZKStat | 1 | 1 | 1 | - | - | Internal -> Internal |
| com.yahoo.pulsar.broker.loadbalance.LoadManager | java.util.concurrent.atomic.AtomicReference<com.yahoo.pulsar.broker.loadbalance.LoadManager> | 9 | 1 | 1 | - | - | Internal -> Jdk |
| org.apache.bookkeeper.mledger.impl.EntryImpl | io.netty.util.Recycler.Handle | 1 | 1 | 1 | Composition | - | Internal -> External |
| void | boolean | 7 | 7 | 1 | - | - | Jdk -> Jdk |
| io.netty.util.ResourceLeak | io.netty.util.ResourceLeakTracker<com.yahoo.pulsar.common.api.DoubleByteBuf> | 1 | 1 | 1 | SIBLING | - | External -> External |
| java.util.concurrent.ConcurrentSkipListMap | java.util.concurrent.ConcurrentNavigableMap | 1 | 1 | 1 | R_SUPER_T | - | Jdk -> Jdk |
| com.yahoo.pulsar.client.api.PulsarClient | com.yahoo.pulsar.client.impl.PulsarClientImpl | 2 | 1 | 1 | T_SUPER_R | - | Internal -> Internal |
| org.eclipse.jetty.websocket.servlet.WebSocketServlet | javax.servlet.Servlet | 1 | 1 | 1 | - | - | External -> External |
| long | com.yahoo.pulsar.broker.service.persistent.PersistentDispatcherMultipleConsumers | 1 | 1 | 1 | - | - | Jdk -> Internal |
| com.yahoo.pulsar.common.util.collections.ConcurrentOpenHashMap<org.apache.bookkeeper.mledger.impl.PositionImpl, java.lang.Integer> | org.apache.bookkeeper.util.collections.ConcurrentLongLongPairHashMap | 2 | 1 | 1 | - | - | Internal -> External |
| java.util.TreeSet<org.apache.bookkeeper.mledger.impl.PositionImpl> | com.yahoo.pulsar.common.util.collections.ConcurrentLongPairSet | 1 | 1 | 1 | - | - | Jdk -> Internal |
| com.yahoo.pulsar.broker.service.Subscription | ? extendscom.yahoo.pulsar.broker.service.Subscription | 3 | 1 | 1 | R_SUPER_T | - | Internal -> Internal |
| com.yahoo.pulsar.utils.StatsOutputStream | com.yahoo.pulsar.utils.SimpleTextOutputStream | 5 | 1 | 1 | R_SUPER_T | - | Internal -> Internal |
| java.util.concurrent.CompletableFuture<java.lang.Boolean> | java.lang.Boolean | 3 | 1 | 1 | - | - | Jdk -> Jdk |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandUnsubscribe.Builder | org.apache.pulsar.common.api.proto.PulsarApi.CommandUnsubscribe.Builder | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandSuccess.Builder | org.apache.pulsar.common.api.proto.PulsarApi.CommandSuccess.Builder | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandConsumerStats | org.apache.pulsar.common.api.proto.PulsarApi.CommandConsumerStats | 20 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandPartitionedTopicMetadata | org.apache.pulsar.common.api.proto.PulsarApi.CommandPartitionedTopicMetadata | 20 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandSendReceipt | org.apache.pulsar.common.api.proto.PulsarApi.CommandSendReceipt | 18 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.MessageMetadata | org.apache.pulsar.common.api.proto.PulsarApi.MessageMetadata | 15 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandPing.Builder | org.apache.pulsar.common.api.proto.PulsarApi.CommandPing.Builder | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandRedeliverUnacknowledgedMessages | org.apache.pulsar.common.api.proto.PulsarApi.CommandRedeliverUnacknowledgedMessages | 20 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandConnect.Builder | org.apache.pulsar.common.api.proto.PulsarApi.CommandConnect.Builder | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.ServerError | org.apache.pulsar.common.api.proto.PulsarApi.ServerError | 20 | 1 | 1 | - | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandConsumerStats.Builder | org.apache.pulsar.common.api.proto.PulsarApi.CommandConsumerStats.Builder | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandError.Builder | org.apache.pulsar.common.api.proto.PulsarApi.CommandError.Builder | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandFlow.Builder | org.apache.pulsar.common.api.proto.PulsarApi.CommandFlow.Builder | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandSuccess | org.apache.pulsar.common.api.proto.PulsarApi.CommandSuccess | 20 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.BaseCommand.Type | org.apache.pulsar.common.api.proto.PulsarApi.BaseCommand.Type | 4 | 1 | 1 | - | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandConnected | org.apache.pulsar.common.api.proto.PulsarApi.CommandConnected | 15 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandSendError | org.apache.pulsar.common.api.proto.PulsarApi.CommandSendError | 15 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandRedeliverUnacknowledgedMessages.Builder | org.apache.pulsar.common.api.proto.PulsarApi.CommandRedeliverUnacknowledgedMessages.Builder | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandLookupTopicResponse.LookupType | org.apache.pulsar.common.api.proto.PulsarApi.CommandLookupTopicResponse.LookupType | 4 | 1 | 1 | - | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandCloseConsumer | org.apache.pulsar.common.api.proto.PulsarApi.CommandCloseConsumer | 20 | 1 | 1 | SIBLING | - | Internal -> Internal |
| java.net.URL | java.io.InputStream | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandLookupTopic | org.apache.pulsar.common.api.proto.PulsarApi.CommandLookupTopic | 20 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandProducer.Builder | org.apache.pulsar.common.api.proto.PulsarApi.CommandProducer.Builder | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandConsumerStatsResponse | org.apache.pulsar.common.api.proto.PulsarApi.CommandConsumerStatsResponse | 15 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.BaseCommand | org.apache.pulsar.common.api.proto.PulsarApi.BaseCommand | 15 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandReachedEndOfTopic | org.apache.pulsar.common.api.proto.PulsarApi.CommandReachedEndOfTopic | 20 | 1 | 1 | SIBLING | - | Internal -> Internal |
| java.io.InputStream | java.net.URL | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandLookupTopic.Builder | org.apache.pulsar.common.api.proto.PulsarApi.CommandLookupTopic.Builder | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandMessage.Builder | org.apache.pulsar.common.api.proto.PulsarApi.CommandMessage.Builder | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CompressionType | org.apache.pulsar.common.api.proto.PulsarApi.CompressionType | 4 | 1 | 1 | - | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandSend | org.apache.pulsar.common.api.proto.PulsarApi.CommandSend | 20 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandCloseProducer | org.apache.pulsar.common.api.proto.PulsarApi.CommandCloseProducer | 20 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandPong.Builder | org.apache.pulsar.common.api.proto.PulsarApi.CommandPong.Builder | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandProducerSuccess | org.apache.pulsar.common.api.proto.PulsarApi.CommandProducerSuccess | 15 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandPartitionedTopicMetadata.Builder | org.apache.pulsar.common.api.proto.PulsarApi.CommandPartitionedTopicMetadata.Builder | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.KeyValue | org.apache.pulsar.common.api.proto.PulsarApi.KeyValue | 27 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandConnect | org.apache.pulsar.common.api.proto.PulsarApi.CommandConnect | 20 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandProducer | org.apache.pulsar.common.api.proto.PulsarApi.CommandProducer | 20 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandAck.AckType | org.apache.pulsar.common.api.proto.PulsarApi.CommandAck.AckType | 4 | 1 | 1 | - | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.AuthMethod | org.apache.pulsar.common.api.proto.PulsarApi.AuthMethod | 4 | 1 | 1 | - | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandError | org.apache.pulsar.common.api.proto.PulsarApi.CommandError | 20 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandLookupTopicResponse | org.apache.pulsar.common.api.proto.PulsarApi.CommandLookupTopicResponse | 15 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandSubscribe.Builder | org.apache.pulsar.common.api.proto.PulsarApi.CommandSubscribe.Builder | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| java.util.concurrent.CompletableFuture<java.lang.Void> | void | 12 | 4 | 1 | - | - | Jdk -> Jdk |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandCloseConsumer.Builder | org.apache.pulsar.common.api.proto.PulsarApi.CommandCloseConsumer.Builder | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandFlow | org.apache.pulsar.common.api.proto.PulsarApi.CommandFlow | 20 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandPartitionedTopicMetadataResponse | org.apache.pulsar.common.api.proto.PulsarApi.CommandPartitionedTopicMetadataResponse | 15 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandMessage | org.apache.pulsar.common.api.proto.PulsarApi.CommandMessage | 20 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.KeyValue.Builder | org.apache.pulsar.common.api.proto.PulsarApi.KeyValue.Builder | 6 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandAck.ValidationError | org.apache.pulsar.common.api.proto.PulsarApi.CommandAck.ValidationError | 4 | 1 | 1 | - | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandReachedEndOfTopic.Builder | org.apache.pulsar.common.api.proto.PulsarApi.CommandReachedEndOfTopic.Builder | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.MessageIdData.Builder | org.apache.pulsar.common.api.proto.PulsarApi.MessageIdData.Builder | 7 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandSubscribe.SubType | org.apache.pulsar.common.api.proto.PulsarApi.CommandSubscribe.SubType | 4 | 1 | 1 | - | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandSend.Builder | org.apache.pulsar.common.api.proto.PulsarApi.CommandSend.Builder | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandAck | org.apache.pulsar.common.api.proto.PulsarApi.CommandAck | 20 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.MessageIdData | org.apache.pulsar.common.api.proto.PulsarApi.MessageIdData | 41 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandSubscribe | org.apache.pulsar.common.api.proto.PulsarApi.CommandSubscribe | 20 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandCloseProducer.Builder | org.apache.pulsar.common.api.proto.PulsarApi.CommandCloseProducer.Builder | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandAck.Builder | org.apache.pulsar.common.api.proto.PulsarApi.CommandAck.Builder | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandPartitionedTopicMetadataResponse.LookupType | org.apache.pulsar.common.api.proto.PulsarApi.CommandPartitionedTopicMetadataResponse.LookupType | 4 | 1 | 1 | - | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandPing | org.apache.pulsar.common.api.proto.PulsarApi.CommandPing | 20 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.SingleMessageMetadata | org.apache.pulsar.common.api.proto.PulsarApi.SingleMessageMetadata | 15 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandPong | org.apache.pulsar.common.api.proto.PulsarApi.CommandPong | 20 | 1 | 1 | SIBLING | - | Internal -> Internal |
| com.yahoo.pulsar.common.api.proto.PulsarApi.CommandUnsubscribe | org.apache.pulsar.common.api.proto.PulsarApi.CommandUnsubscribe | 20 | 1 | 1 | SIBLING | - | Internal -> Internal |
| java.net.InetSocketAddress | org.apache.commons.lang3.tuple.Pair<java.net.InetSocketAddress, java.net.InetSocketAddress> | 4 | 1 | 1 | SIBLING | - | Jdk -> External |
| org.apache.pulsar.common.api.proto.PulsarApi.CommandConnect | int | 1 | 1 | 1 | Composition | - | Internal -> Jdk |
| org.apache.pulsar.broker.stats.TopicLoadStats | org.apache.pulsar.broker.stats.DimensionStats | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.broker.service.persistent.PersistentReplicator | org.apache.pulsar.broker.service.Replicator | 4 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.broker.service.persistent.PersistentTopic | org.apache.pulsar.broker.service.Topic | 26 | 1 | 1 | R_SUPER_T | - | Internal -> Internal |
| org.apache.pulsar.broker.service.persistent.PersistentSubscription | org.apache.pulsar.broker.service.Subscription | 7 | 1 | 1 | R_SUPER_T | - | Internal -> Internal |
| ? extendsorg.apache.pulsar.broker.service.Subscription | org.apache.pulsar.broker.service.Subscription | 1 | 1 | 1 | T_SUPER_R | - | Internal -> Internal |
| org.apache.commons.lang3.tuple.MutablePair<io.netty.channel.ChannelPromise, java.lang.Integer> | org.apache.pulsar.broker.service.Consumer.SendMessageInfo | 1 | 1 | 1 | - | - | External -> Internal |
| org.apache.commons.lang3.tuple.Pair<io.netty.channel.ChannelPromise, java.lang.Integer> | org.apache.pulsar.broker.service.Consumer.SendMessageInfo | 1 | 1 | 1 | - | - | External -> Internal |
| int | void | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| org.apache.pulsar.broker.lookup.LookupResult | java.util.Optional<org.apache.pulsar.broker.lookup.LookupResult> | 5 | 1 | 1 | - | - | Internal -> Jdk |
| java.net.URL | java.util.Optional<java.net.URL> | 4 | 1 | 1 | - | - | Jdk -> Jdk |
| java.lang.String | byte | 15 | 6 | 1 | - | - | Jdk -> Jdk |
| java.lang.reflect.Field | org.apache.pulsar.broker.service.BrokerService.ConfigField | 3 | 1 | 1 | Composition | - | Jdk -> Internal |
| java.lang.String | java.util.Optional<java.lang.String> | 9 | 4 | 1 | - | - | Jdk -> Jdk |
| org.apache.pulsar.client.impl.MessageIdImpl | org.apache.pulsar.client.impl.BatchMessageIdImpl | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| org.apache.pulsar.client.api.MessageId | org.apache.pulsar.client.impl.BatchMessageIdImpl | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.bookkeeper.mledger.Position | org.apache.bookkeeper.mledger.impl.PositionImpl | 2 | 1 | 1 | T_SUPER_R | - | Internal -> Internal |
| org.apache.bookkeeper.mledger.impl.PositionImpl | org.apache.bookkeeper.mledger.impl.ManagedCursorImpl.MarkDeleteEntry | 2 | 1 | 1 | Composition | - | Internal -> Internal |
| org.apache.pulsar.broker.service.Topic.PublishCallback | org.apache.pulsar.broker.service.Topic.PublishContext | 4 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.api.Message | java.util.List<org.apache.pulsar.client.api.Message> | 3 | 1 | 1 | - | - | Internal -> Jdk |
| java.lang.String | org.apache.commons.lang3.tuple.Pair<java.lang.String, java.lang.Long> | 6 | 1 | 1 | SIBLING | - | Jdk -> External |
| java.util.List | org.apache.pulsar.common.util.collections.ConcurrentOpenHashSet | 6 | 1 | 1 | - | - | Jdk -> Internal |
| org.apache.pulsar.common.api.proto.PulsarApi.KeyByteValue.Builder | org.apache.pulsar.common.api.proto.PulsarApi.EncryptionKeys.Builder | 3 | 1 | 1 | SIBLING | - | Internal -> Internal |
| byte | org.apache.pulsar.client.api.EncryptionKeyInfo | 3 | 1 | 1 | - | - | Jdk -> Internal |
| org.apache.pulsar.common.partition.PartitionedTopicMetadata | int | 1 | 1 | 1 | Composition | - | Internal -> Jdk |
| org.apache.pulsar.policies.data.loadbalancer.LoadReport | org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport | 15 | 2 | 1 | R_SUPER_T | - | Internal -> Internal |
| void | org.apache.pulsar.policies.data.loadbalancer.LocalBrokerData | 2 | 1 | 1 | - | - | Jdk -> Internal |
| com.google.gson.JsonObject | org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport | 1 | 1 | 1 | - | - | External -> Internal |
| org.apache.pulsar.policies.data.loadbalancer.LoadReport | org.apache.pulsar.policies.data.loadbalancer.LocalBrokerData | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| org.apache.kafka.clients.producer.Producer | org.apache.pulsar.client.impl.ProducerImpl | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.policies.data.loadbalancer.ServiceLookupData | org.apache.pulsar.policies.data.loadbalancer.LoadManagerReport | 5 | 1 | 1 | R_SUPER_T | - | Internal -> Internal |
| java.lang.Void | org.apache.pulsar.common.policies.data.ClusterData | 2 | 1 | 1 | - | - | Jdk -> Internal |
| org.apache.pulsar.client.impl.PulsarClientImpl | org.apache.pulsar.client.api.ClientConfiguration | 1 | 1 | 1 | Composition | - | Internal -> Internal |
| org.apache.pulsar.client.impl.MessageIdImpl | org.apache.pulsar.client.api.MessageId | 18 | 4 | 1 | R_SUPER_T | - | Internal -> Internal |
| java.util.Map<java.lang.String, java.lang.String> | java.lang.String | 5 | 5 | 1 | - | - | Jdk -> Jdk |
| boolean | int | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| io.netty.buffer.ByteBuf | org.apache.pulsar.common.api.ByteBufPair | 19 | 1 | 1 | Composition | - | External -> Internal |
| long | java.lang.Long | 4 | 2 | 1 | - | Boxing | Jdk -> Jdk |
| org.apache.pulsar.common.api.ByteBufPair | io.netty.buffer.ByteBuf | 2 | 1 | 1 | Composition | - | Internal -> External |
| org.apache.pulsar.broker.loadbalance.ResourceUnit | java.util.Optional<org.apache.pulsar.broker.loadbalance.ResourceUnit> | 5 | 1 | 1 | - | - | Internal -> Jdk |
| org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicies | java.util.Optional<org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicies> | 2 | 1 | 1 | - | - | Internal -> Jdk |
| org.apache.pulsar.common.policies.NamespaceIsolationPolicy | java.util.Optional<org.apache.pulsar.common.policies.NamespaceIsolationPolicy> | 4 | 1 | 1 | - | - | Internal -> Jdk |
| java.lang.String | org.apache.pulsar.broker.service.Subscription | 4 | 1 | 1 | - | - | Jdk -> Internal |
| java.net.ServerSocket | java.io.FileReader | 1 | 1 | 1 | SIBLING | - | Jdk -> Jdk |
| int | double | 1 | 1 | 1 | - | Widening | Jdk -> Jdk |
| java.lang.Integer | java.lang.Double | 3 | 1 | 1 | SIBLING | - | Jdk -> Jdk |
| boolean | org.apache.pulsar.client.api.ClientConfiguration | 1 | 1 | 1 | Composition | - | Jdk -> Internal |
| org.apache.pulsar.broker.authorization.AuthorizationManager | org.apache.pulsar.broker.authorization.AuthorizationService | 15 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.broker.authorization.AuthorizationManager | org.apache.pulsar.broker.authorization.PulsarAuthorizationProvider | 3 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.bookkeeper.mledger.impl.PositionImpl | org.apache.bookkeeper.mledger.Position | 2 | 2 | 1 | R_SUPER_T | - | Internal -> Internal |
| java.lang.String | java.util.Set<java.lang.String> | 2 | 2 | 1 | - | - | Jdk -> Jdk |
| org.apache.pulsar.client.api.ClientConfiguration | org.apache.pulsar.client.impl.conf.ClientConfigurationData | 18 | 4 | 1 | SIBLING | - | Internal -> Internal |
| org.apache.pulsar.client.api.ProducerConfiguration.HashingScheme | org.apache.pulsar.client.api.HashingScheme | 3 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.common.util.collections.ConcurrentOpenHashSet | java.util.Set | 2 | 1 | 1 | - | - | Internal -> Jdk |
| org.apache.pulsar.client.api.ProducerConfiguration | org.apache.pulsar.client.impl.conf.ProducerConfigurationData | 10 | 2 | 1 | SIBLING | - | Internal -> Internal |
| org.apache.pulsar.client.api.ConsumerConfiguration | org.apache.pulsar.client.impl.conf.ConsumerConfigurationData | 17 | 1 | 1 | SIBLING | - | Internal -> Internal |
| org.apache.pulsar.client.api.ReaderConfiguration | org.apache.pulsar.client.impl.conf.ReaderConfigurationData | 2 | 1 | 1 | SIBLING | - | Internal -> Internal |
| java.util.Optional<org.apache.pulsar.client.api.MessageId> | org.apache.pulsar.client.api.MessageId | 1 | 1 | 1 | - | - | Jdk -> Internal |
| org.apache.commons.configuration.Configuration | org.apache.bookkeeper.conf.ClientConfiguration | 1 | 1 | 1 | - | - | External -> External |
| org.apache.bookkeeper.net.BookieSocketAddress | java.lang.String | 12 | 2 | 1 | - | - | External -> Jdk |
| org.apache.bookkeeper.util.OrderedSafeExecutor | org.apache.bookkeeper.common.util.OrderedScheduler | 23 | 1 | 1 | - | - | External -> External |
| org.apache.bookkeeper.client.EnsemblePlacementPolicy | org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl | 1 | 1 | 1 | - | - | Internal -> Internal |
| java.util.Queue | org.apache.pulsar.common.util.collections.GrowableArrayBlockingQueue | 1 | 1 | 1 | - | - | Jdk -> Internal |
| org.apache.bookkeeper.conf.ClientConfiguration | org.apache.bookkeeper.conf.ServerConfiguration | 1 | 1 | 1 | - | - | External -> External |
| org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy | org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl | 2 | 1 | 1 | - | - | Internal -> Internal |
| void | java.util.concurrent.CompletableFuture<?> | 2 | 1 | 1 | - | - | Jdk -> Jdk |
| org.apache.pulsar.client.impl.MessageImpl | org.apache.pulsar.client.api.Message<T> | 1 | 1 | 1 | R_SUPER_T | - | Internal -> Internal |
| org.apache.pulsar.client.api.Reader | org.apache.pulsar.client.api.Reader<T> | 6 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.api.Producer | org.apache.pulsar.client.api.Producer<byte[]> | 77 | 4 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.impl.ConsumerImpl | org.apache.pulsar.client.impl.ConsumerImpl<T> | 19 | 4 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.api.Reader | org.apache.pulsar.client.api.Reader<byte[]> | 6 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.api.Producer | org.apache.pulsar.client.api.Producer<T> | 10 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.api.Message | org.apache.pulsar.client.api.Message<T> | 62 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.api.Consumer | org.apache.pulsar.client.api.Producer<T> | 2 | 1 | 1 | SIBLING | - | Internal -> Internal |
| org.apache.pulsar.client.impl.ProducerImpl | org.apache.pulsar.client.impl.ProducerImpl<T> | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.impl.conf.ConsumerConfigurationData | org.apache.pulsar.client.impl.conf.ProducerConfigurationData | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| org.apache.pulsar.client.impl.ProducerBase | org.apache.pulsar.client.impl.ProducerBase<?> | 3 | 2 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.impl.ConsumerBase | org.apache.pulsar.client.impl.ConsumerBase<?> | 3 | 2 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.api.Consumer | org.apache.pulsar.client.api.Consumer<T> | 21 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.api.Consumer | org.apache.pulsar.client.api.Consumer<byte[]> | 59 | 3 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.api.Message | org.apache.pulsar.client.api.Message<byte[]> | 334 | 4 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.api.ClientConfiguration | org.apache.pulsar.client.api.ClientBuilder | 3 | 2 | 1 | SIBLING | - | Internal -> Internal |
| org.apache.pulsar.client.api.ProducerConfiguration | org.apache.pulsar.client.api.ProducerBuilder<byte[]> | 2 | 1 | 1 | SIBLING | - | Internal -> Internal |
| org.apache.pulsar.client.api.ConsumerConfiguration | org.apache.pulsar.client.impl.conf.ConsumerConfigurationData<byte[]> | 2 | 1 | 1 | SIBLING | - | Internal -> Internal |
| org.apache.pulsar.client.api.PulsarClient | org.apache.pulsar.client.impl.PulsarClientImpl | 9 | 4 | 1 | T_SUPER_R | - | Internal -> Internal |
| org.apache.pulsar.client.api.Message | org.apache.pulsar.client.api.Message<?> | 44 | 2 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.impl.MessageImpl | org.apache.pulsar.client.impl.MessageImpl<?> | 10 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.impl.ConsumerImpl | org.apache.pulsar.client.impl.ConsumerImpl<?> | 11 | 2 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.impl.ProducerImpl | org.apache.pulsar.client.impl.ProducerImpl<?> | 7 | 1 | 1 | - | - | Internal -> Internal |
| java.lang.reflect.Method | java.lang.Class<?> | 1 | 1 | 1 | SIBLING | - | Jdk -> Jdk |
| java.lang.String | org.apache.pulsar.functions.runtime.FunctionID | 1 | 1 | 1 | - | - | Jdk -> Internal |
| java.io.ByteArrayInputStream | java.io.ObjectOutput | 1 | 1 | 1 | SIBLING | - | Jdk -> Jdk |
| org.apache.pulsar.functions.spawner.ExecutionResult | org.apache.pulsar.functions.instance.JavaExecutionResult | 4 | 2 | 1 | T_SUPER_R | - | Internal -> Internal |
| org.apache.pulsar.functions.instance.JavaInstance.ExecutionResult | org.apache.pulsar.functions.spawner.ExecutionResult | 2 | 1 | 1 | - | - | Internal -> Internal |
| byte | java.lang.reflect.AccessibleObject | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| java.lang.reflect.AccessibleObject | java.lang.String | 3 | 2 | 1 | - | - | Jdk -> Jdk |
| org.apache.pulsar.functions.runtime.subscribermanager.ResultsProcessor | org.apache.pulsar.client.api.ConsumerConfiguration | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.admin.cli.CmdFunctions.SubmitFunction | org.apache.pulsar.admin.cli.CmdFunctions.CreateFunction | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| org.apache.pulsar.admin.cli.CmdFunctions.SubmitFunction | org.apache.pulsar.admin.cli.CmdFunctions.UpdateFunction | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| org.apache.pulsar.functions.runtime.container.FunctionContainer | org.apache.pulsar.functions.runtime.subscribermanager.TopicSubscription.ContainerWithStats | 2 | 1 | 1 | Composition | - | Internal -> Internal |
| byte | java.lang.String | 25 | 5 | 1 | - | - | Jdk -> Jdk |
| org.apache.pulsar.functions.runtime.worker.FunctionState | org.apache.pulsar.functions.fs.FunctionConfig | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| org.apache.pulsar.functions.runtime.container.ThreadFunctionContainerFactory | org.apache.pulsar.functions.runtime.container.FunctionContainerFactory | 1 | 1 | 1 | R_SUPER_T | - | Internal -> Internal |
| org.apache.pulsar.functions.runtime.container.ThreadFunctionContainer.Payload | org.apache.pulsar.client.api.Message | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.runtime.container.ExecutionResult | org.apache.pulsar.functions.runtime.instance.JavaExecutionResult | 1 | 1 | 1 | - | - | Internal -> Internal |
| java.net.URI | void | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| java.lang.String | org.apache.pulsar.functions.runtime.worker.PackageLocationMetaData | 1 | 1 | 1 | SIBLING | - | Jdk -> Internal |
| org.apache.pulsar.functions.runtime.worker.request.ServiceRequestManager | org.apache.distributedlog.api.namespace.Namespace | 2 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.distributedlog.api.namespace.Namespace | java.util.concurrent.LinkedBlockingQueue<org.apache.pulsar.functions.runtime.worker.FunctionAction> | 1 | 1 | 1 | - | - | Internal -> Jdk |
| org.apache.pulsar.client.api.ConsumerConfiguration | org.apache.pulsar.client.api.ReaderConfiguration | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| org.apache.pulsar.client.api.Consumer | org.apache.pulsar.client.api.Reader | 3 | 1 | 1 | SIBLING | - | Internal -> Internal |
| boolean | void | 6 | 5 | 1 | - | - | Jdk -> Jdk |
| org.apache.pulsar.functions.runtime.worker.FunctionMetaData | org.apache.pulsar.functions.runtime.worker.FunctionRuntimeInfo | 15 | 1 | 1 | Composition | - | Internal -> Internal |
| void | org.apache.pulsar.functions.fs.FunctionConfig | 1 | 1 | 1 | - | - | Jdk -> Internal |
| org.apache.pulsar.functions.worker.request.ServiceRequest | org.apache.pulsar.functions.generated.ServiceRequest.Request | 1 | 1 | 1 | Composition | - | Internal -> Internal |
| org.apache.pulsar.functions.fs.InstanceID | java.lang.String | 11 | 1 | 1 | - | - | Internal -> Jdk |
| org.apache.pulsar.functions.fs.FunctionID | java.lang.String | 12 | 1 | 1 | - | - | Internal -> Jdk |
| org.apache.pulsar.functions.generated.ServiceRequest.PackageLocationMetaData.Builder | org.apache.pulsar.functions.proto.ServiceRequest.PackageLocationMetaData.Builder | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.generated.ServiceRequest.FunctionConfig.Builder | org.apache.pulsar.functions.proto.ServiceRequest.FunctionConfig.Builder | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.generated.ServiceRequest.Request.ServiceRequestType | org.apache.pulsar.functions.proto.ServiceRequest.Request.ServiceRequestType | 2 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.generated.ServiceRequest.Request | org.apache.pulsar.functions.proto.ServiceRequest.Request | 9 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.generated.ServiceRequest.Request.Builder | org.apache.pulsar.functions.proto.ServiceRequest.Request.Builder | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.generated.ServiceRequest.FunctionMetaData.Builder | org.apache.pulsar.functions.proto.ServiceRequest.FunctionMetaData.Builder | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.worker.PackageLocationMetaData | org.apache.pulsar.functions.proto.Function.PackageLocationMetaData.Builder | 2 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.fs.FunctionConfig | org.apache.pulsar.functions.proto.Function.FunctionConfig.Builder | 2 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.worker.FunctionMetaData | org.apache.pulsar.functions.proto.Function.FunctionMetaData.Builder | 2 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.worker.request.ServiceRequest | org.apache.pulsar.functions.worker.request.ServiceRequestInfo | 2 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.worker.request.MarkerRequest | org.apache.pulsar.functions.proto.Request.ServiceRequest | 2 | 1 | 1 | R_SUPER_T | - | Internal -> Internal |
| org.apache.pulsar.functions.proto.ServiceRequest.Request | org.apache.pulsar.functions.proto.Request.ServiceRequest | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.worker.request.UpdateRequest | org.apache.pulsar.functions.proto.Request.ServiceRequest | 1 | 1 | 1 | R_SUPER_T | - | Internal -> Internal |
| org.apache.pulsar.functions.worker.request.DeregisterRequest | org.apache.pulsar.functions.proto.Request.ServiceRequest | 1 | 1 | 1 | R_SUPER_T | - | Internal -> Internal |
| org.apache.pulsar.functions.fs.FunctionStatus | org.apache.pulsar.functions.proto.InstanceCommunication.FunctionStatus.Builder | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.proto.InstanceCommunication.FunctionStatusResponseProto | org.apache.pulsar.functions.proto.InstanceCommunication.FunctionStatus | 4 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.worker.request.ServiceRequestManager | org.apache.pulsar.client.api.PulsarClient | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.runtime.serde.SerDe | java.util.Map<java.lang.String, org.apache.pulsar.functions.runtime.serde.SerDe> | 1 | 1 | 1 | - | - | Internal -> Jdk |
| org.apache.pulsar.client.api.Message | org.apache.pulsar.functions.runtime.instance.JavaInstanceRunnable.InputMessage | 3 | 1 | 1 | Composition | - | Internal -> Internal |
| org.apache.pulsar.functions.runtime.serde.SerDe | java.util.List<org.apache.pulsar.functions.runtime.serde.SerDe> | 3 | 1 | 1 | - | - | Internal -> Jdk |
| org.apache.pulsar.functions.api.RequestHandler | org.apache.pulsar.functions.api.PulsarFunction | 1 | 1 | 1 | - | - | Internal -> Internal |
| java.lang.String | org.apache.pulsar.client.api.MessageId | 3 | 1 | 1 | - | - | Jdk -> Internal |
| org.apache.pulsar.functions.stats.FunctionStats | InstanceCommunication.FunctionStatus.Builder | 1 | 1 | 1 | - | - | Internal -> External |
| java.util.concurrent.atomic.LongAdder | long | 5 | 1 | 1 | - | - | Jdk -> Jdk |
| java.lang.Class<? extendsorg.apache.pulsar.functions.api.SerDe> | java.lang.String | 5 | 1 | 1 | SIBLING | - | Jdk -> Jdk |
| org.apache.pulsar.functions.runtime.instance.JavaInstanceRunnable | org.apache.pulsar.functions.runtime.spawner.Spawner | 2 | 1 | 1 | SIBLING | - | Internal -> Internal |
| java.lang.reflect.AccessibleObject | org.apache.pulsar.functions.api.PulsarFunction | 1 | 1 | 1 | - | - | Jdk -> Internal |
| java.lang.reflect.Type | java.lang.reflect.AccessibleObject | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| java.lang.reflect.Type | java.lang.Class | 2 | 1 | 1 | T_SUPER_R | - | Jdk -> Jdk |
| java.lang.reflect.AccessibleObject | java.lang.Class | 6 | 2 | 1 | SIBLING | - | Jdk -> Jdk |
| java.lang.String | org.apache.pulsar.functions.worker.MembershipManager.WorkerInfo | 2 | 1 | 1 | Composition | - | Jdk -> Internal |
| org.apache.pulsar.functions.api.PulsarFunction | java.lang.reflect.AccessibleObject | 1 | 1 | 1 | - | - | Internal -> Jdk |
| org.apache.pulsar.functions.api.PulsarFunction | java.lang.Class<?> | 3 | 1 | 1 | - | - | Internal -> Jdk |
| org.apache.pulsar.functions.proto.Function.Assignment | java.util.Collection<org.apache.pulsar.functions.proto.Function.Assignment> | 1 | 1 | 1 | - | - | Internal -> Jdk |
| org.apache.pulsar.functions.proto.Function.Assignment | java.util.Map<java.lang.String, org.apache.pulsar.functions.proto.Function.Assignment> | 1 | 1 | 1 | - | - | Internal -> Jdk |
| org.apache.pulsar.functions.runtime.spawner.AssignmentInfo | org.apache.pulsar.functions.runtime.container.InstanceConfig | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.proto.InstanceCommunication.FunctionStatus | org.apache.pulsar.functions.proto.InstanceCommunication.FunctionStatusList | 4 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.proto.Function.FunctionMetaData | org.apache.pulsar.functions.proto.Function.Instance | 7 | 1 | 1 | - | - | Internal -> Internal |
| java.lang.String | org.apache.pulsar.functions.proto.Function.Instance | 6 | 1 | 1 | - | - | Jdk -> Internal |
| org.apache.pulsar.client.api.Producer | org.apache.pulsar.functions.runtime.instance.producers.Producers | 1 | 1 | 1 | - | - | Internal -> Internal |
| java.util.concurrent.LinkedBlockingQueue | java.util.concurrent.LinkedBlockingDeque | 1 | 1 | 1 | SIBLING | - | Jdk -> Jdk |
| org.apache.pulsar.functions.worker.ClusterServiceCoordinator | org.apache.pulsar.functions.worker.WorkerService | 1 | 1 | 1 | Composition | - | Internal -> Internal |
| java.util.List | java.util.Map | 4 | 1 | 1 | - | - | Jdk -> Jdk |
| void | java.util.concurrent.Future<?> | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| org.apache.pulsar.client.impl.ConsumerImpl | org.apache.pulsar.client.impl.ConsumerImpl<byte[]> | 6 | 2 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.api.Consumer | org.apache.pulsar.client.api.Consumer<?> | 12 | 1 | 1 | - | - | Internal -> Internal |
| byte[] | ? | 2 | 1 | 1 | - | - | Jdk -> TypeVariable |
| org.apache.pulsar.client.impl.ProducerImpl | org.apache.pulsar.client.impl.ProducerImpl<byte[]> | 8 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.impl.ProducerBase | org.apache.pulsar.client.impl.ProducerBase<byte[]> | 2 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.bookkeeper.conf.ClientConfiguration | org.apache.pulsar.client.impl.conf.ClientConfigurationData | 3 | 1 | 1 | - | - | External -> Internal |
| org.apache.pulsar.functions.worker.rest.api.v2.FunctionApiV2Resource | org.apache.pulsar.functions.worker.rest.api.FunctionsImpl | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.impl.ProducerStats | org.apache.pulsar.client.impl.ProducerStatsRecorder | 2 | 1 | 1 | SIBLING | - | Internal -> Internal |
| org.apache.pulsar.common.policies.data.ConsumerStats | org.apache.pulsar.client.impl.ConsumerStatsRecorder | 2 | 1 | 1 | - | - | Internal -> Internal |
| io.netty.util.Timeout | java.util.Optional<io.netty.util.Timeout> | 1 | 1 | 1 | - | - | External -> Jdk |
| org.apache.pulsar.common.policies.data.ConsumerStats | org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl | 2 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.metrics.MetricsSink | java.lang.Long | 2 | 1 | 1 | - | - | Internal -> Jdk |
| org.apache.pulsar.client.api.RawMessage | org.apache.commons.lang3.tuple.ImmutablePair<org.apache.pulsar.client.api.MessageId, java.lang.String> | 1 | 1 | 1 | - | - | Internal -> External |
| java.util.Collection | java.util.List | 2 | 2 | 1 | T_SUPER_R | - | Jdk -> Jdk |
| java.lang.String | org.apache.pulsar.common.naming.TopicName | 5 | 3 | 1 | Composition | - | Jdk -> Internal |
| java.lang.String | java.lang.Void | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| java.lang.String | org.apache.pulsar.common.naming.NamespaceName | 1 | 1 | 1 | Composition | - | Jdk -> Internal |
| java.lang.Long | int | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| org.apache.bookkeeper.mledger.Position | java.lang.Iterable<org.apache.bookkeeper.mledger.Position> | 1 | 1 | 1 | - | - | Internal -> Jdk |
| java.lang.Class | java.lang.Class<?> | 3 | 2 | 1 | - | - | Jdk -> Jdk |
| java.net.URL | java.lang.String | 4 | 1 | 1 | SIBLING | - | Jdk -> Jdk |
| java.util.function.BiFunction | java.util.function.Function | 3 | 1 | 1 | - | - | Jdk -> Jdk |
| org.apache.pulsar.common.api.proto.PulsarApi.MessageIdData.Builder | org.apache.pulsar.common.api.proto.PulsarApi.MessageIdData | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.common.api.proto.PulsarApi.MessageIdData | java.util.List<org.apache.pulsar.common.api.proto.PulsarApi.MessageIdData> | 5 | 1 | 1 | - | - | Internal -> Jdk |
| org.apache.pulsar.common.api.proto.PulsarApi.MessageIdData | org.apache.pulsar.client.impl.MessageIdImpl | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.common.api.proto.PulsarApi.MessageIdData | org.apache.pulsar.common.api.proto.PulsarApi.MessageIdData.Builder | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.bookkeeper.mledger.impl.PositionImpl | java.util.List<org.apache.bookkeeper.mledger.Position> | 3 | 1 | 1 | - | - | Internal -> Jdk |
| java.util.concurrent.ScheduledExecutorService | org.apache.bookkeeper.common.util.OrderedScheduler | 10 | 2 | 1 | T_SUPER_R | - | Jdk -> External |
| java.util.concurrent.ScheduledExecutorService | org.apache.bookkeeper.common.util.OrderedExecutor | 1 | 1 | 1 | - | - | Jdk -> External |
| org.apache.bookkeeper.common.util.OrderedScheduler | org.apache.bookkeeper.common.util.OrderedExecutor | 16 | 2 | 1 | - | - | External -> External |
| org.apache.bookkeeper.common.util.SafeRunnable | java.lang.Runnable | 1 | 1 | 1 | - | - | External -> Jdk |
| org.apache.pulsar.client.api.Message | org.apache.pulsar.client.impl.TopicMessageImpl | 1 | 1 | 1 | T_SUPER_R | - | Internal -> Internal |
| java.util.List | java.util.concurrent.ConcurrentHashMap | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl | org.apache.pulsar.client.impl.ConsumerStatsRecorder | 1 | 1 | 1 | R_SUPER_T | - | Internal -> Internal |
| org.apache.pulsar.client.api.MessageId | org.apache.pulsar.client.impl.TopicMessageIdImpl | 1 | 1 | 1 | T_SUPER_R | - | Internal -> Internal |
| org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl | org.apache.pulsar.client.api.ConsumerStats | 1 | 1 | 1 | - | - | Internal -> Internal |
| java.util.Map | com.google.common.collect.Multimap | 5 | 1 | 1 | - | - | Jdk -> External |
| org.apache.pulsar.broker.service.Topic | java.util.Optional<org.apache.pulsar.broker.service.Topic> | 19 | 2 | 1 | - | - | Internal -> Jdk |
| org.apache.pulsar.client.admin.PulsarAdminWithFunctions | org.apache.pulsar.client.admin.PulsarAdmin | 1 | 1 | 1 | R_SUPER_T | - | Internal -> Internal |
| org.apache.commons.lang3.tuple.Pair<java.lang.Long, java.lang.String> | org.apache.pulsar.client.impl.ProducerResponse | 6 | 1 | 1 | - | - | External -> Internal |
| java.lang.String | org.apache.commons.lang3.tuple.Pair<java.lang.String, java.lang.Integer> | 2 | 1 | 1 | SIBLING | - | Jdk -> External |
| java.util.ArrayDeque | org.jctools.queues.MpmcArrayQueue | 1 | 1 | 1 | - | - | Jdk -> External |
| int | java.lang.Throwable | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| org.apache.bookkeeper.client.BookKeeper.DigestType | org.apache.bookkeeper.client.api.DigestType | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.bookkeeper.client.LedgerHandle | org.apache.bookkeeper.client.api.ReadHandle | 17 | 1 | 1 | - | - | Internal -> Internal |
| org.jctools.queues.MpmcArrayQueue | org.jctools.queues.MessagePassingQueue | 1 | 1 | 1 | R_SUPER_T | - | External -> External |
| org.apache.pulsar.common.util.collections.GrowableArrayBlockingQueue | java.util.concurrent.ConcurrentLinkedQueue | 1 | 1 | 1 | SIBLING | - | Internal -> Jdk |
| org.apache.pulsar.functions.proto.Function.FunctionConfig.Runtime | org.apache.pulsar.functions.proto.Function.FunctionDetails.Runtime | 2 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.proto.Function.FunctionConfig.ProcessingGuarantees | org.apache.pulsar.functions.proto.Function.FunctionDetails.ProcessingGuarantees | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.proto.Function.FunctionConfig.Builder | org.apache.pulsar.functions.proto.Function.FunctionDetails.Builder | 7 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.shaded.proto.Function.FunctionConfig.Builder | org.apache.pulsar.functions.utils.FunctionConfig | 2 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.proto.Function.FunctionConfig | org.apache.pulsar.functions.proto.Function.FunctionDetails | 38 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.proto.Function.FunctionConfig | org.apache.pulsar.functions.shaded.proto.Function.FunctionDetails | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.shaded.proto.Function.FunctionConfig.Builder | org.apache.pulsar.functions.shaded.proto.Function.FunctionDetails.Builder | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.shaded.proto.Function.FunctionConfig | org.apache.pulsar.functions.shaded.proto.Function.FunctionDetails | 6 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.proto.Function.FunctionConfig.SubscriptionType | org.apache.pulsar.functions.proto.Function.FunctionDetails.SubscriptionType | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.proto.Function.FunctionConfig.Builder | org.apache.pulsar.functions.shaded.proto.Function.FunctionDetails.Builder | 1 | 1 | 1 | - | - | Internal -> Internal |
| java.util.function.Consumer | java.util.function.Consumer<?> | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| org.apache.pulsar.client.admin.Properties | org.apache.pulsar.client.admin.Tenants | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.admin.internal.PropertiesImpl | org.apache.pulsar.client.admin.internal.TenantsImpl | 2 | 1 | 1 | SIBLING | - | Internal -> Internal |
| CustomPropertyAdmin | CustomTenantAdmin | 1 | 1 | 1 | - | - | External -> External |
| org.apache.pulsar.common.util.KeyValue | org.apache.pulsar.connect.core.Message | 3 | 1 | 1 | - | - | Internal -> Internal |
| byte | org.apache.pulsar.connect.core.Message<byte[]> | 4 | 1 | 1 | - | - | Jdk -> Internal |
| java.lang.String | org.apache.pulsar.connect.core.Message<java.lang.String> | 2 | 1 | 1 | - | - | Jdk -> Internal |
| org.apache.pulsar.broker.web.RestException | javax.ws.rs.WebApplicationException | 1 | 1 | 1 | R_SUPER_T | - | Internal -> External |
| java.util.Map<java.lang.String, org.apache.pulsar.client.api.Consumer> | org.apache.pulsar.client.api.Consumer | 3 | 1 | 1 | - | - | Jdk -> Internal |
| org.jctools.queues.MessagePassingQueue | java.util.ArrayDeque | 1 | 1 | 1 | - | - | External -> Jdk |
| org.apache.pulsar.connect.core.Message | org.apache.pulsar.common.util.KeyValue | 3 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.connect.core.Message | org.apache.pulsar.connect.core.Record | 8 | 1 | 1 | - | - | Internal -> Internal |
| java.lang.String | java.lang.reflect.AccessibleObject | 26 | 3 | 1 | - | - | Jdk -> Jdk |
| org.apache.pulsar.client.api.Message | org.apache.pulsar.connect.core.Record | 2 | 1 | 1 | - | - | Internal -> Internal |
| byte | java.util.UUID | 4 | 1 | 1 | - | - | Jdk -> Jdk |
| byte | java.lang.Void | 3 | 1 | 1 | - | - | Jdk -> Jdk |
| org.apache.pulsar.client.api.ConsumerConfiguration | org.apache.pulsar.client.api.SubscriptionType | 1 | 1 | 1 | - | - | Internal -> Internal |
| boolean | java.util.concurrent.atomic.AtomicBoolean | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| org.apache.pulsar.functions.instance.InputMessage | org.apache.pulsar.connect.core.Record | 5 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.api.Consumer | org.apache.pulsar.connect.core.Source | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.admin.PersistentTopics | org.apache.pulsar.client.admin.internal.TopicsImpl | 1 | 1 | 1 | T_SUPER_R | - | Internal -> Internal |
| org.apache.pulsar.common.policies.data.NonPersistentTopicStats | org.apache.pulsar.common.policies.data.TopicStats | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.common.policies.data.TopicStats | org.apache.pulsar.broker.service.persistent.PersistentTopic.TopicStatsHelper | 2 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.common.policies.data.PersistentTopicStats | org.apache.pulsar.common.policies.data.TopicStats | 59 | 1 | 1 | R_SUPER_T | - | Internal -> Internal |
| java.lang.IllegalAccessException | void | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| java.lang.Long | long | 7 | 2 | 1 | - | Unboxing | Jdk -> Jdk |
| SchemaRegistryFormat.SchemaInfo.SchemaType | org.apache.pulsar.broker.service.schema.proto.SchemaRegistryFormat.SchemaInfo.SchemaType | 7 | 1 | 1 | - | - | Internal -> Internal |
| SchemaRegistryFormat.SchemaInfo.KeyValuePair.Builder | org.apache.pulsar.broker.service.schema.proto.SchemaRegistryFormat.SchemaInfo.KeyValuePair.Builder | 3 | 1 | 1 | - | - | Internal -> Internal |
| SchemaRegistryFormat.SchemaInfo.KeyValuePair | org.apache.pulsar.broker.service.schema.proto.SchemaRegistryFormat.SchemaInfo.KeyValuePair | 25 | 1 | 1 | Composition | - | Internal -> Internal |
| SchemaRegistryFormat.SchemaInfo.KeyValuePairOrBuilder | org.apache.pulsar.broker.service.schema.proto.SchemaRegistryFormat.SchemaInfo.KeyValuePairOrBuilder | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.api.MessageId | java.util.concurrent.CompletableFuture<org.apache.pulsar.client.api.MessageId> | 1 | 1 | 1 | - | - | Internal -> Jdk |
| org.apache.pulsar.client.api.Message<byte[]> | byte | 1 | 1 | 1 | - | - | Internal -> Jdk |
| org.apache.pulsar.client.api.Message | org.apache.pulsar.client.api.TypedMessageBuilder | 3 | 2 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.proto.Function.FunctionDetails.ProcessingGuarantees | org.apache.pulsar.functions.proto.Function.ProcessingGuarantees | 1 | 1 | 1 | - | - | Internal -> Internal |
| java.util.Map | java.lang.Class | 2 | 1 | 1 | - | - | Jdk -> Jdk |
| org.apache.pulsar.functions.shaded.proto.Function.FunctionDetails.SubscriptionType | org.apache.pulsar.functions.shaded.proto.Function.SubscriptionType | 2 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.shaded.proto.Function.FunctionDetails.ProcessingGuarantees | org.apache.pulsar.functions.shaded.proto.Function.ProcessingGuarantees | 2 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.proto.Function.ConnectorDetails | org.apache.pulsar.functions.proto.Function.SourceSpec | 1 | 1 | 1 | - | - | Internal -> Internal |
| io.netty.util.collection.IntObjectMap | java.util.Map | 4 | 1 | 1 | R_SUPER_T | - | External -> Jdk |
| org.apache.pulsar.functions.source.PulsarRecord | org.apache.pulsar.connect.core.RecordContext | 4 | 1 | 1 | R_SUPER_T | - | Internal -> Internal |
| java.util.Map | org.apache.pulsar.client.api.Producer | 1 | 1 | 1 | - | - | Jdk -> Internal |
| org.apache.pulsar.admin.cli.CmdConnectors.DeleteConnector | org.apache.pulsar.admin.cli.CmdSources.DeleteSource | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| byte | int | 1 | 1 | 1 | - | Widening | Jdk -> Jdk |
| java.util.function.Function | java.util.function.Consumer | 6 | 1 | 1 | - | - | Jdk -> Jdk |
| org.apache.bookkeeper.client.api.ReadHandle | long | 2 | 1 | 1 | - | - | External -> Jdk |
| org.apache.pulsar.functions.sink.RuntimeSink | org.apache.pulsar.io.core.Sink | 1 | 1 | 1 | R_SUPER_T | - | Internal -> Internal |
| org.apache.pulsar.zookeeper.ZooKeeperCache | java.util.concurrent.atomic.AtomicReference<org.apache.pulsar.zookeeper.ZooKeeperCache> | 2 | 1 | 1 | - | - | Internal -> Jdk |
| com.google.protobuf.CodedInputStream | org.apache.pulsar.shaded.com.google.protobuf.v241.CodedInputStream | 120 | 1 | 1 | - | - | External -> Internal |
| com.google.protobuf.ByteString | org.apache.pulsar.shaded.com.google.protobuf.v241.ByteString | 290 | 1 | 1 | - | - | External -> Internal |
| com.google.protobuf.LazyStringList | org.apache.pulsar.shaded.com.google.protobuf.v241.LazyStringList | 4 | 1 | 1 | - | - | External -> Internal |
| com.google.protobuf.CodedOutputStream | org.apache.pulsar.shaded.com.google.protobuf.v241.CodedOutputStream | 40 | 1 | 1 | - | - | External -> Internal |
| com.google.protobuf.ExtensionRegistryLite | org.apache.pulsar.shaded.com.google.protobuf.v241.ExtensionRegistryLite | 281 | 1 | 1 | - | - | External -> Internal |
| org.apache.pulsar.common.util.KeyValue<K, V> | byte | 3 | 1 | 1 | - | - | Internal -> Jdk |
| int | long | 7 | 3 | 1 | - | Widening | Jdk -> Jdk |
| java.io.InputStream | org.apache.pulsar.broker.s3offload.OffloadIndexBlock.IndexInputStream | 3 | 1 | 1 | - | - | Jdk -> Internal |
| java.lang.String | java.lang.Integer | 3 | 2 | 1 | SIBLING | - | Jdk -> Jdk |
| java.lang.annotation.Annotation | java.util.List<java.lang.annotation.Annotation> | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| org.apache.pulsar.client.admin.LongRunningProcessStatus | java.lang.String | 1 | 1 | 1 | Composition | - | Internal -> Jdk |
| org.apache.pulsar.functions.utils.FunctionConfig.SubscriptionType | org.apache.pulsar.client.api.SubscriptionType | 1 | 1 | 1 | - | - | Internal -> Internal |
| java.util.function.Consumer<org.apache.pulsar.io.core.Record<byte[]>> | org.apache.pulsar.io.rabbitmq.RabbitMQSource | 2 | 1 | 1 | Composition | - | Jdk -> Internal |
| java.io.File | java.lang.String | 3 | 2 | 1 | SIBLING | - | Jdk -> Jdk |
| org.apache.pulsar.broker.service.schema.AvroSchemaCompatibilityCheck.CompatibilityStrategy | org.apache.pulsar.broker.service.schema.SchemaCompatibilityStrategy | 3 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.common.schema.SchemaVersion | long | 2 | 1 | 1 | - | - | Internal -> Jdk |
| java.lang.Class<?> | java.lang.String | 2 | 1 | 1 | SIBLING | - | Jdk -> Jdk |
| org.apache.pulsar.functions.api.SerDe | org.apache.pulsar.functions.api.SerDe<T> | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.api.Consumer | java.util.Map<java.lang.String, org.apache.pulsar.client.api.Consumer<T>> | 1 | 1 | 1 | - | - | Internal -> Jdk |
| org.apache.pulsar.client.impl.AcknowledgmentsGroupingTracker | org.apache.pulsar.client.impl.PersistentAcknowledgmentsGroupingTracker | 3 | 1 | 1 | R_SUPER_T | - | Internal -> Internal |
| java.util.Map<java.lang.String, org.apache.pulsar.client.api.Consumer<T>> | org.apache.pulsar.client.api.Consumer | 1 | 1 | 1 | - | - | Jdk -> Internal |
| org.apache.pulsar.functions.api.SerDe<T> | org.apache.pulsar.functions.api.SerDe | 1 | 1 | 1 | - | - | Internal -> Internal |
| java.lang.Class<? extendsorg.apache.pulsar.common.compression.CompressionCodec> | org.apache.pulsar.common.compression.CompressionCodec | 1 | 1 | 1 | - | - | Jdk -> Internal |
| java.util.zip.Deflater | io.netty.util.concurrent.FastThreadLocal<java.util.zip.Deflater> | 1 | 1 | 1 | - | - | Jdk -> External |
| java.util.zip.Inflater | io.netty.util.concurrent.FastThreadLocal<java.util.zip.Inflater> | 1 | 1 | 1 | - | - | Jdk -> External |
| java.util.Map | java.util.Optional | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| java.util.Map<java.util.Map<java.lang.String, org.apache.pulsar.common.policies.data.BookieInfo>, java.lang.String> | org.apache.pulsar.common.policies.data.BookiesRackConfiguration | 4 | 1 | 1 | - | - | Jdk -> Internal |
| org.apache.pulsar.broker.PulsarService | org.apache.pulsar.broker.authentication.AuthenticationService | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.api.Message | org.apache.pulsar.client.impl.MessageImpl | 2 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.impl.MessageImpl | org.apache.pulsar.client.impl.TopicMessageImpl | 2 | 1 | 1 | SIBLING | - | Internal -> Internal |
| org.apache.pulsar.tests.integration.functions.runtime.PulsarFunctionsRuntimeTest.ContainerFactory | org.apache.pulsar.functions.runtime.RuntimeFactory | 2 | 1 | 1 | - | - | Internal -> Internal |
| java.lang.IllegalAccessException | java.lang.Throwable | 18 | 2 | 1 | R_SUPER_T | - | Jdk -> Jdk |
| java.lang.Void | org.apache.pulsar.functions.api.examples.serde.CustomObject | 1 | 1 | 1 | - | - | Jdk -> Internal |
| java.lang.String | org.apache.pulsar.functions.api.examples.serde.CustomObject | 1 | 1 | 1 | - | - | Jdk -> Internal |
| byte | java.nio.ByteBuffer | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| java.lang.String | int | 7 | 2 | 1 | - | - | Jdk -> Jdk |
| org.apache.pulsar.io.core.RecordContext | org.apache.pulsar.io.core.Record<T> | 3 | 1 | 1 | R_SUPER_T | - | Internal -> Internal |
| long | java.util.Optional<java.lang.Long> | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| org.apache.pulsar.io.core.RecordContext | org.apache.pulsar.io.core.Record<byte[]> | 7 | 1 | 1 | R_SUPER_T | - | Internal -> Internal |
| byte | org.apache.pulsar.io.core.Record<byte[]> | 5 | 1 | 1 | - | - | Jdk -> Internal |
| org.apache.pulsar.tests.containers.CassandraContainer | java.util.Map<java.lang.String, org.testcontainers.containers.GenericContainer<?>> | 1 | 1 | 1 | - | - | Internal -> Jdk |
| org.apache.pulsar.client.api.Consumer | java.util.List<java.lang.String> | 3 | 1 | 1 | - | - | Internal -> Jdk |
| org.apache.pulsar.client.api.MessageId | org.apache.pulsar.functions.api.Record<?> | 2 | 1 | 1 | - | - | Internal -> Internal |
| byte | org.apache.pulsar.functions.api.Record<?> | 3 | 1 | 1 | - | - | Jdk -> Internal |
| com.amazonaws.services.s3.AmazonS3 | org.jclouds.blobstore.BlobStore | 8 | 1 | 1 | - | - | External -> External |
| org.apache.pulsar.broker.service.BrokerService | org.apache.pulsar.broker.PulsarService | 3 | 1 | 1 | Composition | - | Internal -> Internal |
| java.lang.StringBuffer | java.lang.AbstractStringBuilder | 1 | 1 | 1 | R_SUPER_T | - | Jdk -> Jdk |
| org.testcontainers.containers.Container.ExecResult | org.apache.pulsar.tests.integration.docker.ContainerExecResult | 32 | 1 | 1 | - | - | External -> Internal |
| java.lang.String | org.apache.pulsar.tests.integration.docker.ContainerExecResult | 1 | 1 | 1 | Composition | - | Jdk -> Internal |
| long | double | 1 | 1 | 1 | - | Widening | Jdk -> Jdk |
| javax.ws.rs.core.Response | java.util.List<org.apache.pulsar.functions.worker.WorkerInfo> | 3 | 1 | 1 | - | - | External -> Jdk |
| org.apache.pulsar.io.core.SinkContext | org.apache.pulsar.io.kinesis.KinesisSink | 1 | 1 | 1 | Composition | - | Internal -> Internal |
| java.lang.ref.Finalizer.FinalizerThread | org.apache.pulsar.functions.worker.rest.WorkerServer | 1 | 1 | 1 | - | - | Jdk -> Internal |
| org.apache.pulsar.common.naming.NamespaceBundles | java.util.List<org.apache.pulsar.common.naming.NamespaceBundle> | 1 | 1 | 1 | - | - | Internal -> Jdk |
| javax.ws.rs.core.Response | java.util.Collection<org.apache.pulsar.common.stats.Metrics> | 2 | 1 | 1 | - | - | External -> Jdk |
| org.apache.pulsar.broker.ServiceConfiguration | org.apache.pulsar.broker.offload.TieredStorageConfigurationData | 2 | 1 | 1 | - | - | Internal -> Internal |
| org.jclouds.blobstore.BlobStoreContext | java.lang.String | 1 | 1 | 1 | - | - | External -> Jdk |
| org.apache.pulsar.client.api.MessageBuilder | org.apache.pulsar.client.api.TypedMessageBuilder<T> | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.api.Producer | org.apache.pulsar.client.api.Producer<?> | 1 | 1 | 1 | - | - | Internal -> Internal |
| java.lang.String | org.apache.pulsar.functions.utils.ConsumerConfig | 1 | 1 | 1 | Composition | - | Jdk -> Internal |
| org.apache.pulsar.client.api.PulsarClient | org.apache.pulsar.functions.worker.WorkerService | 1 | 1 | 1 | Composition | - | Internal -> Internal |
| java.lang.String | org.apache.pulsar.io.twitter.TweetData | 3 | 1 | 1 | Composition | - | Jdk -> Internal |
| org.apache.pulsar.client.api.Consumer | org.apache.pulsar.client.impl.ConsumerImpl | 3 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.worker.WorkerConfig | org.apache.pulsar.functions.worker.WorkerService | 1 | 1 | 1 | Composition | - | Internal -> Internal |
| org.apache.pulsar.functions.worker.rest.api.v2.WorkerStats | org.apache.pulsar.client.admin.Worker | 2 | 1 | 1 | - | - | Internal -> Internal |
| java.lang.Class<T> | org.apache.avro.Schema | 1 | 1 | 1 | - | - | Jdk -> External |
| java.util.concurrent.CountDownLatch | java.util.concurrent.CompletableFuture<org.apache.pulsar.common.api.proto.PulsarApi.BaseCommand> | 5 | 1 | 1 | - | - | Jdk -> Jdk |
| java.lang.Boolean | boolean | 1 | 1 | 1 | - | Unboxing | Jdk -> Jdk |
| org.apache.pulsar.client.impl.schema.GenericAvroSchema | org.apache.pulsar.client.impl.schema.generic.GenericSchema | 2 | 1 | 1 | SIBLING | - | Internal -> Internal |
| java.lang.String | org.apache.pulsar.tests.integration.io.SinkTester.SinkType | 3 | 1 | 1 | - | - | Jdk -> Internal |
| java.lang.Integer | java.lang.Integer[] | 2 | 1 | 1 | - | - | Jdk -> Jdk |
| org.apache.bookkeeper.client.MockBookKeeper | org.apache.bookkeeper.client.PulsarMockBookKeeper | 2 | 1 | 1 | - | - | Internal -> Internal |
| byte | org.apache.pulsar.client.api.schema.GenericRecord | 1 | 1 | 1 | - | - | Jdk -> Internal |
| org.apache.pulsar.io.jdbc.JdbcAvroSchemaSink | org.apache.pulsar.io.jdbc.JdbcAutoSchemaSink | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| java.lang.String | org.apache.pulsar.tests.integration.io.JdbcSinkTester.Foo | 1 | 1 | 1 | Composition | - | Jdk -> Internal |
| java.util.Queue | java.util.concurrent.ArrayBlockingQueue | 1 | 1 | 1 | T_SUPER_R | - | Jdk -> Jdk |
| long | java.util.concurrent.atomic.AtomicLong | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| org.apache.bookkeeper.mledger.ManagedLedgerFactory | org.apache.pulsar.sql.presto.PulsarConnectorCache | 1 | 1 | 1 | Composition | - | Internal -> Internal |
| org.apache.pulsar.io.elasticsearch.ElasticSearchStringSink | org.apache.pulsar.io.elasticsearch.ElasticSearchSink | 1 | 1 | 1 | - | - | Internal -> Internal |
| java.util.concurrent.ExecutorService | java.util.concurrent.ScheduledExecutorService | 1 | 1 | 1 | T_SUPER_R | - | Jdk -> Jdk |
| org.apache.pulsar.functions.proto.Request.AssignmentsUpdate | org.apache.pulsar.functions.proto.Function.Assignment | 6 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.worker.ConnectorsManager | org.apache.pulsar.functions.worker.WorkerService | 1 | 1 | 1 | Composition | - | Internal -> Internal |
| int | java.lang.Integer | 21 | 3 | 1 | - | Boxing | Jdk -> Jdk |
| java.util.List | org.apache.commons.lang3.tuple.Pair | 2 | 1 | 1 | - | - | Jdk -> External |
| java.io.File | java.lang.ClassLoader | 2 | 1 | 1 | - | - | Jdk -> Jdk |
| java.io.InputStream | java.io.File | 2 | 1 | 1 | - | - | Jdk -> Jdk |
| org.apache.pulsar.common.nar.NarClassLoader | java.lang.ClassLoader | 2 | 2 | 1 | - | - | Internal -> Jdk |
| java.net.URLClassLoader | java.lang.ClassLoader | 1 | 1 | 1 | R_SUPER_T | - | Jdk -> Jdk |
| org.apache.pulsar.functions.proto.Function.FunctionDetails | org.apache.pulsar.functions.utils.FunctionConfig | 19 | 3 | 1 | - | - | Internal -> Internal |
| void | java.lang.ClassLoader | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| org.apache.pulsar.shade.io.netty.buffer.ByteBuf | io.netty.buffer.ByteBuf | 2 | 2 | 1 | - | - | Internal -> External |
| io.netty.buffer.ByteBuf | org.apache.pulsar.shade.io.netty.buffer.ByteBuf | 2 | 1 | 1 | - | - | External -> Internal |
| java.lang.String | java.util.concurrent.ThreadFactory | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| org.apache.pulsar.client.admin.Functions | org.apache.pulsar.client.admin.Sink | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.admin.Functions | org.apache.pulsar.client.admin.Source | 1 | 1 | 1 | - | - | Internal -> Internal |
| java.lang.String | java.lang.ClassLoader | 2 | 1 | 1 | - | - | Jdk -> Jdk |
| org.apache.pulsar.functions.proto.Function.FunctionDetails | org.apache.pulsar.functions.utils.SinkConfig | 2 | 1 | 1 | - | - | Internal -> Internal |
| java.lang.String | org.apache.pulsar.functions.proto.Function.FunctionMetaData | 3 | 1 | 1 | - | - | Jdk -> Internal |
| org.apache.pulsar.functions.proto.Function.FunctionDetails | org.apache.pulsar.functions.utils.SourceConfig | 2 | 1 | 1 | - | - | Internal -> Internal |
| java.util.concurrent.ExecutorService | org.eclipse.jetty.util.thread.ExecutorThreadPool | 5 | 1 | 1 | SIBLING | - | Jdk -> External |
| boolean | java.lang.String | 2 | 1 | 1 | - | - | Jdk -> Jdk |
| java.lang.String | java.nio.file.Path | 2 | 1 | 1 | SIBLING | - | Jdk -> Jdk |
| java.lang.ClassLoader | org.apache.pulsar.common.nar.NarClassLoader | 1 | 1 | 1 | - | - | Jdk -> Internal |
| java.lang.String | ? | 2 | 1 | 1 | - | - | Jdk -> TypeVariable |
| java.util.IdentityHashMap<org.apache.kafka.connect.source.SourceRecord, org.apache.kafka.connect.source.SourceRecord> | java.util.concurrent.atomic.AtomicInteger | 1 | 1 | 1 | SIBLING | - | Jdk -> Jdk |
| byte | org.apache.pulsar.common.schema.KeyValue<byte[], byte[]> | 3 | 1 | 1 | - | - | Jdk -> Internal |
| boolean | java.lang.Boolean | 9 | 4 | 1 | - | Boxing | Jdk -> Jdk |
| org.apache.pulsar.common.policies.data.FunctionStats | org.apache.pulsar.functions.instance.FunctionStatsManager | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.proto.InstanceCommunication.MetricsData | java.util.Map<java.lang.Double, java.lang.String> | 6 | 1 | 1 | - | - | Internal -> Jdk |
| InstanceCommunication.MetricsData.DataDigest | java.lang.Double | 2 | 1 | 1 | - | - | External -> Jdk |
| javax.ws.rs.core.Response | FunctionStats.FunctionInstanceStats.FunctionInstanceStatsData | 3 | 1 | 1 | - | - | External -> Internal |
| javax.ws.rs.core.Response | org.apache.pulsar.common.policies.data.FunctionStats | 3 | 1 | 1 | - | - | External -> Internal |
| org.apache.pulsar.functions.proto.InstanceCommunication.FunctionStatusList | org.apache.pulsar.common.policies.data.FunctionStats | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.flink.api.java.tuple.Tuple4<java.lang.String, java.lang.String, java.lang.String, java.lang.Integer> | org.apache.flink.api.java.tuple.Tuple4<java.lang.Integer, java.lang.Integer, java.lang.String, java.lang.Integer> | 3 | 1 | 1 | - | - | External -> External |
| double | java.lang.Double | 2 | 1 | 1 | - | Boxing | Jdk -> Jdk |
| java.lang.String | org.apache.pulsar.common.functions.FunctionState | 4 | 1 | 1 | Composition | - | Jdk -> Internal |
| org.apache.pulsar.websocket.data.ConsumerAck | org.apache.pulsar.websocket.data.ConsumerCommand | 1 | 1 | 1 | - | - | Internal -> Internal |
| java.util.Timer | java.util.concurrent.ScheduledFuture | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| java.util.concurrent.ScheduledExecutorService | java.util.concurrent.ScheduledFuture | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| java.util.concurrent.atomic.AtomicBoolean | boolean | 2 | 1 | 1 | - | - | Jdk -> Jdk |
| java.util.concurrent.ArrayBlockingQueue | org.jctools.queues.SpscArrayQueue | 2 | 1 | 1 | - | - | Jdk -> External |
| org.apache.pulsar.shade.com.google.gson.JsonObject | java.util.Map | 1 | 1 | 1 | - | - | Internal -> Jdk |
| org.apache.pulsar.shade.com.google.gson.JsonElement | java.lang.reflect.AccessibleObject | 1 | 1 | 1 | - | - | Internal -> Jdk |
| org.apache.pulsar.client.api.Message | org.apache.pulsar.common.api.raw.RawMessage | 10 | 1 | 1 | - | - | Internal -> Internal |
| java.lang.String | long | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| byte | org.apache.pulsar.shade.io.netty.buffer.ByteBuf | 2 | 1 | 1 | - | - | Jdk -> Internal |
| org.apache.pulsar.client.api.Message<?> | org.apache.pulsar.common.api.raw.RawMessage | 2 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.common.api.proto.PulsarApi.MessageIdData | long | 1 | 1 | 1 | Composition | - | Internal -> Jdk |
| io.netty.util.concurrent.FastThreadLocal | java.lang.ThreadLocal | 2 | 1 | 1 | - | - | External -> Jdk |
| org.apache.pulsar.common.nar.NarClassLoader | org.apache.pulsar.functions.utils.SourceConfigUtils.ExtractedSourceDetails | 2 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.common.nar.NarClassLoader | org.apache.pulsar.functions.utils.SinkConfigUtils.ExtractedSinkDetails | 2 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.common.api.proto.PulsarApi.MessageMetadata | org.apache.pulsar.common.api.raw.ReferenceCountedObject<org.apache.pulsar.common.api.proto.PulsarApi.MessageMetadata> | 3 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.proto.InstanceCommunication.Metrics | java.util.List<org.apache.pulsar.common.policies.data.WorkerFunctionInstanceStats> | 2 | 1 | 1 | - | - | Internal -> Jdk |
| javax.ws.rs.core.Response | java.util.Map<java.util.Collection<java.lang.String>, java.lang.String> | 3 | 1 | 1 | - | - | External -> Jdk |
| javax.ws.rs.core.Response | org.apache.pulsar.common.functions.WorkerInfo | 3 | 1 | 1 | - | - | External -> Internal |
| javax.ws.rs.core.Response | java.util.List<org.apache.pulsar.common.functions.WorkerInfo> | 3 | 1 | 1 | - | - | External -> Jdk |
| javax.ws.rs.core.Response | java.util.List<org.apache.pulsar.common.policies.data.WorkerFunctionInstanceStats> | 4 | 1 | 1 | - | - | External -> Jdk |
| com.google.gson.JsonArray | java.util.List<org.apache.pulsar.common.policies.data.WorkerFunctionInstanceStats> | 1 | 1 | 1 | SIBLING | - | External -> Jdk |
| int | java.util.Optional<java.lang.Integer> | 16 | 2 | 1 | - | - | Jdk -> Jdk |
| org.eclipse.jetty.util.thread.ExecutorThreadPool | org.apache.pulsar.broker.web.WebExecutorThreadPool | 4 | 1 | 1 | T_SUPER_R | - | External -> Internal |
| javax.ws.rs.core.Response | org.apache.pulsar.common.io.SinkConfig | 3 | 1 | 1 | - | - | External -> Internal |
| javax.ws.rs.core.Response | org.apache.pulsar.common.functions.FunctionConfig | 5 | 1 | 1 | - | - | External -> Internal |
| javax.ws.rs.core.Response | void | 68 | 2 | 1 | - | - | External -> Jdk |
| javax.ws.rs.core.Response | javax.ws.rs.core.StreamingOutput | 3 | 1 | 1 | SIBLING | - | External -> External |
| javax.ws.rs.core.Response | org.apache.pulsar.common.io.SourceConfig | 4 | 1 | 1 | - | - | External -> Internal |
| javax.ws.rs.core.Response | org.apache.pulsar.common.functions.FunctionState | 3 | 1 | 1 | - | - | External -> Internal |
| javax.ws.rs.core.Response | java.lang.String | 3 | 1 | 1 | - | - | External -> Jdk |
| javax.ws.rs.core.Response | java.util.List<java.lang.String> | 15 | 1 | 1 | - | - | External -> Jdk |
| org.apache.pulsar.common.util.collections.ConcurrentOpenHashSet | java.util.concurrent.ConcurrentHashMap | 1 | 1 | 1 | - | - | Internal -> Jdk |
| java.lang.String | javax.ws.rs.core.Response | 1 | 1 | 1 | - | - | Jdk -> External |
| org.apache.pulsar.common.policies.data.FunctionStatus | javax.ws.rs.core.Response | 1 | 1 | 1 | - | - | Internal -> External |
| void | javax.ws.rs.core.Response | 8 | 1 | 1 | - | - | Jdk -> External |
| org.apache.pulsar.common.functions.FunctionState | javax.ws.rs.core.Response | 1 | 1 | 1 | - | - | Internal -> External |
| FunctionStatus.FunctionInstanceStatus.FunctionInstanceStatusData | javax.ws.rs.core.Response | 1 | 1 | 1 | - | - | Internal -> External |
| org.apache.pulsar.common.functions.FunctionConfig | org.apache.pulsar.functions.proto.Function.FunctionDetails | 2 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.common.functions.FunctionConfig | javax.ws.rs.core.Response | 1 | 1 | 1 | - | - | Internal -> External |
| org.apache.pulsar.functions.worker.rest.api.FunctionsImpl | org.apache.pulsar.functions.worker.rest.api.FunctionsImplV2 | 2 | 1 | 1 | Composition | - | Internal -> Internal |
| javax.ws.rs.core.StreamingOutput | javax.ws.rs.core.Response | 1 | 1 | 1 | SIBLING | - | External -> External |
| org.apache.pulsar.functions.instance.stats.FunctionStatsManager | org.apache.pulsar.functions.instance.stats.ComponentStatsManager | 1 | 1 | 1 | R_SUPER_T | - | Internal -> Internal |
| io.netty.bootstrap.ServerBootstrap | io.netty.bootstrap.Bootstrap | 1 | 1 | 1 | SIBLING | - | External -> External |
| org.apache.pulsar.client.api.MessageBuilder | org.apache.pulsar.client.api.TypedMessageBuilder | 2 | 1 | 1 | - | - | Internal -> Internal |
| java.lang.String | java.util.Map<java.lang.String, java.lang.String> | 4 | 1 | 1 | - | - | Jdk -> Jdk |
| org.apache.pulsar.common.api.proto.PulsarApi.CompressionType | org.apache.pulsar.client.api.CompressionType | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.common.api.proto.PulsarApi.CommandGetTopicsOfNamespace.Mode | org.apache.pulsar.client.api.RegexSubscriptionMode | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.common.naming.TopicName | java.lang.String | 2 | 2 | 1 | Composition | - | Internal -> Jdk |
| java.lang.Long | org.apache.pulsar.functions.api.Record<java.lang.Long> | 5 | 1 | 1 | - | - | Jdk -> Internal |
| java.util.function.Function<O, java.util.Collection<I>> | void | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| java.util.function.Function | org.apache.pulsar.functions.api.WindowFunction | 1 | 1 | 1 | - | - | Jdk -> Internal |
| java.util.concurrent.ConcurrentHashMap | java.util.Map | 1 | 1 | 1 | R_SUPER_T | - | Jdk -> Jdk |
| org.apache.pulsar.broker.service.persistent.SubscribeRateLimiter | java.util.Optional<org.apache.pulsar.broker.service.persistent.SubscribeRateLimiter> | 2 | 1 | 1 | - | - | Internal -> Jdk |
| org.apache.pulsar.broker.service.persistent.DispatchRateLimiter | java.util.Optional<org.apache.pulsar.broker.service.persistent.DispatchRateLimiter> | 7 | 1 | 1 | - | - | Internal -> Jdk |
| boolean | io.netty.handler.ssl.SslContext | 3 | 1 | 1 | - | - | Jdk -> External |
| java.util.Set | java.util.List | 1 | 1 | 1 | SIBLING | - | Jdk -> Jdk |
| org.apache.bookkeeper.net.BookieSocketAddress | PlacementResult<org.apache.bookkeeper.net.BookieSocketAddress> | 1 | 1 | 1 | - | - | External -> External |
| java.util.ArrayList | java.util.List | 3 | 1 | 1 | R_SUPER_T | - | Jdk -> Jdk |
| java.util.ArrayList<org.apache.bookkeeper.net.BookieSocketAddress> | PlacementResult<java.util.List<org.apache.bookkeeper.net.BookieSocketAddress>> | 1 | 1 | 1 | - | - | Jdk -> External |
| java.lang.reflect.AccessibleObject | byte | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| io.netty.handler.ssl.SslContext | org.apache.pulsar.common.util.ClientSslContextRefresher | 1 | 1 | 1 | Composition | - | External -> Internal |
| org.apache.pulsar.discovery.service.server.ServiceConfig | org.apache.pulsar.common.util.ServerSslContextRefresher | 1 | 1 | 1 | - | - | Internal -> Internal |
| java.security.cert.X509Certificate | java.security.cert.Certificate | 1 | 1 | 1 | R_SUPER_T | - | Jdk -> Jdk |
| java.lang.String | java.util.Optional<java.lang.reflect.AccessibleObject> | 2 | 1 | 1 | - | - | Jdk -> Jdk |
| org.apache.pulsar.common.util.ServerSslContextRefresher | org.apache.pulsar.common.util.NettySslContextBuilder | 3 | 1 | 1 | - | - | Internal -> Internal |
| java.util.concurrent.ConcurrentHashMap<org.apache.bookkeeper.mledger.Position, java.util.concurrent.atomic.AtomicInteger> | org.apache.bookkeeper.util.collections.ConcurrentLongLongPairHashMap | 1 | 1 | 1 | - | - | Jdk -> External |
| java.lang.Runnable | java.util.function.Consumer<org.apache.pulsar.functions.utils.Actions.ActionResult> | 2 | 1 | 1 | - | - | Jdk -> Jdk |
| RuntimeUtils.Actions.ActionResult | org.apache.pulsar.functions.utils.Actions.ActionResult | 2 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.common.util.collections.ConcurrentLongPairSet | org.apache.pulsar.common.util.collections.LongPairSet | 1 | 1 | 1 | R_SUPER_T | - | Internal -> Internal |
| java.util.Map<java.lang.String, java.lang.String> | int | 1 | 1 | 1 | - | - | Jdk -> Jdk |
| java.lang.String | org.apache.pulsar.client.api.schema.SchemaDefinition<T> | 1 | 1 | 1 | - | - | Jdk -> Internal |
| java.lang.Class<T> | org.apache.pulsar.client.api.schema.SchemaDefinition | 2 | 2 | 1 | - | - | Jdk -> Internal |
| java.lang.String | org.apache.pulsar.client.api.schema.SchemaDefinition | 2 | 1 | 1 | - | - | Jdk -> Internal |
| java.util.Map<java.lang.String, java.lang.String> | org.apache.pulsar.client.api.schema.SchemaDefinition | 1 | 1 | 1 | - | - | Jdk -> Internal |
| java.util.Map<java.util.Map<org.apache.pulsar.common.policies.data.BookieInfo, org.apache.bookkeeper.net.BookieSocketAddress>, java.lang.String> | org.apache.pulsar.common.policies.data.BookiesRackConfiguration | 2 | 1 | 1 | - | - | Jdk -> Internal |
| org.apache.pulsar.io.rabbitmq.RabbitMQConfig | org.apache.pulsar.io.rabbitmq.RabbitMQSourceConfig | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| org.apache.pulsar.functions.utils.Utils.ComponentType | org.apache.pulsar.functions.utils.ComponentType | 7 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.api.Producer | java.util.Map | 1 | 1 | 1 | - | - | Internal -> Jdk |
| org.apache.pulsar.client.admin.PersistentTopics | org.apache.pulsar.client.admin.Topics | 2 | 1 | 1 | R_SUPER_T | - | Internal -> Internal |
| long | java.util.concurrent.CompletableFuture<java.lang.Long> | 2 | 1 | 1 | - | - | Jdk -> Jdk |
| org.apache.pulsar.functions.proto.Function.FunctionDetails | org.apache.pulsar.functions.proto.Function.FunctionMetaData | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.functions.proto.Function.FunctionDetails.Builder | Function.FunctionDetails.Builder | 1 | 1 | 1 | - | - | Internal -> External |
| java.lang.String | org.apache.pulsar.common.api.AuthData | 6 | 1 | 1 | - | - | Jdk -> Internal |
| org.apache.pulsar.shade.com.google.common.collect.Range | com.google.common.collect.Range | 1 | 1 | 1 | - | - | Internal -> External |
| org.apache.bookkeeper.mledger.ReadOnlyCursor | org.apache.bookkeeper.mledger.impl.ReadOnlyCursorImpl | 1 | 1 | 1 | T_SUPER_R | - | Internal -> Internal |
| org.apache.pulsar.shade.com.google.common.base.Predicate | com.google.common.base.Predicate | 1 | 1 | 1 | - | - | Internal -> External |
| java.io.InputStream | javax.ws.rs.client.WebTarget | 1 | 1 | 1 | - | - | Jdk -> External |
| java.util.concurrent.BlockingQueue | java.util.Queue | 1 | 1 | 1 | R_SUPER_T | - | Jdk -> Jdk |
| org.apache.pulsar.client.impl.schema.generic.MultiVersionGenericSchema | org.apache.pulsar.client.impl.schema.AvroSchema | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.api.schema.GenericSchema | org.apache.pulsar.common.schema.SchemaInfo | 4 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.client.impl.schema.generic.GenericSchemaImpl | org.apache.pulsar.client.api.schema.GenericSchema | 2 | 1 | 1 | R_SUPER_T | - | Internal -> Internal |
| java.lang.String | org.apache.pulsar.client.impl.conf.ConsumerConfigurationData<byte[]> | 2 | 2 | 1 | SIBLING | - | Jdk -> Internal |
| org.apache.pulsar.client.api.ClientConfiguration | org.apache.pulsar.client.api.Authentication | 1 | 1 | 1 | SIBLING | - | Internal -> Internal |
| org.apache.spark.streaming.api.java.JavaDStream | org.apache.spark.streaming.api.java.JavaPairDStream | 1 | 1 | 1 | SIBLING | - | External -> External |
| org.apache.pulsar.client.api.ClientConfiguration | java.lang.String | 1 | 1 | 1 | SIBLING | - | Internal -> Jdk |
| org.apache.pulsar.functions.proto.Function.FunctionAuthenticationSpec | java.util.Optional<org.apache.pulsar.functions.proto.Function.FunctionAuthenticationSpec> | 1 | 1 | 1 | - | - | Internal -> Jdk |
| org.apache.pulsar.functions.auth.FunctionAuthData | java.util.Optional<org.apache.pulsar.functions.auth.FunctionAuthData> | 7 | 1 | 1 | - | - | Internal -> Jdk |
| org.apache.pulsar.client.api.Authentication | org.apache.pulsar.client.impl.conf.ClientConfigurationData | 2 | 1 | 1 | SIBLING | - | Internal -> Internal |
| java.lang.String | org.apache.pulsar.client.impl.conf.ProducerConfigurationData | 2 | 1 | 1 | SIBLING | - | Jdk -> Internal |
| java.util.Map<java.lang.String, java.lang.reflect.AccessibleObject> | org.apache.pulsar.client.impl.conf.ProducerConfigurationData | 1 | 1 | 1 | - | - | Jdk -> Internal |
| org.apache.pulsar.functions.utils.ComponentType | Function.FunctionDetails.ComponentType | 8 | 1 | 1 | - | - | Internal -> External |
| org.apache.pulsar.functions.utils.ComponentType | org.apache.pulsar.functions.proto.Function.FunctionDetails.ComponentType | 5 | 1 | 1 | - | - | Internal -> Internal |
| java.lang.String | java.lang.reflect.Type | 2 | 1 | 1 | - | - | Jdk -> Jdk |
| java.lang.Integer | java.util.Optional<java.lang.Integer> | 14 | 1 | 1 | - | - | Jdk -> Jdk |
| org.apache.pulsar.client.api.Consumer<byte[]> | org.apache.pulsar.storm.PulsarSpoutConsumer | 1 | 1 | 1 | - | - | Internal -> Internal |
| com.google.common.collect.RangeSet | org.apache.pulsar.common.util.collections.LongPairRangeSet | 1 | 1 | 1 | - | - | External -> Internal |
| java.lang.String | org.apache.pulsar.common.schema.KeyValue<byte[], byte[]> | 3 | 1 | 1 | - | - | Jdk -> Internal |
| org.apache.pulsar.client.api.Consumer | java.util.Map.Entry<java.lang.Integer, org.apache.pulsar.client.api.Consumer> | 1 | 1 | 1 | - | - | Internal -> Jdk |
| org.apache.pulsar.broker.service.StickyKeyConsumerSelector | org.apache.pulsar.broker.service.HashRangeStickyKeyConsumerSelector | 1 | 1 | 1 | R_SUPER_T | - | Internal -> Internal |
| org.apache.pulsar.client.admin.Source | org.apache.pulsar.client.admin.Sources | 1 | 1 | 1 | R_SUPER_T | - | Internal -> Internal |
| org.apache.pulsar.client.admin.Sink | org.apache.pulsar.client.admin.Sinks | 1 | 1 | 1 | R_SUPER_T | - | Internal -> Internal |
| org.apache.pulsar.io.core.Sink | org.apache.pulsar.client.admin.Sinks | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.apache.pulsar.io.core.Source | org.apache.pulsar.client.admin.Sources | 1 | 1 | 1 | - | - | Internal -> Internal |
| byte | java.lang.Integer | 18 | 1 | 1 | - | - | Jdk -> Jdk |
| java.util.Map<java.lang.String, java.lang.reflect.AccessibleObject> | java.lang.reflect.AccessibleObject | 4 | 1 | 1 | - | - | Jdk -> Jdk |
| org.apache.pulsar.client.impl.conf.ClientConfigurationData | boolean | 1 | 1 | 1 | Composition | - | Internal -> Jdk |
| io.netty.handler.ssl.SslContext | java.util.function.Supplier<io.netty.handler.ssl.SslContext> | 1 | 1 | 1 | - | - | External -> Jdk |
| java.lang.Boolean | org.apache.pulsar.tests.integration.docker.ContainerExecResult | 1 | 1 | 1 | - | - | Jdk -> Internal |
| org.apache.bookkeeper.client.BookKeeper | org.apache.bookkeeper.mledger.impl.ManagedLedgerFactoryImpl.BookkeeperFactoryForCustomEnsemblePlacementPolicy | 1 | 1 | 1 | - | - | Internal -> Internal |
| org.jclouds.domain.Credentials | org.apache.pulsar.jcloud.shade.com.google.common.base.Supplier<org.jclouds.domain.Credentials> | 6 | 1 | 1 | - | - | Internal -> Internal |
| java.lang.Integer | int | 1 | 1 | 1 | - | Unboxing | Jdk -> Jdk |
| org.apache.pulsar.common.policies.data.PartitionedTopicStats | void | 2 | 1 | 1 | - | - | Internal -> Jdk |
| org.apache.pulsar.common.policies.data.PartitionedTopicInternalStats | void | 3 | 1 | 1 | - | - | Internal -> Jdk |
| java.lang.String | org.apache.pulsar.common.policies.data.BookieAffinityGroupData | 11 | 1 | 1 | Composition | - | Jdk -> Internal |
| org.apache.pulsar.client.api.BatchMessageContainer | org.apache.pulsar.client.impl.BatchMessageContainerBase | 1 | 1 | 1 | T_SUPER_R | - | Internal -> Internal |
| java.lang.String | org.apache.pulsar.common.functions.FunctionConfig | 4 | 1 | 1 | Composition | - | Jdk -> Internal |
| java.lang.String | org.apache.pulsar.common.io.SourceConfig | 4 | 1 | 1 | Composition | - | Jdk -> Internal |
| java.lang.String | org.apache.pulsar.common.io.SinkConfig | 4 | 1 | 1 | Composition | - | Jdk -> Internal |