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

Deprecated.

As of BookKeeper 4.2.0, replaced by Subscriber.asyncSubscribe(com.google.protobuf.ByteString, com.google.protobuf.ByteString, PubSubProtocol.SubscriptionOptions,Callback,Object)

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

Deprecated.

replaced by AbstractConfiguration.getLedgerManagerFactoryClass()

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

Deprecated.

use ClientConfiguration.getReadEntryTimeout() or ClientConfiguration.getAddEntryTimeout() instead

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

Deprecated.

replaced by AbstractConfiguration.setLedgerManagerFactoryClass(java.lang.Class<? extends org.apache.bookkeeper.meta.LedgerManagerFactory>)

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

Deprecated.

use ClientConfiguration.setReadEntryTimeout(int) or ClientConfiguration.setAddEntryTimeout(int) instead

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.ServerConfiguration

SKIP_LIST_MAX_ALLOC_ENTRY - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

SKIP_LIST_SIZE_LIMIT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

sockAddrStr(InetSocketAddress) - Static method in class org.apache.hedwig.util.HedwigSocketAddress

SORTED_LEDGER_STORAGE_ENABLED - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

SPECULATIVE_READ_TIMEOUT - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

SRCREGION_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.Message

SSL_ENABLED - Static variable in class org.apache.hedwig.client.conf.ClientConfiguration

START_DELIVERY_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType

startDelivery(ByteString, ByteString, MessageHandler) - Method in interface org.apache.hedwig.client.api.Subscriber

Begin delivery of messages from the server to us for this topic and subscriberId.

STARTDELIVERYREQUEST_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

startDeliveryWithFilter(ByteString, ByteString, MessageHandler, ClientMessageFilter) - Method in interface org.apache.hedwig.client.api.Subscriber

Begin delivery of messages from the server to us for this topic and subscriberId.

STARTSEQIDINCLUDED_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

STATE_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData

STATS_PROVIDER_CLASS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

STATUSCODE_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

STATUSMSG_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

STOP_DELIVERY_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType

stopDelivery(ByteString, ByteString) - Method in interface org.apache.hedwig.client.api.Subscriber

Stop delivery of messages for this topic and subscriberId.

STOPDELIVERYREQUEST_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

subscribe(ByteString, ByteString, PubSubProtocol.SubscribeRequest.CreateOrAttach) - Method in interface org.apache.hedwig.client.api.Subscriber

Deprecated.

As of BookKeeper 4.2.0, replaced by Subscriber.subscribe(com.google.protobuf.ByteString, com.google.protobuf.ByteString, PubSubProtocol.SubscriptionOptions)

subscribe(ByteString, ByteString, PubSubProtocol.SubscriptionOptions) - Method in interface org.apache.hedwig.client.api.Subscriber

Subscribe to the given topic for the inputted subscriberId.

SUBSCRIBE_RECONNECT_RETRY_WAIT_TIME - Static variable in class org.apache.hedwig.client.conf.ClientConfiguration

SUBSCRIBE_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType

Subscriber - Interface in org.apache.hedwig.client.api

Interface to define the client Subscriber API.

SUBSCRIBEREQUEST_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

SUBSCRIBERESPONSE_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody

SUBSCRIBERID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest

SUBSCRIBERID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

SUBSCRIBERID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

SUBSCRIBERID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest

SUBSCRIBERID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest

SUBSCRIBERID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

SUBSCRIBERID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest

SUBSCRIPTION_CHANNEL_SHARING_ENABLED - Static variable in class org.apache.hedwig.client.conf.ClientConfiguration

SUBSCRIPTION_FORCED_CLOSED_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEvent

SUBSCRIPTION_MESSAGE_BOUND - Static variable in class org.apache.hedwig.client.conf.ClientConfiguration

SUBSCRIPTION_STATE_EXISTS_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode

SUBSCRIPTIONEVENT_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody

SubscriptionListener - Interface in org.apache.hedwig.util

This class is used for subscriber to listen on subscription event.

SUCCESS_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode

SYNCHRONOUS_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

T

take(BlockingQueue<T>) - Static method in class org.apache.hedwig.util.ConcurrencyUtils

THROTTLE - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

TIMEOUT_TASK_INTERVAL_MILLIS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

TIMEOUT_THREAD_RUN_INTERVAL - Static variable in class org.apache.hedwig.client.conf.ClientConfiguration

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState

toBuilder() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest

toList() - Method in interface org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.Ensemble

toList() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.EnsembleForReplacement

toList() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.RRRackCoverageEnsemble

TOPIC_BUSY_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode

TOPIC_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

TOPIC_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

TOPIC_MOVED_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEvent

TOPIC_OWNER_INFO_EXISTS_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode

TOPIC_PERSISTENCE_INFO_EXISTS_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode

toString() - Method in class org.apache.bookkeeper.client.LedgerFragment

toString() - Method in class org.apache.bookkeeper.client.LedgerMetadata

toString() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.BookieNode

toString() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy.RRRackCoverageEnsemble

toString() - Method in class org.apache.hedwig.util.HedwigSocketAddress

TRIEDSERVERS_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

tryReadLastConfirmed() - Method in class org.apache.bookkeeper.client.LedgerHandle

Obtains synchronously the last confirmed write from a quorum of bookies.

TXNID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

TXNID_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

TYPE_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

U

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

UNCERTAIN_STATE_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode

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

UNEXPECTED_CONDITION_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode

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

uninitalize() - Method in class org.apache.bookkeeper.client.DefaultEnsemblePlacementPolicy

uninitalize() - Method in interface org.apache.bookkeeper.client.EnsemblePlacementPolicy

Uninitialize the policy

uninitalize() - Method in class org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy

unsubscribe(ByteString, ByteString) - Method in interface org.apache.hedwig.client.api.Subscriber

Unsubscribe from a topic that the subscriberId user has previously subscribed to.

UNSUBSCRIBE_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType

UNSUBSCRIBEREQUEST_FIELD_NUMBER - Static variable in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

updateBookieIdInLedgers(BookieSocketAddress, BookieSocketAddress, int, int, BookieShell.UpdateLedgerNotifier) - Method in class org.apache.bookkeeper.client.UpdateLedgerOp

Update the bookie id present in the ledger metadata.

UpdateLedgerOp - Class in org.apache.bookkeeper.client

Encapsulates updating the ledger metadata operation

UpdateLedgerOp(BookKeeper, BookKeeperAdmin) - Constructor for class org.apache.bookkeeper.client.UpdateLedgerOp

USE_HOST_NAME_AS_BOOKIE_ID - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

V

va(Object...) - Static method in class org.apache.hedwig.util.VarArgs

validate() - Method in class org.apache.bookkeeper.conf.ServerConfiguration

Validate the configuration.

validate() - Method in class org.apache.hedwig.client.conf.ClientConfiguration

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

valueOf(String) - Static method in enum org.apache.bookkeeper.client.BookKeeper.DigestType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType

Returns the enum constant of this type with the specified name.

valueOf(int) - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType

valueOf(Descriptors.EnumValueDescriptor) - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType

valueOf(String) - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.ProtocolVersion

Returns the enum constant of this type with the specified name.

valueOf(int) - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.ProtocolVersion

valueOf(Descriptors.EnumValueDescriptor) - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.ProtocolVersion

valueOf(String) - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode

Returns the enum constant of this type with the specified name.

valueOf(int) - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode

valueOf(Descriptors.EnumValueDescriptor) - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode

valueOf(String) - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.CreateOrAttach

Returns the enum constant of this type with the specified name.

valueOf(int) - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.CreateOrAttach

valueOf(Descriptors.EnumValueDescriptor) - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.CreateOrAttach

valueOf(String) - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEvent

Returns the enum constant of this type with the specified name.

valueOf(int) - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEvent

valueOf(Descriptors.EnumValueDescriptor) - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEvent

values() - Static method in enum org.apache.bookkeeper.client.BookKeeper.DigestType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.OperationType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.ProtocolVersion

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.StatusCode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest.CreateOrAttach

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEvent

Returns an array containing the constants of this enum type, in the order they are declared.

VarArgs - Class in org.apache.hedwig.util

VarArgs() - Constructor for class org.apache.hedwig.util.VarArgs

VERSION_KEY - Static variable in class org.apache.bookkeeper.client.LedgerMetadata

VERSION_ONE_VALUE - Static variable in enum org.apache.hedwig.protocol.PubSubProtocol.ProtocolVersion

W

WRITE_BUFFER_SIZE - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

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

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

writeReplace() - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest

writeReplace() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

writeReplace() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData

writeReplace() - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData

writeReplace() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

writeReplace() - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges

writeReplace() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta

writeReplace() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry

writeReplace() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map

writeReplace() - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message

writeReplace() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader

writeReplace() - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

writeReplace() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest

writeReplace() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse

writeReplace() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

writeReplace() - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

writeReplace() - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

writeReplace() - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody

writeReplace() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest

writeReplace() - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest

writeReplace() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

writeReplace() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse

writeReplace() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData

writeReplace() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse

writeReplace() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions

writeReplace() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences

writeReplace() - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState

writeReplace() - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.CloseSubscriptionRequest

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ConsumeRequest

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubInfoData

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.HubLoadData

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRange

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.LedgerRanges

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ManagerMeta

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map.Entry

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Map

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.Message

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageHeader

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.MessageSeqId

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishRequest

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PublishResponse

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubRequest

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.PubSubResponse

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.RegionSpecificSeqId

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.ResponseBody

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StartDeliveryRequest

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.StopDeliveryRequest

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeRequest

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscribeResponse

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionData

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionEventResponse

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionOptions

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionPreferences

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.SubscriptionState

writeTo(CodedOutputStream) - Method in class org.apache.hedwig.protocol.PubSubProtocol.UnsubscribeRequest

Z

ZK_LEDGERS_ROOT_PATH - Static variable in class org.apache.bookkeeper.conf.AbstractConfiguration

ZK_SERVERS - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

ZK_SERVERS - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

ZK_TIMEOUT - Static variable in class org.apache.bookkeeper.conf.ClientConfiguration

ZK_TIMEOUT - Static variable in class org.apache.bookkeeper.conf.ServerConfiguration

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

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