A B C D E F G H I J K L M N O P Q R S T U V W Z 

A

AbstractConfiguration - Class in org.apache.bookkeeper.conf
Abstract configuration
AbstractConfiguration() - Constructor for class org.apache.bookkeeper.conf.AbstractConfiguration
 
ADD_ENTRY_TIMEOUT_SEC - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
ADD_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
addAllEntries(Iterable<? extends PubSubProtocol.Map.Entry>) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
addAllRanges(Iterable<? extends PubSubProtocol.LedgerRange>) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
addAllRemoteComponents(Iterable<? extends PubSubProtocol.RegionSpecificSeqId>) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
addAllTriedServers(Iterable<? extends ByteString>) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
addBookie(RackawareEnsemblePlacementPolicy.BookieNode) - Method in interface org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.Ensemble
Append the new bookie node to the ensemble.
addBookie(RackawareEnsemblePlacementPolicy.BookieNode) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.EnsembleForReplacement
 
addBookie(RackawareEnsemblePlacementPolicy.BookieNode) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.RRRackCoverageEnsemble
 
addComplete(int, LedgerHandle, long, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.AddCallback
Callback declaration
addEntries(PubSubProtocol.Map.Entry) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
addEntries(int, PubSubProtocol.Map.Entry) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
addEntries(PubSubProtocol.Map.Entry.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
addEntries(int, PubSubProtocol.Map.Entry.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
addEntriesBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
addEntriesBuilder(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
addEntry(byte[]) - Method in class org.apache.bookkeeper.client.LedgerHandle
Add entry synchronously to an open ledger.
addEntry(byte[], int, int) - Method in class org.apache.bookkeeper.client.LedgerHandle
Add entry synchronously to an open ledger.
addRanges(PubSubProtocol.LedgerRange) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
addRanges(int, PubSubProtocol.LedgerRange) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
addRanges(PubSubProtocol.LedgerRange.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
addRanges(int, PubSubProtocol.LedgerRange.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
addRangesBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
addRangesBuilder(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
addRemoteComponents(PubSubProtocol.RegionSpecificSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
addRemoteComponents(int, PubSubProtocol.RegionSpecificSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
addRemoteComponents(PubSubProtocol.RegionSpecificSeqId.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
addRemoteComponents(int, PubSubProtocol.RegionSpecificSeqId.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
addRemoteComponentsBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
addRemoteComponentsBuilder(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
addSubscriptionListener(SubscriptionListener) - Method in interface org.apache.hedwig.client.api.Subscriber
Register a subscription listener which get notified about subscription event indicating a state of a subscription that subscribed disable resubscribe logic.
addTriedServers(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
ALLOW_LOOPBACK - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
apply(RackawareEnsemblePlacementPolicy.BookieNode, RackawareEnsemblePlacementPolicy.Ensemble) - Method in interface org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.Predicate
 
apply(RackawareEnsemblePlacementPolicy.BookieNode, RackawareEnsemblePlacementPolicy.Ensemble) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.RRRackCoverageEnsemble
 
apply(RackawareEnsemblePlacementPolicy.BookieNode, RackawareEnsemblePlacementPolicy.Ensemble) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.TruePredicate
 
asyncAddEntry(byte[], AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle
Add entry asynchronously to an open ledger.
asyncAddEntry(byte[], int, int, AsyncCallback.AddCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle
Add entry asynchronously to an open ledger, using an offset and range.
AsyncCallback - Interface in org.apache.bookkeeper.client
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
AsyncCallback.AddCallback - Interface in org.apache.bookkeeper.client
 
AsyncCallback.CloseCallback - Interface in org.apache.bookkeeper.client
 
AsyncCallback.CreateCallback - Interface in org.apache.bookkeeper.client
 
AsyncCallback.DeleteCallback - Interface in org.apache.bookkeeper.client
 
AsyncCallback.IsClosedCallback - Interface in org.apache.bookkeeper.client
 
AsyncCallback.OpenCallback - Interface in org.apache.bookkeeper.client
 
AsyncCallback.ReadCallback - Interface in org.apache.bookkeeper.client
 
AsyncCallback.ReadLastConfirmedCallback - Interface in org.apache.bookkeeper.client
 
AsyncCallback.RecoverCallback - Interface in org.apache.bookkeeper.client
 
asyncClose(AsyncCallback.CloseCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle
Asynchronous close, any adds in flight will return errors.
asyncCloseSubscription(ByteString, ByteString, Callback<Void>, Object) - Method in interface org.apache.hedwig.client.api.Subscriber
Closes all of the client side cached data for this subscription without actually sending an unsubscribe request to the server.
asyncCreateLedger(int, int, BookKeeper.DigestType, byte[], AsyncCallback.CreateCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeper
Creates a new ledger asynchronously.
asyncCreateLedger(int, int, int, BookKeeper.DigestType, byte[], AsyncCallback.CreateCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeper
Creates a new ledger asynchronously.
asyncDeleteLedger(long, AsyncCallback.DeleteCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeper
Deletes a ledger asynchronously.
asyncIsClosed(long, AsyncCallback.IsClosedCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeper
Check asynchronously whether the ledger with identifier lId has been closed.
asyncOpenLedger(long, BookKeeper.DigestType, byte[], AsyncCallback.OpenCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeper
Open existing ledger asynchronously for reading.
asyncOpenLedger(long, AsyncCallback.OpenCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Open a ledger as an administrator.
asyncOpenLedgerNoRecovery(long, BookKeeper.DigestType, byte[], AsyncCallback.OpenCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeper
Open existing ledger asynchronously for reading, but it does not try to recover the ledger if it is not yet closed.
asyncOpenLedgerNoRecovery(long, AsyncCallback.OpenCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Open a ledger as an administrator without recovering the ledger.
asyncPublish(ByteString, PubSubProtocol.Message, Callback<Void>, Object) - Method in interface org.apache.hedwig.client.api.Publisher
Publishes a message asynchronously on the given topic.
asyncPublishWithResponse(ByteString, PubSubProtocol.Message, Callback<PubSubProtocol.PublishResponse>, Object) - Method in interface org.apache.hedwig.client.api.Publisher
Publishes a message asynchronously on the given topic.
asyncReadEntries(long, long, AsyncCallback.ReadCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle
Read a sequence of entries asynchronously.
asyncReadLastConfirmed(AsyncCallback.ReadLastConfirmedCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle
Obtains asynchronously the last confirmed write from a quorum of bookies.
asyncRecoverBookieData(BookieSocketAddress, BookieSocketAddress, AsyncCallback.RecoverCallback, Object) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Async method to rebuild and recover the ledger fragments data that was stored on the source bookie.
asyncSubscribe(ByteString, ByteString, PubSubProtocol.SubscribeRequest.CreateOrAttach, Callback<Void>, Object) - Method in interface org.apache.hedwig.client.api.Subscriber
asyncSubscribe(ByteString, ByteString, PubSubProtocol.SubscriptionOptions, Callback<Void>, Object) - Method in interface org.apache.hedwig.client.api.Subscriber
Subscribe to the given topic asynchronously for the inputted subscriberId.
asyncTryReadLastConfirmed(AsyncCallback.ReadLastConfirmedCallback, Object) - Method in class org.apache.bookkeeper.client.LedgerHandle
Obtains asynchronously the last confirmed write from a quorum of bookies.
asyncUnsubscribe(ByteString, ByteString, Callback<Void>, Object) - Method in interface org.apache.hedwig.client.api.Subscriber
Unsubscribe from a topic asynchronously that the subscriberId user has previously subscribed to.
ATTACH_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.CreateOrAttach
 
AUDITOR_PERIODIC_BOOKIE_CHECK_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
AUDITOR_PERIODIC_CHECK_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
AUTO_RECOVERY_DAEMON_ENABLED - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
AUTO_SEND_CONSUME_MESSAGE_ENABLED - Static variable in class org.apache.hedwig.client.conf.ClientConfiguration
 
AVAILABLE_NODE - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
availableBookiesChanged() - Method in interface org.apache.bookkeeper.client.BookiesListener
 
await(CyclicBarrier) - Static method in class org.apache.hedwig.util.ConcurrencyUtils
 

B

BAD_VERSION_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode
 
BKException - Exception in org.apache.bookkeeper.client
Class the enumerates all the possible error conditions
BKException.BKBookieException - Exception in org.apache.bookkeeper.client
 
BKException.BKBookieException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKBookieException
 
BKException.BKBookieHandleNotAvailableException - Exception in org.apache.bookkeeper.client
 
BKException.BKBookieHandleNotAvailableException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKBookieHandleNotAvailableException
 
BKException.BKClientClosedException - Exception in org.apache.bookkeeper.client
 
BKException.BKClientClosedException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKClientClosedException
 
BKException.BKDigestMatchException - Exception in org.apache.bookkeeper.client
 
BKException.BKDigestMatchException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKDigestMatchException
 
BKException.BKDigestNotInitializedException - Exception in org.apache.bookkeeper.client
 
BKException.BKDigestNotInitializedException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKDigestNotInitializedException
 
BKException.BKIllegalOpException - Exception in org.apache.bookkeeper.client
 
BKException.BKIllegalOpException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKIllegalOpException
 
BKException.BKIncorrectParameterException - Exception in org.apache.bookkeeper.client
 
BKException.BKIncorrectParameterException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKIncorrectParameterException
 
BKException.BKInterruptedException - Exception in org.apache.bookkeeper.client
 
BKException.BKInterruptedException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKInterruptedException
 
BKException.BKLedgerClosedException - Exception in org.apache.bookkeeper.client
 
BKException.BKLedgerClosedException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKLedgerClosedException
 
BKException.BKLedgerFencedException - Exception in org.apache.bookkeeper.client
 
BKException.BKLedgerFencedException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKLedgerFencedException
 
BKException.BKLedgerRecoveryException - Exception in org.apache.bookkeeper.client
 
BKException.BKLedgerRecoveryException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKLedgerRecoveryException
 
BKException.BKMetadataVersionException - Exception in org.apache.bookkeeper.client
 
BKException.BKMetadataVersionException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKMetadataVersionException
 
BKException.BKNoSuchEntryException - Exception in org.apache.bookkeeper.client
 
BKException.BKNoSuchEntryException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKNoSuchEntryException
 
BKException.BKNoSuchLedgerExistsException - Exception in org.apache.bookkeeper.client
 
BKException.BKNoSuchLedgerExistsException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKNoSuchLedgerExistsException
 
BKException.BKNotEnoughBookiesException - Exception in org.apache.bookkeeper.client
 
BKException.BKNotEnoughBookiesException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKNotEnoughBookiesException
 
BKException.BKProtocolVersionException - Exception in org.apache.bookkeeper.client
 
BKException.BKProtocolVersionException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKProtocolVersionException
 
BKException.BKQuorumException - Exception in org.apache.bookkeeper.client
 
BKException.BKQuorumException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKQuorumException
 
BKException.BKReadException - Exception in org.apache.bookkeeper.client
 
BKException.BKReadException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKReadException
 
BKException.BKReplicationException - Exception in org.apache.bookkeeper.client
 
BKException.BKReplicationException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKReplicationException
 
BKException.BKUnauthorizedAccessException - Exception in org.apache.bookkeeper.client
 
BKException.BKUnauthorizedAccessException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKUnauthorizedAccessException
 
BKException.BKUnclosedFragmentException - Exception in org.apache.bookkeeper.client
 
BKException.BKUnclosedFragmentException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKUnclosedFragmentException
 
BKException.BKUnexpectedConditionException - Exception in org.apache.bookkeeper.client
 
BKException.BKUnexpectedConditionException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKUnexpectedConditionException
 
BKException.BKWriteException - Exception in org.apache.bookkeeper.client
 
BKException.BKWriteException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKWriteException
 
BKException.BKWriteOnReadOnlyBookieException - Exception in org.apache.bookkeeper.client
 
BKException.BKWriteOnReadOnlyBookieException() - Constructor for exception org.apache.bookkeeper.client.BKException.BKWriteOnReadOnlyBookieException
 
BKException.Code - Interface in org.apache.bookkeeper.client
List of return codes
BKException.MetaStoreException - Exception in org.apache.bookkeeper.client
 
BKException.MetaStoreException() - Constructor for exception org.apache.bookkeeper.client.BKException.MetaStoreException
 
BKException.ZKException - Exception in org.apache.bookkeeper.client
 
BKException.ZKException() - Constructor for exception org.apache.bookkeeper.client.BKException.ZKException
 
BODY_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
BOOKIE_PORT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
bookieClient - Variable in class org.apache.bookkeeper.client.LedgerChecker
 
BookieHandleNotAvailableException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
BookiesListener - Interface in org.apache.bookkeeper.client
Listener for the the available bookies changes.
BookKeeper - Class in org.apache.bookkeeper.client
BookKeeper client.
BookKeeper(String) - Constructor for class org.apache.bookkeeper.client.BookKeeper
Create a bookkeeper client.
BookKeeper(ClientConfiguration) - Constructor for class org.apache.bookkeeper.client.BookKeeper
Create a bookkeeper client using a configuration object.
BookKeeper(ClientConfiguration, ZooKeeper) - Constructor for class org.apache.bookkeeper.client.BookKeeper
Create a bookkeeper client but use the passed in zookeeper client instead of instantiating one.
BookKeeper(ClientConfiguration, ZooKeeper, ClientSocketChannelFactory) - Constructor for class org.apache.bookkeeper.client.BookKeeper
Create a bookkeeper client but use the passed in zookeeper client and client socket channel factory instead of instantiating those.
BookKeeper.Builder - Class in org.apache.bookkeeper.client
 
BookKeeper.DigestType - Enum in org.apache.bookkeeper.client
There are 2 digest types that can be used for verification.
BookKeeperAdmin - Class in org.apache.bookkeeper.client
Admin client for BookKeeper clusters
BookKeeperAdmin(String) - Constructor for class org.apache.bookkeeper.client.BookKeeperAdmin
Constructor that takes in a ZooKeeper servers connect string so we know how to connect to ZooKeeper to retrieve information about the BookKeeper cluster.
BookKeeperAdmin(ClientConfiguration) - Constructor for class org.apache.bookkeeper.client.BookKeeperAdmin
Constructor that takes in a configuration object so we know how to connect to ZooKeeper to retrieve information about the BookKeeper cluster.
BookKeeperAdmin(BookKeeper) - Constructor for class org.apache.bookkeeper.client.BookKeeperAdmin
Constructor that takes in a BookKeeper instance .
BookKeeperClientStats - Interface in org.apache.bookkeeper.client
 
build() - Method in class org.apache.bookkeeper.client.BookKeeper.Builder
 
build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest.Builder
 
build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
 
build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
 
build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData.Builder
 
build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
 
build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
 
build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
 
build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
 
build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
 
build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
 
build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
 
build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder
 
build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder
 
build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
 
build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
 
build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse.Builder
 
build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
 
build() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder
 
buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest.Builder
 
buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
 
buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
 
buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData.Builder
 
buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
 
buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
 
buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
 
buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
 
buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
 
buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
 
buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
 
buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder
 
buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder
 
buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
 
buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
 
buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse.Builder
 
buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
 
buildPartial() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder
 

C

Callback<T> - Interface in org.apache.hedwig.util
This class is used for callbacks for asynchronous operations
CallbackUtils - Class in org.apache.hedwig.util
 
CallbackUtils() - Constructor for class org.apache.hedwig.util.CallbackUtils
 
CHANNEL_ADD_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
CHANNEL_READ_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
CHANNEL_SCOPE - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
CHANNEL_TIMEOUT_ADD - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
CHANNEL_TIMEOUT_READ - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
checkLedger(LedgerHandle, BookkeeperInternalCallbacks.GenericCallback<Set<LedgerFragment>>) - Method in class org.apache.bookkeeper.client.LedgerChecker
Check that all the fragments in the passed in ledger, and report those which are missing.
clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest.Builder
 
clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
 
clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
 
clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData.Builder
 
clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
 
clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
 
clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
 
clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
 
clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
 
clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
 
clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
 
clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder
 
clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder
 
clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
 
clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
 
clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse.Builder
 
clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
 
clear() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder
 
clearBody() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
clearCloseSubscriptionRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
clearConsumeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
clearCreateOrAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
clearCreateOrAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
clearCzxid() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
 
clearEnableResubscribe() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
clearEndSeqIdIncluded() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
 
clearEntries() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
clearEvent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse.Builder
 
clearForceAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
clearForceAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
clearHeader() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
clearHostname() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
 
clearKey() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
 
clearLedgerId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
 
clearLocalComponent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
clearManagerImpl() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
 
clearManagerVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
 
clearMessage() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
clearMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
clearMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
clearMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
clearMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
 
clearMessageFilter() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
clearMessageFilter() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
clearMessageType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
 
clearMessageWindowSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
clearMessageWindowSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
clearMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
 
clearMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
 
clearMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
clearMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
 
clearNumTopics() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData.Builder
 
clearOptions() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
clearOptions() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
clearPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
clearPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
 
clearPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
 
clearProperties() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
 
clearProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
clearProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
clearPublishedMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
 
clearPublishRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
clearPublishResponse() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
clearRanges() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
clearRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
 
clearRemoteComponents() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
clearResponseBody() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
clearSeqId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
 
clearShouldClaim() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
clearSrcRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
clearStartDeliveryRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
clearStartSeqIdIncluded() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
 
clearState() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
 
clearStatusCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
clearStatusMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
clearStopDeliveryRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
clearSubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
clearSubscribeResponse() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
clearSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest.Builder
 
clearSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
 
clearSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
clearSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder
 
clearSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder
 
clearSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
clearSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder
 
clearSubscriptionEvent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
clearSynchronous() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
clearTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
clearTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
clearTriedServers() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
clearTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
clearTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
clearType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
clearUnsubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
clearValue() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
 
Client - Interface in org.apache.hedwig.client.api
Interface defining the client API for Hedwig
CLIENT_ALREADY_SUBSCRIBED_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode
 
CLIENT_CONNECT_TIMEOUT_MILLIS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
CLIENT_NOT_SUBSCRIBED_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode
 
CLIENT_RECEIVEBUFFER_SIZE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
CLIENT_SCOPE - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
CLIENT_SENDBUFFER_SIZE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
CLIENT_TCP_NODELAY - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
CLIENT_WRITEBUFFER_HIGH_WATER_MARK - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
CLIENT_WRITEBUFFER_LOW_WATER_MARK - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
ClientClosedException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
ClientConfiguration - Class in org.apache.bookkeeper.conf
Configuration settings for client side
ClientConfiguration() - Constructor for class org.apache.bookkeeper.conf.ClientConfiguration
Construct a default client-side configuration
ClientConfiguration(AbstractConfiguration) - Constructor for class org.apache.bookkeeper.conf.ClientConfiguration
Construct a client-side configuration using a base configuration
ClientConfiguration - Class in org.apache.hedwig.client.conf
 
ClientConfiguration() - Constructor for class org.apache.hedwig.client.conf.ClientConfiguration
 
clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest.Builder
 
clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
 
clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
 
clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData.Builder
 
clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
 
clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
 
clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
 
clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
 
clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
 
clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
 
clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
 
clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder
 
clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder
 
clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
 
clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
 
clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse.Builder
 
clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
 
clone() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder
 
close() - Method in class org.apache.bookkeeper.client.BookKeeper
Shuts down client.
close() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Gracefully release resources that this client uses.
close() - Method in class org.apache.bookkeeper.client.LedgerHandle
Close this ledger synchronously.
close() - Method in interface org.apache.hedwig.client.api.Client
Close the client and free all associated resources.
close() - Method in class org.apache.hedwig.client.HedwigClient
 
closeComplete(int, LedgerHandle, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.CloseCallback
Callback definition
closeSubscription(ByteString, ByteString) - Method in interface org.apache.hedwig.client.api.Subscriber
Closes all of the client side cached data for this subscription without actually sending an unsubscribe request to the server.
CLOSESUBSCRIPTION_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType
 
CLOSESUBSCRIPTIONREQUEST_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
code - Variable in exception org.apache.hedwig.exceptions.PubSubException
 
COLON - Static variable in class org.apache.hedwig.util.HedwigSocketAddress
 
COMPACTION_MAX_OUTSTANDING_REQUESTS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
COMPACTION_RATE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
COMPOSITE_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode
 
ConcurrencyUtils - Class in org.apache.hedwig.util
 
ConcurrencyUtils() - Constructor for class org.apache.hedwig.util.ConcurrencyUtils
 
Configurable - Interface in org.apache.bookkeeper.conf
Class that may be configured with a Configuration.
consume(ByteString, ByteString, PubSubProtocol.MessageSeqId) - Method in interface org.apache.hedwig.client.api.Subscriber
Manually send a consume message to the server for the given inputs.
CONSUME_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType
 
CONSUMED_MESSAGES_BUFFER_SIZE - Static variable in class org.apache.hedwig.client.conf.ClientConfiguration
 
CONSUMEREQUEST_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
COULD_NOT_CONNECT_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode
 
create(int) - Static method in exception org.apache.bookkeeper.client.BKException
Create an exception from an error code
create(PubSubProtocol.StatusCode, String) - Static method in exception org.apache.hedwig.exceptions.PubSubException
 
CREATE_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
CREATE_OR_ATTACH_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.CreateOrAttach
 
CREATE_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.CreateOrAttach
 
createComplete(int, LedgerHandle, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.CreateCallback
Declaration of callback method
createLedger(BookKeeper.DigestType, byte[]) - Method in class org.apache.bookkeeper.client.BookKeeper
Creates a new ledger.
createLedger(int, int, BookKeeper.DigestType, byte[]) - Method in class org.apache.bookkeeper.client.BookKeeper
Synchronous call to create ledger.
createLedger(int, int, int, BookKeeper.DigestType, byte[]) - Method in class org.apache.bookkeeper.client.BookKeeper
Synchronous call to create ledger.
CREATEORATTACH_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
CREATEORATTACH_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
createTempDirectory(String) - Static method in class org.apache.hedwig.util.FileUtils
 
createTempDirectory(String, String) - Static method in class org.apache.hedwig.util.FileUtils
 
CURRENT_METADATA_FORMAT_VERSION - Static variable in class org.apache.bookkeeper.client.LedgerMetadata
 
curry(Callback<T>, T) - Static method in class org.apache.hedwig.util.CallbackUtils
Return a Callback that just calls the given Callback cb with the bound result.
CZXID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
 

D

DEATH_WATCH_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
DEFAULT_SERVER_HOST - Static variable in class org.apache.hedwig.client.conf.ClientConfiguration
 
DefaultEnsemblePlacementPolicy - Class in org.apache.bookkeeper.client
Default Ensemble Placement Policy, which picks bookies randomly
DefaultEnsemblePlacementPolicy() - Constructor for class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy
 
defaultLoader - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
DELETE_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
deleteComplete(int, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.DeleteCallback
Callback definition for delete operations
deleteLedger(long) - Method in class org.apache.bookkeeper.client.BookKeeper
Synchronous call to delete a ledger.
deliver(ByteString, ByteString, PubSubProtocol.Message, Callback<Void>, Object) - Method in interface org.apache.hedwig.client.api.MessageHandler
Delivers a message which has been published for topic.
DIGEST_TYPE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
DigestMatchException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
DigestNotInitializedException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
DISK_CHECK_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
DISK_USAGE_THRESHOLD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
DISK_USAGE_WARN_THRESHOLD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 

E

Either<T,U> - Class in org.apache.hedwig.util
 
ENABLE_STATISTICS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
ENABLERESUBSCRIBE_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
ENDSEQIDINCLUDED_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
 
ENSEMBLE_CHANGES - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
ENSEMBLE_PLACEMENT_POLICY - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
EnsemblePlacementPolicy - Interface in org.apache.bookkeeper.client
Encapsulation of the algorithm that selects a number of bookies from the cluster as an ensemble for storing data, based on the data input as well as the node properties.
ENTRIES_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.Map
 
ENTRY_LOG_FILE_PREALLOCATION_ENABLED - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
ENTRY_LOG_SIZE_LIMIT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
equals(Object) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode
 
equals(Object) - Method in class org.apache.hedwig.util.HedwigSocketAddress
 
EVENT_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
 

F

FileUtils - Class in org.apache.hedwig.util
 
FileUtils() - Constructor for class org.apache.hedwig.util.FileUtils
 
first() - Method in class org.apache.hedwig.util.Pair
 
FLUSH_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
FORCEATTACH_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
FORCEATTACH_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
forConfig(ClientConfiguration) - Static method in class org.apache.bookkeeper.client.BookKeeper
 
format(ClientConfiguration, boolean, boolean) - Static method in class org.apache.bookkeeper.client.BookKeeperAdmin
Format the BookKeeper metadata in zookeeper

G

GC_WAIT_TIME - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
get() - Method in class org.apache.hedwig.util.Option
 
getAckQuorumSize() - Method in class org.apache.bookkeeper.client.LedgerMetadata
 
getAddEntryTimeout() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the timeout for add request.
getAddr() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode
 
getAddress() - Method in class org.apache.bookkeeper.client.LedgerFragment
Gets the failedBookie address
getAllowLoopback() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Is the bookie allowed to use a loopback interface as its primary interface(i.e.
getAuditorPeriodicBookieCheckInterval() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the interval between auditor bookie check runs.
getAuditorPeriodicCheckInterval() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the regularity at which the auditor checks all ledgers.
getAvailableBookies() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Get a list of the available bookies.
getBody() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
getBody() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
getBody() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageOrBuilder
 
getBookiePort() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get bookie port that bookie server listen on
getBookieRecoveryDigestType() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get digest type used in bookkeeper admin
getBookieRecoveryPasswd() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get passwd used in bookkeeper admin
getBookiesIndex() - Method in class org.apache.bookkeeper.client.LedgerFragment
Gets the failedBookie index
getClientConnectTimeoutMillis() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get client netty connect timeout in millis.
getClientReceiveBufferSize() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get client netty channel receive buffer size.
getClientSendBufferSize() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get client netty channel send buffer size.
getClientTcpNoDelay() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Is tcp connection no delay.
getClientWriteBufferHighWaterMark() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get client netty channel write buffer high water mark.
getClientWriteBufferLowWaterMark() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get client netty channel write buffer low water mark.
getCloseSubscriptionRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getCloseSubscriptionRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
getCloseSubscriptionRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
getCloseSubscriptionRequestBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getCloseSubscriptionRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getCloseSubscriptionRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
getCloseSubscriptionRequestOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
getCode() - Method in exception org.apache.bookkeeper.client.BKException
 
getCode() - Method in exception org.apache.hedwig.exceptions.PubSubException
 
getCompactionMaxOutstandingRequests() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the maximum number of entries which can be compacted without flushing.
getCompactionRate() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the rate of compaction adds.
getConf() - Method in class org.apache.bookkeeper.client.BookKeeper
 
getConf() - Method in interface org.apache.bookkeeper.conf.Configurable
Return the configuration used by this object.
getConsumedMessagesBufferSize() - Method in class org.apache.hedwig.client.conf.ClientConfiguration
 
getConsumeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getConsumeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
getConsumeRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
getConsumeRequestBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getConsumeRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getConsumeRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
getConsumeRequestOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
getCreateOrAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
getCreateOrAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
getCreateOrAttach() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
 
getCreateOrAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
getCreateOrAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
getCreateOrAttach() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
 
getCzxid() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
 
getCzxid() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
 
getCzxid() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.HubInfoDataOrBuilder
 
getDeathWatchInterval() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get bookie death watch interval
getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
 
getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
 
getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
 
getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
 
getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
 
getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
 
getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
 
getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
 
getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map
 
getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
 
getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
 
getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
 
getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
 
getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
 
getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest
 
getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest
 
getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
 
getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
 
getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
 
getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
 
getDefaultInstance() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest.Builder
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData.Builder
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse.Builder
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder
 
getDefaultInstanceForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest
 
getDefaultServerHedwigSocketAddress() - Method in class org.apache.hedwig.client.conf.ClientConfiguration
 
getDefaultServerHost() - Method in class org.apache.hedwig.client.conf.ClientConfiguration
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest.Builder
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData.Builder
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
 
getDescriptor() - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType
 
getDescriptor() - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.ProtocolVersion
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest
 
getDescriptor() - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
getDescriptor() - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.CreateOrAttach
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
 
getDescriptor() - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEvent
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse.Builder
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder
 
getDescriptor() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest
 
getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest.Builder
 
getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
 
getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
 
getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData.Builder
 
getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
 
getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
 
getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
 
getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
 
getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
getDescriptorForType() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType
 
getDescriptorForType() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.ProtocolVersion
 
getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
 
getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
 
getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
 
getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder
 
getDescriptorForType() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode
 
getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder
 
getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
getDescriptorForType() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.CreateOrAttach
 
getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
 
getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
 
getDescriptorForType() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEvent
 
getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse.Builder
 
getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
 
getDescriptorForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder
 
getDiskCheckInterval() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the disk checker interval
getDiskUsageThreshold() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Returns disk free space threshold.
getDiskUsageWarnThreshold() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Returns the warning threshold for disk usage.
getEnableResubscribe() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
getEnableResubscribe() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
getEnableResubscribe() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
 
getEndSeqIdIncluded() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
 
getEndSeqIdIncluded() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
 
getEndSeqIdIncluded() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.LedgerRangeOrBuilder
 
getEndSeqIdIncludedBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
 
getEndSeqIdIncludedOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
 
getEndSeqIdIncludedOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
 
getEndSeqIdIncludedOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.LedgerRangeOrBuilder
 
getEnsemble() - Method in class org.apache.bookkeeper.client.LedgerFragment
Gets the ensemble of fragment
getEnsemblePlacementPolicy() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get Ensemble Placement Policy Class.
getEnsembles() - Method in class org.apache.bookkeeper.client.LedgerMetadata
Get the Map of bookie ensembles for the various ledger fragments that make up the ledger.
getEnsembleSize() - Method in class org.apache.bookkeeper.client.LedgerMetadata
 
getEntries(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
getEntries(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map
 
getEntries(int) - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MapOrBuilder
 
getEntriesBuilder(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
getEntriesBuilderList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
getEntriesCount() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
getEntriesCount() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map
 
getEntriesCount() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MapOrBuilder
 
getEntriesList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
getEntriesList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map
 
getEntriesList() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MapOrBuilder
 
getEntriesOrBuilder(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
getEntriesOrBuilder(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map
 
getEntriesOrBuilder(int) - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MapOrBuilder
 
getEntriesOrBuilderList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
getEntriesOrBuilderList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map
 
getEntriesOrBuilderList() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MapOrBuilder
 
getEntry() - Method in class org.apache.bookkeeper.client.LedgerEntry
 
getEntryId() - Method in class org.apache.bookkeeper.client.LedgerEntry
 
getEntryInputStream() - Method in class org.apache.bookkeeper.client.LedgerEntry
 
getEntryLogSizeLimit() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get entry logger size limitation
getEvent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse.Builder
 
getEvent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
 
getEvent() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponseOrBuilder
 
getExceptions() - Method in exception org.apache.hedwig.exceptions.PubSubException.CompositeException
 
getFirstStoredEntryId() - Method in class org.apache.bookkeeper.client.LedgerFragment
Gets the first stored entry id of the fragment in failed bookie.
getFlushInterval() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get flush interval
getForceAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
getForceAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
getForceAttach() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
 
getForceAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
getForceAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
getForceAttach() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
 
getGcWaitTime() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get Garbage collection wait time
getHeader() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
getHeader() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
getHeader() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageOrBuilder
 
getHeaderBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
getHeaderOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
getHeaderOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
getHeaderOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageOrBuilder
 
getHostname() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
 
getHostname() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
 
getHostname() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.HubInfoDataOrBuilder
 
getHostname() - Method in class org.apache.hedwig.util.HedwigSocketAddress
 
getId() - Method in class org.apache.bookkeeper.client.LedgerHandle
Get the id of the current ledger
getIndexDirNames() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get dir name to store index files.
getIndexDirs() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get index dir to store ledger index files.
getJournalAdaptiveGroupWrites() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Should we group journal force writes
getJournalAlignmentSize() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
All the journal writes and commits should be aligned to given size.
getJournalBufferedEntriesThreshold() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Maximum entries to buffer to impose on a journal write to achieve grouping.
getJournalBufferedWritesThreshold() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Maximum bytes to buffer to impose on a journal write to achieve grouping
getJournalDir() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get dir to store journal files
getJournalDirName() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get dir name to store journal files
getJournalFlushWhenQueueEmpty() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Should we flush the journal when queue is empty
getJournalFormatVersionToWrite() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get journal format version to write.
getJournalMaxGroupWaitMSec() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Maximum latency to impose on a journal write to achieve grouping
getJournalPreAllocSizeMB() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
How much space should we pre-allocate at a time in the journal
getJournalRemovePagesFromCache() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Should we remove pages from page cache after force write
getJournalWriteBufferSizeKB() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Size of the write buffers used for the journal
getKey() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
 
getKey() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
 
getKey() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.Map.EntryOrBuilder
 
getLastAddConfirmed() - Method in class org.apache.bookkeeper.client.LedgerHandle
Get the last confirmed entry id on this ledger.
getLastAddPushed() - Method in class org.apache.bookkeeper.client.LedgerHandle
Get the entry id of the last entry that has been enqueued for addition (but may not have possibly been persited to the ledger)
getLastEntryId() - Method in class org.apache.bookkeeper.client.LedgerMetadata
 
getLastStoredEntryId() - Method in class org.apache.bookkeeper.client.LedgerFragment
Gets the last stored entry id of the fragment in failed bookie.
getLedgerDirNames() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get dir names to store ledger data
getLedgerDirs() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get dirs that stores ledger data
getLedgerId() - Method in class org.apache.bookkeeper.client.LedgerEntry
 
getLedgerId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
 
getLedgerId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
 
getLedgerId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.LedgerRangeOrBuilder
 
getLedgerKey() - Method in class org.apache.bookkeeper.client.LedgerHandle
Get the Ledger's key/password.
getLedgerManagerFactoryClass() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get ledger manager factory class.
getLedgerManagerType() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
getLedgerMetadata(LedgerHandle) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
 
getLength() - Method in class org.apache.bookkeeper.client.LedgerEntry
 
getLength() - Method in class org.apache.bookkeeper.client.LedgerHandle
Returns the length of the ledger in bytes.
getLength() - Method in class org.apache.bookkeeper.client.LedgerMetadata
 
getLevel() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode
 
getListeningInterface() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the network interface that the bookie should listen for connections on.
getLocalComponent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
getLocalComponent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
 
getLocalComponent() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageSeqIdOrBuilder
 
getMajorCompactionInterval() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get interval to run major compaction, in seconds.
getMajorCompactionThreshold() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get threshold of major compaction.
getManagerImpl() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
 
getManagerImpl() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
 
getManagerImpl() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ManagerMetaOrBuilder
 
getManagerVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
 
getManagerVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
 
getManagerVersion() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ManagerMetaOrBuilder
 
getMaxBackupJournals() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Max number of older journal files kept
getMaximumMessageSize() - Method in class org.apache.hedwig.client.conf.ClientConfiguration
 
getMaximumOutstandingMessages() - Method in class org.apache.hedwig.client.conf.ClientConfiguration
 
getMaximumServerRedirects() - Method in class org.apache.hedwig.client.conf.ClientConfiguration
 
getMaxJournalSizeMB() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Max journal file size
getMessage(int) - Static method in exception org.apache.bookkeeper.client.BKException
 
getMessage() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
getMessage() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
getMessage() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
 
getMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
getMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
getMessageBound() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
 
getMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
getMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
getMessageBound() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
 
getMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
getMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
getMessageBound() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferencesOrBuilder
 
getMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
 
getMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
 
getMessageBound() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionStateOrBuilder
 
getMessageBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
getMessageConsumeRetryWaitTime() - Method in class org.apache.hedwig.client.conf.ClientConfiguration
 
getMessageFilter() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
getMessageFilter() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
getMessageFilter() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
 
getMessageFilter() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
getMessageFilter() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
getMessageFilter() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferencesOrBuilder
 
getMessageOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
getMessageOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
getMessageOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
 
getMessageType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
 
getMessageType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
 
getMessageType() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageHeaderOrBuilder
 
getMessageWindowSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
getMessageWindowSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
getMessageWindowSize() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
 
getMessageWindowSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
getMessageWindowSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
getMessageWindowSize() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferencesOrBuilder
 
getMetastoreImplClass() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get metastore implementation class.
getMetastoreMaxEntriesPerScan() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get max entries per scan in metastore.
getMinorCompactionInterval() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get interval to run minor compaction, in seconds.
getMinorCompactionThreshold() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get threshold of minor compaction.
getMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
 
getMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
 
getMsg() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PublishRequestOrBuilder
 
getMsgBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
 
getMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
 
getMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
 
getMsgId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequestOrBuilder
 
getMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
getMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
getMsgId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageOrBuilder
 
getMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
 
getMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
 
getMsgId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionStateOrBuilder
 
getMsgIdBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
 
getMsgIdBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
getMsgIdBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
 
getMsgIdOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
 
getMsgIdOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
 
getMsgIdOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequestOrBuilder
 
getMsgIdOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
getMsgIdOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
getMsgIdOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageOrBuilder
 
getMsgIdOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
 
getMsgIdOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
 
getMsgIdOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionStateOrBuilder
 
getMsgOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
 
getMsgOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
 
getMsgOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PublishRequestOrBuilder
 
getName() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode
 
getNetworkLocation() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode
 
getNumAddWorkerThreads() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the number of threads that should handle write requests.
getNumber() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType
 
getNumber() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.ProtocolVersion
 
getNumber() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode
 
getNumber() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.CreateOrAttach
 
getNumber() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEvent
 
getNumChannelsPerBookie() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get num channels per bookie.
getNumJournalCallbackThreads() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the number of threads that should handle journal callbacks.
getNumReadWorkerThreads() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the number of threads that should handle read requests.
getNumTopics() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData.Builder
 
getNumTopics() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
 
getNumTopics() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.HubLoadDataOrBuilder
 
getNumWorkerThreads() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the number of worker threads.
getOpenFileLimit() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get open file limit
getOpenLedgerRereplicationGracePeriod() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the grace period which the rereplication worker to wait before fencing and rereplicating a ledger fragment which is still being written to, on bookie failure.
getOptions() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
getOptions() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
getOptions() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
 
getOptions() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
getOptions() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
getOptions() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferencesOrBuilder
 
getOptionsBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
getOptionsBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
getOptionsOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
getOptionsOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
getOptionsOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
 
getOptionsOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
getOptionsOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
getOptionsOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferencesOrBuilder
 
getPageLimit() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get limitation number of index pages in ledger cache
getPageSize() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get page size
getParent() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode
 
getPCBCTimeoutTimerNumTicks() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get number of ticks that used for HashedWheelTimer that used by PCBC to timeout requests.
getPCBCTimeoutTimerTickDurationMs() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the tick duration in milliseconds that used for the HashedWheelTimer that used by PCBC to timeout requests.
getPort() - Method in class org.apache.hedwig.util.HedwigSocketAddress
 
getPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
getPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
getPreferences() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
 
getPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
 
getPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
 
getPreferences() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponseOrBuilder
 
getPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
 
getPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
 
getPreferences() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionDataOrBuilder
 
getPreferencesBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
getPreferencesBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
 
getPreferencesBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
 
getPreferencesOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
getPreferencesOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
getPreferencesOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
 
getPreferencesOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
 
getPreferencesOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
 
getPreferencesOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponseOrBuilder
 
getPreferencesOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
 
getPreferencesOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
 
getPreferencesOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionDataOrBuilder
 
getProperties() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
 
getProperties() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
 
getProperties() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageHeaderOrBuilder
 
getPropertiesBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
 
getPropertiesOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
 
getPropertiesOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
 
getPropertiesOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageHeaderOrBuilder
 
getProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
getProtocolVersion() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
getProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
getProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
getProtocolVersion() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
 
getPublishedMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
 
getPublishedMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
 
getPublishedMsgId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PublishResponseOrBuilder
 
getPublishedMsgIdBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
 
getPublishedMsgIdOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
 
getPublishedMsgIdOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
 
getPublishedMsgIdOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PublishResponseOrBuilder
 
getPublisher() - Method in interface org.apache.hedwig.client.api.Client
Retrieve the Publisher object for the client.
getPublisher() - Method in class org.apache.hedwig.client.HedwigClient
 
getPublishRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getPublishRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
getPublishRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
getPublishRequestBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getPublishRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getPublishRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
getPublishRequestOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
getPublishResponse() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
getPublishResponse() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
getPublishResponse() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ResponseBodyOrBuilder
 
getPublishResponseBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
getPublishResponseOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
getPublishResponseOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
getPublishResponseOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ResponseBodyOrBuilder
 
getRanges(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
getRanges(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
 
getRanges(int) - Method in interface org.apache.hedwig.protocol.PubSubProtocol.LedgerRangesOrBuilder
 
getRangesBuilder(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
getRangesBuilderList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
getRangesCount() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
getRangesCount() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
 
getRangesCount() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.LedgerRangesOrBuilder
 
getRangesList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
getRangesList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
 
getRangesList() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.LedgerRangesOrBuilder
 
getRangesOrBuilder(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
getRangesOrBuilder(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
 
getRangesOrBuilder(int) - Method in interface org.apache.hedwig.protocol.PubSubProtocol.LedgerRangesOrBuilder
 
getRangesOrBuilderList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
getRangesOrBuilderList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
 
getRangesOrBuilderList() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.LedgerRangesOrBuilder
 
getReadBufferBytes() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the number of bytes we should use as capacity for org.apache.bookkeeper.bookie.BufferedReadChannel Default is 512 bytes
getReadEntryTimeout() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the timeout for read entry.
getReadOnlyBookies() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Get a list of readonly bookies
getReadTimeout() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
getRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
 
getRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
 
getRegion() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqIdOrBuilder
 
getRemoteComponents(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
getRemoteComponents(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
 
getRemoteComponents(int) - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageSeqIdOrBuilder
 
getRemoteComponentsBuilder(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
getRemoteComponentsBuilderList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
getRemoteComponentsCount() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
getRemoteComponentsCount() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
 
getRemoteComponentsCount() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageSeqIdOrBuilder
 
getRemoteComponentsList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
getRemoteComponentsList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
 
getRemoteComponentsList() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageSeqIdOrBuilder
 
getRemoteComponentsOrBuilder(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
getRemoteComponentsOrBuilder(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
 
getRemoteComponentsOrBuilder(int) - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageSeqIdOrBuilder
 
getRemoteComponentsOrBuilderList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
getRemoteComponentsOrBuilderList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
 
getRemoteComponentsOrBuilderList() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageSeqIdOrBuilder
 
getRemoteRack(RackawareEnsemblePlacementPolicy.BookieNode) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
getRereplicationEntryBatchSize() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get the re-replication entry batch size
getResponseBody() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
getResponseBody() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
getResponseBody() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
 
getResponseBodyBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
getResponseBodyOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
getResponseBodyOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
getResponseBodyOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
 
getSeqId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
 
getSeqId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
 
getSeqId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqIdOrBuilder
 
getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
 
getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
 
getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
 
getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
 
getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
 
getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
 
getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
 
getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
 
getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map
 
getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
 
getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
 
getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
 
getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
 
getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
 
getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest
 
getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest
 
getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
 
getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
 
getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
 
getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
 
getSerializedSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest
 
getServerAckResponseTimeout() - Method in class org.apache.hedwig.client.conf.ClientConfiguration
 
getServerTcpNoDelay() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Is tcp connection no delay.
getShouldClaim() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getShouldClaim() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
getShouldClaim() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
getSkipListArenaChunkSize() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the number of bytes we should use as chunk allocation for org.apache.bookkeeper.bookie.SkipListArena Default is 4 MB
getSkipListArenaMaxAllocSize() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the max size we should allocate from the skiplist arena.
getSkipListSizeLimit() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get skip list data size limitation (default 64MB)
getSocketAddress() - Method in class org.apache.hedwig.util.HedwigSocketAddress
 
getSortedLedgerStorageEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Check if sorted-ledger storage enabled (default true)
getSpeculativeReadTimeout() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get the period of time after which a speculative entry read should be triggered.
getSrcRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
getSrcRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
getSrcRegion() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageOrBuilder
 
getSSLPort() - Method in class org.apache.hedwig.util.HedwigSocketAddress
 
getSSLSocketAddress() - Method in class org.apache.hedwig.util.HedwigSocketAddress
 
getStartDeliveryRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getStartDeliveryRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
getStartDeliveryRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
getStartDeliveryRequestBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getStartDeliveryRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getStartDeliveryRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
getStartDeliveryRequestOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
getStartSeqIdIncluded() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
 
getStartSeqIdIncluded() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
 
getStartSeqIdIncluded() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.LedgerRangeOrBuilder
 
getState() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
 
getState() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
 
getState() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionDataOrBuilder
 
getStateBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
 
getStateOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
 
getStateOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
 
getStateOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionDataOrBuilder
 
getStatsProviderClass() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the stats provider used by bookie.
getStatusCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
getStatusCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
getStatusCode() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
 
getStatusMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
getStatusMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
getStatusMsg() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
 
getStopDeliveryRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getStopDeliveryRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
getStopDeliveryRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
getStopDeliveryRequestBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getStopDeliveryRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getStopDeliveryRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
getStopDeliveryRequestOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
getSubscriber() - Method in interface org.apache.hedwig.client.api.Client
Retrieve the Subscriber object for the client.
getSubscriber() - Method in class org.apache.hedwig.client.HedwigClient
 
getSubscribeReconnectRetryWaitTime() - Method in class org.apache.hedwig.client.conf.ClientConfiguration
 
getSubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getSubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
getSubscribeRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
getSubscribeRequestBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getSubscribeRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getSubscribeRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
getSubscribeRequestOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
getSubscribeResponse() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
getSubscribeResponse() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
getSubscribeResponse() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ResponseBodyOrBuilder
 
getSubscribeResponseBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
getSubscribeResponseOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
getSubscribeResponseOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
getSubscribeResponseOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ResponseBodyOrBuilder
 
getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest.Builder
 
getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
 
getSubscriberId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequestOrBuilder
 
getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
 
getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
 
getSubscriberId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequestOrBuilder
 
getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
getSubscriberId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
 
getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder
 
getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest
 
getSubscriberId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequestOrBuilder
 
getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder
 
getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest
 
getSubscriberId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequestOrBuilder
 
getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
getSubscriberId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
 
getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder
 
getSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest
 
getSubscriberId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequestOrBuilder
 
getSubscriptionEvent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
getSubscriptionEvent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
getSubscriptionEvent() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ResponseBodyOrBuilder
 
getSubscriptionEventBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
getSubscriptionEventOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
getSubscriptionEventOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
getSubscriptionEventOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ResponseBodyOrBuilder
 
getSubscriptionList(ByteString) - Method in interface org.apache.hedwig.client.api.Subscriber
Fills the input List with the subscriptions this subscriberId client is subscribed to.
getSubscriptionMessageBound() - Method in class org.apache.hedwig.client.conf.ClientConfiguration
The maximum number of messages the hub will queue for subscriptions created using this configuration.
getSynchronous() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
getSynchronous() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
getSynchronous() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
 
getThrottleValue() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get throttle value
getTimeoutTaskIntervalMillis() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Deprecated.
getTimeoutThreadRunInterval() - Method in class org.apache.hedwig.client.conf.ClientConfiguration
 
getTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
getTopic() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
getTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
getTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
getTopic() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
 
getTriedServers(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getTriedServers(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
getTriedServers(int) - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
getTriedServersCount() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getTriedServersCount() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
getTriedServersCount() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
getTriedServersList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getTriedServersList() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
getTriedServersList() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
getTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
getTxnId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
getTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
getTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
getTxnId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
 
getType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
getType() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
getUnsubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getUnsubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
getUnsubscribeRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
getUnsubscribeRequestBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getUnsubscribeRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
getUnsubscribeRequestOrBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
getUnsubscribeRequestOrBuilder() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
getUseHostNameAsBookieID() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get whether bookie is using hostname for registration and in ledger metadata.
getValue() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
 
getValue() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
 
getValue() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.Map.EntryOrBuilder
 
getValueDescriptor() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType
 
getValueDescriptor() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.ProtocolVersion
 
getValueDescriptor() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode
 
getValueDescriptor() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.CreateOrAttach
 
getValueDescriptor() - Method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEvent
 
getVersion() - Method in class org.apache.bookkeeper.client.LedgerMetadata
Returns the last version.
getWriteBufferBytes() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get the number of bytes used as capacity for the write buffer.
getWriteQuorumSize() - Method in class org.apache.bookkeeper.client.LedgerMetadata
 
getZkAvailableBookiesPath() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get the node under which available bookies are stored
getZkLedgersRootPath() - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Get Zk Ledgers Root Path.
getZkServers() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get zookeeper servers to connect
getZkServers() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get zookeeper servers to connect
getZkTimeout() - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Get zookeeper timeout
getZkTimeout() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get zookeeper timeout
getZooKeeper() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Get ZooKeeper used by bookkeeper admin client.

H

hasBody() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
hasBody() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
hasBody() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageOrBuilder
 
hasCloseSubscriptionRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
hasCloseSubscriptionRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
hasCloseSubscriptionRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
hasConsumeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
hasConsumeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
hasConsumeRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
hasCreateOrAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
hasCreateOrAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
hasCreateOrAttach() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
 
hasCreateOrAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
hasCreateOrAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
hasCreateOrAttach() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
 
hasCzxid() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
 
hasCzxid() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
 
hasCzxid() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.HubInfoDataOrBuilder
 
hasEnableResubscribe() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
hasEnableResubscribe() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
hasEnableResubscribe() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
 
hasEndSeqIdIncluded() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
 
hasEndSeqIdIncluded() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
 
hasEndSeqIdIncluded() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.LedgerRangeOrBuilder
 
hasEvent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse.Builder
 
hasEvent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
 
hasEvent() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponseOrBuilder
 
hasForceAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
hasForceAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
hasForceAttach() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
 
hasForceAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
hasForceAttach() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
hasForceAttach() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
 
hashCode() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode
 
hashCode() - Method in class org.apache.hedwig.util.HedwigSocketAddress
 
hasHeader() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
hasHeader() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
hasHeader() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageOrBuilder
 
hasHostname() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
 
hasHostname() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
 
hasHostname() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.HubInfoDataOrBuilder
 
hasKey() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
 
hasKey() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
 
hasKey() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.Map.EntryOrBuilder
 
hasLedgerId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
 
hasLedgerId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
 
hasLedgerId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.LedgerRangeOrBuilder
 
hasLocalComponent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
hasLocalComponent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
 
hasLocalComponent() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageSeqIdOrBuilder
 
hasManagerImpl() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
 
hasManagerImpl() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
 
hasManagerImpl() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ManagerMetaOrBuilder
 
hasManagerVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
 
hasManagerVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
 
hasManagerVersion() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ManagerMetaOrBuilder
 
hasMessage() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
hasMessage() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
hasMessage() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
 
hasMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
hasMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
hasMessageBound() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
 
hasMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
hasMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
hasMessageBound() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
 
hasMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
hasMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
hasMessageBound() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferencesOrBuilder
 
hasMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
 
hasMessageBound() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
 
hasMessageBound() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionStateOrBuilder
 
hasMessageFilter() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
hasMessageFilter() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
hasMessageFilter() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
 
hasMessageFilter() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
hasMessageFilter() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
hasMessageFilter() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferencesOrBuilder
 
hasMessageType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
 
hasMessageType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
 
hasMessageType() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageHeaderOrBuilder
 
hasMessageWindowSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
hasMessageWindowSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
hasMessageWindowSize() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
 
hasMessageWindowSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
hasMessageWindowSize() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
hasMessageWindowSize() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferencesOrBuilder
 
hasMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
 
hasMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
 
hasMsg() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PublishRequestOrBuilder
 
hasMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
 
hasMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
 
hasMsgId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequestOrBuilder
 
hasMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
hasMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
hasMsgId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageOrBuilder
 
hasMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
 
hasMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
 
hasMsgId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionStateOrBuilder
 
hasNumTopics() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData.Builder
 
hasNumTopics() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
 
hasNumTopics() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.HubLoadDataOrBuilder
 
hasOptions() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
hasOptions() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
hasOptions() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptionsOrBuilder
 
hasOptions() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
hasOptions() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
hasOptions() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferencesOrBuilder
 
hasPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
hasPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
hasPreferences() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
 
hasPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
 
hasPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
 
hasPreferences() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponseOrBuilder
 
hasPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
 
hasPreferences() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
 
hasPreferences() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionDataOrBuilder
 
hasProperties() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
 
hasProperties() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
 
hasProperties() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageHeaderOrBuilder
 
hasProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
hasProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
hasProtocolVersion() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
hasProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
hasProtocolVersion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
hasProtocolVersion() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
 
hasPublishedMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
 
hasPublishedMsgId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
 
hasPublishedMsgId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PublishResponseOrBuilder
 
hasPublishRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
hasPublishRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
hasPublishRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
hasPublishResponse() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
hasPublishResponse() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
hasPublishResponse() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ResponseBodyOrBuilder
 
hasRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
 
hasRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
 
hasRegion() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqIdOrBuilder
 
hasResponseBody() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
hasResponseBody() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
hasResponseBody() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
 
hasSeqId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
 
hasSeqId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
 
hasSeqId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqIdOrBuilder
 
hasShouldClaim() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
hasShouldClaim() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
hasShouldClaim() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
hasSrcRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
hasSrcRegion() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
hasSrcRegion() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.MessageOrBuilder
 
hasStartDeliveryRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
hasStartDeliveryRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
hasStartDeliveryRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
hasStartSeqIdIncluded() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
 
hasStartSeqIdIncluded() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
 
hasStartSeqIdIncluded() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.LedgerRangeOrBuilder
 
hasState() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
 
hasState() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
 
hasState() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscriptionDataOrBuilder
 
hasStatusCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
hasStatusCode() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
hasStatusCode() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
 
hasStatusMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
hasStatusMsg() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
hasStatusMsg() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
 
hasStopDeliveryRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
hasStopDeliveryRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
hasStopDeliveryRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
hasSubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
hasSubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
hasSubscribeRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
hasSubscribeResponse() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
hasSubscribeResponse() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
hasSubscribeResponse() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ResponseBodyOrBuilder
 
hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest.Builder
 
hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
 
hasSubscriberId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequestOrBuilder
 
hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
 
hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
 
hasSubscriberId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequestOrBuilder
 
hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
hasSubscriberId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
 
hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder
 
hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest
 
hasSubscriberId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequestOrBuilder
 
hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder
 
hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest
 
hasSubscriberId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequestOrBuilder
 
hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
hasSubscriberId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
 
hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder
 
hasSubscriberId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest
 
hasSubscriberId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequestOrBuilder
 
hasSubscription(ByteString, ByteString) - Method in interface org.apache.hedwig.client.api.Subscriber
Checks if the subscriberId client is currently subscribed to the given topic.
hasSubscriptionEvent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
hasSubscriptionEvent() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
hasSubscriptionEvent() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.ResponseBodyOrBuilder
 
hasSynchronous() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
hasSynchronous() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
hasSynchronous() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequestOrBuilder
 
hasTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
hasTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
hasTopic() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
hasTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
hasTopic() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
hasTopic() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
 
hasTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
hasTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
hasTxnId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
hasTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
hasTxnId() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
hasTxnId() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubResponseOrBuilder
 
hasType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
hasType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
hasType() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
hasUnsubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
hasUnsubscribeRequest() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
hasUnsubscribeRequest() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.PubSubRequestOrBuilder
 
hasValue() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
 
hasValue() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
 
hasValue() - Method in interface org.apache.hedwig.protocol.PubSubProtocol.Map.EntryOrBuilder
 
HEADER_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
HedwigClient - Class in org.apache.hedwig.client
Hedwig client uses as starting point for all communications with the Hedwig service.
HedwigClient(ClientConfiguration) - Constructor for class org.apache.hedwig.client.HedwigClient
Construct a hedwig client object.
HedwigClient(ClientConfiguration, ChannelFactory) - Constructor for class org.apache.hedwig.client.HedwigClient
Construct a hedwig client object, using a preexisting socket factory.
HedwigSocketAddress - Class in org.apache.hedwig.util
This is a data wrapper class that is basically an InetSocketAddress with one extra piece of information for the SSL port (optional).
HedwigSocketAddress(String, int, int) - Constructor for class org.apache.hedwig.util.HedwigSocketAddress
 
HedwigSocketAddress(String, int) - Constructor for class org.apache.hedwig.util.HedwigSocketAddress
 
HedwigSocketAddress(String) - Constructor for class org.apache.hedwig.util.HedwigSocketAddress
 
HOSTNAME_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
 

I

IllegalOpException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
IncorrectParameterException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
INDEX_DIRS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
initialize(Configuration) - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy
 
initialize(Configuration) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy
Initialize the policy.
initialize(Configuration) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
instance - Static variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.EnsembleForReplacement
 
instance - Static variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.TruePredicate
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest
 
internalGetValueMap() - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType
 
internalGetValueMap() - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.ProtocolVersion
 
internalGetValueMap() - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode
 
internalGetValueMap() - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.CreateOrAttach
 
internalGetValueMap() - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEvent
 
InterruptedException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
INVALID_ENTRY_ID - Static variable in class org.apache.bookkeeper.client.LedgerHandle
Invalid entry id.
INVALID_MESSAGE_FILTER_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode
 
isAutoRecoveryDaemonEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get whether the Bookie itself can start auto-recovery service also or not
isAutoSendConsumeMessageEnabled() - Method in class org.apache.hedwig.client.conf.ClientConfiguration
 
isClosed(long) - Method in class org.apache.bookkeeper.client.BookKeeper
Check whether the ledger with identifier lId has been closed.
isClosed() - Method in class org.apache.bookkeeper.client.LedgerFragment
Returns true, if and only if the ledger fragment will never be modified by any of the clients in future, otherwise false.
isClosed() - Method in class org.apache.bookkeeper.client.LedgerHandle
Has the ledger been closed?
isClosed() - Method in class org.apache.bookkeeper.client.LedgerMetadata
 
isClosedComplete(int, boolean, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.IsClosedCallback
Callback definition for isClosed operation
isEntryLogFilePreAllocationEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Is entry log file preallocation enabled.
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest.Builder
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData.Builder
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse.Builder
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder
 
isInitialized() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest
 
isInRecovery() - Method in class org.apache.bookkeeper.client.LedgerMetadata
 
isPrefix(String, String) - Static method in class org.apache.hedwig.util.PathUtils
Return true iff prefix is a prefix of path.
isReadOnlyModeEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Get whether read-only mode is enabled.
isSSLEnabled() - Method in class org.apache.hedwig.client.conf.ClientConfiguration
 
isSSLEnabled() - Method in class org.apache.hedwig.util.HedwigSocketAddress
 
isStatisticsEnabled() - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Is statistics enabled
isSubscriptionChannelSharingEnabled() - Method in class org.apache.hedwig.client.conf.ClientConfiguration
This parameter is a boolean flag indicating if multiplexing subscription channels.

J

JOURNAL_ADAPTIVE_GROUP_WRITES - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_ALIGNMENT_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_BUFFERED_ENTRIES_THRESHOLD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_BUFFERED_WRITES_THRESHOLD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_DIR - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_FLUSH_WHEN_QUEUE_EMPTY - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_FORMAT_VERSION_TO_WRITE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_MAX_GROUP_WAIT_MSEC - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_PRE_ALLOC_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_REMOVE_FROM_PAGE_CACHE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
JOURNAL_WRITE_BUFFER_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 

K

KEY_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
 

L

LAC_UPDATE_HITS - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
LAC_UPDATE_MISSES - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
LEDGER_DIRS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
LEDGER_MANAGER_FACTORY_CLASS - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
LEDGER_MANAGER_TYPE - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
LedgerChecker - Class in org.apache.bookkeeper.client
Checks the complete ledger and finds the UnderReplicated fragments if any
LedgerChecker(BookKeeper) - Constructor for class org.apache.bookkeeper.client.LedgerChecker
 
LedgerClosedException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
LedgerEntry - Class in org.apache.bookkeeper.client
Ledger entry.
LedgerFencedException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
LedgerFragment - Class in org.apache.bookkeeper.client
Represents the entries of a segment of a ledger which are stored on a single bookie in the segments bookie ensemble.
LedgerFragmentReplicator - Class in org.apache.bookkeeper.client
This is the helper class for replicating the fragments from one bookie to another
LedgerFragmentReplicator(BookKeeper) - Constructor for class org.apache.bookkeeper.client.LedgerFragmentReplicator
 
LedgerHandle - Class in org.apache.bookkeeper.client
Ledger handle contains ledger metadata and is used to access the read and write operations to a ledger.
LEDGERID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
 
LedgerMetadata - Class in org.apache.bookkeeper.client
This class encapsulates all the ledger metadata that is persistently stored in zookeeper.
LedgerMetadata(int, int, int, BookKeeper.DigestType, byte[]) - Constructor for class org.apache.bookkeeper.client.LedgerMetadata
 
LedgerRecoveryException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
left(T) - Static method in class org.apache.hedwig.util.Either
 
left() - Method in class org.apache.hedwig.util.Either
 
LISTENING_INTERFACE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
listLedgers() - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
This method returns an iterable object for the list of ledger identifiers of the ledgers currently available.
loadConf(URL) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
You can load configurations in precedence order.
loadConf(AbstractConfiguration) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
You can load configuration from other configuration
loadConf(Configuration) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Load configuration from other configuration object
LOCALCOMPONENT_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
 
logger(Logger, String, String, Callback<T>) - Static method in class org.apache.hedwig.util.CallbackUtils
Logs what happened before continuing the callback chain.
logger(Logger, String, String) - Static method in class org.apache.hedwig.util.CallbackUtils
Logs what happened (no continuation).
LOWEST_COMPAT_METADATA_FORMAT_VERSION - Static variable in class org.apache.bookkeeper.client.LedgerMetadata
 

M

MAJOR_COMPACTION_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
MAJOR_COMPACTION_THRESHOLD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
MALFORMED_REQUEST_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode
 
MANAGERIMPL_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
 
MANAGERVERSION_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
 
MAX_BACKUP_JOURNALS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
MAX_JOURNAL_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
MAX_MESSAGE_SIZE - Static variable in class org.apache.hedwig.client.conf.ClientConfiguration
 
MAX_OUTSTANDING_MESSAGES - Static variable in class org.apache.hedwig.client.conf.ClientConfiguration
 
MAX_SERVER_REDIRECTS - Static variable in class org.apache.hedwig.client.conf.ClientConfiguration
 
mergeCloseSubscriptionRequest(PubSubProtocol.CloseSubscriptionRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
mergeConsumeRequest(PubSubProtocol.ConsumeRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
mergeEndSeqIdIncluded(PubSubProtocol.MessageSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
 
mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest.Builder
 
mergeFrom(PubSubProtocol.CloseSubscriptionRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest.Builder
 
mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
 
mergeFrom(PubSubProtocol.ConsumeRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
 
mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
 
mergeFrom(PubSubProtocol.HubInfoData) - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
 
mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData.Builder
 
mergeFrom(PubSubProtocol.HubLoadData) - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData.Builder
 
mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
 
mergeFrom(PubSubProtocol.LedgerRange) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
 
mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
mergeFrom(PubSubProtocol.LedgerRanges) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
 
mergeFrom(PubSubProtocol.ManagerMeta) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
 
mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
mergeFrom(PubSubProtocol.Map) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
 
mergeFrom(PubSubProtocol.Map.Entry) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
 
mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
mergeFrom(PubSubProtocol.Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
 
mergeFrom(PubSubProtocol.MessageHeader) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
 
mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
mergeFrom(PubSubProtocol.MessageSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
 
mergeFrom(PubSubProtocol.PublishRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
 
mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
 
mergeFrom(PubSubProtocol.PublishResponse) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
 
mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
mergeFrom(PubSubProtocol.PubSubRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
mergeFrom(PubSubProtocol.PubSubResponse) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
 
mergeFrom(PubSubProtocol.RegionSpecificSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
 
mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
mergeFrom(PubSubProtocol.ResponseBody) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder
 
mergeFrom(PubSubProtocol.StartDeliveryRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder
 
mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder
 
mergeFrom(PubSubProtocol.StopDeliveryRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder
 
mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
mergeFrom(PubSubProtocol.SubscribeRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
 
mergeFrom(PubSubProtocol.SubscribeResponse) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
 
mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
 
mergeFrom(PubSubProtocol.SubscriptionData) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
 
mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse.Builder
 
mergeFrom(PubSubProtocol.SubscriptionEventResponse) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse.Builder
 
mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
mergeFrom(PubSubProtocol.SubscriptionOptions) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
mergeFrom(PubSubProtocol.SubscriptionPreferences) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
 
mergeFrom(PubSubProtocol.SubscriptionState) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
 
mergeFrom(Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder
 
mergeFrom(PubSubProtocol.UnsubscribeRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder
 
mergeHeader(PubSubProtocol.MessageHeader) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
mergeMessage(PubSubProtocol.Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
mergeMsg(PubSubProtocol.Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
 
mergeMsgId(PubSubProtocol.MessageSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
 
mergeMsgId(PubSubProtocol.MessageSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
mergeMsgId(PubSubProtocol.MessageSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
 
mergeOptions(PubSubProtocol.Map) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
mergeOptions(PubSubProtocol.Map) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
mergePreferences(PubSubProtocol.SubscriptionPreferences) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
mergePreferences(PubSubProtocol.SubscriptionPreferences) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
 
mergePreferences(PubSubProtocol.SubscriptionPreferences) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
 
mergeProperties(PubSubProtocol.Map) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
 
mergePublishedMsgId(PubSubProtocol.MessageSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
 
mergePublishRequest(PubSubProtocol.PublishRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
mergePublishResponse(PubSubProtocol.PublishResponse) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
mergeResponseBody(PubSubProtocol.ResponseBody) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
mergeStartDeliveryRequest(PubSubProtocol.StartDeliveryRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
mergeState(PubSubProtocol.SubscriptionState) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
 
mergeStopDeliveryRequest(PubSubProtocol.StopDeliveryRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
mergeSubscribeRequest(PubSubProtocol.SubscribeRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
mergeSubscribeResponse(PubSubProtocol.SubscribeResponse) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
mergeSubscriptionEvent(PubSubProtocol.SubscriptionEventResponse) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
mergeUnsubscribeRequest(PubSubProtocol.UnsubscribeRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
MESSAGE_CONSUME_RETRY_WAIT_TIME - Static variable in class org.apache.hedwig.client.conf.ClientConfiguration
 
MESSAGE_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
MESSAGEBOUND_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
MESSAGEBOUND_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
MESSAGEBOUND_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
MESSAGEBOUND_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
 
MESSAGEFILTER_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
MESSAGEFILTER_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
MessageHandler - Interface in org.apache.hedwig.client.api
Interface to define the client handler logic to deliver messages it is subscribed to.
MESSAGETYPE_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
 
MESSAGEWINDOWSIZE_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
MESSAGEWINDOWSIZE_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
MetadataVersionException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
METASTORE_IMPL_CLASS - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
METASTORE_MAX_ENTRIES_PER_SCAN - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
MetaStoreException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
MINOR_COMPACTION_INTERVAL - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
MINOR_COMPACTION_THRESHOLD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
MSG_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
 
MSGID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
 
MSGID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
MSGID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
 
multiCallback(int, Callback<Void>, Object, Logger, String, String, Runnable) - Static method in class org.apache.hedwig.util.CallbackUtils
A callback that waits for all of a number of events to fire.
multiCallback(int, Callback<Void>, Object) - Static method in class org.apache.hedwig.util.CallbackUtils
A callback that waits for all of a number of events to fire.
multinCallback(int, Callback<Void>, Object, Runnable) - Static method in class org.apache.hedwig.util.CallbackUtils
A callback that waits for all of a number of events to fire.
myDefaultServerAddress - Variable in class org.apache.hedwig.client.conf.ClientConfiguration
 

N

newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
 
newBuilder(PubSubProtocol.CloseSubscriptionRequest) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
 
newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
 
newBuilder(PubSubProtocol.ConsumeRequest) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
 
newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
 
newBuilder(PubSubProtocol.HubInfoData) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
 
newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
 
newBuilder(PubSubProtocol.HubLoadData) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
 
newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
 
newBuilder(PubSubProtocol.LedgerRange) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
 
newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
 
newBuilder(PubSubProtocol.LedgerRanges) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
 
newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
 
newBuilder(PubSubProtocol.ManagerMeta) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
 
newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
 
newBuilder(PubSubProtocol.Map.Entry) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
 
newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map
 
newBuilder(PubSubProtocol.Map) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map
 
newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
newBuilder(PubSubProtocol.Message) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
 
newBuilder(PubSubProtocol.MessageHeader) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
 
newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
 
newBuilder(PubSubProtocol.MessageSeqId) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
 
newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
 
newBuilder(PubSubProtocol.PublishRequest) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
 
newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
 
newBuilder(PubSubProtocol.PublishResponse) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
 
newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
newBuilder(PubSubProtocol.PubSubRequest) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
newBuilder(PubSubProtocol.PubSubResponse) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
 
newBuilder(PubSubProtocol.RegionSpecificSeqId) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
 
newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
newBuilder(PubSubProtocol.ResponseBody) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest
 
newBuilder(PubSubProtocol.StartDeliveryRequest) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest
 
newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest
 
newBuilder(PubSubProtocol.StopDeliveryRequest) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest
 
newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
newBuilder(PubSubProtocol.SubscribeRequest) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
 
newBuilder(PubSubProtocol.SubscribeResponse) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
 
newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
 
newBuilder(PubSubProtocol.SubscriptionData) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
 
newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
 
newBuilder(PubSubProtocol.SubscriptionEventResponse) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
 
newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
newBuilder(PubSubProtocol.SubscriptionOptions) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
newBuilder(PubSubProtocol.SubscriptionPreferences) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
 
newBuilder(PubSubProtocol.SubscriptionState) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
 
newBuilder() - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest
 
newBuilder(PubSubProtocol.UnsubscribeRequest) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest
 
newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
 
newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
 
newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
 
newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
 
newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
 
newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
 
newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
 
newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
 
newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map
 
newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
 
newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
 
newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
 
newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
 
newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
 
newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest
 
newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest
 
newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
 
newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
 
newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
 
newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
 
newBuilderForType() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest
 
newBuilderForType(GeneratedMessage.BuilderParent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest
 
newEnsemble(int, int, Set<BookieSocketAddress>) - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy
 
newEnsemble(int, int, Set<BookieSocketAddress>) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy
Choose numBookies bookies for ensemble.
newEnsemble(int, int, Set<BookieSocketAddress>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
NO_SUBSCRIPTION_STATE_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode
 
NO_SUCH_TOPIC_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode
 
NO_TOPIC_OWNER_INFO_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode
 
NO_TOPIC_PERSISTENCE_INFO_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode
 
NoBookieAvailableException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
nop() - Static method in class org.apache.hedwig.util.CallbackUtils
A do-nothing callback.
NoSuchEntryException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
NoSuchLedgerExistsException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
NOT_RESPONSIBLE_FOR_TOPIC_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode
 
NotEnoughBookiesException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
notifyBookiesChanged(BookiesListener) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Notify when the available list of bookies changes.
NUM_ADD_WORKER_THREADS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
NUM_CHANNELS_PER_BOOKIE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
NUM_JOURNAL_CALLBACK_THREADS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
NUM_READ_WORKER_THREADS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
NUM_WORKER_THREADS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
NUMTOPICS_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
 

O

of(T, U) - Static method in class org.apache.hedwig.util.Either
 
of(T) - Static method in class org.apache.hedwig.util.Option
 
of() - Static method in class org.apache.hedwig.util.Option
 
of(T, U) - Static method in class org.apache.hedwig.util.Pair
 
OK - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
onClusterChanged(Set<BookieSocketAddress>, Set<BookieSocketAddress>) - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy
 
onClusterChanged(Set<BookieSocketAddress>, Set<BookieSocketAddress>) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy
A consistent view of the cluster (what bookies are available as writable, what bookies are available as readonly) is updated when any changes happen in the cluster.
onClusterChanged(Set<BookieSocketAddress>, Set<BookieSocketAddress>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
OPEN_FILE_LIMIT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
OPEN_LEDGER_REREPLICATION_GRACE_PERIOD - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
OPEN_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
openComplete(int, LedgerHandle, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.OpenCallback
Callback for asynchronous call to open ledger
openLedger(long, BookKeeper.DigestType, byte[]) - Method in class org.apache.bookkeeper.client.BookKeeper
Synchronous open ledger call
openLedger(long) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Open a ledger as an administrator.
openLedgerNoRecovery(long, BookKeeper.DigestType, byte[]) - Method in class org.apache.bookkeeper.client.BookKeeper
Synchronous, unsafe open ledger call
openLedgerNoRecovery(long) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Open a ledger as an administrator without recovering the ledger.
operationFailed(Object, PubSubException) - Method in interface org.apache.hedwig.util.Callback
This method is called when the operation failed due to some reason.
operationFinished(Object, T) - Method in interface org.apache.hedwig.util.Callback
This method is called when the asynchronous operation finishes
Option<T> - Class in org.apache.hedwig.util
 
Option() - Constructor for class org.apache.hedwig.util.Option
 
Option(T) - Constructor for class org.apache.hedwig.util.Option
 
OPTIONS_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
OPTIONS_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
org.apache.bookkeeper.client - package org.apache.bookkeeper.client
 
org.apache.bookkeeper.conf - package org.apache.bookkeeper.conf
 
org.apache.hedwig.client - package org.apache.hedwig.client
 
org.apache.hedwig.client.api - package org.apache.hedwig.client.api
 
org.apache.hedwig.client.conf - package org.apache.hedwig.client.conf
 
org.apache.hedwig.exceptions - package org.apache.hedwig.exceptions
 
org.apache.hedwig.protocol - package org.apache.hedwig.protocol
 
org.apache.hedwig.util - package org.apache.hedwig.util
 

P

PAGE_LIMIT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
PAGE_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
Pair<T,U> - Class in org.apache.hedwig.util
 
Pair(T, U) - Constructor for class org.apache.hedwig.util.Pair
 
parent(String) - Static method in class org.apache.hedwig.util.PathUtils
Like File.getParent but always uses the / separator.
parseConfig(byte[], Version) - Static method in class org.apache.bookkeeper.client.LedgerMetadata
Parses a given byte array and transforms into a LedgerConfig object
parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
 
parseDelimitedFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest
 
parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
 
parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
 
parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
 
parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest
 
parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
 
parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
 
parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
 
parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest
 
parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
 
parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
 
parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
 
parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData
 
parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
 
parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
 
parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
 
parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData
 
parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
 
parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
 
parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
 
parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange
 
parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
 
parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
 
parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
 
parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
 
parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
 
parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
 
parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
 
parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta
 
parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
 
parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
 
parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
 
parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry
 
parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map
 
parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map
 
parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map
 
parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Map
 
parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.Message
 
parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
 
parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
 
parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
 
parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
 
parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
 
parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
 
parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
 
parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
 
parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
 
parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
 
parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
 
parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest
 
parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
 
parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
 
parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
 
parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
 
parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
 
parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
 
parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
 
parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
 
parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest
 
parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest
 
parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest
 
parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest
 
parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest
 
parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest
 
parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest
 
parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest
 
parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
 
parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
 
parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
 
parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
 
parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
 
parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
 
parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
 
parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
 
parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
 
parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
 
parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
 
parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse
 
parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions
 
parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences
 
parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
 
parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
 
parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
 
parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState
 
parseFrom(ByteString) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest
 
parseFrom(byte[]) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest
 
parseFrom(InputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest
 
parseFrom(CodedInputStream) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest
 
PASSWD - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
PathUtils - Class in org.apache.hedwig.util
 
PathUtils() - Constructor for class org.apache.hedwig.util.PathUtils
 
PCBC_TIMEOUT_TIMER_NUM_TICKS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
PCBC_TIMEOUT_TIMER_TICK_DURATION_MS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
PENDING_ADDS - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
PREFERENCES_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest
 
PREFERENCES_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse
 
PREFERENCES_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData
 
prefixes(String) - Static method in class org.apache.hedwig.util.PathUtils
Generate all prefixes for a path.
processEvent(ByteString, ByteString, PubSubProtocol.SubscriptionEvent) - Method in interface org.apache.hedwig.util.SubscriptionListener
Process an event from a subscription.
PROPERTIES_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader
 
PROTOCOLVERSION_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
PROTOCOLVERSION_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
ProtocolVersionException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
publish(ByteString, PubSubProtocol.Message) - Method in interface org.apache.hedwig.client.api.Publisher
Publishes a message on the given topic.
PUBLISH_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType
 
PUBLISHEDMSGID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse
 
Publisher - Interface in org.apache.hedwig.client.api
Interface to define the client Publisher API.
PUBLISHREQUEST_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
PUBLISHRESPONSE_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody
 
PubSubException - Exception in org.apache.hedwig.exceptions
 
PubSubException(PubSubProtocol.StatusCode, String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException
 
PubSubException(PubSubProtocol.StatusCode, Throwable) - Constructor for exception org.apache.hedwig.exceptions.PubSubException
 
PubSubException(PubSubProtocol.StatusCode, String, Throwable) - Constructor for exception org.apache.hedwig.exceptions.PubSubException
 
PubSubException.BadVersionException - Exception in org.apache.hedwig.exceptions
 
PubSubException.BadVersionException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.BadVersionException
 
PubSubException.ClientAlreadySubscribedException - Exception in org.apache.hedwig.exceptions
 
PubSubException.ClientAlreadySubscribedException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.ClientAlreadySubscribedException
 
PubSubException.ClientNotSubscribedException - Exception in org.apache.hedwig.exceptions
 
PubSubException.ClientNotSubscribedException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.ClientNotSubscribedException
 
PubSubException.ClientNotSubscribedRuntimeException - Exception in org.apache.hedwig.exceptions
 
PubSubException.ClientNotSubscribedRuntimeException() - Constructor for exception org.apache.hedwig.exceptions.PubSubException.ClientNotSubscribedRuntimeException
 
PubSubException.CompositeException - Exception in org.apache.hedwig.exceptions
 
PubSubException.CompositeException(Collection<PubSubException>) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.CompositeException
 
PubSubException.CouldNotConnectException - Exception in org.apache.hedwig.exceptions
 
PubSubException.CouldNotConnectException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.CouldNotConnectException
 
PubSubException.InvalidMessageFilterException - Exception in org.apache.hedwig.exceptions
 
PubSubException.InvalidMessageFilterException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.InvalidMessageFilterException
 
PubSubException.InvalidMessageFilterException(String, Throwable) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.InvalidMessageFilterException
 
PubSubException.MalformedRequestException - Exception in org.apache.hedwig.exceptions
 
PubSubException.MalformedRequestException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.MalformedRequestException
 
PubSubException.NoSubscriptionStateException - Exception in org.apache.hedwig.exceptions
 
PubSubException.NoSubscriptionStateException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.NoSubscriptionStateException
 
PubSubException.NoSuchTopicException - Exception in org.apache.hedwig.exceptions
 
PubSubException.NoSuchTopicException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.NoSuchTopicException
 
PubSubException.NoTopicOwnerInfoException - Exception in org.apache.hedwig.exceptions
 
PubSubException.NoTopicOwnerInfoException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.NoTopicOwnerInfoException
 
PubSubException.NoTopicPersistenceInfoException - Exception in org.apache.hedwig.exceptions
 
PubSubException.NoTopicPersistenceInfoException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.NoTopicPersistenceInfoException
 
PubSubException.ResubscribeException - Exception in org.apache.hedwig.exceptions
 
PubSubException.ResubscribeException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.ResubscribeException
 
PubSubException.ServerNotResponsibleForTopicException - Exception in org.apache.hedwig.exceptions
 
PubSubException.ServerNotResponsibleForTopicException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.ServerNotResponsibleForTopicException
 
PubSubException.ServiceDownException - Exception in org.apache.hedwig.exceptions
 
PubSubException.ServiceDownException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.ServiceDownException
 
PubSubException.ServiceDownException(Exception) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.ServiceDownException
 
PubSubException.ServiceDownException(String, Throwable) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.ServiceDownException
 
PubSubException.SubscriptionStateExistsException - Exception in org.apache.hedwig.exceptions
 
PubSubException.SubscriptionStateExistsException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.SubscriptionStateExistsException
 
PubSubException.TopicBusyException - Exception in org.apache.hedwig.exceptions
 
PubSubException.TopicBusyException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.TopicBusyException
 
PubSubException.TopicOwnerInfoExistsException - Exception in org.apache.hedwig.exceptions
 
PubSubException.TopicOwnerInfoExistsException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.TopicOwnerInfoExistsException
 
PubSubException.TopicPersistenceInfoExistsException - Exception in org.apache.hedwig.exceptions
 
PubSubException.TopicPersistenceInfoExistsException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.TopicPersistenceInfoExistsException
 
PubSubException.UncertainStateException - Exception in org.apache.hedwig.exceptions
 
PubSubException.UncertainStateException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.UncertainStateException
 
PubSubException.UnexpectedConditionException - Exception in org.apache.hedwig.exceptions
 
PubSubException.UnexpectedConditionException(String) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.UnexpectedConditionException
 
PubSubException.UnexpectedConditionException(String, Throwable) - Constructor for exception org.apache.hedwig.exceptions.PubSubException.UnexpectedConditionException
 
PubSubProtocol - Class in org.apache.hedwig.protocol
 
PubSubProtocol.CloseSubscriptionRequest - Class in org.apache.hedwig.protocol
 
PubSubProtocol.CloseSubscriptionRequest.Builder - Class in org.apache.hedwig.protocol
 
PubSubProtocol.CloseSubscriptionRequestOrBuilder - Interface in org.apache.hedwig.protocol
 
PubSubProtocol.ConsumeRequest - Class in org.apache.hedwig.protocol
 
PubSubProtocol.ConsumeRequest.Builder - Class in org.apache.hedwig.protocol
 
PubSubProtocol.ConsumeRequestOrBuilder - Interface in org.apache.hedwig.protocol
 
PubSubProtocol.HubInfoData - Class in org.apache.hedwig.protocol
 
PubSubProtocol.HubInfoData.Builder - Class in org.apache.hedwig.protocol
 
PubSubProtocol.HubInfoDataOrBuilder - Interface in org.apache.hedwig.protocol
 
PubSubProtocol.HubLoadData - Class in org.apache.hedwig.protocol
 
PubSubProtocol.HubLoadData.Builder - Class in org.apache.hedwig.protocol
 
PubSubProtocol.HubLoadDataOrBuilder - Interface in org.apache.hedwig.protocol
 
PubSubProtocol.LedgerRange - Class in org.apache.hedwig.protocol
 
PubSubProtocol.LedgerRange.Builder - Class in org.apache.hedwig.protocol
 
PubSubProtocol.LedgerRangeOrBuilder - Interface in org.apache.hedwig.protocol
 
PubSubProtocol.LedgerRanges - Class in org.apache.hedwig.protocol
 
PubSubProtocol.LedgerRanges.Builder - Class in org.apache.hedwig.protocol
 
PubSubProtocol.LedgerRangesOrBuilder - Interface in org.apache.hedwig.protocol
 
PubSubProtocol.ManagerMeta - Class in org.apache.hedwig.protocol
 
PubSubProtocol.ManagerMeta.Builder - Class in org.apache.hedwig.protocol
 
PubSubProtocol.ManagerMetaOrBuilder - Interface in org.apache.hedwig.protocol
 
PubSubProtocol.Map - Class in org.apache.hedwig.protocol
 
PubSubProtocol.Map.Builder - Class in org.apache.hedwig.protocol
 
PubSubProtocol.Map.Entry - Class in org.apache.hedwig.protocol
 
PubSubProtocol.Map.Entry.Builder - Class in org.apache.hedwig.protocol
 
PubSubProtocol.Map.EntryOrBuilder - Interface in org.apache.hedwig.protocol
 
PubSubProtocol.MapOrBuilder - Interface in org.apache.hedwig.protocol
 
PubSubProtocol.Message - Class in org.apache.hedwig.protocol
 
PubSubProtocol.Message.Builder - Class in org.apache.hedwig.protocol
 
PubSubProtocol.MessageHeader - Class in org.apache.hedwig.protocol
 
PubSubProtocol.MessageHeader.Builder - Class in org.apache.hedwig.protocol
 
PubSubProtocol.MessageHeaderOrBuilder - Interface in org.apache.hedwig.protocol
 
PubSubProtocol.MessageOrBuilder - Interface in org.apache.hedwig.protocol
 
PubSubProtocol.MessageSeqId - Class in org.apache.hedwig.protocol
 
PubSubProtocol.MessageSeqId.Builder - Class in org.apache.hedwig.protocol
 
PubSubProtocol.MessageSeqIdOrBuilder - Interface in org.apache.hedwig.protocol
 
PubSubProtocol.OperationType - Enum in org.apache.hedwig.protocol
 
PubSubProtocol.ProtocolVersion - Enum in org.apache.hedwig.protocol
 
PubSubProtocol.PublishRequest - Class in org.apache.hedwig.protocol
 
PubSubProtocol.PublishRequest.Builder - Class in org.apache.hedwig.protocol
 
PubSubProtocol.PublishRequestOrBuilder - Interface in org.apache.hedwig.protocol
 
PubSubProtocol.PublishResponse - Class in org.apache.hedwig.protocol
 
PubSubProtocol.PublishResponse.Builder - Class in org.apache.hedwig.protocol
 
PubSubProtocol.PublishResponseOrBuilder - Interface in org.apache.hedwig.protocol
 
PubSubProtocol.PubSubRequest - Class in org.apache.hedwig.protocol
 
PubSubProtocol.PubSubRequest.Builder - Class in org.apache.hedwig.protocol
 
PubSubProtocol.PubSubRequestOrBuilder - Interface in org.apache.hedwig.protocol
 
PubSubProtocol.PubSubResponse - Class in org.apache.hedwig.protocol
 
PubSubProtocol.PubSubResponse.Builder - Class in org.apache.hedwig.protocol
 
PubSubProtocol.PubSubResponseOrBuilder - Interface in org.apache.hedwig.protocol
 
PubSubProtocol.RegionSpecificSeqId - Class in org.apache.hedwig.protocol
 
PubSubProtocol.RegionSpecificSeqId.Builder - Class in org.apache.hedwig.protocol
 
PubSubProtocol.RegionSpecificSeqIdOrBuilder - Interface in org.apache.hedwig.protocol
 
PubSubProtocol.ResponseBody - Class in org.apache.hedwig.protocol
 
PubSubProtocol.ResponseBody.Builder - Class in org.apache.hedwig.protocol
 
PubSubProtocol.ResponseBodyOrBuilder - Interface in org.apache.hedwig.protocol
 
PubSubProtocol.StartDeliveryRequest - Class in org.apache.hedwig.protocol
 
PubSubProtocol.StartDeliveryRequest.Builder - Class in org.apache.hedwig.protocol
 
PubSubProtocol.StartDeliveryRequestOrBuilder - Interface in org.apache.hedwig.protocol
 
PubSubProtocol.StatusCode - Enum in org.apache.hedwig.protocol
 
PubSubProtocol.StopDeliveryRequest - Class in org.apache.hedwig.protocol
 
PubSubProtocol.StopDeliveryRequest.Builder - Class in org.apache.hedwig.protocol
 
PubSubProtocol.StopDeliveryRequestOrBuilder - Interface in org.apache.hedwig.protocol
 
PubSubProtocol.SubscribeRequest - Class in org.apache.hedwig.protocol
 
PubSubProtocol.SubscribeRequest.Builder - Class in org.apache.hedwig.protocol
 
PubSubProtocol.SubscribeRequest.CreateOrAttach - Enum in org.apache.hedwig.protocol
 
PubSubProtocol.SubscribeRequestOrBuilder - Interface in org.apache.hedwig.protocol
 
PubSubProtocol.SubscribeResponse - Class in org.apache.hedwig.protocol
 
PubSubProtocol.SubscribeResponse.Builder - Class in org.apache.hedwig.protocol
 
PubSubProtocol.SubscribeResponseOrBuilder - Interface in org.apache.hedwig.protocol
 
PubSubProtocol.SubscriptionData - Class in org.apache.hedwig.protocol
 
PubSubProtocol.SubscriptionData.Builder - Class in org.apache.hedwig.protocol
 
PubSubProtocol.SubscriptionDataOrBuilder - Interface in org.apache.hedwig.protocol
 
PubSubProtocol.SubscriptionEvent - Enum in org.apache.hedwig.protocol
 
PubSubProtocol.SubscriptionEventResponse - Class in org.apache.hedwig.protocol
 
PubSubProtocol.SubscriptionEventResponse.Builder - Class in org.apache.hedwig.protocol
 
PubSubProtocol.SubscriptionEventResponseOrBuilder - Interface in org.apache.hedwig.protocol
 
PubSubProtocol.SubscriptionOptions - Class in org.apache.hedwig.protocol
 
PubSubProtocol.SubscriptionOptions.Builder - Class in org.apache.hedwig.protocol
 
PubSubProtocol.SubscriptionOptionsOrBuilder - Interface in org.apache.hedwig.protocol
 
PubSubProtocol.SubscriptionPreferences - Class in org.apache.hedwig.protocol
 
PubSubProtocol.SubscriptionPreferences.Builder - Class in org.apache.hedwig.protocol
 
PubSubProtocol.SubscriptionPreferencesOrBuilder - Interface in org.apache.hedwig.protocol
 
PubSubProtocol.SubscriptionState - Class in org.apache.hedwig.protocol
 
PubSubProtocol.SubscriptionState.Builder - Class in org.apache.hedwig.protocol
 
PubSubProtocol.SubscriptionStateOrBuilder - Interface in org.apache.hedwig.protocol
 
PubSubProtocol.UnsubscribeRequest - Class in org.apache.hedwig.protocol
 
PubSubProtocol.UnsubscribeRequest.Builder - Class in org.apache.hedwig.protocol
 
PubSubProtocol.UnsubscribeRequestOrBuilder - Interface in org.apache.hedwig.protocol
 
put(V, U) - Static method in class org.apache.hedwig.util.ConcurrencyUtils
 

Q

QuorumException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 

R

RackawareEnsemblePlacementPolicy - Class in org.apache.bookkeeper.client
Simple rackware ensemble placement policy.
RackawareEnsemblePlacementPolicy() - Constructor for class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
RackawareEnsemblePlacementPolicy.BookieNode - Class in org.apache.bookkeeper.client
 
RackawareEnsemblePlacementPolicy.Ensemble - Interface in org.apache.bookkeeper.client
Ensemble used to hold the result of an ensemble selected for placement.
RackawareEnsemblePlacementPolicy.EnsembleForReplacement - Class in org.apache.bookkeeper.client
 
RackawareEnsemblePlacementPolicy.EnsembleForReplacement() - Constructor for class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.EnsembleForReplacement
 
RackawareEnsemblePlacementPolicy.Predicate - Interface in org.apache.bookkeeper.client
Predicate used when choosing an ensemble.
RackawareEnsemblePlacementPolicy.RRRackCoverageEnsemble - Class in org.apache.bookkeeper.client
A predicate checking the rack coverage for write quorum in RoundRobinDistributionSchedule, which ensures that a write quorum should be covered by at least two racks.
RackawareEnsemblePlacementPolicy.RRRackCoverageEnsemble(int, int) - Constructor for class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.RRRackCoverageEnsemble
 
RackawareEnsemblePlacementPolicy.TruePredicate - Class in org.apache.bookkeeper.client
 
RackawareEnsemblePlacementPolicy.TruePredicate() - Constructor for class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.TruePredicate
 
RANGES_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges
 
READ_BUFFER_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
READ_ENTRY_TIMEOUT_SEC - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
READ_ONLY_MODE_ENABLED - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
READ_OP - Static variable in interface org.apache.bookkeeper.client.BookKeeperClientStats
 
READ_TIMEOUT - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration
 
readComplete(int, LedgerHandle, Enumeration<LedgerEntry>, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.ReadCallback
Callback declaration
readEntries(long, long) - Method in class org.apache.bookkeeper.client.LedgerHandle
Read a sequence of entries synchronously.
ReadException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
readLastConfirmed() - Method in class org.apache.bookkeeper.client.LedgerHandle
Obtains synchronously the last confirmed write from a quorum of bookies.
readLastConfirmedComplete(int, long, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.ReadLastConfirmedCallback
Callback definition for bookie recover operations
recoverBookieData(BookieSocketAddress, BookieSocketAddress) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Synchronous method to rebuild and recover the ledger fragments data that was stored on the source bookie.
recoverComplete(int, Object) - Method in interface org.apache.bookkeeper.client.AsyncCallback.RecoverCallback
Callback definition for bookie recover operations
REGION_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
 
registerAllExtensions(ExtensionRegistry) - Static method in class org.apache.hedwig.protocol.PubSubProtocol
 
REMOTECOMPONENTS_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId
 
removeEntries(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
removeRanges(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
removeRemoteComponents(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
removeSubscriptionListener(SubscriptionListener) - Method in interface org.apache.hedwig.client.api.Subscriber
Unregister a subscription listener.
replaceBookie(BookieSocketAddress, Set<BookieSocketAddress>) - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy
 
replaceBookie(BookieSocketAddress, Set<BookieSocketAddress>) - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy
Choose a new bookie to replace bookieToReplace.
replaceBookie(BookieSocketAddress, Set<BookieSocketAddress>) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
replicateLedgerFragment(LedgerHandle, LedgerFragment, BookieSocketAddress) - Method in class org.apache.bookkeeper.client.BookKeeperAdmin
Replicate the Ledger fragment to target Bookie passed.
ReplicationException - Static variable in interface org.apache.bookkeeper.client.BKException.Code
 
REPP_DNS_RESOLVER_CLASS - Static variable in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
REREPLICATION_ENTRY_BATCH_SIZE - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration
 
RESPONSEBODY_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse
 
RESUBSCRIBE_EXCEPTION_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode
 
right(U) - Static method in class org.apache.hedwig.util.Either
 
right() - Method in class org.apache.hedwig.util.Either
 

S

second() - Method in class org.apache.hedwig.util.Pair
 
selectFromRack(String, Set<Node>, RackawareEnsemblePlacementPolicy.Predicate, RackawareEnsemblePlacementPolicy.Ensemble) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
 
selectRandom(int, Set<Node>, RackawareEnsemblePlacementPolicy.Ensemble) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
Choose a random node from whole cluster.
selectRandomFromRack(String, Set<Node>, RackawareEnsemblePlacementPolicy.Predicate, RackawareEnsemblePlacementPolicy.Ensemble) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy
Choose random node under a given network path.
SEQID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId
 
serialize() - Method in class org.apache.bookkeeper.client.LedgerMetadata
Generates a byte array of this object
SERVER_ACK_RESPONSE_TIMEOUT - Static variable in class org.apache.hedwig.client.conf.ClientConfiguration
 
SERVER_TCP_NODELAY - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration
 
ServerConfiguration - Class in org.apache.bookkeeper.conf
Configuration manages server-side settings
ServerConfiguration() - Constructor for class org.apache.bookkeeper.conf.ServerConfiguration
Construct a default configuration object
ServerConfiguration(AbstractConfiguration) - Constructor for class org.apache.bookkeeper.conf.ServerConfiguration
Construct a configuration based on other configuration
SERVICE_DOWN_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode
 
setAddEntryTimeout(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set timeout for add entry request.
setAllowLoopback(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Configure the bookie to allow loopback interfaces to be used as the primary bookie interface.
setAuditorPeriodicBookieCheckInterval(long) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set the interval between auditor bookie checks.
setAuditorPeriodicCheckInterval(long) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set the regularity at which the auditor will run a check of all ledgers.
setAutoRecoveryDaemonEnabled(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Sets that whether the auto-recovery service can start along with Bookie server itself or not
setBody(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
setBookiePort(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set new bookie port that bookie server listen on
setBookieRecoveryDigestType(BookKeeper.DigestType) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set digest type used in bookkeeper admin.
setBookieRecoveryPasswd(byte[]) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set passwd used in bookkeeper admin.
setChannelFactory(ClientSocketChannelFactory) - Method in class org.apache.bookkeeper.client.BookKeeper.Builder
 
setClientConnectTimeoutMillis(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set client netty connect timeout in millis.
setClientReceiveBufferSize(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set client netty channel receive buffer size.
setClientSendBufferSize(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set client netty channel send buffer size.
setClientTcpNoDelay(boolean) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set socket nodelay setting.
setClientWriteBufferHighWaterMark(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set client netty channel write buffer high water mark.
setClientWriteBufferLowWaterMark(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set client netty channel write buffer low water mark.
setCloseSubscriptionRequest(PubSubProtocol.CloseSubscriptionRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
setCloseSubscriptionRequest(PubSubProtocol.CloseSubscriptionRequest.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
setCode(int) - Method in exception org.apache.bookkeeper.client.BKException
 
setCompactionMaxOutstandingRequests(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set the maximum number of entries which can be compacted without flushing.
setCompactionRate(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set the rate of compaction adds.
setConf(Configuration) - Method in interface org.apache.bookkeeper.conf.Configurable
Set the configuration to be used by this object.
setConsumeRequest(PubSubProtocol.ConsumeRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
setConsumeRequest(PubSubProtocol.ConsumeRequest.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
setCreateOrAttach(PubSubProtocol.SubscribeRequest.CreateOrAttach) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
setCreateOrAttach(PubSubProtocol.SubscribeRequest.CreateOrAttach) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
setCzxid(long) - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
 
setDiskCheckInterval(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set the disk checker interval to monitor ledger disk space
setDiskUsageThreshold(float) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set the Disk free space threshold as a fraction of the total after which disk will be considered as full during disk check.
setDiskUsageWarnThreshold(float) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set the warning threshold for disk usage.
setEnableResubscribe(boolean) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
setEndSeqIdIncluded(PubSubProtocol.MessageSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
 
setEndSeqIdIncluded(PubSubProtocol.MessageSeqId.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
 
setEnsemblePlacementPolicy(Class<? extends EnsemblePlacementPolicy>) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set Ensemble Placement Policy Class.
setEntries(int, PubSubProtocol.Map.Entry) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
setEntries(int, PubSubProtocol.Map.Entry.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Builder
 
setEntryLogFilePreAllocationEnabled(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Enable/disable entry log file preallocation.
setEntryLogSizeLimit(long) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set entry logger size limitation
setEvent(PubSubProtocol.SubscriptionEvent) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse.Builder
 
setFlushInterval(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set flush interval
setForceAttach(boolean) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
setForceAttach(boolean) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
setGcWaitTime(long) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set garbage collection wait time
setHeader(PubSubProtocol.MessageHeader) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
setHeader(PubSubProtocol.MessageHeader.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
setHostname(String) - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData.Builder
 
setIndexDirName(String[]) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set dir name to store index files.
setJournalAdaptiveGroupWrites(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Enable/disable group journal force writes
setJournalAlignmentSize(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set journal alignment size.
setJournalBufferedEntriesThreshold(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set maximum entries to buffer to impose on a journal write to achieve grouping.
setJournalDirName(String) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set dir name to store journal files
setJournalFlushWhenQueueEmpty(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set if we should flush the journal when queue is empty
setJournalFormatVersionToWrite(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set journal format version to write.
setJournalRemovePagesFromCache(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Sets that whether should we remove pages from page cache after force write.
setKey(String) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
 
setLedgerDirNames(String[]) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set dir names to store ledger data
setLedgerId(long) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
 
setLedgerManagerFactoryClass(Class<? extends LedgerManagerFactory>) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Set Ledger Manager Factory Class.
setLedgerManagerFactoryClassName(String) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Set Ledger Manager Factory Class Name.
setLedgerManagerType(String) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
setLevel(int) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode
 
setListeningInterface(String) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set the network interface that the bookie should listen on.
setLocalComponent(long) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
setMajorCompactionInterval(long) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set interval to run major compaction.
setMajorCompactionThreshold(double) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set threshold of major compaction.
setManagerImpl(String) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
 
setManagerVersion(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta.Builder
 
setMaxBackupJournals(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set max number of older journal files to kept
setMaxJournalSizeMB(long) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set new max journal file size
setMessage(PubSubProtocol.Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
setMessage(PubSubProtocol.Message.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
setMessageBound(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
setMessageBound(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
setMessageBound(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
setMessageBound(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
 
setMessageFilter(String) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
setMessageFilter(String) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
setMessageType(String) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
 
setMessageWindowSize(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
setMessageWindowSize(int) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
setMetastoreImplClass(String) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Set metastore implementation class.
setMetastoreMaxEntriesPerScan(int) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Set max entries per scan in metastore.
setMinorCompactionInterval(long) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set interval to run minor compaction
setMinorCompactionThreshold(double) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set threshold of minor compaction
setMsg(PubSubProtocol.Message) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
 
setMsg(PubSubProtocol.Message.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest.Builder
 
setMsgId(PubSubProtocol.MessageSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
 
setMsgId(PubSubProtocol.MessageSeqId.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
 
setMsgId(PubSubProtocol.MessageSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
setMsgId(PubSubProtocol.MessageSeqId.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
setMsgId(PubSubProtocol.MessageSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
 
setMsgId(PubSubProtocol.MessageSeqId.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState.Builder
 
setNetworkLocation(String) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode
 
setNumAddWorkerThreads(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set the number of threads that would handle write requests.
setNumChannelsPerBookie(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set num channels per bookie.
setNumJournalCallbackThreads(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set the number of threads that would handle journal callbacks.
setNumReadWorkerThreads(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set the number of threads that would handle read requests.
setNumTopics(long) - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData.Builder
 
setNumWorkerThreads(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set the number of worker threads.
setOpenFileLimit(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set limitation of number of open files.
setOpenLedgerRereplicationGracePeriod(String) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set the grace period which the rereplication worker will wait before fencing and rereplicating a ledger fragment which is still being written to, on bookie failure.
setOptions(PubSubProtocol.Map) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
setOptions(PubSubProtocol.Map.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions.Builder
 
setOptions(PubSubProtocol.Map) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
setOptions(PubSubProtocol.Map.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences.Builder
 
setPageLimit(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set limitation number of index pages in ledger cache.
setPageSize(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set page size
setParent(Node) - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode
 
setPCBCTimeoutTimerNumTicks(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set number of ticks that used for HashedWheelTimer that used by PCBC to timeout request.
setPCBCTimeoutTimerTickDurationMs(long) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set the tick duration in milliseconds that used for HashedWheelTimer that used by PCBC to timeout requests.
setPreferences(PubSubProtocol.SubscriptionPreferences) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
setPreferences(PubSubProtocol.SubscriptionPreferences.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
setPreferences(PubSubProtocol.SubscriptionPreferences) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
 
setPreferences(PubSubProtocol.SubscriptionPreferences.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse.Builder
 
setPreferences(PubSubProtocol.SubscriptionPreferences) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
 
setPreferences(PubSubProtocol.SubscriptionPreferences.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
 
setProperties(PubSubProtocol.Map) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
 
setProperties(PubSubProtocol.Map.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader.Builder
 
setProtocolVersion(PubSubProtocol.ProtocolVersion) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
setProtocolVersion(PubSubProtocol.ProtocolVersion) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
setPublishedMsgId(PubSubProtocol.MessageSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
 
setPublishedMsgId(PubSubProtocol.MessageSeqId.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse.Builder
 
setPublishRequest(PubSubProtocol.PublishRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
setPublishRequest(PubSubProtocol.PublishRequest.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
setPublishResponse(PubSubProtocol.PublishResponse) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
setPublishResponse(PubSubProtocol.PublishResponse.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
setRanges(int, PubSubProtocol.LedgerRange) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
setRanges(int, PubSubProtocol.LedgerRange.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges.Builder
 
setReadBufferBytes(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set the number of bytes we should use as capacity for org.apache.bookkeeper.bookie.BufferedReadChannel
setReadEntryTimeout(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set the timeout for read entry request.
setReadOnlyModeEnabled(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set whether the bookie is able to go into read-only mode.
setReadTimeout(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
setRegion(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
 
setRemoteComponents(int, PubSubProtocol.RegionSpecificSeqId) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
setRemoteComponents(int, PubSubProtocol.RegionSpecificSeqId.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId.Builder
 
setRereplicationEntryBatchSize(long) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Set the max entries to keep in fragment for re-replication.
setResponseBody(PubSubProtocol.ResponseBody) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
setResponseBody(PubSubProtocol.ResponseBody.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
setSeqId(long) - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId.Builder
 
setServerTcpNoDelay(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set socket nodelay setting
setShouldClaim(boolean) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
setSkipListArenaChunkSize(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set the number of bytes w used as chunk allocation for org.apache.bookkeeper.bookie.SkipListArena
setSkipListSizeLimit(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set skip list size limit.
setSortedLedgerStorageEnabled(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set sorted-ledger storage enabled or not
setSpeculativeReadTimeout(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set the speculative read timeout.
setSrcRegion(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message.Builder
 
setStartDeliveryRequest(PubSubProtocol.StartDeliveryRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
setStartDeliveryRequest(PubSubProtocol.StartDeliveryRequest.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
setStartSeqIdIncluded(long) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange.Builder
 
setState(PubSubProtocol.SubscriptionState) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
 
setState(PubSubProtocol.SubscriptionState.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData.Builder
 
setStatisticsEnabled(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Turn on/off statistics
setStatsLogger(StatsLogger) - Method in class org.apache.bookkeeper.client.BookKeeper.Builder
 
setStatsProviderClass(Class<? extends StatsProvider>) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set the stats provider used by bookie.
setStatusCode(PubSubProtocol.StatusCode) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
setStatusMsg(String) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
setStopDeliveryRequest(PubSubProtocol.StopDeliveryRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
setStopDeliveryRequest(PubSubProtocol.StopDeliveryRequest.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
setSubscribeRequest(PubSubProtocol.SubscribeRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
setSubscribeRequest(PubSubProtocol.SubscribeRequest.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
setSubscribeResponse(PubSubProtocol.SubscribeResponse) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
setSubscribeResponse(PubSubProtocol.SubscribeResponse.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
setSubscriberId(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest.Builder
 
setSubscriberId(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest.Builder
 
setSubscriberId(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
setSubscriberId(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest.Builder
 
setSubscriberId(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest.Builder
 
setSubscriberId(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
setSubscriberId(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest.Builder
 
setSubscriptionEvent(PubSubProtocol.SubscriptionEventResponse) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
setSubscriptionEvent(PubSubProtocol.SubscriptionEventResponse.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody.Builder
 
setSynchronous(boolean) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.Builder
 
setThrottleValue(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set throttle value.
setTimeoutTaskIntervalMillis(long) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Deprecated.
setTopic(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
setTopic(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
setTriedServers(int, ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
setTxnId(long) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
setTxnId(long) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse.Builder
 
setType(PubSubProtocol.OperationType) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
setUnsubscribeRequest(PubSubProtocol.UnsubscribeRequest) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
setUnsubscribeRequest(PubSubProtocol.UnsubscribeRequest.Builder) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest.Builder
 
setUseHostNameAsBookieID(boolean) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Configure the bookie to use its hostname to register with the co-ordination service(eg: zookeeper) and in ledger metadata
setValue(ByteString) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry.Builder
 
setVersion(Version) - Method in class org.apache.bookkeeper.client.LedgerMetadata
Updates the version of this metadata.
setWriteBufferBytes(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set the number of bytes used as capacity for the write buffer.
setZkLedgersRootPath(String) - Method in class org.apache.bookkeeper.conf.AbstractConfiguration
Set Zk Ledgers Root Path.
setZkServers(String) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set zookeeper servers to connect
setZkServers(String) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set zookeeper servers to connect
setZkTimeout(int) - Method in class org.apache.bookkeeper.conf.ClientConfiguration
Set zookeeper timeout
setZkTimeout(int) - Method in class org.apache.bookkeeper.conf.ServerConfiguration
Set zookeeper timeout
setZookeeper(ZooKeeper) - Method in class org.apache.bookkeeper.client.BookKeeper.Builder
 
SHOULDCLAIM_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest
 
SKIP_LIST_CHUNK_SIZE_ENTRY - Static variable in class org.apache.bookkeeper.conf.