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

A

abort() - Method in interface org.apache.distributedlog.io.Abortable
Aborts the object and releases any resources associated with it.
abort(Abortable, boolean) - Static method in class org.apache.distributedlog.io.Abortables
Aborts a Abortable, with control over whether an IOException may be thrown.
abort(AsyncAbortable, boolean) - Static method in class org.apache.distributedlog.io.Abortables
Abort async abortable.
ABORT_FUNC - Static variable in interface org.apache.distributedlog.io.AsyncAbortable
 
Abortable - Interface in org.apache.distributedlog.io
An Abortable is a source or destination of data that can be aborted.
Abortables - Class in org.apache.distributedlog.io
Utility methods for working with Abortable objects.
abortQuietly(Abortable) - Static method in class org.apache.distributedlog.io.Abortables
Aborts the given abortable, logging any IOException that's thrown rather than propagating it.
abortQuietly(AsyncAbortable) - Static method in class org.apache.distributedlog.io.Abortables
Aborts the given abortable, logging any IOException that's thrown rather than propagating it.
abortSequence(ExecutorService, AsyncAbortable...) - Static method in class org.apache.distributedlog.io.Abortables
Abort the abortables in sequence.
abortTransmit(Throwable) - Method in interface org.apache.distributedlog.LogRecordSetBuffer
Abort transmit.
AbstractFeatureProvider<T extends org.apache.bookkeeper.feature.Feature> - Class in org.apache.distributedlog.feature
Decider based feature provider
AbstractFeatureProvider(String, DistributedLogConfiguration, StatsLogger) - Constructor for class org.apache.distributedlog.feature.AbstractFeatureProvider
 
accept(T, Throwable) - Method in interface org.apache.distributedlog.common.concurrent.FutureEventListener
 
acquire() - Method in class org.apache.distributedlog.common.concurrent.AsyncSemaphore
Acquire a [[Permit]], asynchronously.
acquire() - Method in interface org.apache.distributedlog.common.util.PermitLimiter
Acquire a permit.
acquireAndRun(Supplier<CompletableFuture<T>>) - Method in class org.apache.distributedlog.common.concurrent.AsyncSemaphore
Execute the function asynchronously when a permit becomes available.
acquirePermit() - Method in interface org.apache.distributedlog.common.util.PermitManager
Obetain a permit from permit manager.
add(String, LogSegmentMetadata) - Method in class org.apache.distributedlog.logsegment.PerStreamLogSegmentCache
Add the segment metadata for name in the cache.
addNewSegmentAndDeleteOldSegment(LogSegmentMetadata, LogSegmentMetadata) - Method in class org.apache.distributedlog.metadata.LogSegmentMetadataStoreUpdater
 
addNewSegmentAndDeleteOldSegment(Transaction<Object>, LogSegmentMetadata, LogSegmentMetadata) - Method in class org.apache.distributedlog.metadata.LogSegmentMetadataStoreUpdater
 
addPropertyDirect(String, Object) - Method in class org.apache.distributedlog.common.config.ConcurrentBaseConfiguration
 
address(SocketAddress) - Method in class org.apache.distributedlog.client.routing.SingleHostRoutingService.Builder
 
address - Variable in class org.apache.distributedlog.service.DistributedLogCluster.DLServer
 
address2ShardId - Variable in class org.apache.distributedlog.client.routing.ConsistentHashRoutingService
 
addTriedHost(SocketAddress, StatusCode) - Method in class org.apache.distributedlog.client.routing.RoutingService.RoutingContext
Add tried host to routing context.
advanceCommitPosition(String, DLSN) - Method in interface org.apache.distributedlog.api.subscription.SubscriptionsStore
Advance the last committed position for subscriberId.
advanceCommitPosition(DLSN) - Method in interface org.apache.distributedlog.api.subscription.SubscriptionStateStore
Advances the position associated with the subscriber
advanceCommitPosition(String, DLSN) - Method in interface org.apache.distributedlog.subscription.SubscriptionsStore
Advance the last committed position for subscriberId.
ALLOCATION_PATH - Static variable in class org.apache.distributedlog.metadata.LogMetadata
 
ALLOCATION_POOL_NODE - Static variable in class org.apache.distributedlog.DistributedLogConstants
 
allocationPath - Variable in class org.apache.distributedlog.metadata.LogMetadata
 
ALLOWED - Static variable in interface org.apache.distributedlog.common.util.PermitManager.Permit
 
allowObtainPermits() - Method in interface org.apache.distributedlog.common.util.PermitManager
Allow obtaining permits.
ALREADY_CLOSED - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
AlreadyClosedException - Exception in org.apache.distributedlog.exceptions
Thrown when any distributedlog resources have already been closed.
AlreadyClosedException(String) - Constructor for exception org.apache.distributedlog.exceptions.AlreadyClosedException
 
AlreadyTruncatedTransactionException - Exception in org.apache.distributedlog.exceptions
Thrown when the transaction Id specified in the API is in the range that has already been truncated.
AlreadyTruncatedTransactionException(String) - Constructor for exception org.apache.distributedlog.exceptions.AlreadyTruncatedTransactionException
 
AppendOnlyStreamReader - Class in org.apache.distributedlog
 
AppendOnlyStreamWriter - Class in org.apache.distributedlog
 
AppendOnlyStreamWriter(BKAsyncLogWriter, long) - Constructor for class org.apache.distributedlog.AppendOnlyStreamWriter
 
asyncAbort() - Method in interface org.apache.distributedlog.AsyncLogWriter
Aborts the object and releases any resources associated with it.
asyncAbort(AsyncAbortable, boolean) - Static method in class org.apache.distributedlog.io.Abortables
 
asyncAbort() - Method in interface org.apache.distributedlog.io.AsyncAbortable
Aborts the object and releases any resources associated with it.
AsyncAbortable - Interface in org.apache.distributedlog.io
An Abortable is a source or destination of data that can be aborted.
asyncAcquire() - Method in interface org.apache.distributedlog.lock.DistributedLock
Asynchronously acquire the lock.
asyncAcquire() - Method in class org.apache.distributedlog.lock.NopDistributedLock
 
asyncAcquire() - Method in class org.apache.distributedlog.lock.ZKDistributedLock
Asynchronously acquire the lock.
asyncAddEntry(ByteBuf, AsyncCallback.AddCallback, Object) - Method in interface org.apache.distributedlog.logsegment.LogSegmentEntryWriter
Async add entry to the log segment.
asyncClose() - Method in interface org.apache.distributedlog.AsyncLogReader
Closes this source and releases any system resources associated with it.
asyncClose() - Method in interface org.apache.distributedlog.AsyncLogWriter
Closes this source and releases any system resources associated with it.
asyncClose() - Method in interface org.apache.distributedlog.DistributedLogManager
Closes this source and releases any system resources associated with it.
asyncClose() - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
asyncClose() - Method in interface org.apache.distributedlog.io.AsyncCloseable
Closes this source and releases any system resources associated with it.
asyncClose() - Method in class org.apache.distributedlog.lock.NopDistributedLock
 
asyncClose() - Method in class org.apache.distributedlog.lock.ZKDistributedLock
 
asyncClose() - Method in interface org.apache.distributedlog.LogReader
Closes this source and releases any system resources associated with it.
asyncClose(AsyncCallback.CloseCallback, Object) - Method in interface org.apache.distributedlog.logsegment.LogSegmentEntryWriter
Close the entry writer.
AsyncCloseable - Interface in org.apache.distributedlog.io
A AsyncCloseable is a source or destination of data that can be closed asynchronously.
AsyncDeleteable - Interface in org.apache.distributedlog.io
A AsyncDeleteable is a source or destination of data that can be deleted asynchronously.
AsyncLogReader - Interface in org.apache.distributedlog.api
 
AsyncLogReader - Interface in org.apache.distributedlog
A log reader to read records in asynchronous way.
AsyncLogWriter - Interface in org.apache.distributedlog.api
 
AsyncLogWriter - Interface in org.apache.distributedlog
A writer that appends log records asynchronously.
asyncReadFirstUserRecord(String, LogSegmentMetadata, int, int, AtomicInteger, ExecutorService, LogSegmentEntryStore, DLSN) - Static method in class org.apache.distributedlog.ReadUtils
Read first record from a log segment with a DLSN larger than that given.
asyncReadLastRecord(String, LogSegmentMetadata, boolean, boolean, boolean, int, int, AtomicInteger, ExecutorService, LogSegmentEntryStore) - Static method in class org.apache.distributedlog.ReadUtils
Read last record from a log segment.
AsyncSemaphore - Class in org.apache.distributedlog.common.concurrent
An AsyncSemaphore is a traditional semaphore but with asynchronous execution.
AsyncSemaphore(int, Optional<Integer>) - Constructor for class org.apache.distributedlog.common.concurrent.AsyncSemaphore
 
asyncTryLock(long, TimeUnit) - Method in interface org.apache.distributedlog.lock.SessionLock
Acquire the lock in asynchronous way.
asyncUnlock() - Method in interface org.apache.distributedlog.lock.SessionLock
Release a claimed lock in the asynchronous way.
asyncWrite(LogRecord) - Method in interface org.apache.distributedlog.logsegment.LogSegmentWriter
Write a log record to a log segment.
authenticate(ZooKeeper) - Method in interface org.apache.distributedlog.ZooKeeperClient.Credentials
 
authenticate(ZooKeeper) - Method in class org.apache.distributedlog.ZooKeeperClient.DigestCredentials
 

B

BACKEND_BK - Static variable in class org.apache.distributedlog.DistributedLogConstants
 
BitMaskUtils - Class in org.apache.distributedlog.common.util
Utils for bit mask operations.
BitMaskUtils() - Constructor for class org.apache.distributedlog.common.util.BitMaskUtils
 
BK_TRANSMIT_ERROR - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
bkc(BookKeeperClient) - Method in class org.apache.distributedlog.BookKeeperClientBuilder
Build BookKeeper client using existing bkc client.
bkConf(ServerConfiguration) - Method in class org.apache.distributedlog.service.DistributedLogCluster.Builder
Set the Bookkeeper server configuration.
BKDistributedLogNamespace - Class in org.apache.distributedlog
BKDistributedLogNamespace is the default implementation of Namespace.
BKDistributedLogNamespace(DistributedLogConfiguration, URI, NamespaceDriver, OrderedScheduler, FeatureProvider, PermitLimiter, AsyncFailureInjector, StatsLogger, StatsLogger, String, int) - Constructor for class org.apache.distributedlog.BKDistributedLogNamespace
 
BKDL_BK_DNS_RESOLVER_OVERRIDES - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BK_DNS_RESOLVER_OVERRIDES_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BKCLEINT_NUM_WORKER_THREADS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BKCLIENT_NUM_IO_THREADS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BKCLIENT_NUM_WORKER_THREADS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BKCLIENT_READ_TIMEOUT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BKCLIENT_READ_TIMEOUT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BKCLIENT_WRITE_TIMEOUT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BKCLIENT_WRITE_TIMEOUT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BKCLIENT_ZK_NUM_RETRIES - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BKCLIENT_ZK_NUM_RETRIES_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BKCLIENT_ZK_REQUEST_RATE_LIMIT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BKCLIENT_ZK_REQUEST_RATE_LIMIT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BKCLIENT_ZK_RETRY_BACKOFF_MAX_MILLIS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BKCLIENT_ZK_RETRY_BACKOFF_MAX_MILLIS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BKCLIENT_ZK_RETRY_BACKOFF_START_MILLIS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BKCLIENT_ZK_RETRY_BACKOFF_START_MILLIS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BKCLIENT_ZK_SESSION_TIMEOUT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BKCLIENT_ZK_SESSION_TIMEOUT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BOOKKEEPER_ACK_QUORUM_SIZE - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BOOKKEEPER_ACK_QUORUM_SIZE_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BOOKKEEPER_ACK_QUORUM_SIZE_OLD - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BOOKKEEPER_DIGEST_PW - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BOOKKEEPER_DIGEST_PW_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BOOKKEEPER_ENSEMBLE_SIZE - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BOOKKEEPER_ENSEMBLE_SIZE_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BOOKKEEPER_ENSEMBLE_SIZE_OLD - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BOOKKEEPER_WRITE_QUORUM_SIZE - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BOOKKEEPER_WRITE_QUORUM_SIZE_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BOOKKEEPER_WRITE_QUORUM_SIZE_OLD - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BPS_HARD_SERVICE_LIMIT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BPS_HARD_SERVICE_LIMIT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BPS_HARD_WRITE_LIMIT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BPS_HARD_WRITE_LIMIT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BPS_SOFT_SERVICE_LIMIT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BPS_SOFT_SERVICE_LIMIT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BPS_SOFT_WRITE_LIMIT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BPS_SOFT_WRITE_LIMIT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BPS_STREAM_ACQUIRE_SERVICE_LIMIT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_BPS_STREAM_ACQUIRE_SERVICE_LIMIT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_CHECK_LOG_EXISTENCE_BACKOFF_MAX_MS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_CHECK_LOG_EXISTENCE_BACKOFF_MAX_MS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_CHECK_LOG_EXISTENCE_BACKOFF_START_MS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_CHECK_LOG_EXISTENCE_BACKOFF_START_MS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_COMPRESSION_TYPE - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
CompressionCodec.Type String to use (See CompressionUtils) --------------------- ------------------------------------ NONE none LZ4 lz4 UNKNOWN any other instance of String.class
BKDL_COMPRESSION_TYPE_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_CREATE_STREAM_IF_NOT_EXISTS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_CREATE_STREAM_IF_NOT_EXISTS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_DATA_LATENCY_WARN_THRESHOLD_MS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_DATA_LATENCY_WARN_THRESHOLD_MS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_DESERIALIZE_RECORDSET_ON_READS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_DESERIALIZE_RECORDSET_ON_READS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_DISABLE_ROLLING_ON_LOG_SEGMENT_ERROR - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_DISABLE_ROLLING_ON_LOG_SEGMENT_ERROR_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_DYNAMIC_CONFIG_RELOAD_INTERVAL_SEC - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_DYNAMIC_CONFIG_RELOAD_INTERVAL_SEC_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_EI_INJECT_MAX_READAHEAD_DELAY_MS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_EI_INJECT_MAX_READAHEAD_DELAY_MS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_EI_INJECT_READAHEAD_BROKEN_ENTRIES - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_EI_INJECT_READAHEAD_BROKEN_ENTRIES_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_EI_INJECT_READAHEAD_DELAY - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_EI_INJECT_READAHEAD_DELAY_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_EI_INJECT_READAHEAD_DELAY_PERCENT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_EI_INJECT_READAHEAD_DELAY_PERCENT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_EI_INJECT_READAHEAD_STALL - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_EI_INJECT_READAHEAD_STALL_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_EI_INJECT_WRITE_DELAY - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_EI_INJECT_WRITE_DELAY_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_EI_INJECTED_WRITE_DELAY_MS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_EI_INJECTED_WRITE_DELAY_MS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_EI_INJECTED_WRITE_DELAY_PERCENT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_EI_INJECTED_WRITE_DELAY_PERCENT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ENABLE_FORCEREAD - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ENABLE_FORCEREAD_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ENABLE_IMMEDIATE_FLUSH - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ENABLE_IMMEDIATE_FLUSH_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ENABLE_LEDGER_ALLOCATOR_POOL - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ENABLE_LEDGER_ALLOCATOR_POOL_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ENABLE_PERSTREAM_STAT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ENABLE_PERSTREAM_STAT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ENABLE_READAHEAD - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ENABLE_READAHEAD_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ENABLE_RECORD_COUNTS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ENABLE_RECORD_COUNTS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ENABLE_TASK_EXECUTION_STATS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ENABLE_TASK_EXECUTION_STATS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ENCODE_REGION_ID_IN_VERSION - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ENCODE_REGION_ID_IN_VERSION_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ENSEMBLE_PLACEMENT_DNS_RESOLVER_CLASS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ENSEMBLE_PLACEMENT_DNS_RESOLVER_CLASS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_EXPLICIT_TRUNCATION_BY_APPLICATION - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_EXPLICIT_TRUNCATION_BY_APPLICATION_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_FAILFAST_ON_STREAM_NOT_READY - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_FAILFAST_ON_STREAM_NOT_READY_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_FEATURE_PROVIDER_CLASS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_FEDERATED_CHECK_EXISTENCE_WHEN_CACHE_MISS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_FEDERATED_CHECK_EXISTENCE_WHEN_CACHE_MISS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_FEDERATED_MAX_LOGS_PER_SUBNAMESPACE - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_FEDERATED_MAX_LOGS_PER_SUBNAMESPACE_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_FEDERATED_NAMESPACE_ENABLED - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_FEDERATED_NAMESPACE_ENABLED_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_FILE_FEATURE_PROVIDER_BASE_CONFIG_PATH - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_FILE_FEATURE_PROVIDER_BASE_CONFIG_PATH_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_FILE_FEATURE_PROVIDER_OVERLAY_CONFIG_PATH - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_FILE_FEATURE_PROVIDER_OVERLAY_CONFIG_PATH_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_FIRST_LOGSEGMENT_SEQUENCE_NUMBER - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_FIRST_LOGSEGMENT_SEQUENCE_NUMBER_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_FIRST_LOGSEGMENT_SEQUENCE_NUMBER_OLD - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_FIRST_NUM_ENTRIES_PER_READ_LAST_RECORD_SCAN - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_FIRST_NUM_ENTRIES_PER_READ_LAST_RECORD_SCAN_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_GLOBAL_OUTSTANDING_WRITE_LIMIT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_GLOBAL_OUTSTANDING_WRITE_LIMIT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_IS_DURABLE_WRITE_ENABLED - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_IS_DURABLE_WRITE_ENABLED_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LEDGER_ALLOCATOR_POOL_CORE_SIZE - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LEDGER_ALLOCATOR_POOL_CORE_SIZE_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LEDGER_ALLOCATOR_POOL_NAME - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LEDGER_ALLOCATOR_POOL_NAME_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LEDGER_ALLOCATOR_POOL_PATH - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LEDGER_ALLOCATOR_POOL_PATH_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LEDGER_METADATA_LAYOUT_VERSION - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LEDGER_METADATA_LAYOUT_VERSION_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LEDGER_METADATA_LAYOUT_VERSION_OLD - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LEDGER_METADATA_SKIP_MIN_VERSION_CHECK - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LEDGER_METADATA_SKIP_MIN_VERSION_CHECK_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LOCK_OP_TIMEOUT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LOCK_OP_TIMEOUT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LOCK_REACQUIRE_TIMEOUT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LOCK_REACQUIRE_TIMEOUT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LOCK_TIMEOUT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LOCK_TIMEOUT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LOG_FLUSH_TIMEOUT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LOG_FLUSH_TIMEOUT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LOGSEGMENT_CACHE_ENABLED - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LOGSEGMENT_CACHE_ENABLED_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LOGSEGMENT_CACHE_MAX_SIZE - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LOGSEGMENT_CACHE_MAX_SIZE_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LOGSEGMENT_CACHE_TTL_MS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LOGSEGMENT_CACHE_TTL_MS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LOGSEGMENT_NAME_VERSION - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LOGSEGMENT_NAME_VERSION_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LOGSEGMENT_ROLLING_CONCURRENCY - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LOGSEGMENT_ROLLING_CONCURRENCY_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LOGSEGMENT_SEQUENCE_NUMBER_VALIDATION_ENABLED - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_LOGSEGMENT_SEQUENCE_NUMBER_VALIDATION_ENABLED_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_MAX_ACQUIRED_PARTITIONS_PER_PROXY - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_MAX_ACQUIRED_PARTITIONS_PER_PROXY_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_MAX_CACHED_PARTITIONS_PER_PROXY - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_MAX_CACHED_PARTITIONS_PER_PROXY_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_MAX_LOGSEGMENT_BYTES - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_MAX_LOGSEGMENT_BYTES_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_MAX_NUM_ENTRIES_PER_READ_LAST_RECORD_SCAN - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_MAX_NUM_ENTRIES_PER_READ_LAST_RECORD_SCAN_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_MAX_PREFETCH_ENTRIES_PER_LOGSEGMENT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_MAX_PREFETCH_ENTRIES_PER_LOGSEGMENT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_MAXID_SANITYCHECK - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_MAXID_SANITYCHECK_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_METADATA_LATENCY_WARN_THRESHOLD_MS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_METADATA_LATENCY_WARN_THRESHOLD_MS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_MINIMUM_DELAY_BETWEEN_IMMEDIATE_FLUSH_MILLISECONDS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_MINIMUM_DELAY_BETWEEN_IMMEDIATE_FLUSH_MILLISECONDS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_NUM_LOCKSTATE_THREADS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_NUM_PREFETCH_ENTRIES_PER_LOGSEGMENT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_NUM_PREFETCH_ENTRIES_PER_LOGSEGMENT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_NUM_READAHEAD_WORKER_THREADS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_NUM_RESOURCE_RELEASE_THREADS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_NUM_WORKER_THREADS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_OUTPUT_BUFFER_SIZE - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_OUTPUT_BUFFER_SIZE_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_OUTPUT_BUFFER_SIZE_OLD - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_OUTSTANDING_WRITE_LIMIT_DARKMODE - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_OUTSTANDING_WRITE_LIMIT_DARKMODE_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_PER_WRITER_OUTSTANDING_WRITE_LIMIT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_PER_WRITER_OUTSTANDING_WRITE_LIMIT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_PERIODIC_FLUSH_FREQUENCY_MILLISECONDS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_PERIODIC_FLUSH_FREQUENCY_MILLISECONDS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_PERIODIC_KEEP_ALIVE_MILLISECONDS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_PERIODIC_KEEP_ALIVE_MILLISECONDS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READAHEAD_BATCHSIZE - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READAHEAD_BATCHSIZE_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READAHEAD_BATCHSIZE_OLD - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READAHEAD_MAX_RECORDS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READAHEAD_MAX_RECORDS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READAHEAD_MAX_RECORDS_OLD - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READAHEAD_NOSUCHLEDGER_EXCEPTION_ON_READLAC_ERROR_THRESHOLD_MILLIS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READAHEAD_NOSUCHLEDGER_EXCEPTION_ON_READLAC_ERROR_THRESHOLD_MILLIS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READAHEAD_SKIP_BROKEN_ENTRIES - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READAHEAD_SKIP_BROKEN_ENTRIES_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READAHEAD_WAITTIME - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READAHEAD_WAITTIME_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READAHEAD_WAITTIME_OLD - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READAHEAD_WAITTIME_ON_ENDOFSTREAM - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READAHEAD_WAITTIME_ON_ENDOFSTREAM_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READAHEAD_WAITTIME_ON_ENDOFSTREAM_OLD - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READER_ALERT_POSITION_ON_TRUNCATED - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READER_ALERT_POSITION_ON_TRUNCATED_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READER_IDLE_ERROR_THRESHOLD_MILLIS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READER_IDLE_ERROR_THRESHOLD_MILLIS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READER_IDLE_WARN_THRESHOLD_MILLIS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READER_IDLE_WARN_THRESHOLD_MILLIS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READER_IGNORE_TRUNCATION_STATUS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READER_IGNORE_TRUNCATION_STATUS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READER_POSITION_GAP_DETECTION_ENABLED - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READER_POSITION_GAP_DETECTION_ENABLED_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READLAC_OPTION - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READLAC_OPTION_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READLACLONGPOLL_TIMEOUT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_READLACLONGPOLL_TIMEOUT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_RETENTION_PERIOD_IN_HOURS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_RETENTION_PERIOD_IN_HOURS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_RETENTION_PERIOD_IN_HOURS_OLD - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ROLLING_INTERVAL_IN_MINUTES - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ROLLING_INTERVAL_IN_MINUTES_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ROLLING_INTERVAL_IN_MINUTES_OLD - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ROW_AWARE_ENSEMBLE_PLACEMENT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ROW_AWARE_ENSEMBLE_PLACEMENT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ROW_AWARE_ENSEMBLE_PLACEMENT_OLD - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_RPS_HARD_SERVICE_LIMIT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_RPS_HARD_SERVICE_LIMIT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_RPS_HARD_WRITE_LIMIT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_RPS_HARD_WRITE_LIMIT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_RPS_SOFT_SERVICE_LIMIT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_RPS_SOFT_SERVICE_LIMIT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_RPS_SOFT_WRITE_LIMIT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_RPS_SOFT_WRITE_LIMIT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_RPS_STREAM_ACQUIRE_SERVICE_LIMIT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_RPS_STREAM_ACQUIRE_SERVICE_LIMIT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_SCHEDULER_SHUTDOWN_TIMEOUT_MS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_SCHEDULER_SHUTDOWN_TIMEOUT_MS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_STREAM_CONFIG_ROUTER_CLASS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_STREAM_CONFIG_ROUTER_CLASS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_TASK_EXECUTION_WARN_TIME_MICROS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_TASK_EXECUTION_WARN_TIME_MICROS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_TIMEOUT_TIMER_NUM_TICKS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_TIMEOUT_TIMER_NUM_TICKS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_TIMEOUT_TIMER_TICK_DURATION_MS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_TIMEOUT_TIMER_TICK_DURATION_MS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_TRACE_READAHEAD_DELIVERY_LATENCY - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_TRACE_READAHEAD_DELIVERY_LATENCY_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_TRACE_READAHEAD_MEATDATA_CHANGES_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_TRACE_READAHEAD_METADATA_CHANGES - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_UNPARTITIONED_STREAM_NAME - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_UNPARTITIONED_STREAM_NAME_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_USE_DAEMON_THREAD - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_USE_DAEMON_THREAD_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_WRITE_LOCK_ENABLED - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_WRITE_LOCK_ENABLED_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ZK_ACL_ID - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ZK_ACL_ID_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ZK_NUM_RETRIES - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ZK_NUM_RETRIES_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ZK_REQUEST_RATE_LIMIT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ZK_REQUEST_RATE_LIMIT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ZK_RETRY_BACKOFF_MAX_MILLIS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ZK_RETRY_BACKOFF_MAX_MILLIS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ZK_RETRY_BACKOFF_START_MILLIS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ZK_RETRY_BACKOFF_START_MILLIS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ZK_SESSION_TIMEOUT_SECONDS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ZK_SESSION_TIMEOUT_SECONDS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ZKCLIENT_NUM_RETRY_THREADS - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKDL_ZKCLIENT_NUM_RETRY_THREADS_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConfiguration
 
BKTransmitException - Exception in org.apache.distributedlog.exceptions
Thrown when the send to bookkeeper fails.
BKTransmitException(String, int) - Constructor for exception org.apache.distributedlog.exceptions.BKTransmitException
 
blackoutSeconds - Variable in class org.apache.distributedlog.client.routing.ConsistentHashRoutingService
 
blackoutSeconds(int) - Method in class org.apache.distributedlog.client.routing.ConsistentHashRoutingService.Builder
 
BookKeeperClient - Class in org.apache.distributedlog
BookKeeper Client wrapper over BookKeeper.
BookKeeperClientBuilder - Class in org.apache.distributedlog
Builder to build bookkeeper client.
BroadCastStatsLogger - Class in org.apache.distributedlog.common.stats
Stats Loggers that broadcast stats to multiple StatsLogger.
BroadCastStatsLogger() - Constructor for class org.apache.distributedlog.common.stats.BroadCastStatsLogger
 
bufferSize(int) - Method in class org.apache.distributedlog.client.DistributedLogMultiStreamWriter.Builder
Set the output buffer size.
build() - Method in class org.apache.distributedlog.api.namespace.NamespaceBuilder
Build the namespace.
build() - Method in class org.apache.distributedlog.BookKeeperClientBuilder
 
build() - Method in class org.apache.distributedlog.client.DistributedLogMultiStreamWriter.Builder
Build the multi stream writer.
build(SocketAddress) - Method in interface org.apache.distributedlog.client.proxy.ProxyClient.Builder
Build a proxy client to address.
build(SocketAddress) - Method in class org.apache.distributedlog.client.proxy.ProxyClient.DefaultBuilder
 
build() - Method in class org.apache.distributedlog.client.routing.ConsistentHashRoutingService.Builder
 
build() - Method in class org.apache.distributedlog.client.routing.RegionsRoutingService.Builder
 
build() - Method in interface org.apache.distributedlog.client.routing.RoutingService.Builder
Build the routing service.
build() - Method in class org.apache.distributedlog.client.routing.SingleHostRoutingService.Builder
 
build() - Method in class org.apache.distributedlog.LocalDLMEmulator.Builder
 
build() - Method in class org.apache.distributedlog.LogSegmentMetadata.LogSegmentMetadataBuilder
 
build() - Method in class org.apache.distributedlog.namespace.DistributedLogNamespaceBuilder
Build the namespace.
build() - Method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Build distributedlog client.
build() - Method in class org.apache.distributedlog.service.DistributedLogCluster.Builder
 
build() - Method in class org.apache.distributedlog.ZooKeeperClientBuilder
Build a zookeeper client.
buildClient(DistributedLogClientBuilder) - Static method in class org.apache.distributedlog.service.ClientUtils
 
Builder() - Constructor for class org.apache.distributedlog.LocalDLMEmulator.Builder
 
buildMonitorClient() - Method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Build monitor service client.
buildReader() - Method in class org.apache.distributedlog.Entry.Builder
 
buildRoutingService(String) - Static method in class org.apache.distributedlog.client.routing.RoutingUtils
Building routing service from finagleNameStr.
buildRoutingService(ServerSet) - Static method in class org.apache.distributedlog.client.routing.RoutingUtils
Building routing service from serverSet.
buildRoutingService(SocketAddress) - Static method in class org.apache.distributedlog.client.routing.RoutingUtils
Building routing service from address.
buildRoutingService(RoutingService) - Static method in class org.apache.distributedlog.client.routing.RoutingUtils
Build routing service builder of a routing service routingService.
bulkWrite(ResponseHeader) - Static method in class org.apache.distributedlog.service.ResponseUtils
 
bulkWriteDenied() - Static method in class org.apache.distributedlog.service.ResponseUtils
 
bulkWriteSuccess() - Static method in class org.apache.distributedlog.service.ResponseUtils
 
ByteBufUtils - Class in org.apache.distributedlog.common.util
Utils to handle with ByteBuf.
ByteBufUtils() - Constructor for class org.apache.distributedlog.common.util.ByteBufUtils
 

C

changeAddrs(List<Address>) - Method in class org.apache.distributedlog.client.routing.TestName
 
changes(AbstractFunction1<Addr, BoxedUnit>) - Method in class org.apache.distributedlog.client.routing.TestName
 
changeSequenceNumber(LogSegmentMetadata, long) - Method in class org.apache.distributedlog.metadata.LogSegmentMetadataStoreUpdater
 
changeSequenceNumber(LogSegmentMetadata, long) - Method in interface org.apache.distributedlog.metadata.MetadataUpdater
Change ledger sequence number of segment to given logSegmentSeqNo.
check(String) - Method in class org.apache.distributedlog.client.DistributedLogClientImpl
 
check(String) - Method in interface org.apache.distributedlog.client.monitor.MonitorServiceClient
Check a given stream.
checkBookiesUp(int, int) - Method in class org.apache.distributedlog.LocalDLMEmulator
Check that a number of bookies are available
checkClosedOrInError() - Method in class org.apache.distributedlog.BookKeeperClient
 
checkOwnership() - Method in interface org.apache.distributedlog.lock.DistributedLock
Check if the lock is held.
checkOwnership() - Method in class org.apache.distributedlog.lock.NopDistributedLock
 
checkOwnership() - Method in class org.apache.distributedlog.lock.ZKDistributedLock
Check if lock is held.
checkOwnershipAndReacquire() - Method in interface org.apache.distributedlog.lock.DistributedLock
Check if hold lock.
checkOwnershipAndReacquire() - Method in class org.apache.distributedlog.lock.NopDistributedLock
 
checkOwnershipAndReacquire() - Method in class org.apache.distributedlog.lock.ZKDistributedLock
Check if hold lock, if it doesn't, then re-acquire the lock.
checksum(boolean) - Method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Enable checksum on requests to the proxy.
CHECKSUM_FAILED - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
ChecksumFailedException - Exception in org.apache.distributedlog.exceptions
Exception thrown when checksum failures occurred.
ChecksumFailedException() - Constructor for exception org.apache.distributedlog.exceptions.ChecksumFailedException
 
circle - Variable in class org.apache.distributedlog.client.routing.ConsistentHashRoutingService
 
clearPropertyDirect(String) - Method in class org.apache.distributedlog.common.config.ConcurrentBaseConfiguration
 
client(DistributedLogClient) - Method in class org.apache.distributedlog.client.DistributedLogMultiStreamWriter.Builder
Set the distributedlog client used for multi stream writer.
CLIENT_CLOSED - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
clientBuilder(ClientBuilder) - Method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Set underlying finagle client builder.
ClientConfig - Class in org.apache.distributedlog.client
Client Config.
ClientConfig() - Constructor for class org.apache.distributedlog.client.ClientConfig
 
clientId(String) - Method in class org.apache.distributedlog.api.namespace.NamespaceBuilder
Client Id used for accessing the namespace
clientId(String) - Method in class org.apache.distributedlog.namespace.DistributedLogNamespaceBuilder
Client Id used for accessing the namespace.
clientId(ClientId) - Method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Client ID.
ClientStats - Class in org.apache.distributedlog.client.stats
Client Stats.
ClientStats(StatsReceiver, boolean, RegionResolver) - Constructor for class org.apache.distributedlog.client.stats.ClientStats
 
ClientStatsLogger - Class in org.apache.distributedlog.client.stats
Stats Logger to collect client stats.
ClientStatsLogger(StatsReceiver) - Constructor for class org.apache.distributedlog.client.stats.ClientStatsLogger
 
ClientUtils - Class in org.apache.distributedlog.service
DistributedLog Client Related Utils.
ClientUtils() - Constructor for class org.apache.distributedlog.service.ClientUtils
 
clockTicker(Ticker) - Method in class org.apache.distributedlog.client.DistributedLogMultiStreamWriter.Builder
Ticker for timing.
close() - Method in interface org.apache.distributedlog.api.MetadataAccessor
Close the distributed log metadata, freeing any resources it may hold.
close() - Method in interface org.apache.distributedlog.api.namespace.Namespace
Close the namespace.
close() - Method in class org.apache.distributedlog.AppendOnlyStreamWriter
 
close() - Method in class org.apache.distributedlog.BKDistributedLogNamespace
Close the distributed log manager factory, freeing any resources it may hold.
close() - Method in class org.apache.distributedlog.BookKeeperClient
 
close() - Method in class org.apache.distributedlog.client.DistributedLogClientImpl
 
close() - Method in class org.apache.distributedlog.client.DistributedLogMultiStreamWriter
 
close() - Method in interface org.apache.distributedlog.client.monitor.MonitorServiceClient
Close the client.
close() - Method in class org.apache.distributedlog.client.proxy.ClusterClient
 
close() - Method in class org.apache.distributedlog.client.proxy.ProxyClient
 
close() - Method in class org.apache.distributedlog.client.proxy.ProxyClientManager
 
close() - Method in class org.apache.distributedlog.client.serverset.DLZkServerSet
 
close() - Method in interface org.apache.distributedlog.common.util.PermitLimiter
Close the resources created by the limiter.
close() - Method in interface org.apache.distributedlog.common.util.PermitManager
Release the resources.
close() - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
close() - Method in interface org.apache.distributedlog.namespace.DistributedLogNamespace
Close the namespace.
close() - Method in interface org.apache.distributedlog.service.DistributedLogClient
Close the client.
close() - Method in class org.apache.distributedlog.service.DistributedLogServer
Close the server.
close() - Method in class org.apache.distributedlog.service.MonitorService
Close the server.
close() - Method in class org.apache.distributedlog.ZooKeeperClient
Closes the the underlying zookeeper instance.
CLOSE_FUNC - Static variable in interface org.apache.distributedlog.io.AsyncCloseable
 
CLOSE_FUNC_IGNORE_ERRORS - Static variable in interface org.apache.distributedlog.io.AsyncCloseable
 
closed - Variable in class org.apache.distributedlog.BKDistributedLogNamespace
 
closeInternal() - Method in class org.apache.distributedlog.ZooKeeperClient
Closes the current connection if any expiring the current ZooKeeper session.
ClusterClient - Class in org.apache.distributedlog.client.proxy
Cluster client.
ClusterClient(Service<ThriftClientRequest, byte[]>, DistributedLogService.ServiceIface) - Constructor for class org.apache.distributedlog.client.proxy.ClusterClient
 
code - Variable in exception org.apache.distributedlog.exceptions.DLException
 
code() - Method in enum org.apache.distributedlog.io.CompressionCodec.Type
 
collect(List<CompletableFuture<T>>) - Static method in class org.apache.distributedlog.common.concurrent.FutureUtils
 
commit() - Method in interface org.apache.distributedlog.api.LogWriter
Flush and sync all data that is ready to be flush LogWriter.flush() into underlying persistent store.
commit() - Method in interface org.apache.distributedlog.logsegment.LogSegmentWriter
Commit the current acknowledged data.
COMPARATOR - Static variable in class org.apache.distributedlog.LogSegmentMetadata
 
compareTo(DLSN) - Method in class org.apache.distributedlog.DLSN
 
complete(CompletableFuture<T>, T) - Static method in class org.apache.distributedlog.common.concurrent.FutureUtils
 
COMPLETED_LOGSEGMENT_PREFIX - Static variable in class org.apache.distributedlog.DistributedLogConstants
 
completeExceptionally(CompletableFuture<T>, Throwable) - Static method in class org.apache.distributedlog.common.concurrent.FutureUtils
 
completeProxyRequest(SocketAddress, StatusCode, long) - Method in class org.apache.distributedlog.client.stats.ClientStats
 
completeProxyRequest(StatusCode, long) - Method in class org.apache.distributedlog.client.stats.ClientStatsLogger
 
completeRequest(SocketAddress, long, int) - Method in class org.apache.distributedlog.client.stats.OpStats
 
completeRequest(long, int) - Method in class org.apache.distributedlog.client.stats.OpStatsLogger
 
completeTransmit(long, long, long) - Method in interface org.apache.distributedlog.LogRecordSetBuffer
Complete transmit.
completionTime - Variable in class org.apache.distributedlog.LogSegmentMetadata.LogSegmentMetadataBuilder
 
compress(ByteBuf, int) - Method in interface org.apache.distributedlog.io.CompressionCodec
Return the compressed data as a byte buffer.
compress(ByteBuf, int) - Method in class org.apache.distributedlog.io.IdentityCompressionCodec
 
compress(ByteBuf, int) - Method in class org.apache.distributedlog.io.LZ4CompressionCodec
 
CompressionBenchmark - Class in org.apache.distributedlog.tests
Benchmarking serialization and deserilization.
CompressionBenchmark() - Constructor for class org.apache.distributedlog.tests.CompressionBenchmark
 
compressionCodec(CompressionCodec.Type) - Method in class org.apache.distributedlog.client.DistributedLogMultiStreamWriter.Builder
Set compression codec.
CompressionCodec - Interface in org.apache.distributedlog.io
Common interface for compression/decompression operations using different compression codecs.
CompressionCodec.Type - Enum in org.apache.distributedlog.io
Enum specifying the currently supported compression types.
CompressionUtils - Class in org.apache.distributedlog.io
Utils for compression related operations.
CompressionUtils() - Constructor for class org.apache.distributedlog.io.CompressionUtils
 
ConcurrentBaseConfiguration - Class in org.apache.distributedlog.common.config
Configuration view built on concurrent hash map for fast thread-safe access.
ConcurrentBaseConfiguration() - Constructor for class org.apache.distributedlog.common.config.ConcurrentBaseConfiguration
 
ConcurrentConstConfiguration - Class in org.apache.distributedlog.common.config
Invariant thread-safe view of some configuration.
ConcurrentConstConfiguration(Configuration) - Constructor for class org.apache.distributedlog.common.config.ConcurrentConstConfiguration
 
conf(DistributedLogConfiguration) - Method in class org.apache.distributedlog.api.namespace.NamespaceBuilder
DistributedLog Configuration used for the namespace.
conf - Variable in class org.apache.distributedlog.feature.AbstractFeatureProvider
 
conf(DistributedLogConfiguration) - Method in class org.apache.distributedlog.namespace.DistributedLogNamespaceBuilder
DistributedLog Configuration used for the namespace.
ConfigurationListener - Interface in org.apache.distributedlog.common.config
Configuration listener triggered when reloading configuration settings.
ConfigurationSubscription - Class in org.apache.distributedlog.common.config
ConfigurationSubscription publishes a reloading, thread-safe view of file configuration.
ConfigurationSubscription(ConcurrentBaseConfiguration, List<FileConfigurationBuilder>, ScheduledExecutorService, int, TimeUnit) - Constructor for class org.apache.distributedlog.common.config.ConfigurationSubscription
 
connectionTimeoutMs(int) - Method in class org.apache.distributedlog.ZooKeeperClientBuilder
Set zookeeper connection timeout in milliseconds
connectZooKeeper(String, int) - Static method in class org.apache.distributedlog.LocalDLMEmulator
 
connectZooKeeper(String, int, int) - Static method in class org.apache.distributedlog.LocalDLMEmulator
 
ConsistentHashRoutingService - Class in org.apache.distributedlog.client.routing
Consistent Hashing Based RoutingService.
ConsistentHashRoutingService.Builder - Class in org.apache.distributedlog.client.routing
Builder for building consistent hash based routing service.
containsKey(String) - Method in class org.apache.distributedlog.common.config.ConcurrentBaseConfiguration
 
CoreFeatureKeys - Enum in org.apache.distributedlog.feature
List of feature keys used by distributedlog core
create(String) - Method in class org.apache.distributedlog.client.DistributedLogClientImpl
 
create(URI) - Method in class org.apache.distributedlog.metadata.DLMetadata
 
create(BKDLConfig) - Static method in class org.apache.distributedlog.metadata.DLMetadata
 
create(String) - Method in interface org.apache.distributedlog.service.DistributedLogClient
Create a stream with name stream.
create(String, WriteContext) - Method in class org.apache.distributedlog.service.DistributedLogServiceImpl
 
createAccessControlManager() - Method in interface org.apache.distributedlog.api.namespace.Namespace
Create an access control manager to manage/check acl for logs.
createAccessControlManager() - Method in class org.apache.distributedlog.BKDistributedLogNamespace
 
createAccessControlManager() - Method in interface org.apache.distributedlog.namespace.DistributedLogNamespace
Create an access control manager to manage/check acl for logs.
createClient(SocketAddress) - Method in class org.apache.distributedlog.client.proxy.ProxyClientManager
Create a client to proxy address.
createDLMURI(String) - Static method in class org.apache.distributedlog.LocalDLMEmulator
 
createDLMURI(String, String) - Static method in class org.apache.distributedlog.LocalDLMEmulator
 
createFuture() - Static method in class org.apache.distributedlog.common.concurrent.FutureUtils
 
createLedger(int, int, int) - Method in class org.apache.distributedlog.BookKeeperClient
 
createLock(String, DistributedLockContext) - Method in interface org.apache.distributedlog.lock.SessionLockFactory
Create a lock with lock path.
createLock(String, DistributedLockContext) - Method in class org.apache.distributedlog.lock.ZKSessionLockFactory
 
createLog(String) - Method in interface org.apache.distributedlog.api.namespace.Namespace
Create a log named logName.
createLog(String) - Method in class org.apache.distributedlog.BKDistributedLogNamespace
 
createLog(String) - Method in interface org.apache.distributedlog.metadata.LogMetadataStore
Create a stream and return it is namespace location.
createLog(String) - Method in interface org.apache.distributedlog.namespace.DistributedLogNamespace
Create a log named logName.
createLogSegment(Transaction<Object>, LogSegmentMetadata, Transaction.OpListener<Void>) - Method in interface org.apache.distributedlog.logsegment.LogSegmentMetadataStore
Create a log segment segment under transaction txn.
createMetadataUpdater(DistributedLogConfiguration, LogSegmentMetadataStore) - Static method in class org.apache.distributedlog.metadata.LogSegmentMetadataStoreUpdater
 
createOrUpdateMetadata(byte[]) - Method in interface org.apache.distributedlog.api.MetadataAccessor
 
createReadLock(LogMetadataForReader, Optional<String>) - Method in interface org.apache.distributedlog.metadata.LogStreamMetadataStore
Create the read lock for the log stream.
createWriteLock(LogMetadataForWriter) - Method in interface org.apache.distributedlog.metadata.LogStreamMetadataStore
Create the write lock for the log stream.

D

decompress(ByteBuf, int) - Method in interface org.apache.distributedlog.io.CompressionCodec
Return the decompressed data as a byte array.
decompress(ByteBuf, int) - Method in class org.apache.distributedlog.io.IdentityCompressionCodec
 
decompress(ByteBuf, int) - Method in class org.apache.distributedlog.io.LZ4CompressionCodec
 
DEFAULT_FILTER - Static variable in interface org.apache.distributedlog.logsegment.LogSegmentFilter
 
DefaultFeatureProvider - Class in org.apache.distributedlog.feature
Default feature provider which disable all features by default.
DefaultFeatureProvider(String, DistributedLogConfiguration, StatsLogger) - Constructor for class org.apache.distributedlog.feature.DefaultFeatureProvider
 
DefaultRegionResolver - Class in org.apache.distributedlog.client.resolver
Default implementation of RegionResolver.
DefaultRegionResolver() - Constructor for class org.apache.distributedlog.client.resolver.DefaultRegionResolver
 
DefaultRegionResolver(Map<SocketAddress, String>) - Constructor for class org.apache.distributedlog.client.resolver.DefaultRegionResolver
 
DefaultSpeculativeRequestExecutionPolicy - Class in org.apache.distributedlog.client.speculative
Default implementation of SpeculativeRequestExecutionPolicy.
DefaultSpeculativeRequestExecutionPolicy(int, int, float) - Constructor for class org.apache.distributedlog.client.speculative.DefaultSpeculativeRequestExecutionPolicy
 
delete() - Method in interface org.apache.distributedlog.api.DistributedLogManager
Delete the log.
delete(String) - Method in class org.apache.distributedlog.client.DistributedLogClientImpl
 
delete() - Method in interface org.apache.distributedlog.DistributedLogManager
Delete the log.
delete() - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
delete() - Method in interface org.apache.distributedlog.io.AsyncDeleteable
Releases any system resources associated with this and delete the source.
delete(String) - Method in interface org.apache.distributedlog.service.DistributedLogClient
Delete a given stream stream.
delete(String, WriteContext) - Method in class org.apache.distributedlog.service.DistributedLogServiceImpl
 
deleteLedger(long, boolean) - Method in class org.apache.distributedlog.BookKeeperClient
 
deleteLog(String) - Method in interface org.apache.distributedlog.api.namespace.Namespace
Delete a log named logName.
deleteLog(String) - Method in class org.apache.distributedlog.BKDistributedLogNamespace
 
deleteLog(URI, String) - Method in interface org.apache.distributedlog.metadata.LogStreamMetadataStore
Delete the metadata of a log.
deleteLog(String) - Method in interface org.apache.distributedlog.namespace.DistributedLogNamespace
Delete a log named logName.
deleteLogSegment(LogSegmentMetadata) - Method in interface org.apache.distributedlog.logsegment.LogSegmentEntryStore
Delete the actual log segment from the entry store.
deleteLogSegment(Transaction<Object>, LogSegmentMetadata, Transaction.OpListener<Void>) - Method in interface org.apache.distributedlog.logsegment.LogSegmentMetadataStore
Delete a log segment segment under transaction txn.
deleteMetadata() - Method in interface org.apache.distributedlog.api.MetadataAccessor
 
deleteSubscriber(String) - Method in interface org.apache.distributedlog.api.subscription.SubscriptionsStore
Delete the subscriber subscriberId permanently.
deleteSubscriber(String) - Method in interface org.apache.distributedlog.subscription.SubscriptionsStore
Delete the subscriber subscriberId permanently.
deniedHeader() - Static method in class org.apache.distributedlog.service.ResponseUtils
 
DESC_COMPARATOR - Static variable in class org.apache.distributedlog.LogSegmentMetadata
 
deserialize(String) - Static method in class org.apache.distributedlog.DLSN
Deserialize the DLSN from base64 encoded string dlsn.
deserialize(byte[]) - Method in interface org.apache.distributedlog.metadata.DLConfig
Deserialize the dl config from a readable stream.
deserialize(URI, byte[]) - Static method in class org.apache.distributedlog.metadata.DLMetadata
Deserialize dl metadata of given uri from a given bytes array.
deserialize(String) - Static method in class org.apache.distributedlog.service.DLSocketAddress
Deserialize proxy address from a string representation.
deserializeBytes(byte[]) - Static method in class org.apache.distributedlog.DLSN
Deserialize the DLSN from bytes array.
deserializeRecordSet(boolean) - Method in class org.apache.distributedlog.Entry.Builder
Enable/disable deserialize record set.
diff(Set<String>) - Method in class org.apache.distributedlog.logsegment.PerStreamLogSegmentCache
Diff with new received segment list segmentReceived.
DigestCredentials(String, String) - Constructor for class org.apache.distributedlog.ZooKeeperClient.DigestCredentials
 
DISALLOW_PLACEMENT_IN_REGION_FEATURE_NAME - Static variable in class org.apache.distributedlog.DistributedLogConstants
 
disallowObtainPermits(PermitManager.Permit) - Method in interface org.apache.distributedlog.common.util.PermitManager
Disallow obtaining permits.
DistributedLock - Interface in org.apache.distributedlog.lock
Interface for distributed locking
DistributedLogAnnotations - Class in org.apache.distributedlog.common.annotations
Common annotation types.
DistributedLogAnnotations() - Constructor for class org.apache.distributedlog.common.annotations.DistributedLogAnnotations
 
DistributedLogAnnotations.Compression - Annotation Type in org.apache.distributedlog.common.annotations
Annotation to specify the occurrence of a compression operation.
DistributedLogAnnotations.FlakyTest - Annotation Type in org.apache.distributedlog.common.annotations
Annotation to identify flaky tests in DistributedLog.
DistributedLogClient - Interface in org.apache.distributedlog.service
Interface for distributedlog client.
DistributedLogClientBuilder - Class in org.apache.distributedlog.service
Builder to build DistributedLogClient.
DistributedLogClientImpl - Class in org.apache.distributedlog.client
Implementation of distributedlog client.
DistributedLogClientImpl(String, ClientId, RoutingService, ClientBuilder, ClientConfig, Optional<ClusterClient>, StatsReceiver, StatsReceiver, RegionResolver, boolean) - Constructor for class org.apache.distributedlog.client.DistributedLogClientImpl
 
DistributedLogCluster - Class in org.apache.distributedlog.service
DistributedLog Cluster is an emulator to run distributedlog components.
DistributedLogCluster.Builder - Class in org.apache.distributedlog.service
Builder to build distributedlog cluster.
DistributedLogCluster.DLServer - Class in org.apache.distributedlog.service
Run a distributedlog proxy server.
DistributedLogConfiguration - Class in org.apache.distributedlog
DistributedLog Configuration.
DistributedLogConfiguration() - Constructor for class org.apache.distributedlog.DistributedLogConfiguration
Construct distributedlog configuration with default settings.
DistributedLogConstants - Class in org.apache.distributedlog
Constants used in DistributedLog.
DistributedLogConstants() - Constructor for class org.apache.distributedlog.DistributedLogConstants
 
DistributedLogManager - Interface in org.apache.distributedlog.api
A DistributedLogManager is responsible for managing a single place of storing edit logs.
DistributedLogManager - Interface in org.apache.distributedlog
A DistributedLogManager is responsible for managing a single place of storing edit logs.
DistributedLogManagerImpl - Class in org.apache.distributedlog
The wrapper of DistributedLogManager.
DistributedLogManagerImpl(DistributedLogManager) - Constructor for class org.apache.distributedlog.DistributedLogManagerImpl
 
DistributedLogMultiStreamWriter - Class in org.apache.distributedlog.client
Write to multiple streams.
DistributedLogMultiStreamWriter.Builder - Class in org.apache.distributedlog.client
Builder for the multi stream writer.
DistributedLogNamespace - Interface in org.apache.distributedlog.namespace
A namespace is the basic unit for managing a set of distributedlogs.
DistributedLogNamespaceBuilder - Class in org.apache.distributedlog.namespace
Builder to construct a DistributedLogNamespace.
DistributedLogServer - Class in org.apache.distributedlog.service
Running the distributedlog proxy server.
DistributedLogServerApp - Class in org.apache.distributedlog.service
The launcher of the distributedlog proxy server.
DistributedLogServiceImpl - Class in org.apache.distributedlog.service
Implementation of distributedlog thrift service.
DL_INTERRUPTED_EXCEPTION_RESULT_CODE - Static variable in class org.apache.distributedlog.DistributedLogConstants
 
DLClientClosedException - Exception in org.apache.distributedlog.exceptions
Exceptions thrown when a distributedlog client is closed.
DLClientClosedException(String) - Constructor for exception org.apache.distributedlog.exceptions.DLClientClosedException
 
DLClientClosedException(String, Throwable) - Constructor for exception org.apache.distributedlog.exceptions.DLClientClosedException
 
dlConf(DistributedLogConfiguration) - Method in class org.apache.distributedlog.service.DistributedLogCluster.Builder
Set the distributedlog configuration.
dlConfig(DistributedLogConfiguration) - Method in class org.apache.distributedlog.BookKeeperClientBuilder
dlConfig used to configure bookkeeper client.
DLConfig - Interface in org.apache.distributedlog.metadata
Specific config of a given implementation of DL
DLException - Exception in org.apache.distributedlog.exceptions
The basic exception of all distributedlog exceptions.
DLException(int) - Constructor for exception org.apache.distributedlog.exceptions.DLException
 
DLException(int, String) - Constructor for exception org.apache.distributedlog.exceptions.DLException
 
DLException(int, Throwable) - Constructor for exception org.apache.distributedlog.exceptions.DLException
 
DLException(int, String, Throwable) - Constructor for exception org.apache.distributedlog.exceptions.DLException
 
DLIllegalStateException - Exception in org.apache.distributedlog.exceptions
Signals that a method has been invoked at an illegal or inappropriate time.
DLIllegalStateException(String) - Constructor for exception org.apache.distributedlog.exceptions.DLIllegalStateException
 
DLIllegalStateException(String, Throwable) - Constructor for exception org.apache.distributedlog.exceptions.DLIllegalStateException
 
DLInterruptedException - Exception in org.apache.distributedlog.exceptions
An interrupted exception wrapper indicates dl operations are interrupted.
DLInterruptedException(String) - Constructor for exception org.apache.distributedlog.exceptions.DLInterruptedException
 
DLInterruptedException(String, Throwable) - Constructor for exception org.apache.distributedlog.exceptions.DLInterruptedException
 
DLMetadata - Class in org.apache.distributedlog.metadata
Metadata of a given DL instance.
DLMetadata(String, DLConfig) - Constructor for class org.apache.distributedlog.metadata.DLMetadata
 
DLOG_NAMESPACE - Static variable in class org.apache.distributedlog.LocalDLMEmulator
 
DLServer(DistributedLogConfiguration, URI, int, boolean) - Constructor for class org.apache.distributedlog.service.DistributedLogCluster.DLServer
 
dlServer - Variable in class org.apache.distributedlog.service.DistributedLogCluster.DLServer
 
DLSN - Class in org.apache.distributedlog
DistributedLog Sequence Number (DLSN) is the system generated sequence number for log record.
DLSN(long, long, long) - Constructor for class org.apache.distributedlog.DLSN
 
DLSocketAddress - Class in org.apache.distributedlog.service
Socket Address identifier for a DL proxy.
DLSocketAddress(int, InetSocketAddress) - Constructor for class org.apache.distributedlog.service.DLSocketAddress
 
DLZkServerSet - Class in org.apache.distributedlog.client.serverset
A wrapper over zookeeper client and its server set.
DLZkServerSet(ZooKeeperClient, ServerSet) - Constructor for class org.apache.distributedlog.client.serverset.DLZkServerSet
 
DNSResolver - Class in org.apache.distributedlog.net
Abstract DNS resolver for bookkeeper ensemble placement.
DNSResolver() - Constructor for class org.apache.distributedlog.net.DNSResolver
Construct the default dns resolver without host-region overrides.
DNSResolver(String) - Constructor for class org.apache.distributedlog.net.DNSResolver
Construct the dns resolver with host-region overrides.
DNSResolverForRacks - Class in org.apache.distributedlog.net
Resolve the dns by racks.
DNSResolverForRacks() - Constructor for class org.apache.distributedlog.net.DNSResolverForRacks
 
DNSResolverForRacks(String) - Constructor for class org.apache.distributedlog.net.DNSResolverForRacks
 
DNSResolverForRows - Class in org.apache.distributedlog.net
Resolve the dns by rows.
DNSResolverForRows() - Constructor for class org.apache.distributedlog.net.DNSResolverForRows
 
DNSResolverForRows(String) - Constructor for class org.apache.distributedlog.net.DNSResolverForRows
 
domainNameToNetworkLocation - Variable in class org.apache.distributedlog.net.DNSResolver
 
DryrunLogSegmentMetadataStoreUpdater - Class in org.apache.distributedlog.metadata
 
DryrunLogSegmentMetadataStoreUpdater(DistributedLogConfiguration, LogSegmentMetadataStore) - Constructor for class org.apache.distributedlog.metadata.DryrunLogSegmentMetadataStoreUpdater
 
DynamicConfigurationFeatureProvider - Class in org.apache.distributedlog.feature
Feature Provider based dynamic configuration.
DynamicConfigurationFeatureProvider(String, DistributedLogConfiguration, StatsLogger) - Constructor for class org.apache.distributedlog.feature.DynamicConfigurationFeatureProvider
 
dynConf(DynamicDistributedLogConfiguration) - Method in class org.apache.distributedlog.api.namespace.NamespaceBuilder
Dynamic DistributedLog Configuration used for the namespace
dynConf(DynamicDistributedLogConfiguration) - Method in class org.apache.distributedlog.namespace.DistributedLogNamespaceBuilder
Dynamic DistributedLog Configuration used for the namespace.

E

EMPTY_BYTES - Static variable in class org.apache.distributedlog.DistributedLogConstants
 
EMPTY_LOGSEGMENT_TX_ID - Static variable in class org.apache.distributedlog.DistributedLogConstants
 
END_OF_LOG_SEGMENT - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
END_OF_STREAM - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
EndOfLogSegmentException - Exception in org.apache.distributedlog.exceptions
Exception thrown when reach end of the log segment.
EndOfLogSegmentException(String) - Constructor for exception org.apache.distributedlog.exceptions.EndOfLogSegmentException
 
EndOfStreamException - Exception in org.apache.distributedlog.exceptions
Exception thrown when a reader reaches end of a sealed log stream.
EndOfStreamException(String) - Constructor for exception org.apache.distributedlog.exceptions.EndOfStreamException
 
ensure(CompletableFuture<T>, Runnable) - Static method in class org.apache.distributedlog.common.concurrent.FutureUtils
 
Entry - Class in org.apache.distributedlog
A set of LogRecords.
Entry() - Constructor for class org.apache.distributedlog.Entry
 
Entry.Builder - Class in org.apache.distributedlog
Build the record set object.
Entry.Reader - Interface in org.apache.distributedlog
Reader to read LogRecords from this record set.
Entry.Writer - Interface in org.apache.distributedlog
Writer to append LogRecords to Entry.
envelopeEntries - Variable in class org.apache.distributedlog.LogSegmentMetadata.LogSegmentMetadataBuilder
 
EpochChangedException - Exception in org.apache.distributedlog.lock
Exception indicates that epoch already changed when executing a given LockAction.
EpochChangedException(String, int, int) - Constructor for exception org.apache.distributedlog.lock.EpochChangedException
 
equals(Object) - Method in class org.apache.distributedlog.DLSN
 
equals(Object) - Method in class org.apache.distributedlog.LogSegmentMetadata
 
equals(Object) - Method in class org.apache.distributedlog.metadata.DLMetadata
 
equals(Object) - Method in class org.apache.distributedlog.service.DLSocketAddress
 
eventLoopGroup(EventLoopGroup) - Method in class org.apache.distributedlog.BookKeeperClientBuilder
Build BookKeeper client using existing channelFactory.
EVERYONE_READ_CREATOR_ALL - Static variable in class org.apache.distributedlog.DistributedLogConstants
 
exception(Throwable) - Static method in class org.apache.distributedlog.common.concurrent.FutureUtils
 
exception(ResponseHeader) - Static method in class org.apache.distributedlog.protocol.util.ProtocolUtils
 
exceptionToHeader(Throwable) - Static method in class org.apache.distributedlog.service.ResponseUtils
 

F

fail(Throwable) - Method in class org.apache.distributedlog.common.concurrent.AsyncSemaphore
Fail the semaphore and stop it from distributing further permits.
failProxyRequest(SocketAddress, Throwable, long) - Method in class org.apache.distributedlog.client.stats.ClientStats
 
failProxyRequest(Throwable, long) - Method in class org.apache.distributedlog.client.stats.ClientStatsLogger
 
failRequest(SocketAddress, long, int) - Method in class org.apache.distributedlog.client.stats.OpStats
 
failRequest(long, int) - Method in class org.apache.distributedlog.client.stats.OpStatsLogger
 
FatalErrorHandler - Interface in org.apache.distributedlog.service
Implement handling for an unrecoverable error.
featureProvider(FeatureProvider) - Method in class org.apache.distributedlog.api.namespace.NamespaceBuilder
Feature provider used to control the availabilities of features in the namespace.
featureProvider(Optional<FeatureProvider>) - Method in class org.apache.distributedlog.BookKeeperClientBuilder
 
featureProvider(FeatureProvider) - Method in class org.apache.distributedlog.namespace.DistributedLogNamespaceBuilder
Feature provider used to control the availabilities of features in the namespace.
FileConfigurationBuilder - Interface in org.apache.distributedlog.common.config
Abstract out FileConfiguration subclass construction.
filter(Collection<String>) - Method in interface org.apache.distributedlog.logsegment.LogSegmentFilter
Filter the log segments from the full log segment list.
finagleNameStr(String) - Method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Name to access proxy services.
finagleNameStrs(String, String...) - Method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Finagle name strs to access proxy services.
FIRST_LOGSEGMENT_SEQNO - Static variable in class org.apache.distributedlog.DistributedLogConstants
 
firstSpeculativeTimeoutMs(int) - Method in class org.apache.distributedlog.client.DistributedLogMultiStreamWriter.Builder
Set the first speculative timeout in milliseconds.
firstTxId - Variable in class org.apache.distributedlog.LogSegmentMetadata.LogSegmentMetadataBuilder
 
flush() - Method in interface org.apache.distributedlog.api.LogWriter
All data that has been written to the stream so far will be sent to persistent storage.
flush() - Method in interface org.apache.distributedlog.logsegment.LogSegmentWriter
Transmit the buffered data and wait for it being persisted and return the last acknowledged transaction id.
FLUSH_TIMEOUT - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
flushAndSync() - Method in interface org.apache.distributedlog.LogWriter
Flush and sync all data that is ready to be flush LogWriter.setReadyToFlush() into underlying persistent store.
FlushException - Exception in org.apache.distributedlog.exceptions
Exception indicates that errors occurred on flushing data.
FlushException(String, long, long) - Constructor for exception org.apache.distributedlog.exceptions.FlushException
 
FlushException(String, long, long, Throwable) - Constructor for exception org.apache.distributedlog.exceptions.FlushException
 
flushIntervalMicros(int) - Method in class org.apache.distributedlog.client.DistributedLogMultiStreamWriter.Builder
Set the flush interval in microseconds.
flushIntervalMs(int) - Method in class org.apache.distributedlog.client.DistributedLogMultiStreamWriter.Builder
Set the flush interval in milliseconds.
force(boolean) - Method in class org.apache.distributedlog.AppendOnlyStreamWriter
 
FOUND - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
FUTURE_TIMEOUT_IMMEDIATE - Static variable in class org.apache.distributedlog.DistributedLogConstants
 
FUTURE_TIMEOUT_INFINITE - Static variable in class org.apache.distributedlog.DistributedLogConstants
 
FutureEventListener<T> - Interface in org.apache.distributedlog.common.concurrent
Provide similar interface (as twitter future) over java future.
FutureUtils - Class in org.apache.distributedlog.common.concurrent
Future related utils.

G

get() - Method in class org.apache.distributedlog.BookKeeperClient
 
get(long, long) - Static method in class org.apache.distributedlog.common.util.BitMaskUtils
Get the bits where mask is 1.
get(String) - Method in class org.apache.distributedlog.logsegment.LogSegmentMetadataCache
Retrieve the log segment of path from the cache.
get(String) - Method in class org.apache.distributedlog.logsegment.PerStreamLogSegmentCache
Retrieve log segment name from the cache.
get() - Method in class org.apache.distributedlog.ZooKeeperClient
Returns the current active ZK connection or establishes a new one if none has yet been established or a previous connection was disconnected or had its session time out.
getAccessControlManager() - Method in interface org.apache.distributedlog.namespace.NamespaceDriver
Create an access control manager to manage/check acl for logs.
getAckQuorumSize() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get ack quorum size of each log segment (ledger) will use.
getAcquireFuture() - Method in class org.apache.distributedlog.lock.LockWaiter
Return the future representing the waiting result.
getAddress() - Method in class org.apache.distributedlog.client.proxy.ProxyClient
 
getAddress() - Method in class org.apache.distributedlog.service.DistributedLogCluster.DLServer
 
getAlertWhenPositioningOnTruncated() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get if we should alert when reader is positioned on a truncated segment
getAllClients() - Method in class org.apache.distributedlog.client.proxy.ProxyClientManager
Return all clients.
getAllocationData() - Method in class org.apache.distributedlog.metadata.LogMetadataForWriter
 
getAllocationPath() - Method in class org.apache.distributedlog.metadata.LogMetadata
 
getAppendOnlyStreamReader() - Method in interface org.apache.distributedlog.api.DistributedLogManager
Get a reader to read a log stream as a sequence of bytes
getAppendOnlyStreamReader() - Method in interface org.apache.distributedlog.DistributedLogManager
Get a reader to read a log stream as a sequence of bytes.
getAppendOnlyStreamReader() - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
getAppendOnlyStreamWriter() - Method in interface org.apache.distributedlog.api.DistributedLogManager
Begin appending to the end of the log stream which is being treated as a sequence of bytes
getAppendOnlyStreamWriter() - Method in interface org.apache.distributedlog.DistributedLogManager
Begin appending to the end of the log stream which is being treated as a sequence of bytes.
getAppendOnlyStreamWriter() - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
getArray(ByteBuf) - Static method in class org.apache.distributedlog.common.util.ByteBufUtils
 
getAsyncLogReader(long) - Method in interface org.apache.distributedlog.api.DistributedLogManager
Get an async log reader to read records from a log starting from fromTxnId.
getAsyncLogReader(DLSN) - Method in interface org.apache.distributedlog.api.DistributedLogManager
Get an async log reader to read records from a log starting from fromDLSN.
getAsyncLogReader(long) - Method in interface org.apache.distributedlog.DistributedLogManager
 
getAsyncLogReader(DLSN) - Method in interface org.apache.distributedlog.DistributedLogManager
 
getAsyncLogReader(long) - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
getAsyncLogReader(DLSN) - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
getAsyncLogReaderWithLock(DLSN) - Method in interface org.apache.distributedlog.api.DistributedLogManager
Get a log reader with lock starting from fromDLSN.
getAsyncLogReaderWithLock(DLSN, String) - Method in interface org.apache.distributedlog.api.DistributedLogManager
Get a log reader with lock starting from fromDLSN and using subscriberId.
getAsyncLogReaderWithLock(String) - Method in interface org.apache.distributedlog.api.DistributedLogManager
Get a log reader using subscriberId with lock.
getAsyncLogReaderWithLock(DLSN) - Method in interface org.apache.distributedlog.DistributedLogManager
 
getAsyncLogReaderWithLock(DLSN, String) - Method in interface org.apache.distributedlog.DistributedLogManager
Get a log reader with lock starting from fromDLSN and using subscriberId.
getAsyncLogReaderWithLock(String) - Method in interface org.apache.distributedlog.DistributedLogManager
Get a log reader using subscriberId with lock.
getAsyncLogReaderWithLock(DLSN) - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
getAsyncLogReaderWithLock(DLSN, String) - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
getAsyncLogReaderWithLock(String) - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
getBKClientNumberIOThreads() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get BK client number of i/o threads used by Netty.
getBKClientNumberWorkerThreads() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Deprecated. 
getBKClientReadTimeout() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Deprecated. 
getBKClientWriteTimeout() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Deprecated. 
getBKClientZKNumRetries() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get num of retries for zookeeper client that used by bookkeeper client.
getBKClientZKRequestRateLimit() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get zookeeper access rate limit for zookeeper client used in bookkeeper client.
getBKClientZKRetryBackoffMaxMillis() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the max backoff time of zookeeper operation retries, in milliseconds.
getBKClientZKRetryBackoffStartMillis() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the start backoff time of zookeeper operation retries, in milliseconds.
getBKClientZKSessionTimeoutMilliSeconds() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get BK's zookeeper session timout in milliseconds.
getBKDigestPW() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get password used by bookkeeper client for digestion.
getBkDNSResolverOverrides() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get mapping used to override the region mapping derived by the default resolver.
getBkLedgerPath() - Static method in class org.apache.distributedlog.LocalDLMEmulator
 
getBKResultCode() - Method in exception org.apache.distributedlog.exceptions.BKTransmitException
 
getBpsHardWriteLimit() - Method in class org.apache.distributedlog.DistributedLogConfiguration
An upper threshold bytes per second limit on writes to the distributedlog proxy.
getBpsSoftWriteLimit() - Method in class org.apache.distributedlog.DistributedLogConfiguration
A lower threshold bytes per second limit on writes to the distributedlog proxy.
getBuffer() - Method in interface org.apache.distributedlog.LogRecordSetBuffer
Get the buffer to transmit.
getCheckLogExistenceBackoffMaxMillis() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the backoff max time to check log existence if the log doesn't exist.
getCheckLogExistenceBackoffStartMillis() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the backoff start time to check log existence if the log doesn't exist.
getClient() - Method in class org.apache.distributedlog.client.proxy.ClusterClient
 
getClient() - Method in class org.apache.distributedlog.client.proxy.ProxyClient
 
getClient(SocketAddress) - Method in class org.apache.distributedlog.client.proxy.ProxyClientManager
Retrieve a client to proxy address.
getCode() - Method in exception org.apache.distributedlog.exceptions.DLException
Return the status code representing the exception.
getCompletionTime() - Method in class org.apache.distributedlog.LogSegmentMetadata
 
getCompressionCodec(CompressionCodec.Type) - Static method in class org.apache.distributedlog.io.CompressionUtils
Get a cached compression codec instance for the specified type.
getCompressionType() - Method in class org.apache.distributedlog.DistributedLogConfiguration
The compression type to use while sending data to bookkeeper.
getConfiguration() - Method in interface org.apache.distributedlog.common.config.FileConfigurationBuilder
 
getConfiguration() - Method in class org.apache.distributedlog.common.config.PropertiesConfigurationBuilder
 
getCreateStreamIfNotExists() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Whether to create stream if not exists.
getCurrentOwner() - Method in exception org.apache.distributedlog.exceptions.OwnershipAcquireFailedException
 
getCurrentOwner() - Method in class org.apache.distributedlog.lock.LockWaiter
Return the owner that observed when waiter is waiting.
getDataLatencyWarnThresholdMillis() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the warn threshold (in millis) of data access latency.
getDefaultACL() - Method in class org.apache.distributedlog.ZooKeeperClient
 
getDeserializeRecordSetOnReads() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the flag whether to deserialize record set on reads.
getDisableRollingOnLogSegmentError() - Method in class org.apache.distributedlog.DistributedLogConfiguration
If this option is set, the log writer won't reset the segment writer if an error is encountered.
getDistributedLogNamespace() - Method in class org.apache.distributedlog.service.DistributedLogServiceImpl
 
getDLConfig() - Method in class org.apache.distributedlog.metadata.DLMetadata
 
getDLLedgerMetadataLayoutVersion() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get DL ledger metadata output layout version.
getDLLedgerMetadataSkipMinVersionCheck() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the setting for whether we should enforce the min ledger metadata version check.
getDlsn() - Method in class org.apache.distributedlog.LogRecordWithDLSN
Get the DLSN of the record in the log.
getDLSNNotLessThanTxId(long) - Method in interface org.apache.distributedlog.api.DistributedLogManager
Get the DLSN of first log record whose transaction id is not less than transactionId.
getDLSNNotLessThanTxId(long) - Method in interface org.apache.distributedlog.DistributedLogManager
Get the DLSN of first log record whose transaction id is not less than transactionId.
getDLSNNotLessThanTxId(long) - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
getDLType() - Method in class org.apache.distributedlog.metadata.DLMetadata
 
getDNSResolver(Class<? extends DNSToSwitchMapping>, String) - Static method in class org.apache.distributedlog.net.NetUtils
Get the dns resolver from class resolverClassName with optional hostRegionOverrides.
getDriver(String) - Static method in class org.apache.distributedlog.namespace.NamespaceDriverManager
Retrieve the namespace driver for scheme.
getDriver(URI) - Static method in class org.apache.distributedlog.namespace.NamespaceDriverManager
Retrieve the namespace driver for uri.
getDynamicConfigReloadIntervalSec() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get dynamic configuration reload interval in seconds.
getEIInjectedWriteDelayMs() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get amount of time to delay writes for in writer failure injection.
getEIInjectedWriteDelayPercent() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get percent of write requests which should be delayed by BKDL_EI_INJECTED_WRITE_DELAY_MS.
getEIInjectMaxReadAheadDelayMs() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the max injected delay in read ahead, in millis.
getEIInjectReadAheadBrokenEntries() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the flag whether to inject broken entries in readahead.
getEIInjectReadAheadDelay() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the flag whether to inject delay in read ahead.
getEIInjectReadAheadDelayPercent() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the percentage of operations to delay in read ahead.
getEIInjectReadAheadStall() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the flag whether to inject stalls in read ahead.
getEIInjectWriteDelay() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Should we enable write delay injection? If false we won't check other write delay settings.
getEnableForceRead() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get if we should enable force read
getEnableLedgerAllocatorPool() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Whether to enable ledger allocator pool or not.
getEnablePerStreamStat() - Method in class org.apache.distributedlog.DistributedLogConfiguration
getEnableReadAhead() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get if we should enable read ahead
getEnableRecordCounts() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Whether we should publish record counts in the log records and metadata.
getEnableTaskExecutionStats() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Whether to trace long running tasks and record task execution stats in thread pools.
getEncodeRegionIDInLogSegmentMetadata() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Whether encode region id in log segment metadata.
getEnsemblePlacementDnsResolverClass() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the DNS resolver class for bookkeeper ensemble placement.
getEnsembleSize() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get ensemble size of each log segment (ledger) will use.
getEntryId() - Method in class org.apache.distributedlog.DLSN
Return the entry id of the batch that the record is written to.
getEntryId() - Method in interface org.apache.distributedlog.Entry.Reader
Return the entry id.
getEnvelopeEntries() - Method in class org.apache.distributedlog.LogSegmentMetadata
 
getExplicitTruncationByApplication() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Is truncation managed explicitly by the application.
getFailFastOnStreamNotReady() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Whether to fail immediately if the stream is not ready rather than queueing the request.
getFeatureProvider(String, DistributedLogConfiguration, StatsLogger) - Static method in class org.apache.distributedlog.feature.AbstractFeatureProvider
 
getFeatureProviderClass() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get feature provider class.
getFederatedCheckExistenceWhenCacheMiss() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Whether check the existence of a log if querying local cache of a federated namespace missed.
getFederatedMaxLogsPerSubnamespace() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the max logs per sub namespace for federated namespace.
getFileFeatureProviderBaseConfigPath() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the base config path for file feature provider.
getFileFeatureProviderOverlayConfigPath() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the overlay config path for file feature provider.
getFinagleStatsReceiver(SocketAddress) - Method in class org.apache.distributedlog.client.stats.ClientStats
 
getFinalisedData() - Method in class org.apache.distributedlog.LogSegmentMetadata
 
getFinalisedData(LogSegmentMetadata.LogSegmentMetadataVersion) - Method in class org.apache.distributedlog.LogSegmentMetadata
 
getFirstDLSN() - Method in class org.apache.distributedlog.LogSegmentMetadata
 
getFirstDLSNAsync() - Method in interface org.apache.distributedlog.api.DistributedLogManager
Get first DLSN in the log.
getFirstDLSNAsync() - Method in interface org.apache.distributedlog.DistributedLogManager
Get first DLSN in the log.
getFirstDLSNAsync() - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
getFirstLogSegmentSequenceNumber() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the value at which ledger sequence number should start for streams that are being upgraded and did not have ledger sequence number to start with or for newly created streams.
getFirstNumEntriesPerReadLastRecordScan() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Number of entries to scan for first scan of reading last record.
getFirstTxId() - Method in interface org.apache.distributedlog.api.DistributedLogManager
Get the earliest Transaction Id available in the log
getFirstTxId() - Method in interface org.apache.distributedlog.DistributedLogManager
Get the earliest Transaction Id available in the log.
getFirstTxId() - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
getFirstTxId() - Method in class org.apache.distributedlog.LogSegmentMetadata
 
getFullyQualifiedName() - Method in class org.apache.distributedlog.metadata.LogMetadata
Get the fully qualified name of the log.
getGlobalOutstandingWriteLimit() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the global write limit for dl.
getHandshakeWithClientInfo() - Method in class org.apache.distributedlog.client.ClientConfig
 
getHost(String, RoutingService.RoutingContext) - Method in class org.apache.distributedlog.client.routing.ConsistentHashRoutingService
 
getHost(String, RoutingService.RoutingContext) - Method in class org.apache.distributedlog.client.routing.RegionsRoutingService
 
getHost(String, RoutingService.RoutingContext) - Method in interface org.apache.distributedlog.client.routing.RoutingService
Get the host to route the request by key.
getHost(String, RoutingService.RoutingContext) - Method in class org.apache.distributedlog.client.routing.SingleHostRoutingService
 
getHosts() - Method in class org.apache.distributedlog.client.DistributedLogClientImpl
 
getHosts() - Method in interface org.apache.distributedlog.client.proxy.HostProvider
Get the list of hosts for handshaking.
getHosts() - Method in class org.apache.distributedlog.client.routing.ConsistentHashRoutingService
 
getHosts() - Method in class org.apache.distributedlog.client.routing.RegionsRoutingService
 
getHosts() - Method in interface org.apache.distributedlog.client.routing.RoutingService
Get all the hosts that available in routing service.
getHosts() - Method in class org.apache.distributedlog.client.routing.SingleHostRoutingService
 
getId() - Method in class org.apache.distributedlog.lock.LockWaiter
Return the lock id of the waiter.
getIgnoreTruncationStatus() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get if we should ignore truncation status when reading the records
getImmediateFlushEnabled() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Is immediate flush enabled.
getInputStream(long) - Method in interface org.apache.distributedlog.api.DistributedLogManager
Get the input stream starting with fromTxnId for the specified log
getInputStream(DLSN) - Method in interface org.apache.distributedlog.api.DistributedLogManager
Get the input stream starting with fromTxnId for the specified log
getInputStream(long) - Method in interface org.apache.distributedlog.DistributedLogManager
Get the input stream starting with fromTxnId for the specified log.
getInputStream(DLSN) - Method in interface org.apache.distributedlog.DistributedLogManager
 
getInputStream(long) - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
getInputStream(DLSN) - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
getKeeperExceptionCode() - Method in exception org.apache.distributedlog.exceptions.ZKException
 
getKeys() - Method in class org.apache.distributedlog.common.config.ConcurrentBaseConfiguration
 
getLastAddConfirmed() - Method in interface org.apache.distributedlog.logsegment.LogSegmentEntryReader
Return the last add confirmed entry id (LAC).
getLastAddConfirmed() - Method in interface org.apache.distributedlog.logsegment.LogSegmentRandomAccessEntryReader
Return the last add confirmed entry id (LAC).
getLastCommitPosition(String) - Method in interface org.apache.distributedlog.api.subscription.SubscriptionsStore
Get the last committed position stored for subscriberId.
getLastCommitPosition() - Method in interface org.apache.distributedlog.api.subscription.SubscriptionStateStore
Get the last committed position stored for this subscription
getLastCommitPosition(String) - Method in interface org.apache.distributedlog.subscription.SubscriptionsStore
Get the last committed position stored for subscriberId.
getLastCommitPositions() - Method in interface org.apache.distributedlog.api.subscription.SubscriptionsStore
Get the last committed positions for all subscribers.
getLastCommitPositions() - Method in interface org.apache.distributedlog.subscription.SubscriptionsStore
Get the last committed positions for all subscribers.
getLastDLSN() - Method in interface org.apache.distributedlog.api.DistributedLogManager
Get Latest DLSN in the log
getLastDLSN() - Method in interface org.apache.distributedlog.DistributedLogManager
Get Latest DLSN in the log.
getLastDLSN() - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
getLastDLSN() - Method in class org.apache.distributedlog.LogSegmentMetadata
 
getLastDLSNAsync() - Method in interface org.apache.distributedlog.api.DistributedLogManager
Get Latest DLSN in the log - async
getLastDLSNAsync() - Method in interface org.apache.distributedlog.DistributedLogManager
Get Latest DLSN in the log - async.
getLastDLSNAsync() - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
getLastEntryId() - Method in class org.apache.distributedlog.LogSegmentMetadata
 
getLastLogRecord() - Method in interface org.apache.distributedlog.api.DistributedLogManager
Get the last log record in the stream
getLastLogRecord() - Method in interface org.apache.distributedlog.DistributedLogManager
Get the last log record in the stream.
getLastLogRecord() - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
getLastLogRecordAsync() - Method in interface org.apache.distributedlog.api.DistributedLogManager
Get Latest log record with DLSN in the log - async
getLastLogRecordAsync() - Method in interface org.apache.distributedlog.DistributedLogManager
Get Latest log record with DLSN in the log - async.
getLastLogRecordAsync() - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
getLastSlotId() - Method in class org.apache.distributedlog.LogSegmentMetadata
 
getLastTxId() - Method in interface org.apache.distributedlog.api.AsyncLogWriter
Get the last committed transaction id.
getLastTxId() - Method in interface org.apache.distributedlog.api.DistributedLogManager
Get Latest Transaction Id in the log
getLastTxId() - Method in interface org.apache.distributedlog.AsyncLogWriter
Get the last committed transaction id.
getLastTxId() - Method in interface org.apache.distributedlog.DistributedLogManager
Get Latest Transaction Id in the log.
getLastTxId() - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
getLastTxId() - Method in class org.apache.distributedlog.LogSegmentMetadata
 
getLastTxIdAcknowledged() - Method in exception org.apache.distributedlog.exceptions.FlushException
 
getLastTxIdAsync() - Method in interface org.apache.distributedlog.api.DistributedLogManager
Get Latest Transaction Id in the log - async
getLastTxIdAsync() - Method in interface org.apache.distributedlog.DistributedLogManager
Get Latest Transaction Id in the log - async.
getLastTxIdAsync() - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
getLastTxIdWritten() - Method in exception org.apache.distributedlog.exceptions.FlushException
 
getLastTxnId() - Method in exception org.apache.distributedlog.exceptions.TransactionIdOutOfOrderException
 
getLedgerAllocatorPoolCoreSize() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the core size of ledger allocator pool.
getLedgerAllocatorPoolName() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the name of ledger allocator pool.
getLedgerAllocatorPoolPath() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the path of ledger allocator pool.
getLockOpTimeoutMilliSeconds() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get lock internal operation timeout in milliseconds.
getLockPath() - Method in class org.apache.distributedlog.metadata.LogMetadata
 
getLockReacquireTimeoutMilliSeconds() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get lock reacquire timeout in milliseconds.
getLockTimeoutMilliSeconds() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get lock timeout in milliseconds.
getLog(URI, String, boolean, boolean) - Method in interface org.apache.distributedlog.metadata.LogStreamMetadataStore
Create the metadata of a log.
getLogComponentPath(URI, String, String, String) - Static method in class org.apache.distributedlog.metadata.LogMetadata
 
getLogFlushTimeoutSeconds() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get Log Flush timeout in seconds.
getLogLocation(String) - Method in interface org.apache.distributedlog.metadata.LogMetadataStore
Get the location of the log.
getLogMetadataStore() - Method in interface org.apache.distributedlog.namespace.NamespaceDriver
Retrieve the log metadata store used by the namespace.
getLogName() - Method in class org.apache.distributedlog.metadata.LogMetadata
 
getLogRecordCount() - Method in interface org.apache.distributedlog.api.DistributedLogManager
Get the number of log records in the active portion of the log Any log segments that have already been truncated will not be included
getLogRecordCount() - Method in interface org.apache.distributedlog.DistributedLogManager
Get the number of log records in the active portion of the log.
getLogRecordCount() - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
getLogRecordCountAsync(DLSN) - Method in interface org.apache.distributedlog.api.DistributedLogManager
Get the number of log records in the active portion of the log - async.
getLogRecordCountAsync(DLSN) - Method in interface org.apache.distributedlog.DistributedLogManager
Get the number of log records in the active portion of the log - async.
getLogRecordCountAsync(DLSN) - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
getLogRecordNotLessThanTxId(String, LogSegmentMetadata, long, ExecutorService, LogSegmentEntryStore, int) - Static method in class org.apache.distributedlog.ReadUtils
Get the log record whose transaction id is not less than provided transactionId.
getLogRootPath(URI, String, String) - Static method in class org.apache.distributedlog.metadata.LogMetadata
Get the log root path for a given log.
getLogRootPath() - Method in class org.apache.distributedlog.metadata.LogMetadata
Get the root path of the log.
getLogs() - Method in interface org.apache.distributedlog.api.namespace.Namespace
Retrieve the logs under the namespace.
getLogs() - Method in class org.apache.distributedlog.BKDistributedLogNamespace
 
getLogs() - Method in interface org.apache.distributedlog.metadata.LogMetadataStore
Retrieves logs from the namespace.
getLogs() - Method in interface org.apache.distributedlog.namespace.DistributedLogNamespace
Retrieve the logs under the namespace.
getLogSegment(String) - Method in interface org.apache.distributedlog.logsegment.LogSegmentMetadataStore
Retrieve the log segment associated path.
getLogSegmentCacheMaxSize() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the maximum size of the log segment cache.
getLogSegmentCacheTTLMs() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the log segment cache entry TTL in milliseconds.
getLogSegmentEntryStore(NamespaceDriver.Role) - Method in interface org.apache.distributedlog.namespace.NamespaceDriver
Retrieve the log segment entry store used by the namespace.
getLogSegmentId() - Method in interface org.apache.distributedlog.logsegment.LogSegmentEntryWriter
Get the log segment id.
getLogSegmentId() - Method in interface org.apache.distributedlog.logsegment.LogSegmentWriter
Get the unique log segment id.
getLogSegmentId() - Method in class org.apache.distributedlog.LogSegmentMetadata
 
getLogSegmentMetadataStore() - Method in interface org.apache.distributedlog.metadata.LogStreamMetadataStore
Get the log segment metadata store.
getLogSegmentNames(String, LogSegmentNamesListener) - Method in interface org.apache.distributedlog.logsegment.LogSegmentMetadataStore
Retrieve the list of log segments under logSegmentsPath and register a listener for subsequent changes for the list of log segments.
getLogSegmentNameVersion() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get log segment name version.
getLogSegmentPath(String) - Method in class org.apache.distributedlog.metadata.LogMetadata
Get the path for a log segment of the log.
getLogSegmentRollingConcurrency() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get log segment rolling concurrency.
getLogSegmentRollingIntervalMinutes() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get log segment rolling interval in minutes.
getLogSegments() - Method in interface org.apache.distributedlog.api.DistributedLogManager
Get log segments.
getLogSegments() - Method in interface org.apache.distributedlog.DistributedLogManager
Get log segments.
getLogSegments() - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
getLogSegments(Comparator<LogSegmentMetadata>) - Method in class org.apache.distributedlog.logsegment.PerStreamLogSegmentCache
Retrieve log segments from the cache.
getLogSegmentSequenceNo() - Method in class org.apache.distributedlog.DLSN
Return the sequence number of the log segment that the record is written to.
getLogSegmentSequenceNumber() - Method in class org.apache.distributedlog.LogSegmentMetadata
 
getLogSegmentsPath(URI, String, String) - Static method in class org.apache.distributedlog.metadata.LogMetadata
Get the logsegments root path for a given log.
getLogSegmentsPath() - Method in class org.apache.distributedlog.metadata.LogMetadata
Get the root path for log segments.
getLogStreamMetadataStore(NamespaceDriver.Role) - Method in interface org.apache.distributedlog.namespace.NamespaceDriver
Retrieve the log stream metadata store used by the namespace.
getLogStreamPath(URI, String) - Static method in class org.apache.distributedlog.metadata.LogMetadata
Get the top stream path for a given log.
getLSSN() - Method in interface org.apache.distributedlog.Entry.Reader
Get the log segment sequence number.
getMaxAcquiredPartitionsPerProxy() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the maximum number of partitions of each stream allowed to be acquired per proxy.
getMaxCachedPartitionsPerProxy() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the maximum number of partitions of each stream allowed to cache per proxy.
getMaxLogSegmentBytes() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get Max LogSegment Size in Bytes.
getMaxLSSNData() - Method in class org.apache.distributedlog.metadata.LogMetadataForWriter
 
getMaxNumEntriesPerReadLastRecordScan() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Max number of entries for each scan to read last record.
getMaxPrefetchEntriesPerLogSegment() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the max prefetch entries per log segment.
getMaxRedirects() - Method in class org.apache.distributedlog.client.ClientConfig
 
getMaxTxIdData() - Method in class org.apache.distributedlog.metadata.LogMetadataForWriter
 
getMaxTxIdPath() - Method in class org.apache.distributedlog.metadata.LogMetadata
 
getMetadata() - Method in interface org.apache.distributedlog.api.MetadataAccessor
 
getMetadata() - Method in class org.apache.distributedlog.LogRecord
 
getMetadataAccessor(String) - Method in interface org.apache.distributedlog.namespace.NamespaceDriver
Retrieve the metadata accessor for log stream streamName.
getMetadataLatencyWarnThresholdMillis() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the warn threshold (in millis) of metadata access latency.
getMinActiveDLSN() - Method in class org.apache.distributedlog.LogSegmentMetadata
 
getMinDelayBetweenImmediateFlushMs() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get minimum delay between immediate flushes in milliseconds.
getNamespaceDriver() - Method in interface org.apache.distributedlog.api.DistributedLogManager
Get the namespace driver used by this manager.
getNamespaceDriver() - Method in interface org.apache.distributedlog.api.namespace.Namespace
Get the namespace driver used by this namespace.
getNamespaceDriver() - Method in class org.apache.distributedlog.BKDistributedLogNamespace
 
getNamespaceDriver() - Method in interface org.apache.distributedlog.DistributedLogManager
Get the namespace driver used by this manager.
getNamespaceDriver() - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
getNamespaceDriver() - Method in interface org.apache.distributedlog.namespace.DistributedLogNamespace
Get the namespace driver used by this namespace.
getNextDLSN() - Method in class org.apache.distributedlog.DLSN
Positions to a DLSN greater than the current value.
getNumBytes() - Method in interface org.apache.distributedlog.LogRecordSetBuffer
Return number of bytes in current record set.
getNumCachedStreams() - Method in class org.apache.distributedlog.client.ownership.OwnershipCache
Get the number cached streams.
getNumLockStateThreads() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the number of lock state threads used by distributedlog namespace.
getNumPrefetchEntriesPerLogSegment() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the number prefetch entries per log segment.
getNumProxies() - Method in class org.apache.distributedlog.client.proxy.ProxyClientManager
Return number of proxies managed by client manager.
getNumReadAheadWorkerThreads() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Deprecated.
getNumRecords() - Method in interface org.apache.distributedlog.LogRecordSetBuffer
Return number of records in current record set.
getNumResourceReleaseThreads() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the number of resource release threads used by distributedlog namespace.
getNumWorkerThreads() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the number of worker threads used by distributedlog namespace.
getOpStats(String) - Method in class org.apache.distributedlog.client.stats.ClientStats
 
getOutputBufferSize() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get output buffer size for DL writers, in bytes.
getOutstandingWriteLimitDarkmode() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Whether to darkmode outstanding writes limit.
getOwner(String) - Method in class org.apache.distributedlog.client.ownership.OwnershipCache
Get the cached owner for stream stream.
getOwner(String, WriteContext) - Method in class org.apache.distributedlog.service.DistributedLogServiceImpl
 
getOwnershipStatsLogger() - Method in class org.apache.distributedlog.client.ownership.OwnershipCache
 
getPayload() - Method in class org.apache.distributedlog.LogRecord
Return the payload of this log record.
getPayloadBuf() - Method in class org.apache.distributedlog.LogRecord
Return the payload buf of this log record.
getPayLoadInputStream() - Method in class org.apache.distributedlog.LogRecord
Return the payload as an InputStream.
getPendingBytes() - Method in class org.apache.distributedlog.LogRecord.Writer
 
getPeriodicDumpOwnershipCacheIntervalMs() - Method in class org.apache.distributedlog.client.ClientConfig
 
getPeriodicFlushFrequencyMilliSeconds() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get Periodic Log Flush Frequency in milliseconds.
getPeriodicHandshakeIntervalMs() - Method in class org.apache.distributedlog.client.ClientConfig
 
getPeriodicKeepAliveMilliSeconds() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get Periodic Keep Alive Frequency in milliseconds.
getPeriodicOwnershipSyncIntervalMs() - Method in class org.apache.distributedlog.client.ClientConfig
 
getPermitManager() - Method in interface org.apache.distributedlog.metadata.LogStreamMetadataStore
Get the permit manager for this metadata store.
getPerWriterOutstandingWriteLimit() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the per stream outstanding write limit for dl.
getPositionGapDetectionEnabled() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get whether position gap detection for reader enabled.
getPositionWithinLogSegment() - Method in class org.apache.distributedlog.LogRecord
The position in the log segment means how many records (inclusive) added to the log segment so far.
getProperty(String) - Method in class org.apache.distributedlog.common.config.ConcurrentBaseConfiguration
 
getPropsAsString() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get all properties as a string.
getProxyFinagleStr() - Method in class org.apache.distributedlog.service.DistributedLogCluster
 
getQuorumConfig() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the quorum config for each log segment (ledger).
getReadAheadBatchSize() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get number of entries read as a batch by readahead worker.
getReadAheadMaxRecords() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the max records cached by readahead cache.
getReadAheadNoSuchLedgerExceptionOnReadLACErrorThresholdMillis() - Method in class org.apache.distributedlog.DistributedLogConfiguration
If readahead keeps receiving BKException.BKNoSuchLedgerExistsException on reading last add confirmed in given period, it would stop polling last add confirmed and re-initialize the ledger handle and retry.
getReadAheadSkipBrokenEntries() - Method in class org.apache.distributedlog.DistributedLogConfiguration
When corruption is encountered in an entry, skip it and move on.
getReadAheadWaitTime() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the wait time between successive attempts to poll for new log records, in milliseconds.
getReadAheadWaitTimeOnEndOfStream() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the wait time if it reaches end of stream and there isn't any inprogress logsegment in the stream, in millis.
getReaderIdleErrorThresholdMillis() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the time in milliseconds as the threshold for when an idle reader should throw errors
getReaderIdleWarnThresholdMillis() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the time in milliseconds as the threshold for when an idle reader should dump warnings
getReadLACLongPollTimeout() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the long poll time out for read last add confirmed requests, in milliseconds.
getReadLockPath(Optional<String>) - Method in class org.apache.distributedlog.metadata.LogMetadataForReader
Get the readlock path for the log or a subscriber of the log.
getRecordCount() - Method in class org.apache.distributedlog.LogSegmentMetadata
 
getRedirectBackoffMaxMs() - Method in class org.apache.distributedlog.client.ClientConfig
 
getRedirectBackoffStartMs() - Method in class org.apache.distributedlog.client.ClientConfig
 
getRegionId() - Method in class org.apache.distributedlog.LogSegmentMetadata
 
getRequestTimeoutMs() - Method in class org.apache.distributedlog.client.ClientConfig
 
getRetentionPeriodHours() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get log segment retention period in hours.
getRowAwareEnsemblePlacementEnabled() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get if row aware ensemble placement is enabled.
getRpsHardWriteLimit() - Method in class org.apache.distributedlog.DistributedLogConfiguration
An upper threshold requests per second limit on writes to the distributedlog proxy.
getRpsSoftWriteLimit() - Method in class org.apache.distributedlog.DistributedLogConfiguration
A lower threshold requests per second limit on writes to the distributedlog proxy.
getSanityCheckTxnID() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Deprecated.
getSchedulerShutdownTimeoutMs() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get timeout for shutting down schedulers in dl manager, in milliseconds.
getScheme() - Method in interface org.apache.distributedlog.namespace.NamespaceDriver
Get the scheme of the namespace driver.
getSegment() - Method in interface org.apache.distributedlog.logsegment.LogSegmentEntryReader
Return the log segment metadata for this reader.
getSequenceId() - Method in class org.apache.distributedlog.LogRecordWithDLSN
Get the sequence id of the record in the log.
getServerSet() - Method in class org.apache.distributedlog.client.serverset.DLZkServerSet
 
getService() - Method in class org.apache.distributedlog.client.proxy.ClusterClient
 
getService() - Method in class org.apache.distributedlog.client.proxy.ProxyClient
 
getShard() - Method in class org.apache.distributedlog.service.DLSocketAddress
Shard id for dl write proxy.
getSlotId() - Method in class org.apache.distributedlog.DLSN
Return the slot id in the batch that the record is written to.
getSocketAddress() - Method in class org.apache.distributedlog.service.DLSocketAddress
Socket address for dl write proxy.
getSocketAddress(int) - Static method in class org.apache.distributedlog.service.DLSocketAddress
 
getStartSequenceId() - Method in class org.apache.distributedlog.LogSegmentMetadata
 
getStatsReceiver() - Method in class org.apache.distributedlog.client.stats.ClientStatsLogger
 
getStreamConfigRouterClass() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get config router class which determines how stream name is mapped to configuration.
getStreamFailfast() - Method in class org.apache.distributedlog.client.ClientConfig
 
getStreamName() - Method in interface org.apache.distributedlog.api.AsyncLogReader
Get stream name that the reader reads from.
getStreamName() - Method in interface org.apache.distributedlog.api.AsyncLogWriter
Get the name of the stream this writer writes data to
getStreamName() - Method in interface org.apache.distributedlog.api.DistributedLogManager
Get the name of the stream managed by this log manager
getStreamName() - Method in interface org.apache.distributedlog.api.MetadataAccessor
Get the name of the stream managed by this log manager
getStreamName() - Method in interface org.apache.distributedlog.AsyncLogReader
Get stream name that the reader reads from.
getStreamName() - Method in interface org.apache.distributedlog.AsyncLogWriter
Get the name of the stream this writer writes data to.
getStreamName() - Method in interface org.apache.distributedlog.DistributedLogManager
Get the name of the stream managed by this log manager.
getStreamName() - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
getStreamNameRegex() - Method in class org.apache.distributedlog.client.ClientConfig
 
getStreamOwnerMapping() - Method in class org.apache.distributedlog.client.ownership.OwnershipCache
Get the stream ownership mapping.
getStreamOwnershipDistribution() - Method in class org.apache.distributedlog.client.DistributedLogClientImpl
 
getStreamOwnershipDistribution() - Method in interface org.apache.distributedlog.client.monitor.MonitorServiceClient
Get current ownership distribution from current monitor service view.
getStreamOwnershipDistribution() - Method in class org.apache.distributedlog.client.ownership.OwnershipCache
Get the stream ownership distribution across proxies.
getSubscriberPath(URI, String, String, String) - Static method in class org.apache.distributedlog.metadata.LogMetadataForReader
Get the path that stores subscription info for a subscriberId for a log.
getSubscribersPath(URI, String, String) - Static method in class org.apache.distributedlog.metadata.LogMetadataForReader
Get the root path to store subscription infos of a log.
getSubscriptionsStore() - Method in interface org.apache.distributedlog.api.DistributedLogManager
Get the subscriptions store provided by the distributedlog manager.
getSubscriptionsStore() - Method in interface org.apache.distributedlog.DistributedLogManager
Get the subscriptions store provided by the distributedlog manager.
getSubscriptionsStore() - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
getSubscriptionsStore(String) - Method in interface org.apache.distributedlog.namespace.NamespaceDriver
Retrieve the subscriptions store for log stream streamName.
getTaskExecutionWarnTimeMicros() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Report long running task after execution takes longer than the given interval.
getThriftMux() - Method in class org.apache.distributedlog.client.ClientConfig
 
getTimeoutTimerNumTicks() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get number of ticks that used for timeout timer in bookkeeper client.
getTimeoutTimerTickDurationMs() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the tick duration in milliseconds that used for timeout timer in bookkeeper client.
getTraceReadAheadDeliveryLatency() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Whether to trace read ahead delivery latency or not?
getTraceReadAheadMetadataChanges() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Whether to trace read ahead changes? If enabled, it will log readahead metadata changes with timestamp.
getTransactionId() - Method in class org.apache.distributedlog.LogRecord
Return application defined transaction id.
getUnpartitionedStreamName() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get name of the unpartitioned stream.
getUri() - Method in class org.apache.distributedlog.LocalDLMEmulator
 
getUri() - Method in class org.apache.distributedlog.metadata.LogMetadata
 
getUri() - Method in interface org.apache.distributedlog.namespace.NamespaceDriver
Get the root uri of the namespace driver.
getUri() - Method in class org.apache.distributedlog.service.DistributedLogCluster
 
getUseDaemonThread() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Whether to use daemon thread for DL threads.
getVersion() - Method in class org.apache.distributedlog.LogSegmentMetadata
 
getWatcherManager() - Method in class org.apache.distributedlog.ZooKeeperClient
 
getWriteQuorumSize() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get write quorum size of each log segment (ledger) will use.
getZkAclId() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get digest id used for ZK acl.
getZkClient() - Method in class org.apache.distributedlog.client.serverset.DLZkServerSet
 
getZKClientNumberRetryThreads() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get ZK client number of retry executor threads.
getZKNumRetries() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get num of retries per request for zookeeper client.
getZkPath() - Method in class org.apache.distributedlog.LogSegmentMetadata
 
getZKRequestRateLimit() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get zookeeper access rate limit.
getZKRetryBackoffMaxMillis() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the max backoff time of zookeeper operation retries, in milliseconds.
getZKRetryBackoffStartMillis() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get the start backoff time of zookeeper operation retries, in milliseconds.
getZkServers() - Method in class org.apache.distributedlog.LocalDLMEmulator
 
getZkServers() - Method in class org.apache.distributedlog.service.DistributedLogCluster
 
getZKSessionTimeoutMilliseconds() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get ZK Session timeout in milliseconds.
getZKSessionTimeoutSeconds() - Method in class org.apache.distributedlog.DistributedLogConfiguration
getZNodeName() - Method in class org.apache.distributedlog.LogSegmentMetadata
 

H

handshake() - Method in class org.apache.distributedlog.client.DistributedLogClientImpl
 
handshake() - Method in class org.apache.distributedlog.client.proxy.ProxyClientManager
Handshake with all proxies.
handshake() - Method in class org.apache.distributedlog.service.DistributedLogServiceImpl
 
handshakeTracing(boolean) - Method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Enable handshake tracing.
handshakeWithClientInfo(boolean) - Method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Whether to use the new handshake endpoint to exchange ownership cache.
handshakeWithClientInfo(ClientInfo) - Method in class org.apache.distributedlog.service.DistributedLogServiceImpl
 
hasCaughtUpOnInprogress() - Method in interface org.apache.distributedlog.logsegment.LogSegmentEntryReader
Has the log segment reader caught up with the inprogress log segment.
hashCode() - Method in class org.apache.distributedlog.DLSN
 
hashCode() - Method in class org.apache.distributedlog.LogSegmentMetadata
 
hashCode() - Method in class org.apache.distributedlog.metadata.DLMetadata
 
hashCode() - Method in class org.apache.distributedlog.service.DLSocketAddress
 
hashedWheelTimer - Variable in class org.apache.distributedlog.client.routing.ConsistentHashRoutingService
 
hashFunction - Variable in class org.apache.distributedlog.client.routing.ConsistentHashRoutingService
 
hasUnavailableRegions() - Method in class org.apache.distributedlog.client.routing.RoutingService.RoutingContext
Whether encountered unavailable regions.
HEADER_LEN - Static variable in class org.apache.distributedlog.LogRecordSet
 
heartbeat(String) - Method in class org.apache.distributedlog.client.DistributedLogClientImpl
 
heartbeat(String) - Method in interface org.apache.distributedlog.client.monitor.MonitorServiceClient
Send heartbeat to the stream and its readers.
heartbeat(String, WriteContext) - Method in class org.apache.distributedlog.service.DistributedLogServiceImpl
 
heartbeatWithOptions(String, WriteContext, HeartbeatOptions) - Method in class org.apache.distributedlog.service.DistributedLogServiceImpl
 
host(SocketAddress) - Method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Address of write proxy to connect.
hostNameToRegion - Variable in class org.apache.distributedlog.net.DNSResolver
 
HostProvider - Interface in org.apache.distributedlog.client.proxy
Provider to provider list of hosts for handshaking.

I

IdentityCompressionCodec - Class in org.apache.distributedlog.io
An identity compression codec implementation for CompressionCodec.
IdentityCompressionCodec() - Constructor for class org.apache.distributedlog.io.IdentityCompressionCodec
 
IdleReaderException - Exception in org.apache.distributedlog.exceptions
An exception is thrown when a log reader becomes idle.
IdleReaderException(String) - Constructor for exception org.apache.distributedlog.exceptions.IdleReaderException
 
ignore(CompletableFuture<T>) - Static method in class org.apache.distributedlog.common.concurrent.FutureUtils
Ignore exception from the future.
ignore(CompletableFuture<T>, String) - Static method in class org.apache.distributedlog.common.concurrent.FutureUtils
Ignore exception from the future and log errorMsg on exceptions.
ILLEGAL_STATE - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
initialBookiePort(int) - Method in class org.apache.distributedlog.LocalDLMEmulator.Builder
 
InitialDLSN - Static variable in class org.apache.distributedlog.DLSN
 
initialize(DistributedLogConfiguration, DynamicDistributedLogConfiguration, URI, OrderedScheduler, FeatureProvider, AsyncFailureInjector, StatsLogger, StatsLogger, String, int) - Method in interface org.apache.distributedlog.namespace.NamespaceDriver
Initialize the namespace manager.
initiateSpeculativeRequest(ScheduledExecutorService, SpeculativeRequestExecutor) - Method in class org.apache.distributedlog.client.speculative.DefaultSpeculativeRequestExecutionPolicy
Initialize the speculative request execution policy.
initiateSpeculativeRequest(ScheduledExecutorService, SpeculativeRequestExecutor) - Method in interface org.apache.distributedlog.client.speculative.SpeculativeRequestExecutionPolicy
Initialize the speculative request execution policy and initiate requests.
inprogress - Variable in class org.apache.distributedlog.LogSegmentMetadata.LogSegmentMetadataBuilder
 
INPROGRESS_LOGSEGMENT_PREFIX - Static variable in class org.apache.distributedlog.DistributedLogConstants
 
INSTANCE - Static variable in class org.apache.distributedlog.lock.NopDistributedLock
 
INTERNAL_SERVER_ERROR - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
InternalServerException - Exception in org.apache.distributedlog.exceptions
Exception indicates that there is an internal error at distributedlog service side.
InternalServerException(String) - Constructor for exception org.apache.distributedlog.exceptions.InternalServerException
 
InternalServerException(Throwable) - Constructor for exception org.apache.distributedlog.exceptions.InternalServerException
 
InternalServerException(String, Throwable) - Constructor for exception org.apache.distributedlog.exceptions.InternalServerException
 
INTERRUPTED - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
INVALID_ENVELOPED_ENTRY - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
INVALID_STREAM_NAME - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
INVALID_TXID - Static variable in class org.apache.distributedlog.DistributedLogConstants
 
INVALID_TXID - Static variable in exception org.apache.distributedlog.exceptions.TransactionIdOutOfOrderException
 
invalidate(String) - Method in class org.apache.distributedlog.logsegment.LogSegmentMetadataCache
Invalid the cache entry associated with path.
InvalidDLSN - Static variable in class org.apache.distributedlog.DLSN
 
InvalidEnvelopedEntryException - Exception in org.apache.distributedlog.exceptions
Exception thrown when encounter invalid enveloped entry.
InvalidEnvelopedEntryException(String) - Constructor for exception org.apache.distributedlog.exceptions.InvalidEnvelopedEntryException
 
InvalidStreamNameException - Exception in org.apache.distributedlog.exceptions
Exception is thrown when encountered invalid log stream.
InvalidStreamNameException(String) - Constructor for exception org.apache.distributedlog.exceptions.InvalidStreamNameException
 
InvalidStreamNameException(String, String) - Constructor for exception org.apache.distributedlog.exceptions.InvalidStreamNameException
 
isAllowed() - Method in interface org.apache.distributedlog.common.util.PermitManager.Permit
 
isBeyondLastAddConfirmed() - Method in interface org.apache.distributedlog.logsegment.LogSegmentEntryReader
Is the reader reading beyond last add confirmed.
isChecksumEnabled() - Method in class org.apache.distributedlog.client.ClientConfig
 
isControl() - Method in class org.apache.distributedlog.LogRecord
Check if the record is a control record.
isControl(long) - Static method in class org.apache.distributedlog.LogRecord
Check flags to see if it indicates a control record.
isDLSNinThisSegment(DLSN) - Method in class org.apache.distributedlog.LogSegmentMetadata
 
isDurableWriteEnabled() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Check whether the durable write is enabled.
isEmpty() - Method in class org.apache.distributedlog.common.config.ConcurrentBaseConfiguration
 
isEndOfStreamMarked() - Method in interface org.apache.distributedlog.api.DistributedLogManager
Check if an end of stream marker was added to the stream A stream with an end of stream marker cannot be appended to
isEndOfStreamMarked() - Method in interface org.apache.distributedlog.DistributedLogManager
Check if an end of stream marker was added to the stream A stream with an end of stream marker cannot be appended to.
isEndOfStreamMarked() - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
isFederatedNamespaceEnabled() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Is federated namespace implementation enabled.
isHandshakeTracingEnabled() - Method in class org.apache.distributedlog.client.ClientConfig
 
isInProgress() - Method in class org.apache.distributedlog.LogSegmentMetadata
 
isLockExpired() - Method in interface org.apache.distributedlog.lock.SessionLock
Whether the lock is expired or not?
isLockHeld() - Method in interface org.apache.distributedlog.lock.SessionLock
Whether the lock is held or not?
isLogSegmentCacheEnabled() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Is log segment cache enabled?
isLogSegmentSequenceNumberValidationEnabled() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Whether log segment sequence number validation is enabled?
isNonTruncated() - Method in class org.apache.distributedlog.LogSegmentMetadata
 
isPartiallyTruncated() - Method in class org.apache.distributedlog.LogSegmentMetadata
 
isPeriodicDumpOwnershipCacheEnabled() - Method in class org.apache.distributedlog.client.ClientConfig
 
isRecordLastPositioninThisSegment(LogRecord) - Method in class org.apache.distributedlog.LogSegmentMetadata
 
isRecordPositionWithinSegmentScope(LogRecord) - Method in class org.apache.distributedlog.LogSegmentMetadata
 
isRecordSet() - Method in class org.apache.distributedlog.LogRecord
Check if the record represents a set of records.
isRecordSet(long) - Static method in class org.apache.distributedlog.LogRecord
 
isRetryableZKException(ZKException) - Static method in exception org.apache.distributedlog.exceptions.ZKException
 
issueSpeculativeRequest() - Method in interface org.apache.distributedlog.client.speculative.SpeculativeRequestExecutor
Issues a speculative request and indicates if more speculative requests should be issued.
isTriedHost(SocketAddress) - Method in class org.apache.distributedlog.client.routing.RoutingService.RoutingContext
Is the host address already tried.
isTruncated() - Method in class org.apache.distributedlog.LogSegmentMetadata
 
isUnavailableRegion(String) - Method in class org.apache.distributedlog.client.routing.RoutingService.RoutingContext
Whether the region is unavailable.
isWriteLockEnabled() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Is lock enabled when opening a writer to write a stream?

J

join() - Method in class org.apache.distributedlog.service.DistributedLogServer
 
join() - Method in class org.apache.distributedlog.service.MonitorService
 

L

lastEntryId - Variable in class org.apache.distributedlog.LogSegmentMetadata.LogSegmentMetadataBuilder
 
lastSlotId - Variable in class org.apache.distributedlog.LogSegmentMetadata.LogSegmentMetadataBuilder
 
lastTxId - Variable in class org.apache.distributedlog.LogSegmentMetadata.LogSegmentMetadataBuilder
 
LATENCY_WARN_THRESHOLD_IN_MILLIS - Static variable in class org.apache.distributedlog.DistributedLogConstants
 
LAYOUT_VERSION - Static variable in class org.apache.distributedlog.metadata.LogMetadata
 
LEDGER_METADATA_CURRENT_LAYOUT_VERSION - Static variable in class org.apache.distributedlog.LogSegmentMetadata
 
LEDGER_METADATA_OLDEST_SUPPORTED_VERSION - Static variable in class org.apache.distributedlog.LogSegmentMetadata
 
ledgersPath(String) - Method in class org.apache.distributedlog.BookKeeperClientBuilder
Set the ledgers path that bookkeeper client is going to access.
lid2LogSegments - Variable in class org.apache.distributedlog.logsegment.PerStreamLogSegmentCache
 
LIST_TO_VOID_FUNC - Static variable in class org.apache.distributedlog.common.functions.VoidFunctions
 
listeners - Variable in class org.apache.distributedlog.namespace.NamespaceWatcher
 
loadConf(URL) - Method in class org.apache.distributedlog.DistributedLogConfiguration
You can load configurations in precedence order.
loadConf(DistributedLogConfiguration) - Method in class org.apache.distributedlog.DistributedLogConfiguration
You can load configuration from other configuration
loadConf(Configuration) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Load configuration from other configuration object
loadStreamConf(Optional<DistributedLogConfiguration>) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Load whitelisted stream configuration from another configuration object
loadStreamConf(Optional<DistributedLogConfiguration>) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Load whitelisted stream configuration from another configuration object.
LOCAL_REGION_ID - Static variable in class org.apache.distributedlog.DistributedLogConstants
 
LocalDLMEmulator - Class in org.apache.distributedlog
Utility class for setting up bookkeeper ensembles and bringing individual bookies up and down
LocalDLMEmulator.Builder - Class in org.apache.distributedlog
 
LOCK_IMMEDIATE - Static variable in class org.apache.distributedlog.DistributedLogConstants
 
LOCK_OP_TIMEOUT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConstants
 
LOCK_PATH - Static variable in class org.apache.distributedlog.metadata.LogMetadata
 
LOCK_REACQUIRE_TIMEOUT_DEFAULT - Static variable in class org.apache.distributedlog.DistributedLogConstants
 
LOCK_TIMEOUT_INFINITE - Static variable in class org.apache.distributedlog.DistributedLogConstants
 
LockCancelledException - Exception in org.apache.distributedlog.exceptions
A lock is cancelled when waiting for locking a stream.
LockCancelledException(String, String, Throwable) - Constructor for exception org.apache.distributedlog.exceptions.LockCancelledException
 
LockClosedException - Exception in org.apache.distributedlog.lock
Exception indicates that the lock was closed (unlocked) before the lock request could complete.
LockClosedException(String, String) - Constructor for exception org.apache.distributedlog.lock.LockClosedException
 
LockClosedException(String, Pair<String, Long>, ZKSessionLock.State) - Constructor for exception org.apache.distributedlog.lock.LockClosedException
 
LOCKING_EXCEPTION - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
LockingException - Exception in org.apache.distributedlog.exceptions
Exception when a log writer attempts to acquire a lock to write data to the stream.
LockingException(String, String) - Constructor for exception org.apache.distributedlog.exceptions.LockingException
 
LockingException(String, String, Throwable) - Constructor for exception org.apache.distributedlog.exceptions.LockingException
 
LockingException(int, String, String) - Constructor for exception org.apache.distributedlog.exceptions.LockingException
 
LockingException(int, String, String, Throwable) - Constructor for exception org.apache.distributedlog.exceptions.LockingException
 
lockPath - Variable in class org.apache.distributedlog.metadata.LogMetadata
 
LockSessionExpiredException - Exception in org.apache.distributedlog.lock
Exception indicates that the lock's zookeeper session was expired before the lock request could complete.
LockSessionExpiredException(String, Pair<String, Long>, ZKSessionLock.State) - Constructor for exception org.apache.distributedlog.lock.LockSessionExpiredException
 
LockStateChangedException - Exception in org.apache.distributedlog.lock
Exception thrown when lock state changed
LockTimeoutException - Exception in org.apache.distributedlog.lock
Exception thrown when acquiring lock timeout
LockWaiter - Class in org.apache.distributedlog.lock
Lock waiter represents the attempt that application tries to lock.
LockWaiter(String, String, CompletableFuture<Boolean>) - Constructor for class org.apache.distributedlog.lock.LockWaiter
 
LOG_EMPTY - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
LOG_EXISTS - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
LOG_NOT_FOUND - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
LOG_READ_ERROR - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
LOG_SEGMENT_IS_TRUNCATED - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
LOG_SEGMENT_NOT_FOUND - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
LogEmptyException - Exception in org.apache.distributedlog.exceptions
Exceptions are thrown when attempt to read a log stream that doesn't have any records.
LogEmptyException(String) - Constructor for exception org.apache.distributedlog.exceptions.LogEmptyException
 
logExists(String) - Method in interface org.apache.distributedlog.api.namespace.Namespace
Check whether the log logName exist.
logExists(String) - Method in class org.apache.distributedlog.BKDistributedLogNamespace
 
logExists(URI, String) - Method in interface org.apache.distributedlog.metadata.LogStreamMetadataStore
Ensure the existence of a log stream
logExists(String) - Method in interface org.apache.distributedlog.namespace.DistributedLogNamespace
Check whether the log logName exist.
LogExistsException - Exception in org.apache.distributedlog.exceptions
Exception thrown on creating a log stream but the log stream already exists.
LogExistsException(String) - Constructor for exception org.apache.distributedlog.exceptions.LogExistsException
 
logger - Static variable in class org.apache.distributedlog.feature.AbstractFeatureProvider
 
logIdentifier - Variable in class org.apache.distributedlog.metadata.LogMetadata
 
LogMetadata - Class in org.apache.distributedlog.metadata
Class to represent the layout and metadata of the zookeeper-based log metadata
LogMetadata(URI, String, String) - Constructor for class org.apache.distributedlog.metadata.LogMetadata
metadata representation of a log
LogMetadataForReader - Class in org.apache.distributedlog.metadata
Log Metadata for Reader
LogMetadataForWriter - Class in org.apache.distributedlog.metadata
Log Metadata for writer
LogMetadataForWriter(URI, String, String, Versioned<byte[]>, Versioned<byte[]>, Versioned<byte[]>) - Constructor for class org.apache.distributedlog.metadata.LogMetadataForWriter
metadata representation of a log
LogMetadataStore - Interface in org.apache.distributedlog.metadata
Interface for log metadata store.
logName - Variable in class org.apache.distributedlog.metadata.LogMetadata
 
LogNotFoundException - Exception in org.apache.distributedlog.exceptions
Exception is thrown when a reader attempts to read a log stream that doesn't exist.
LogNotFoundException(String) - Constructor for exception org.apache.distributedlog.exceptions.LogNotFoundException
 
LogReader - Interface in org.apache.distributedlog.api
LogReader is a `synchronous` reader reading records from a DL log.
LogReader - Interface in org.apache.distributedlog
LogReader is a `synchronous` reader reading records from a DL log.
LogReadException - Exception in org.apache.distributedlog.exceptions
Thrown when there's a failure to read an edit log op from disk when loading edits.
LogReadException(String) - Constructor for exception org.apache.distributedlog.exceptions.LogReadException
 
LogRecord - Class in org.apache.distributedlog
Log record is the basic element in a log.
LogRecord() - Constructor for class org.apache.distributedlog.LogRecord
Construct an uninitialized log record.
LogRecord(long, byte[]) - Constructor for class org.apache.distributedlog.LogRecord
Construct a log record with TransactionId and payload.
LogRecord(long, ByteBuffer) - Constructor for class org.apache.distributedlog.LogRecord
Construct a log record with txid and payload buffer.
LogRecord(long, ByteBuf) - Constructor for class org.apache.distributedlog.LogRecord
Used by LogRecordWithDLSN to construct a log record read by readers.
LogRecord.Reader - Class in org.apache.distributedlog
Reader class to read log records from an input stream.
LogRecord.Writer - Class in org.apache.distributedlog
Writer class to write log records into an output stream.
LogRecordSet - Class in org.apache.distributedlog
A set of LogRecords.
LogRecordSet() - Constructor for class org.apache.distributedlog.LogRecordSet
 
LogRecordSet.Reader - Interface in org.apache.distributedlog
Reader to read LogRecords from this record set.
LogRecordSet.Writer - Interface in org.apache.distributedlog
Writer to append LogRecords to LogRecordSet.
LogRecordSetBuffer - Interface in org.apache.distributedlog
Write representation of a LogRecordSet.
LogRecordTooLongException - Exception in org.apache.distributedlog.exceptions
Exception is thrown when attempting to write a record whose size is too larger.
LogRecordTooLongException(String) - Constructor for exception org.apache.distributedlog.exceptions.LogRecordTooLongException
 
LogRecordWithDLSN - Class in org.apache.distributedlog
Log record with DLSN and SequenceId.
LogRecordWithDLSN(DLSN, long, byte[], long) - Constructor for class org.apache.distributedlog.LogRecordWithDLSN
 
LogRecordWithDLSN(DLSN, long, ByteBuf, long) - Constructor for class org.apache.distributedlog.LogRecordWithDLSN
 
logRootPath - Variable in class org.apache.distributedlog.metadata.LogMetadata
 
LOGSEGMENT_DEFAULT_STATUS - Static variable in class org.apache.distributedlog.DistributedLogConstants
 
LOGSEGMENT_NAME_VERSION - Static variable in class org.apache.distributedlog.DistributedLogConstants
 
LogSegmentEntryReader - Interface in org.apache.distributedlog.logsegment
An interface class to read the enveloped entry (serialized bytes of Entry) from a log segment
LogSegmentEntryReader.StateChangeListener - Interface in org.apache.distributedlog.logsegment
 
LogSegmentEntryStore - Interface in org.apache.distributedlog.logsegment
Log Segment Store to read log segments
LogSegmentEntryWriter - Interface in org.apache.distributedlog.logsegment
An interface class to write the enveloped entry (serialized bytes of Entry into the log segment.
LogSegmentFilter - Interface in org.apache.distributedlog.logsegment
Filter to filter log segments
logSegmentId - Variable in class org.apache.distributedlog.LogSegmentMetadata.LogSegmentMetadataBuilder
 
LogSegmentIsTruncatedException - Exception in org.apache.distributedlog.exceptions
Exception is thrown when reading data from a truncated log segment.
LogSegmentIsTruncatedException(String) - Constructor for exception org.apache.distributedlog.exceptions.LogSegmentIsTruncatedException
 
LogSegmentListener - Interface in org.apache.distributedlog.callback
Listener on log segments changes for a given stream used by BKLogReadHandler
LogSegmentMetadata - Class in org.apache.distributedlog
Utility class for storing the metadata associated with a single edit log segment, stored in a single ledger
LogSegmentMetadata.LogSegmentMetadataBuilder - Class in org.apache.distributedlog
 
LogSegmentMetadata.LogSegmentMetadataVersion - Enum in org.apache.distributedlog
 
LogSegmentMetadata.Mutator - Class in org.apache.distributedlog
Mutator to mutate the metadata of a log segment.
LogSegmentMetadata.TruncationStatus - Enum in org.apache.distributedlog
 
LogSegmentMetadataCache - Class in org.apache.distributedlog.logsegment
Cache the log segment metadata
LogSegmentMetadataCache(DistributedLogConfiguration, Ticker) - Constructor for class org.apache.distributedlog.logsegment.LogSegmentMetadataCache
 
LogSegmentMetadataStore - Interface in org.apache.distributedlog.logsegment
Interface for log segment metadata store.
LogSegmentMetadataStoreUpdater - Class in org.apache.distributedlog.metadata
 
LogSegmentMetadataStoreUpdater(DistributedLogConfiguration, LogSegmentMetadataStore) - Constructor for class org.apache.distributedlog.metadata.LogSegmentMetadataStoreUpdater
 
LogSegmentNamesListener - Interface in org.apache.distributedlog.callback
Listener on list of log segments changes for a given stream used by LogSegmentMetadataStore.
LogSegmentNotFoundException - Exception in org.apache.distributedlog.exceptions
Exception on log segment not found.
LogSegmentNotFoundException(String) - Constructor for exception org.apache.distributedlog.exceptions.LogSegmentNotFoundException
 
LogSegmentRandomAccessEntryReader - Interface in org.apache.distributedlog.logsegment
An interface class to read entries Entry from a random access log segment.
logSegments - Variable in class org.apache.distributedlog.logsegment.PerStreamLogSegmentCache
 
LOGSEGMENTS_PATH - Static variable in class org.apache.distributedlog.metadata.LogMetadata
 
logSegmentSequenceNo - Variable in class org.apache.distributedlog.LogSegmentMetadata.LogSegmentMetadataBuilder
 
logSegmentsPath - Variable in class org.apache.distributedlog.metadata.LogMetadata
 
LogSegmentWriter - Interface in org.apache.distributedlog.logsegment
An interface class to write log records into a log segment.
LogStreamMetadataStore - Interface in org.apache.distributedlog.metadata
The interface to manage the log stream metadata.
LogWriter - Interface in org.apache.distributedlog.api
 
LogWriter - Interface in org.apache.distributedlog
A generic interface class to support writing log records into a persistent distributed log.
LZ4 - Static variable in class org.apache.distributedlog.io.CompressionUtils
 
LZ4CompressionCodec - Class in org.apache.distributedlog.io
An lz4 based CompressionCodec implementation.
LZ4CompressionCodec() - Constructor for class org.apache.distributedlog.io.LZ4CompressionCodec
 

M

main(String[]) - Static method in class org.apache.distributedlog.LocalDLMEmulator
 
main(String[]) - Static method in class org.apache.distributedlog.service.DistributedLogServerApp
 
main(String[]) - Static method in class org.apache.distributedlog.service.MonitorServiceApp
 
main(String[]) - Static method in class org.apache.distributedlog.tests.backward.ReaderTest
 
main(String[]) - Static method in class org.apache.distributedlog.tests.backward.WriterTest
 
makeFeature(String) - Method in class org.apache.distributedlog.feature.DefaultFeatureProvider
 
makeFeature(String) - Method in class org.apache.distributedlog.feature.DynamicConfigurationFeatureProvider
 
makeProvider(String) - Method in class org.apache.distributedlog.feature.DefaultFeatureProvider
 
makeProvider(String) - Method in class org.apache.distributedlog.feature.DynamicConfigurationFeatureProvider
 
markEndOfStream() - Method in interface org.apache.distributedlog.api.AsyncLogWriter
Seal the log stream.
markEndOfStream() - Method in interface org.apache.distributedlog.api.LogWriter
Flushes all the data up to this point, adds the end of stream marker and marks the stream as read-only in the metadata.
markEndOfStream() - Method in class org.apache.distributedlog.AppendOnlyStreamWriter
 
markEndOfStream() - Method in interface org.apache.distributedlog.LogWriter
Flushes all the data up to this point, adds the end of stream marker and marks the stream as read-only in the metadata.
masterslave(StatsLogger, StatsLogger) - Static method in class org.apache.distributedlog.common.stats.BroadCastStatsLogger
Create a broadcast stats logger of two stats loggers master and slave.
MathUtil - Class in org.apache.distributedlog.common.util
Helpers for math related utils.
MathUtil() - Constructor for class org.apache.distributedlog.common.util.MathUtil
 
MAX_LOGRECORD_SIZE - Static variable in class org.apache.distributedlog.LogRecord
 
MAX_LOGRECORDSET_SIZE - Static variable in class org.apache.distributedlog.LogRecord
 
MAX_TXID - Static variable in class org.apache.distributedlog.DistributedLogConstants
 
MAX_TXID_PATH - Static variable in class org.apache.distributedlog.metadata.LogMetadata
 
maxRedirects(int) - Method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Max redirects that is allowed per request.
maxSpeculativeTimeoutMs(int) - Method in class org.apache.distributedlog.client.DistributedLogMultiStreamWriter.Builder
Set the max speculative timeout in milliseconds.
maxTxIdPath - Variable in class org.apache.distributedlog.metadata.LogMetadata
 
METADATA_EXCEPTION - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
MetadataAccessor - Interface in org.apache.distributedlog.api
Provide a metadata accessor to access customized metadata associated with logs.
MetadataException - Exception in org.apache.distributedlog.exceptions
Exception is thrown when encountering metadata errors.
MetadataException(String) - Constructor for exception org.apache.distributedlog.exceptions.MetadataException
 
MetadataException(String, Throwable) - Constructor for exception org.apache.distributedlog.exceptions.MetadataException
 
MetadataResolver - Interface in org.apache.distributedlog.metadata
Resolver to resolve the metadata used to instantiate a DL instance.
metadataStore - Variable in class org.apache.distributedlog.metadata.LogSegmentMetadataStoreUpdater
 
MetadataUpdater - Interface in org.apache.distributedlog.metadata
An updater to update metadata.
metadataVersion - Variable in class org.apache.distributedlog.metadata.LogSegmentMetadataStoreUpdater
 
minActiveEntryId - Variable in class org.apache.distributedlog.LogSegmentMetadata.LogSegmentMetadataBuilder
 
minActiveSlotId - Variable in class org.apache.distributedlog.LogSegmentMetadata.LogSegmentMetadataBuilder
 
MonitorException(String) - Constructor for exception org.apache.distributedlog.client.routing.ServerSetWatcher.MonitorException
 
MonitorException(String, Throwable) - Constructor for exception org.apache.distributedlog.client.routing.ServerSetWatcher.MonitorException
 
MonitorService - Class in org.apache.distributedlog.service
Monitor Service.
MonitorServiceApp - Class in org.apache.distributedlog.service
The launcher to run monitor service.
MonitorServiceClient - Interface in org.apache.distributedlog.client.monitor
Interface for distributedlog monitor service.
mutator() - Method in class org.apache.distributedlog.LogSegmentMetadata
 

N

name(String) - Method in class org.apache.distributedlog.BookKeeperClientBuilder
Set client name.
name(String) - Method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Client Name.
name(String) - Method in class org.apache.distributedlog.ZooKeeperClientBuilder
Set zookeeper client name
Namespace - Interface in org.apache.distributedlog.api.namespace
A namespace is the basic unit for managing a set of distributedlogs.
NamespaceBuilder - Class in org.apache.distributedlog.api.namespace
Builder to construct a Namespace.
NamespaceDriver - Interface in org.apache.distributedlog.namespace
Manager to manage all the stores required by a namespace.
NamespaceDriver.Role - Enum in org.apache.distributedlog.namespace
 
NamespaceDriverManager - Class in org.apache.distributedlog.namespace
The basic service for managing a set of namespace drivers.
NamespaceListener - Interface in org.apache.distributedlog.callback
 
NamespaceWatcher - Class in org.apache.distributedlog.namespace
Namespace Watcher watching namespace changes.
NamespaceWatcher() - Constructor for class org.apache.distributedlog.namespace.NamespaceWatcher
 
NetUtils - Class in org.apache.distributedlog.net
Utils about network
NetUtils() - Constructor for class org.apache.distributedlog.net.NetUtils
 
newBuilder() - Static method in class org.apache.distributedlog.api.namespace.NamespaceBuilder
 
newBuilder() - Static method in class org.apache.distributedlog.BookKeeperClientBuilder
Create a bookkeeper client builder to build bookkeeper clients.
newBuilder() - Static method in class org.apache.distributedlog.client.DistributedLogMultiStreamWriter
Create a new builder to create a multi stream writer.
newBuilder(String, ClientId, ClientBuilder, ClientConfig, ClientStats) - Static method in class org.apache.distributedlog.client.proxy.ProxyClient
 
newBuilder() - Static method in class org.apache.distributedlog.client.routing.ConsistentHashRoutingService
Builder helper class to build a consistent hash bashed RoutingService.
newBuilder() - Static method in class org.apache.distributedlog.client.routing.RegionsRoutingService
Create a builder to build a multiple-regions routing service.
newBuilder() - Static method in class org.apache.distributedlog.client.routing.SingleHostRoutingService
Builder to build single host based routing service.
newBuilder() - Static method in class org.apache.distributedlog.Entry
 
newBuilder() - Static method in class org.apache.distributedlog.LocalDLMEmulator
 
newBuilder() - Static method in class org.apache.distributedlog.namespace.DistributedLogNamespaceBuilder
 
newBuilder() - Static method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Create a client builder.
newBuilder(DistributedLogClientBuilder) - Static method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Create a new client builder from an existing builder.
newBuilder() - Static method in class org.apache.distributedlog.service.DistributedLogCluster
 
newBuilder() - Static method in class org.apache.distributedlog.ZooKeeperClientBuilder
Create a zookeeper client builder to build zookeeper clients.
newConfig(ClientConfig) - Static method in class org.apache.distributedlog.client.ClientConfig
 
newEntry(String, int, boolean, CompressionCodec.Type) - Static method in class org.apache.distributedlog.Entry
Create a new log record set.
newJFuture(Promise<T>) - Static method in class org.apache.distributedlog.protocol.util.TwitterFutureUtils
 
newLogSegmentAllocator(LogMetadataForWriter, DynamicDistributedLogConfiguration) - Method in interface org.apache.distributedlog.logsegment.LogSegmentEntryStore
Create a new log segment allocator for allocating log segment entry writers.
newTFuture(CompletableFuture<T>) - Static method in class org.apache.distributedlog.protocol.util.TwitterFutureUtils
 
newTFutureList(CompletableFuture<List<CompletableFuture<T>>>) - Static method in class org.apache.distributedlog.protocol.util.TwitterFutureUtils
 
newTransaction() - Method in interface org.apache.distributedlog.metadata.LogStreamMetadataStore
Create a transaction for the metadata operations happening in the metadata store.
newWriter(int, CompressionCodec.Type) - Static method in class org.apache.distributedlog.LogRecordSet
 
nextId() - Method in interface org.apache.distributedlog.common.util.Sequencer
Return next transaction id generated by the sequencer.
nextRecord() - Method in interface org.apache.distributedlog.Entry.Reader
Read next log record from this record set.
nextRecord() - Method in interface org.apache.distributedlog.LogRecordSet.Reader
Read next log record from this record set.
NONE - Static variable in class org.apache.distributedlog.io.CompressionUtils
 
NONE - Static variable in interface org.apache.distributedlog.ZooKeeperClient.Credentials
 
NonInclusiveLowerBound - Static variable in class org.apache.distributedlog.DLSN
 
NopDistributedLock - Class in org.apache.distributedlog.lock
An implementation of DistributedLock which does nothing.
NOT_IMPLEMENTED - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
notifyFatalError() - Method in class org.apache.distributedlog.service.DistributedLogServiceImpl
 
notifyFatalError() - Method in interface org.apache.distributedlog.service.FatalErrorHandler
This method is invoked when an unrecoverable error has occurred and no progress can be made.
notifySessionExpired() - Method in interface org.apache.distributedlog.ZooKeeperClient.ZooKeeperSessionExpireNotifier
 
NotYetImplementedException - Exception in org.apache.distributedlog.exceptions
Exception is thrown when a method is not implemented yet.
NotYetImplementedException(String) - Constructor for exception org.apache.distributedlog.exceptions.NotYetImplementedException
 
NULL - Static variable in interface org.apache.distributedlog.io.AsyncAbortable
 
NULL - Static variable in interface org.apache.distributedlog.io.AsyncCloseable
 
NULL_PERMIT_LIMITER - Static variable in interface org.apache.distributedlog.common.util.PermitLimiter
 
numBlackoutHosts - Variable in class org.apache.distributedlog.client.routing.ConsistentHashRoutingService
 
numBlackoutHostsGauge - Variable in class org.apache.distributedlog.client.routing.ConsistentHashRoutingService
 
numBookies(int) - Method in class org.apache.distributedlog.LocalDLMEmulator.Builder
 
numBookies(int) - Method in class org.apache.distributedlog.service.DistributedLogCluster.Builder
How many bookies to run.
numHostsGauge - Variable in class org.apache.distributedlog.client.routing.ConsistentHashRoutingService
 
numRecords(LogRecord) - Static method in class org.apache.distributedlog.LogRecordSet
 
numReplicas(int) - Method in class org.apache.distributedlog.client.routing.ConsistentHashRoutingService.Builder
 

O

of(ServerSetWatcher, int) - Static method in class org.apache.distributedlog.client.routing.ConsistentHashRoutingService
Deprecated.
of(RegionResolver, RoutingService...) - Static method in class org.apache.distributedlog.client.routing.RegionsRoutingService
Deprecated.
of(RegionResolver) - Static method in class org.apache.distributedlog.client.routing.RoutingService.RoutingContext
 
of(SocketAddress) - Static method in class org.apache.distributedlog.client.routing.SingleHostRoutingService
 
of(URI, int) - Static method in class org.apache.distributedlog.client.serverset.DLZkServerSet
 
of(int) - Static method in enum org.apache.distributedlog.io.CompressionCodec.Type
 
of() - Static method in class org.apache.distributedlog.io.IdentityCompressionCodec
 
of() - Static method in class org.apache.distributedlog.io.LZ4CompressionCodec
 
of(LogRecordWithDLSN) - Static method in class org.apache.distributedlog.LogRecordSet
 
of(int) - Static method in enum org.apache.distributedlog.LogSegmentMetadata.LogSegmentMetadataVersion
 
of(URI, String, String) - Static method in class org.apache.distributedlog.metadata.LogMetadataForReader
Create a metadata representation of a log for reader.
onAdd(String) - Method in class org.apache.distributedlog.client.stats.OwnershipStatsLogger
 
onAdd() - Method in class org.apache.distributedlog.client.stats.OwnershipStatsLogger.OwnershipStat
 
onCaughtupOnInprogress() - Method in interface org.apache.distributedlog.logsegment.LogSegmentEntryReader.StateChangeListener
Notify when caught up on inprogress.
onChange(ImmutableSet<DLSocketAddress>) - Method in interface org.apache.distributedlog.client.routing.ServerSetWatcher.ServerSetMonitor
Called when either the available set of services changes.
onExpired() - Method in class org.apache.distributedlog.lock.ZKDistributedLock
NOTE: The LockListener.onExpired() is already executed in lock executor.
onFailure(Throwable) - Method in interface org.apache.distributedlog.common.concurrent.FutureEventListener
 
onFailure(Throwable) - Method in class org.apache.distributedlog.common.stats.OpStatsListener
 
onHandshakeFailure(SocketAddress, ProxyClient, Throwable) - Method in class org.apache.distributedlog.client.DistributedLogClientImpl
 
onHandshakeFailure(SocketAddress, ProxyClient, Throwable) - Method in interface org.apache.distributedlog.client.proxy.ProxyListener
Failed to handshake with a proxy.
onHandshakeSuccess(SocketAddress, ProxyClient, ServerInfo) - Method in class org.apache.distributedlog.client.DistributedLogClientImpl
 
onHandshakeSuccess(SocketAddress, ProxyClient, ServerInfo) - Method in interface org.apache.distributedlog.client.proxy.ProxyListener
When a proxy's server info changed, it would be notified.
onHit(String) - Method in class org.apache.distributedlog.client.stats.OwnershipStatsLogger
 
onHit() - Method in class org.apache.distributedlog.client.stats.OwnershipStatsLogger.OwnershipStat
 
onLogSegmentMetadataUpdated(LogSegmentMetadata) - Method in interface org.apache.distributedlog.logsegment.LogSegmentEntryReader
Update the log segment each time when the metadata has changed.
onLogStreamDeleted() - Method in interface org.apache.distributedlog.callback.LogSegmentListener
Notified when the log stream is deleted.
onLogStreamDeleted() - Method in interface org.apache.distributedlog.callback.LogSegmentNamesListener
Notified when the log stream is deleted.
onMiss(String) - Method in class org.apache.distributedlog.client.stats.OwnershipStatsLogger
 
onMiss() - Method in class org.apache.distributedlog.client.stats.OwnershipStatsLogger.OwnershipStat
 
onRedirect(String) - Method in class org.apache.distributedlog.client.stats.OwnershipStatsLogger
 
onRedirect() - Method in class org.apache.distributedlog.client.stats.OwnershipStatsLogger.OwnershipStat
 
onReload(ConcurrentBaseConfiguration) - Method in interface org.apache.distributedlog.common.config.ConfigurationListener
Reload the configuration.
onReload(ConcurrentBaseConfiguration) - Method in class org.apache.distributedlog.feature.DynamicConfigurationFeatureProvider
 
onRemoval(RemovalNotification<String, LogSegmentMetadata>) - Method in class org.apache.distributedlog.logsegment.LogSegmentMetadataCache
 
onRemove(String) - Method in class org.apache.distributedlog.client.stats.OwnershipStatsLogger
 
onRemove() - Method in class org.apache.distributedlog.client.stats.OwnershipStatsLogger.OwnershipStat
 
onSegmentsUpdated(List<LogSegmentMetadata>) - Method in interface org.apache.distributedlog.callback.LogSegmentListener
Notified when segments updated.
onSegmentsUpdated(Versioned<List<String>>) - Method in interface org.apache.distributedlog.callback.LogSegmentNamesListener
Notified when segments updated.
onServerJoin(SocketAddress) - Method in class org.apache.distributedlog.client.DistributedLogClientImpl
 
onServerJoin(SocketAddress) - Method in interface org.apache.distributedlog.client.routing.RoutingService.RoutingListener
Trigger when server joint.
onServerLeft(SocketAddress) - Method in class org.apache.distributedlog.client.DistributedLogClientImpl
 
onServerLeft(SocketAddress) - Method in interface org.apache.distributedlog.client.routing.RoutingService.RoutingListener
Trigger when server left.
onStreamsChanged(Iterator<String>) - Method in interface org.apache.distributedlog.callback.NamespaceListener
Updated with latest streams.
onStreamsChanged(Iterator<String>) - Method in class org.apache.distributedlog.service.MonitorService
 
onSuccess(T) - Method in interface org.apache.distributedlog.common.concurrent.FutureEventListener
 
onSuccess(T) - Method in class org.apache.distributedlog.common.stats.OpStatsListener
 
openAsyncLogReader(long) - Method in interface org.apache.distributedlog.api.DistributedLogManager
Open an async log reader to read records from a log starting from fromTxnId.
openAsyncLogReader(DLSN) - Method in interface org.apache.distributedlog.api.DistributedLogManager
Open an async log reader to read records from a log starting from fromDLSN
openAsyncLogReader(long) - Method in interface org.apache.distributedlog.DistributedLogManager
Open an async log reader to read records from a log starting from fromTxnId.
openAsyncLogReader(DLSN) - Method in interface org.apache.distributedlog.DistributedLogManager
Open an async log reader to read records from a log starting from fromDLSN.
openAsyncLogReader(long) - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
openAsyncLogReader(DLSN) - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
openAsyncLogWriter() - Method in interface org.apache.distributedlog.api.DistributedLogManager
Open async log writer to write records to the log stream.
openAsyncLogWriter() - Method in interface org.apache.distributedlog.DistributedLogManager
Open async log writer to write records to the log stream.
openAsyncLogWriter() - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
openLog(String) - Method in interface org.apache.distributedlog.api.namespace.Namespace
Open a log named logName.
openLog(String, Optional<DistributedLogConfiguration>, Optional<DynamicDistributedLogConfiguration>, Optional<StatsLogger>) - Method in interface org.apache.distributedlog.api.namespace.Namespace
Open a log named logName with specific log configurations.
openLog(String) - Method in class org.apache.distributedlog.BKDistributedLogNamespace
 
openLog(String, Optional<DistributedLogConfiguration>, Optional<DynamicDistributedLogConfiguration>, Optional<StatsLogger>) - Method in class org.apache.distributedlog.BKDistributedLogNamespace
 
openLog(String) - Method in interface org.apache.distributedlog.namespace.DistributedLogNamespace
Open a log named logName.
openLog(String, Optional<DistributedLogConfiguration>, Optional<DynamicDistributedLogConfiguration>, Optional<StatsLogger>) - Method in interface org.apache.distributedlog.namespace.DistributedLogNamespace
Open a log named logName with specific log configurations.
openLogInternal(URI, String, Optional<DistributedLogConfiguration>, Optional<DynamicDistributedLogConfiguration>) - Method in class org.apache.distributedlog.BKDistributedLogNamespace
Open the log in location uri.
openLogReader(long) - Method in interface org.apache.distributedlog.api.DistributedLogManager
Open an sync log reader to read records from a log starting from fromTxnId.
openLogReader(DLSN) - Method in interface org.apache.distributedlog.api.DistributedLogManager
Open an async log reader to read records from a log starting from fromDLSN
openLogWriter() - Method in interface org.apache.distributedlog.api.DistributedLogManager
Open sync log writer to write records to the log stream.
openRandomAccessReader(LogSegmentMetadata, boolean) - Method in interface org.apache.distributedlog.logsegment.LogSegmentEntryStore
Open the reader for reading entries from a random access log segment.
openReader(LogSegmentMetadata, long) - Method in interface org.apache.distributedlog.logsegment.LogSegmentEntryStore
Open the reader for reading data to the log segment.
OpStats - Class in org.apache.distributedlog.client.stats
Op Stats.
OpStats(StatsReceiver, boolean, RegionResolver) - Constructor for class org.apache.distributedlog.client.stats.OpStats
 
OpStatsListener<T> - Class in org.apache.distributedlog.common.stats
A FutureEventListener monitors the stats for a given operation.
OpStatsListener(OpStatsLogger, Stopwatch) - Constructor for class org.apache.distributedlog.common.stats.OpStatsListener
 
OpStatsListener(OpStatsLogger) - Constructor for class org.apache.distributedlog.common.stats.OpStatsListener
 
OpStatsLogger - Class in org.apache.distributedlog.client.stats
Stats Logger per operation type.
OpStatsLogger(StatsReceiver) - Constructor for class org.apache.distributedlog.client.stats.OpStatsLogger
 
org.apache.distributedlog - package org.apache.distributedlog
Future based API.
org.apache.distributedlog.api - package org.apache.distributedlog.api
DistributedLog NEW API.
org.apache.distributedlog.api.namespace - package org.apache.distributedlog.api.namespace
Namespace API and the builder to build namespace instance.
org.apache.distributedlog.api.subscription - package org.apache.distributedlog.api.subscription
 
org.apache.distributedlog.callback - package org.apache.distributedlog.callback
Callbacks for distributedlog operations.
org.apache.distributedlog.client - package org.apache.distributedlog.client
DistributedLog Client.
org.apache.distributedlog.client.monitor - package org.apache.distributedlog.client.monitor
DistributedLog Monitor Client.
org.apache.distributedlog.client.ownership - package org.apache.distributedlog.client.ownership
Utils for managing ownership at client side.
org.apache.distributedlog.client.proxy - package org.apache.distributedlog.client.proxy
Clients that interact with individual proxies.
org.apache.distributedlog.client.resolver - package org.apache.distributedlog.client.resolver
Resolver to resolve network addresses.
org.apache.distributedlog.client.routing - package org.apache.distributedlog.client.routing
Routing Mechanisms to route the traffic to the owner of streams.
org.apache.distributedlog.client.serverset - package org.apache.distributedlog.client.serverset
Utils related to server set.
org.apache.distributedlog.client.speculative - package org.apache.distributedlog.client.speculative
Speculative Mechanism.
org.apache.distributedlog.client.stats - package org.apache.distributedlog.client.stats
Client side stats utils.
org.apache.distributedlog.common - package org.apache.distributedlog.common
Common functions and utils used across the project.
org.apache.distributedlog.common.annotations - package org.apache.distributedlog.common.annotations
Defines annotations used across distributedlog project.
org.apache.distributedlog.common.concurrent - package org.apache.distributedlog.common.concurrent
Utility classes commonly useful in concurrent programming.
org.apache.distributedlog.common.config - package org.apache.distributedlog.common.config
Configuration Related Utils.
org.apache.distributedlog.common.functions - package org.apache.distributedlog.common.functions
Common Functions.
org.apache.distributedlog.common.stats - package org.apache.distributedlog.common.stats
Stats Related Utils.
org.apache.distributedlog.common.util - package org.apache.distributedlog.common.util
Common utility functions.
org.apache.distributedlog.exceptions - package org.apache.distributedlog.exceptions
Defines exceptions used across distributedlog project.
org.apache.distributedlog.feature - package org.apache.distributedlog.feature
Feature & FeatureProvider for distributedlog
org.apache.distributedlog.io - package org.apache.distributedlog.io
IO Utils for distributedlog.
org.apache.distributedlog.lock - package org.apache.distributedlog.lock
Distributed locking mechanism in distributedlog
org.apache.distributedlog.logsegment - package org.apache.distributedlog.logsegment
Log Segment Management
org.apache.distributedlog.metadata - package org.apache.distributedlog.metadata
Metadata management for distributedlog.
org.apache.distributedlog.namespace - package org.apache.distributedlog.namespace
Future based namespace API.
org.apache.distributedlog.net - package org.apache.distributedlog.net
This package contains all the utilities of network.
org.apache.distributedlog.protocol.util - package org.apache.distributedlog.protocol.util
defines the protocol related utilities.
org.apache.distributedlog.service - package org.apache.distributedlog.service
DistributedLog Proxy Service.
org.apache.distributedlog.subscription - package org.apache.distributedlog.subscription
Future based subscription API.
org.apache.distributedlog.tests - package org.apache.distributedlog.tests
DistributedLog Tests Package.
org.apache.distributedlog.tests.backward - package org.apache.distributedlog.tests.backward
 
OVER_CAPACITY - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
OverCapacityException - Exception in org.apache.distributedlog.exceptions
Exception is thrown when the system is over capacity.
OverCapacityException(String) - Constructor for exception org.apache.distributedlog.exceptions.OverCapacityException
 
OverCapacityException(int, String) - Constructor for exception org.apache.distributedlog.exceptions.OverCapacityException
 
OwnershipAcquireFailedException - Exception in org.apache.distributedlog.exceptions
Exception is thrown when a log writer attempt to acquire a lock.
OwnershipAcquireFailedException(String, String) - Constructor for exception org.apache.distributedlog.exceptions.OwnershipAcquireFailedException
 
OwnershipCache - Class in org.apache.distributedlog.client.ownership
Client Side Ownership Cache.
OwnershipCache(ClientConfig, HashedWheelTimer, StatsReceiver, StatsReceiver) - Constructor for class org.apache.distributedlog.client.ownership.OwnershipCache
 
OwnershipStatsLogger - Class in org.apache.distributedlog.client.stats
Stats Logger for ownerships.
OwnershipStatsLogger(StatsReceiver, StatsReceiver) - Constructor for class org.apache.distributedlog.client.stats.OwnershipStatsLogger
 
OwnershipStatsLogger.OwnershipStat - Class in org.apache.distributedlog.client.stats
Ownership related stats.
ownerToHeader(String) - Static method in class org.apache.distributedlog.service.ResponseUtils
 

P

parseData(String, byte[]) - Static method in class org.apache.distributedlog.LogSegmentMetadata
 
parseServerSet(String) - Method in class org.apache.distributedlog.service.MonitorService
 
parseSocketAddress(String) - Static method in class org.apache.distributedlog.service.DLSocketAddress
Parse the inet socket address from the string representation.
performServerSetChange(ImmutableSet<DLSocketAddress>) - Method in class org.apache.distributedlog.client.routing.ConsistentHashRoutingService
 
periodicDumpOwnershipCache(boolean) - Method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Enable/Disable periodic dumping ownership cache.
periodicDumpOwnershipCacheIntervalMs(long) - Method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Set periodic dumping ownership cache interval.
periodicHandshakeIntervalMs(long) - Method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Set the periodic handshake interval in milliseconds.
periodicOwnershipSyncIntervalMs(long) - Method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Set the periodic ownership sync interval in milliseconds.
perLogStatsLogger(StatsLogger) - Method in class org.apache.distributedlog.api.namespace.NamespaceBuilder
Stats Logger used for collecting per log stats.
perLogStatsLogger(StatsLogger) - Method in class org.apache.distributedlog.namespace.DistributedLogNamespaceBuilder
Stats Logger used for collecting per log stats.
Permit - Interface in org.apache.distributedlog.common.util
Permit.
PermitLimiter - Interface in org.apache.distributedlog.common.util
A simple limiter interface which tracks acquire/release of permits, for example for tracking outstanding writes.
PermitManager - Interface in org.apache.distributedlog.common.util
Permit manager for managing permits.
PermitManager.Permit - Interface in org.apache.distributedlog.common.util
A class present a permit managed by a permit manager.
PerStreamLogSegmentCache - Class in org.apache.distributedlog.logsegment
Managing log segments in local cache.
PerStreamLogSegmentCache(String, boolean) - Constructor for class org.apache.distributedlog.logsegment.PerStreamLogSegmentCache
 
position() - Method in class org.apache.distributedlog.AppendOnlyStreamReader
 
position() - Method in class org.apache.distributedlog.AppendOnlyStreamWriter
 
positionOnTheNextLedger() - Method in class org.apache.distributedlog.DLSN
Positions to next log segment than the current value.
prepare() - Method in class org.apache.distributedlog.tests.CompressionBenchmark
 
preRun(DistributedLogConfiguration, ServerConfiguration) - Method in class org.apache.distributedlog.service.DistributedLogServer
 
processList(List<T>, Function<T, CompletableFuture<R>>, ExecutorService) - Static method in class org.apache.distributedlog.common.concurrent.FutureUtils
Process the list of items one by one using the process function processFunc.
PropertiesConfigurationBuilder - Class in org.apache.distributedlog.common.config
Hide PropertiesConfiguration dependency.
PropertiesConfigurationBuilder(URL) - Constructor for class org.apache.distributedlog.common.config.PropertiesConfigurationBuilder
 
ProtocolUtils - Class in org.apache.distributedlog.protocol.util
With CRC embedded in the application, we have to keep track of per api crc.
ProtocolUtils() - Constructor for class org.apache.distributedlog.protocol.util.ProtocolUtils
 
ProxyClient - Class in org.apache.distributedlog.client.proxy
Client talks to a single proxy.
ProxyClient(SocketAddress, Service<ThriftClientRequest, byte[]>, DistributedLogService.ServiceIface) - Constructor for class org.apache.distributedlog.client.proxy.ProxyClient
 
ProxyClient.Builder - Interface in org.apache.distributedlog.client.proxy
Builder to build a proxy client talking to given host address.
ProxyClient.DefaultBuilder - Class in org.apache.distributedlog.client.proxy
Default Builder for ProxyClient.
ProxyClientManager - Class in org.apache.distributedlog.client.proxy
Manager manages clients (channels) to proxies.
ProxyClientManager(ClientConfig, ProxyClient.Builder, HashedWheelTimer, HostProvider, ClientStats) - Constructor for class org.apache.distributedlog.client.proxy.ProxyClientManager
 
ProxyListener - Interface in org.apache.distributedlog.client.proxy
Listener on server changes.
proxyPort(int) - Method in class org.apache.distributedlog.service.DistributedLogCluster.Builder
Port that proxy server to listen on.
proxyTo(CompletableFuture<T>, CompletableFuture<T>) - Static method in class org.apache.distributedlog.common.concurrent.FutureUtils
 
purgeLogsOlderThan(long) - Method in interface org.apache.distributedlog.api.DistributedLogManager
The DistributedLogManager may archive/purge any logs for transactionId less than or equal to minImageTxId.
purgeLogsOlderThan(long) - Method in interface org.apache.distributedlog.DistributedLogManager
The DistributedLogManager may archive/purge any logs for transactionId less than or equal to minImageTxId.
purgeLogsOlderThan(long) - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
put(String, LogSegmentMetadata) - Method in class org.apache.distributedlog.logsegment.LogSegmentMetadataCache
Add the log segment of path to the cache.

R

read() - Method in class org.apache.distributedlog.AppendOnlyStreamReader
 
read(byte[], int, int) - Method in class org.apache.distributedlog.AppendOnlyStreamReader
 
read(ZooKeeperClient, String) - Static method in class org.apache.distributedlog.LogSegmentMetadata
 
read(ZooKeeperClient, String, boolean) - Static method in class org.apache.distributedlog.LogSegmentMetadata
 
READ_CANCELLED_EXCEPTION - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
READ_LOCK_PATH - Static variable in class org.apache.distributedlog.metadata.LogMetadata
 
readBulk(int) - Method in interface org.apache.distributedlog.api.AsyncLogReader
Read next numEntries entries.
readBulk(int, long, TimeUnit) - Method in interface org.apache.distributedlog.api.AsyncLogReader
Read next numEntries entries in a given waitTime.
readBulk(boolean, int) - Method in interface org.apache.distributedlog.api.LogReader
Read the next numLogRecords log records from the stream
readBulk(int) - Method in interface org.apache.distributedlog.AsyncLogReader
Read next numEntries entries.
readBulk(int, long, TimeUnit) - Method in interface org.apache.distributedlog.AsyncLogReader
Read next numEntries entries in a given waitTime.
readBulk(boolean, int) - Method in interface org.apache.distributedlog.LogReader
Read the next numLogRecords log records from the stream.
ReadCancelledException - Exception in org.apache.distributedlog.exceptions
Signals that a read request has been cancelled.
ReadCancelledException(String, String) - Constructor for exception org.apache.distributedlog.exceptions.ReadCancelledException
 
readEntries(long, long) - Method in interface org.apache.distributedlog.logsegment.LogSegmentRandomAccessEntryReader
Read entries [startEntryId, endEntryId] from a random access log segment.
Reader(RecordStream, ByteBuf, long) - Constructor for class org.apache.distributedlog.LogRecord.Reader
Construct the reader.
Reader(RecordStream, ByteBuf, long, boolean) - Constructor for class org.apache.distributedlog.LogRecord.Reader
 
ReaderTest - Class in org.apache.distributedlog.tests.backward
A test program to read records.
ReaderTest() - Constructor for class org.apache.distributedlog.tests.backward.ReaderTest
 
readNext() - Method in interface org.apache.distributedlog.api.AsyncLogReader
Read the next record from the log stream
readNext(boolean) - Method in interface org.apache.distributedlog.api.LogReader
Read the next log record from the stream.
readNext() - Method in interface org.apache.distributedlog.AsyncLogReader
Read the next record from the log stream.
readNext(boolean) - Method in interface org.apache.distributedlog.LogReader
Read the next log record from the stream.
readNext(int) - Method in interface org.apache.distributedlog.logsegment.LogSegmentEntryReader
Read next numEntries entries from current log segment.
readOp() - Method in class org.apache.distributedlog.LogRecord.Reader
Read an log record from the input stream.
readPayload(ByteBuf, boolean) - Method in class org.apache.distributedlog.LogRecord
 
ReadUtils - Class in org.apache.distributedlog
Utility function for readers
ReadUtils() - Constructor for class org.apache.distributedlog.ReadUtils
 
recordCount - Variable in class org.apache.distributedlog.LogSegmentMetadata.LogSegmentMetadataBuilder
 
recover() - Method in interface org.apache.distributedlog.api.DistributedLogManager
Run recovery on the log.
recover() - Method in interface org.apache.distributedlog.DistributedLogManager
Run recovery on the log.
recover() - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
redirectBackoffMaxMs(int) - Method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Max backoff time when redirecting to an already retried host.
redirectBackoffStartMs(int) - Method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Backoff time when redirecting to an already retried host.
ReferenceCounted - Interface in org.apache.distributedlog.common.util
An interface for indicating an object is reference counted.
REGION_UNAVAILABLE - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
regionId(int) - Method in class org.apache.distributedlog.api.namespace.NamespaceBuilder
Region Id used for encoding logs in the namespace.
regionId - Variable in class org.apache.distributedlog.LogSegmentMetadata.LogSegmentMetadataBuilder
 
regionId(int) - Method in class org.apache.distributedlog.namespace.DistributedLogNamespaceBuilder
Region Id used for encoding logs in the namespace.
RegionResolver - Interface in org.apache.distributedlog.client.resolver
Resolve address to region.
regionResolver - Variable in class org.apache.distributedlog.client.routing.RegionsRoutingService
 
RegionsRoutingService - Class in org.apache.distributedlog.client.routing
Chain multiple routing services.
RegionsRoutingService.Builder - Class in org.apache.distributedlog.client.routing
Builder to build a multiple-regions routing service.
RegionUnavailableException - Exception in org.apache.distributedlog.exceptions
Exception indicates that the service is not available in one region.
RegionUnavailableException(String) - Constructor for exception org.apache.distributedlog.exceptions.RegionUnavailableException
 
register(Watcher) - Method in class org.apache.distributedlog.ZooKeeperClient
Clients that need to register a top-level Watcher should do so using this method.
registerDriver(String, Class<? extends NamespaceDriver>) - Static method in class org.apache.distributedlog.namespace.NamespaceDriverManager
Register the namespace driver.
registerExpirationHandler(ZooKeeperClient.ZooKeeperSessionExpireNotifier) - Method in class org.apache.distributedlog.ZooKeeperClient
Clients that need to re-establish state after session expiration can register an onExpired command to execute.
registerListener(LogSegmentListener) - Method in interface org.apache.distributedlog.api.DistributedLogManager
Register listener on log segment updates of this stream.
registerListener(RoutingService.RoutingListener) - Method in class org.apache.distributedlog.client.routing.RegionsRoutingService
 
registerListener(RoutingService.RoutingListener) - Method in interface org.apache.distributedlog.client.routing.RoutingService
Register routing listener.
registerListener(RoutingService.RoutingListener) - Method in class org.apache.distributedlog.client.routing.SingleHostRoutingService
 
registerListener(ConfigurationListener) - Method in class org.apache.distributedlog.common.config.ConfigurationSubscription
 
registerListener(LogSegmentListener) - Method in interface org.apache.distributedlog.DistributedLogManager
Register listener on log segment updates of this stream.
registerListener(LogSegmentListener) - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
registerListener(LogSegmentEntryReader.StateChangeListener) - Method in interface org.apache.distributedlog.logsegment.LogSegmentEntryReader
Register the state change listener
registerListener(NamespaceListener) - Method in class org.apache.distributedlog.namespace.NamespaceWatcher
Register listener for namespace changes.
registerNamespaceListener(NamespaceListener) - Method in interface org.apache.distributedlog.api.namespace.Namespace
Register namespace listener on stream updates under the namespace.
registerNamespaceListener(NamespaceListener) - Method in class org.apache.distributedlog.BKDistributedLogNamespace
 
registerNamespaceListener(NamespaceListener) - Method in interface org.apache.distributedlog.metadata.LogMetadataStore
Register a namespace listener on streams changes.
registerNamespaceListener(NamespaceListener) - Method in interface org.apache.distributedlog.namespace.DistributedLogNamespace
Register namespace listener on stream updates under the namespace.
registerProxyListener(ProxyListener) - Method in class org.apache.distributedlog.client.proxy.ProxyClientManager
Register a proxy listener on proxy related changes.
release(String) - Method in class org.apache.distributedlog.client.DistributedLogClientImpl
 
release() - Method in interface org.apache.distributedlog.common.util.Permit
 
release(int) - Method in interface org.apache.distributedlog.common.util.PermitLimiter
Release a permit.
release() - Method in interface org.apache.distributedlog.common.util.ReferenceCounted
Release the reference.
release() - Method in interface org.apache.distributedlog.Entry.Reader
Release the resources held by the entry reader.
release() - Method in interface org.apache.distributedlog.LogRecordSet.Reader
Release the resources hold by this record set reader.
release(String) - Method in interface org.apache.distributedlog.service.DistributedLogClient
Release the ownership of a stream stream.
release(String, WriteContext) - Method in class org.apache.distributedlog.service.DistributedLogServiceImpl
 
releasePermit(PermitManager.Permit) - Method in interface org.apache.distributedlog.common.util.PermitManager
Release a given permit.
reloadCachedMappings() - Method in class org.apache.distributedlog.net.DNSResolver
remove(String) - Method in class org.apache.distributedlog.logsegment.PerStreamLogSegmentCache
Remove log segment name from the cache.
removeAllStreamsFromOwner(SocketAddress) - Method in class org.apache.distributedlog.client.ownership.OwnershipCache
Remove all streams from host addr.
removeCachedHost(SocketAddress) - Method in class org.apache.distributedlog.client.resolver.DefaultRegionResolver
 
removeCachedHost(SocketAddress) - Method in interface org.apache.distributedlog.client.resolver.RegionResolver
Remove cached host.
removeClient(SocketAddress) - Method in class org.apache.distributedlog.client.proxy.ProxyClientManager
Remove the client to proxy address.
removeClient(SocketAddress, ProxyClient) - Method in class org.apache.distributedlog.client.proxy.ProxyClientManager
Remove the client sc to proxy address.
removeHost(SocketAddress, Throwable) - Method in class org.apache.distributedlog.client.routing.ConsistentHashRoutingService
 
removeHost(SocketAddress, Throwable) - Method in class org.apache.distributedlog.client.routing.RegionsRoutingService
 
removeHost(SocketAddress, Throwable) - Method in interface org.apache.distributedlog.client.routing.RoutingService
Remove the host address for a specific reason.
removeHost(SocketAddress, Throwable) - Method in class org.apache.distributedlog.client.routing.SingleHostRoutingService
 
removeOwnerFromStream(String, SocketAddress, String) - Method in class org.apache.distributedlog.client.ownership.OwnershipCache
Remove the owner addr from stream for a given reason.
REQUEST_DENIED - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
RequestDeniedException - Exception in org.apache.distributedlog.exceptions
Signals that a request has been denied at the server.
RequestDeniedException(String, String) - Constructor for exception org.apache.distributedlog.exceptions.RequestDeniedException
 
requestRateLimit(double) - Method in class org.apache.distributedlog.ZooKeeperClientBuilder
 
requestTimeoutMs(long) - Method in class org.apache.distributedlog.client.DistributedLogMultiStreamWriter.Builder
Set request timeout in milliseconds.
requestTimeoutMs(int) - Method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Timeout per request in millis.
requestTimer(HashedWheelTimer) - Method in class org.apache.distributedlog.BookKeeperClientBuilder
Build BookKeeper client using existing request timer.
rescue(CompletableFuture<T>, Function<Throwable, CompletableFuture<T>>) - Static method in class org.apache.distributedlog.common.concurrent.FutureUtils
 
resolve(URI) - Method in interface org.apache.distributedlog.metadata.MetadataResolver
Resolve the path to get the DL metadata.
resolve(List<String>) - Method in class org.apache.distributedlog.net.DNSResolver
resolveFromName(boolean) - Method in class org.apache.distributedlog.client.routing.ConsistentHashRoutingService.Builder
 
resolver(RegionResolver) - Method in class org.apache.distributedlog.client.routing.RegionsRoutingService.Builder
 
resolveRegion(SocketAddress) - Method in class org.apache.distributedlog.client.resolver.DefaultRegionResolver
 
resolveRegion(SocketAddress) - Method in interface org.apache.distributedlog.client.resolver.RegionResolver
Resolve address to region.
resolveToNetworkLocation(String) - Method in class org.apache.distributedlog.net.DNSResolver
Resolve the domainName to its network location.
resolveToNetworkLocation(String) - Method in class org.apache.distributedlog.net.DNSResolverForRacks
 
resolveToNetworkLocation(String) - Method in class org.apache.distributedlog.net.DNSResolverForRows
 
ResponseUtils - Class in org.apache.distributedlog.service
Utility methods for building write proxy service responses.
ResponseUtils() - Constructor for class org.apache.distributedlog.service.ResponseUtils
 
result(CompletableFuture<T>) - Static method in class org.apache.distributedlog.common.concurrent.FutureUtils
 
result(CompletableFuture<T>, long, TimeUnit) - Static method in class org.apache.distributedlog.common.concurrent.FutureUtils
 
result(CompletableFuture<T>, Function<Throwable, ExceptionT>) - Static method in class org.apache.distributedlog.common.concurrent.FutureUtils
 
result(CompletableFuture<T>, Function<Throwable, ExceptionT>, long, TimeUnit) - Static method in class org.apache.distributedlog.common.concurrent.FutureUtils
 
retain() - Method in interface org.apache.distributedlog.common.util.ReferenceCounted
Retain the reference.
RETRYABLE_READ - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
RetryableReadException - Exception in org.apache.distributedlog.exceptions
Signals that a read request can be retried..
RetryableReadException(String, String) - Constructor for exception org.apache.distributedlog.exceptions.RetryableReadException
 
RetryableReadException(String, String, Throwable) - Constructor for exception org.apache.distributedlog.exceptions.RetryableReadException
 
retryPolicy(RetryPolicy) - Method in class org.apache.distributedlog.ZooKeeperClientBuilder
Build zookeeper client with given retry policy retryPolicy.
retryThreadCount(int) - Method in class org.apache.distributedlog.ZooKeeperClientBuilder
 
RollingPolicy - Interface in org.apache.distributedlog.logsegment
 
RoutingService - Interface in org.apache.distributedlog.client.routing
Routing Service provides mechanism how to route requests.
routingService(RoutingService) - Method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Routing Service to access proxy services.
RoutingService.Builder - Interface in org.apache.distributedlog.client.routing
Builder to build routing service.
RoutingService.RoutingContext - Class in org.apache.distributedlog.client.routing
Routing Context of a request.
RoutingService.RoutingListener - Interface in org.apache.distributedlog.client.routing
Listener for server changes on routing service.
routingServiceBuilders(RoutingService.Builder...) - Method in class org.apache.distributedlog.client.routing.RegionsRoutingService.Builder
 
routingServices - Variable in class org.apache.distributedlog.client.routing.RegionsRoutingService
 
RoutingUtils - Class in org.apache.distributedlog.client.routing
Utils for routing services.
RoutingUtils() - Constructor for class org.apache.distributedlog.client.routing.RoutingUtils
 
run() - Method in class org.apache.distributedlog.client.DistributedLogMultiStreamWriter
 
run(Timeout) - Method in class org.apache.distributedlog.client.ownership.OwnershipCache
 
run(Timeout) - Method in class org.apache.distributedlog.client.proxy.ProxyClientManager
 
runServer() - Method in class org.apache.distributedlog.service.DistributedLogServer
 
runServer(Optional<String>, Optional<String>, Optional<String>, Optional<Integer>, Optional<Integer>, Optional<Integer>, Optional<Boolean>, Optional<String>, Optional<Boolean>, RoutingService, StatsReceiver, StatsProvider) - Static method in class org.apache.distributedlog.service.DistributedLogServer
Running distributedlog server.
runServer() - Method in class org.apache.distributedlog.service.MonitorService
 
runZookeeperOnAnyPort(File) - Static method in class org.apache.distributedlog.LocalDLMEmulator
Try to start zookkeeper locally on any port.
runZookeeperOnAnyPort(int, File) - Static method in class org.apache.distributedlog.LocalDLMEmulator
Try to start zookkeeper locally on any port beginning with some base port.

S

scheduler(ScheduledExecutorService) - Method in class org.apache.distributedlog.client.DistributedLogMultiStreamWriter.Builder
Set the scheduler to flush output buffers.
SchedulerUtils - Class in org.apache.distributedlog.common.util
Scheduler related utils.
SchedulerUtils() - Constructor for class org.apache.distributedlog.common.util.SchedulerUtils
 
SCHEME_PREFIX - Static variable in class org.apache.distributedlog.DistributedLogConstants
 
Sequencer - Interface in org.apache.distributedlog.common.util
Sequencer generating transaction id.
serialize() - Method in class org.apache.distributedlog.DLSN
Serialize the DLSN into base64 encoded string.
serialize(byte) - Method in class org.apache.distributedlog.DLSN
Serialize the DLSN into base64 encoded string with given version.
serialize() - Method in interface org.apache.distributedlog.metadata.DLConfig
Serialize the dl config into a string.
serialize() - Method in class org.apache.distributedlog.metadata.DLMetadata
Serialize the DL metadata into bytes array.
serialize() - Method in class org.apache.distributedlog.service.DLSocketAddress
Serialize the write proxy identifier to string.
serializeBytes() - Method in class org.apache.distributedlog.DLSN
Serialize the DLSN into bytes with current version.
serializeBytes(byte) - Method in class org.apache.distributedlog.DLSN
Serialize the DLSN into bytes with given version.
serverConf(ServerConfiguration) - Method in class org.apache.distributedlog.LocalDLMEmulator.Builder
 
ServerFeatureKeys - Enum in org.apache.distributedlog.service
List of feature keys used by distributedlog server.
serverRoutingServiceFinagleNameStr(String) - Method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Configure the finagle name string for the server-side routing service.
serverSet(ServerSet) - Method in class org.apache.distributedlog.client.routing.ConsistentHashRoutingService.Builder
 
serverSet(ServerSet) - Method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Serverset to access proxy services.
serverSets(ServerSet, ServerSet...) - Method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Server Sets to access proxy services.
ServerSetWatcher - Interface in org.apache.distributedlog.client.routing
Watch on server set changes.
ServerSetWatcher.MonitorException - Exception in org.apache.distributedlog.client.routing
Exception thrown when failed to monitor serverset.
ServerSetWatcher.ServerSetMonitor - Interface in org.apache.distributedlog.client.routing
An interface to an object that is interested in receiving notification whenever the host set changes.
SERVICE_UNAVAILABLE - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
ServiceUnavailableException - Exception in org.apache.distributedlog.exceptions
Exception indicates that the service is unavailable at the server side.
ServiceUnavailableException(String) - Constructor for exception org.apache.distributedlog.exceptions.ServiceUnavailableException
 
SessionLock - Interface in org.apache.distributedlog.lock
One time lock.
SessionLockFactory - Interface in org.apache.distributedlog.lock
Factory to create SessionLock
sessionTimeoutMs(int) - Method in class org.apache.distributedlog.ZooKeeperClientBuilder
Set zookeeper session timeout in milliseconds.
set(long, long, long) - Static method in class org.apache.distributedlog.common.util.BitMaskUtils
1) Unset all bits where value in mask is set.
setAcceptNewStream(boolean) - Method in class org.apache.distributedlog.client.DistributedLogClientImpl
 
setAcceptNewStream(boolean) - Method in interface org.apache.distributedlog.client.monitor.MonitorServiceClient
Enable/Disable accepting new stream on a given proxy.
setAcceptNewStream(boolean) - Method in class org.apache.distributedlog.service.DistributedLogServiceImpl
 
setAckQuorumSize(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set ack quorum size of each log segment (ledger) will use.
setAddress(SocketAddress) - Method in class org.apache.distributedlog.client.routing.SingleHostRoutingService
 
setAlertWhenPositioningOnTruncated(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set if we should alert when reader is positioned on a truncated segment
setBKClientNumberIOThreads(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set BK client number of i/o threads used by netty.
setBKClientNumberWorkerThreads(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Deprecated. 
setBKClientReadTimeout(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Deprecated. 
setBKClientWriteTimeout(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Deprecated. 
setBKClientZKRequestRateLimit(double) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set zookeeper access rate limit for zookeeper client used in bookkeeper client.
setBKClientZKSessionTimeout(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set BK's zookeeper session timeout in seconds.
setBKDigestPW(String) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set password used by bookkeeper client for digestion.
setBkDNSResolverOverrides(String) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set mapping used to override the region mapping derived by the default resolver
setCheckLogExistenceBackoffMaxMillis(long) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the backoff max time to check log existence if the log doesn't exist.
setCheckLogExistenceBackoffStartMillis(long) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the backoff start time to check log existence if the log doesn't exist.
setChecksumEnabled(boolean) - Method in class org.apache.distributedlog.client.ClientConfig
 
setCompletionTime(long) - Method in class org.apache.distributedlog.LogSegmentMetadata.LogSegmentMetadataBuilder
 
setCompressionType(String) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the compression type to use while sending data to bookkeeper.
setControl() - Method in class org.apache.distributedlog.LogRecord
 
setCreateStreamIfNotExists(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Enable/Disable creating stream if not exists.
setDataLatencyWarnThresholdMillis(long) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the warn threshold of data access latency, in millis.
setDeserializeRecordSetOnReads(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Enable or disable deserialize recordset on reads.
setDisableRollingOnLogSegmentError(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the roll on segment error flag.
setDLLedgerMetadataLayoutVersion(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set DL ledger metadata output layout version.
setDLLedgerMetadataSkipMinVersionCheck(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set if we should skip the enforcement of min ledger metadata version.
setDurableWriteEnabled(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Enable/Disable durable writes in writers.
setDynamicConfigReloadIntervalSec(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Get dynamic configuration reload interval in seconds.
setEIInjectedWriteDelayMs(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set amount of time to delay writes for in writer failure injection.
setEIInjectedWriteDelayPercent(double) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set percent of write requests which should be delayed by BKDL_EI_INJECTED_WRITE_DELAY_MS.
setEIInjectMaxReadAheadDelayMs(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the max injected delay in read ahead, in millis.
setEIInjectReadAheadBrokenEntries(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the flag whether to inject broken entries in read ahead.
setEIInjectReadAheadDelay(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the flag whether to inject delays in read ahead.
setEIInjectReadAheadDelayPercent(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the percentage of operations to delay in read ahead.
setEIInjectReadAheadStall(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the flag whether to inject stalls in read ahead.
setEnableForceRead(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set if we should enable force read
setEnableLedgerAllocatorPool(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Enable/Disable ledger allocator pool.
setEnablePerStreamStat(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
setEnableReadAhead(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set if we should enable read ahead.
setEnableRecordCounts(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set if we should publish record counts in the log records and metadata.
setEnableTaskExecutionStats(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set to trace long running tasks and record task execution stats in thread pools.
setEncodeRegionIDInLogSegmentMetadata(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Enable/Disable encoding region id in log segment metadata.
setEnsemblePlacementDnsResolverClass(Class<? extends DNSToSwitchMapping>) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the DNS resolver class for bookkeeper ensemble placement.
setEnsembleSize(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set ensemble size of each log segment (ledger) will use.
setEntry(ByteBuf) - Method in class org.apache.distributedlog.Entry.Builder
Set the entry buffer of the serialized bytes data of this record set.
setEntryId(long) - Method in class org.apache.distributedlog.Entry.Builder
Set the entry id of this log record set.
setEnvelopeEntry(boolean) - Method in class org.apache.distributedlog.Entry.Builder
Set whether this record set is enveloped or not.
setExplicitTruncationByApplication(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Enable/Disable whether truncation is managed explicitly by the application.
setFailFastOnStreamNotReady(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the failfast on stream not ready flag.
setFeatureProviderClass(Class<? extends FeatureProvider>) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set feature provider class.
setFederatedCheckExistenceWhenCacheMiss(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Enable check existence of a log if quering local cache of a federated namespace missed.
setFederatedMaxLogsPerSubnamespace(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the max logs per sub namespace for federated namespace.
setFederatedNamespaceEnabled(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Use federated namespace implementation if this flag is enabled.
setFileFeatureProviderBaseConfigPath(String) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the base config path for file feature provider.
setFileFeatureProviderOverlayConfigPath(String) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the overlay config path for file feature provider.
setFirstLogSegmentSequenceNumber(long) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the value at which ledger sequence number should start for streams that are being upgraded and did not have ledger sequence number to start with or for newly created streams
setFirstNumEntriesPerReadLastRecordScan(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set number of entries to scan for first scan of reading last record.
setGlobalOutstandingWriteLimit(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the global write limit for dl.
setHandshakeTracingEnabled(boolean) - Method in class org.apache.distributedlog.client.ClientConfig
 
setHandshakeWithClientInfo(boolean) - Method in class org.apache.distributedlog.client.ClientConfig
 
setIgnoreTruncationStatus(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set if we should ignore truncation status when reading the records
setImmediateFlushEnabled(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Enable/Disable immediate flush
setInprogress(boolean) - Method in class org.apache.distributedlog.LogSegmentMetadata.LogSegmentMetadataBuilder
 
setLastDLSN(DLSN) - Method in class org.apache.distributedlog.LogSegmentMetadata.Mutator
 
setLastEntryId(long) - Method in class org.apache.distributedlog.LogSegmentMetadata.LogSegmentMetadataBuilder
 
setLastTxId(long) - Method in class org.apache.distributedlog.LogSegmentMetadata.LogSegmentMetadataBuilder
 
setLedgerAllocatorPoolCoreSize(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set core size of ledger allocator pool.
setLedgerAllocatorPoolName(String) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set name of ledger allocator pool.
setLedgerAllocatorPoolPath(String) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the root path of ledger allocator pool
setLockListener(LockListener) - Method in interface org.apache.distributedlog.lock.SessionLock
Set lock listener for lock state changes.
setLockOpTimeoutSeconds(long) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set lock internal operation timeout in seconds.
setLockReacquireTimeoutSeconds(long) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set lock reacquire timeout in seconds.
setLockTimeout(long) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set lock timeout in seconds.
setLogFlushTimeoutSeconds(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set Log Flush Timeout in seconds.
setLogSegmentActive(LogSegmentMetadata) - Method in class org.apache.distributedlog.metadata.LogSegmentMetadataStoreUpdater
Change the truncation status of a log segment to be active
setLogSegmentActive(LogSegmentMetadata) - Method in interface org.apache.distributedlog.metadata.MetadataUpdater
Change the truncation status of a log segment to be active
setLogSegmentCacheEnabled(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Enable/disable log segment cache.
setLogSegmentCacheMaxSize(long) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the maximum size of the log segment cache.
setLogSegmentCacheTTLMs(long) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the log segment cache entry TTL in milliseconds.
setLogSegmentInfo(long, long) - Method in class org.apache.distributedlog.Entry.Builder
Set the segment info of the log segment that this record set belongs to.
setLogSegmentNameVersion(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set log segment name version.
setLogSegmentPartiallyTruncated(LogSegmentMetadata, DLSN) - Method in class org.apache.distributedlog.metadata.LogSegmentMetadataStoreUpdater
Change the truncation status of a log segment to partially truncated
setLogSegmentPartiallyTruncated(Transaction<Object>, LogSegmentMetadata, DLSN) - Method in class org.apache.distributedlog.metadata.LogSegmentMetadataStoreUpdater
 
setLogSegmentPartiallyTruncated(LogSegmentMetadata, DLSN) - Method in interface org.apache.distributedlog.metadata.MetadataUpdater
Change the truncation status of a log segment to partially truncated
setLogSegmentPartiallyTruncated(Transaction<Object>, LogSegmentMetadata, DLSN) - Method in interface org.apache.distributedlog.metadata.MetadataUpdater
Change the truncation status of a log segment to partially truncated.
setLogSegmentRollingConcurrency(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set log segment rolling concurrency.
setLogSegmentRollingIntervalMinutes(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set log segment rolling interval in minutes.
setLogSegmentSequenceNumber(long) - Method in class org.apache.distributedlog.LogSegmentMetadata.Mutator
 
setLogSegmentSequenceNumberValidationEnabled(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Whether log segment sequence number validation is enabled?
setLogSegmentTruncated(LogSegmentMetadata) - Method in class org.apache.distributedlog.metadata.LogSegmentMetadataStoreUpdater
Change the truncation status of a log segment to truncated
setLogSegmentTruncated(Transaction<Object>, LogSegmentMetadata) - Method in class org.apache.distributedlog.metadata.LogSegmentMetadataStoreUpdater
 
setLogSegmentTruncated(LogSegmentMetadata) - Method in interface org.apache.distributedlog.metadata.MetadataUpdater
Change the truncation status of a log segment to truncated
setLogSegmentTruncated(Transaction<Object>, LogSegmentMetadata) - Method in interface org.apache.distributedlog.metadata.MetadataUpdater
Change the truncation status of a log segment to truncated.
setMaxAcquiredPartitionsPerProxy(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the maximum number of partitions of each stream allowed to be acquired per proxy.
setMaxCachedPartitionsPerProxy(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the maximum number of partitions of each stream allowed to cache per proxy.
setMaxLogSegmentBytes(long) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set Max LogSegment Size in Bytes.
setMaxNumEntriesPerReadLastRecordScan(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set max number of entries for each scan to read last record.
setMaxPrefetchEntriesPerLogSegment(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the max prefetch entries per log segment.
setMaxRedirects(int) - Method in class org.apache.distributedlog.client.ClientConfig
 
setMetadata(long) - Method in class org.apache.distributedlog.LogRecord
 
setMetadataLatencyWarnThresholdMillis(long) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the warn threshold of metadata access latency, in millis.
setMinActiveDLSN(DLSN) - Method in class org.apache.distributedlog.LogSegmentMetadata.Mutator
 
setMinDelayBetweenImmediateFlushMs(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set minimum delay between immediate flushes in milliseconds
setNumLockStateThreads(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the number of lock state threads used by distributedlog manager factory.
setNumPrefetchEntriesPerLogSegment(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the number prefetch entries per log segment.
setNumReadAheadWorkerThreads(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Deprecated.
setNumResourceReleaseThreads(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the number of resource release threads used by distributedlog manager factory.
setNumWorkerThreads(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the number of worker threads used by distributedlog namespace.
setOutputBufferSize(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set output buffer size for DL writers, in bytes.
setOutstandingWriteLimitDarkmode(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the flag to darkmode outstanding writes limit.
setPeriodicDumpOwnershipCacheEnabled(boolean) - Method in class org.apache.distributedlog.client.ClientConfig
 
setPeriodicDumpOwnershipCacheIntervalMs(long) - Method in class org.apache.distributedlog.client.ClientConfig
 
setPeriodicFlushFrequencyMilliSeconds(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set Periodic Log Flush Frequency in milliseconds.
setPeriodicHandshakeIntervalMs(long) - Method in class org.apache.distributedlog.client.ClientConfig
 
setPeriodicKeepAliveMilliSeconds(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set Periodic Keep Alive Frequency in milliseconds.
setPeriodicOwnershipSyncIntervalMs(long) - Method in class org.apache.distributedlog.client.ClientConfig
 
setPerWriterOutstandingWriteLimit(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the per stream outstanding write limit for dl.
setPositionGapDetectionEnabled(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set if enable position gap detection for reader.
setReadAheadBatchSize(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set number of entries read as a batch by readahead worker.
setReadAheadMaxRecords(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the maximum records allowed to be cached by read ahead worker.
setReadAheadNoSuchLedgerExceptionOnReadLACErrorThresholdMillis(long) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the error threshold that readahead will reinitialize ledger handle after keeping receiving no such ledger exceptions.
setReadAheadSkipBrokenEntries(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the percentage of operations to delay in read ahead.
setReadAheadWaitTime(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the wait time between successive attempts to poll for new log records, in milliseconds
setReadAheadWaitTimeOnEndOfStream(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the wait time that would be used for readahead to backoff polling logsegments from zookeeper when it reaches end of stream and there isn't any inprogress logsegment in the stream.
setReaderIdleErrorThresholdMillis(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the time in milliseconds as the threshold for when an idle reader should throw errors
setReaderIdleWarnThresholdMillis(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the time in milliseconds as the threshold for when an idle reader should dump warnings
setReadLACLongPollTimeout(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the long poll time out for read last add confirmed requests, in milliseconds.
setReadyToFlush() - Method in interface org.apache.distributedlog.LogWriter
All data that has been written to the stream so far will be sent to persistent storage.
setRecordCount(int) - Method in class org.apache.distributedlog.LogSegmentMetadata.LogSegmentMetadataBuilder
 
setRecordCount(LogRecord) - Method in class org.apache.distributedlog.LogSegmentMetadata.LogSegmentMetadataBuilder
 
setRecordSet() - Method in class org.apache.distributedlog.LogRecord
Set the record to represent a set of records.
setRedirectBackoffMaxMs(int) - Method in class org.apache.distributedlog.client.ClientConfig
 
setRedirectBackoffStartMs(int) - Method in class org.apache.distributedlog.client.ClientConfig
 
setRequestTimeoutMs(int) - Method in class org.apache.distributedlog.client.ClientConfig
 
setRetentionPeriodHours(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set log segment retention period in hours.
setRowAwareEnsemblePlacementEnabled(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set if we should enable row aware ensemble placement.
setSanityCheckTxnID(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Deprecated.
setSchedulerShutdownTimeoutMs(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set timeout for shutting down schedulers in dl manager, in milliseconds.
setStartSequenceId(long) - Method in class org.apache.distributedlog.LogSegmentMetadata.Mutator
 
setStreamConfigRouterClass(String) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set config router class.
setStreamFailfast(boolean) - Method in class org.apache.distributedlog.client.ClientConfig
 
setStreamNameRegex(String) - Method in class org.apache.distributedlog.client.ClientConfig
 
setTaskExecutionWarnTimeMicros(long) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set warn time for reporting long running tasks.
setThriftMux(boolean) - Method in class org.apache.distributedlog.client.ClientConfig
 
setTimeoutTimerNumTicks(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set number of ticks that used for timeout timer in bookkeeper client.
setTimeoutTimerTickDurationMs(long) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the tick duration in milliseconds that used for timeout timer in bookkeeper client.
setTraceReadAheadDeliveryLatency(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the flag to trace readahead delivery latency.
setTraceReadAheadMetadataChanges(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the flag to trace readahead metadata changes.
setTransactionId(long) - Method in class org.apache.distributedlog.LogRecord
Set application defined transaction id.
setTruncationStatus(LogSegmentMetadata.TruncationStatus) - Method in class org.apache.distributedlog.LogSegmentMetadata.Mutator
 
setUnpartitionedStreamName(String) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set name of the unpartitioned stream
setUseDaemonThread(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set whether to use daemon thread for DL threads.
setValue(Promise<T>, T) - Static method in class org.apache.distributedlog.protocol.util.TwitterFutureUtils
 
setVersion(LogSegmentMetadata.LogSegmentMetadataVersion) - Method in class org.apache.distributedlog.LogSegmentMetadata.Mutator
 
setWriteLockEnabled(boolean) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Enable lock for opening a writer to write a stream?
setWriteQuorumSize(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set write quorum size of each log segment (ledger) will use.
setZkAclId(String) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set digest id to use for ZK acl.
setZKClientNumberRetryThreads(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set ZK client number of retry executor threads.
setZKNumRetries(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set num of retries per request for zookeeper client.
setZkPath(String) - Method in class org.apache.distributedlog.LogSegmentMetadata.Mutator
 
setZKRequestRateLimit(double) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set zookeeper access rate limit (rps).
setZKRetryBackoffMaxMillis(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the max backoff time of zookeeper operation retries, in milliseconds.
setZKRetryBackoffStartMillis(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set the start backoff time of zookeeper operation retries, in milliseconds.
setZKSessionTimeoutSeconds(int) - Method in class org.apache.distributedlog.DistributedLogConfiguration
Set ZK Session Timeout in seconds.
shardId2Address - Variable in class org.apache.distributedlog.client.routing.ConsistentHashRoutingService
 
shouldRollover(Sizable, long) - Method in interface org.apache.distributedlog.logsegment.RollingPolicy
Determines if a rollover may be appropriate at this time.
shouldRollover(Sizable, long) - Method in class org.apache.distributedlog.logsegment.SizeBasedRollingPolicy
 
shouldRollover(Sizable, long) - Method in class org.apache.distributedlog.logsegment.TimeBasedRollingPolicy
 
shouldStartProxy(boolean) - Method in class org.apache.distributedlog.service.DistributedLogCluster.Builder
Whether to start proxy or not.
shouldStartZK(boolean) - Method in class org.apache.distributedlog.LocalDLMEmulator.Builder
 
shouldStartZK(boolean) - Method in class org.apache.distributedlog.service.DistributedLogCluster.Builder
Whether to start zookeeper? By default is true.
shutdown() - Method in class org.apache.distributedlog.service.DistributedLogCluster.DLServer
 
shutdownScheduler(ExecutorService, long, TimeUnit) - Static method in class org.apache.distributedlog.common.util.SchedulerUtils
 
signSafeMod(long, int) - Static method in class org.apache.distributedlog.common.util.MathUtil
 
SingleHostRoutingService - Class in org.apache.distributedlog.client.routing
Single Host Routing Service.
SingleHostRoutingService.Builder - Class in org.apache.distributedlog.client.routing
Builder to build single host based routing service.
Sizable - Interface in org.apache.distributedlog.common.util
The Sizable interface is to provide the capability of calculating size of any objects.
size() - Method in interface org.apache.distributedlog.common.util.Sizable
Calculate the size for this instance.
SizeBasedRollingPolicy - Class in org.apache.distributedlog.logsegment
 
SizeBasedRollingPolicy(long) - Constructor for class org.apache.distributedlog.logsegment.SizeBasedRollingPolicy
 
skipTo(long) - Method in class org.apache.distributedlog.AppendOnlyStreamReader
Position the reader at the given offset.
skipTo(long) - Method in interface org.apache.distributedlog.Entry.Reader
Skip the reader to the record whose transaction id is txId.
skipTo(DLSN) - Method in interface org.apache.distributedlog.Entry.Reader
Skip the reader to the record whose DLSN is dlsn.
skipTo(long, boolean) - Method in class org.apache.distributedlog.LogRecord.Reader
 
skipTo(DLSN) - Method in class org.apache.distributedlog.LogRecord.Reader
 
SMALL_LOGSEGMENT_THRESHOLD - Static variable in class org.apache.distributedlog.DistributedLogConstants
 
speculativeBackoffMultiplier(float) - Method in class org.apache.distributedlog.client.DistributedLogMultiStreamWriter.Builder
Set the speculative timeout backoff multiplier.
SpeculativeRequestExecutionPolicy - Interface in org.apache.distributedlog.client.speculative
Speculative request execution policy.
SpeculativeRequestExecutor - Interface in org.apache.distributedlog.client.speculative
Executor to execute speculative requests.
start() - Method in class org.apache.distributedlog.feature.AbstractFeatureProvider
Start the feature provider.
start() - Method in class org.apache.distributedlog.feature.DynamicConfigurationFeatureProvider
 
start() - Method in class org.apache.distributedlog.LocalDLMEmulator
 
start() - Method in interface org.apache.distributedlog.logsegment.LogSegmentEntryReader
Start the reader.
start() - Method in class org.apache.distributedlog.service.DistributedLogCluster
 
startAsyncLogSegmentNonPartitioned() - Method in interface org.apache.distributedlog.api.DistributedLogManager
Begin writing to the log stream identified by the name
startAsyncLogSegmentNonPartitioned() - Method in interface org.apache.distributedlog.DistributedLogManager
Begin writing to the log stream identified by the name.
startAsyncLogSegmentNonPartitioned() - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
startLogSegmentNonPartitioned() - Method in interface org.apache.distributedlog.api.DistributedLogManager
Begin writing to the log stream identified by the name
startLogSegmentNonPartitioned() - Method in interface org.apache.distributedlog.DistributedLogManager
Begin writing to the log stream identified by the name.
startLogSegmentNonPartitioned() - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
startPlacementPolicy() - Method in class org.apache.distributedlog.service.DistributedLogServiceImpl
 
startSequenceId - Variable in class org.apache.distributedlog.LogSegmentMetadata.LogSegmentMetadataBuilder
 
startService() - Method in class org.apache.distributedlog.client.routing.ConsistentHashRoutingService
 
startService() - Method in class org.apache.distributedlog.client.routing.RegionsRoutingService
 
startService() - Method in interface org.apache.distributedlog.client.routing.RoutingService
Start routing service.
startService() - Method in class org.apache.distributedlog.client.routing.SingleHostRoutingService
 
stats(CompletableFuture<T>, OpStatsLogger, Stopwatch) - Static method in class org.apache.distributedlog.common.concurrent.FutureUtils
Add a event listener over result for collecting the operation stats.
statsLogger(StatsLogger) - Method in class org.apache.distributedlog.api.namespace.NamespaceBuilder
Stats Logger used for stats collection
statsLogger(StatsLogger) - Method in class org.apache.distributedlog.BookKeeperClientBuilder
Build BookKeeper Client using given stats logger statsLogger.
statsLogger - Variable in class org.apache.distributedlog.feature.AbstractFeatureProvider
 
statsLogger(StatsLogger) - Method in class org.apache.distributedlog.namespace.DistributedLogNamespaceBuilder
Stats Logger used for stats collection.
statsLogger(StatsLogger) - Method in class org.apache.distributedlog.ZooKeeperClientBuilder
Build zookeeper client with given stats logger statsLogger.
statsReceiver(StatsReceiver) - Method in class org.apache.distributedlog.client.routing.ConsistentHashRoutingService.Builder
 
statsReceiver - Variable in class org.apache.distributedlog.client.routing.ConsistentHashRoutingService
 
statsReceiver(StatsReceiver) - Method in class org.apache.distributedlog.client.routing.RegionsRoutingService.Builder
 
statsReceiver(StatsReceiver) - Method in interface org.apache.distributedlog.client.routing.RoutingService.Builder
Build routing service with stats receiver.
statsReceiver(StatsReceiver) - Method in class org.apache.distributedlog.client.routing.SingleHostRoutingService.Builder
 
statsReceiver(StatsReceiver) - Method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Stats receiver to expose client stats.
status - Variable in class org.apache.distributedlog.LogSegmentMetadata.LogSegmentMetadataBuilder
 
StatusCode - Interface in org.apache.distributedlog.exceptions
Exception Status Code.
stop() - Method in class org.apache.distributedlog.feature.AbstractFeatureProvider
Stop the feature provider.
stop() - Method in class org.apache.distributedlog.feature.DynamicConfigurationFeatureProvider
 
stop() - Method in class org.apache.distributedlog.service.DistributedLogCluster
 
stopService() - Method in class org.apache.distributedlog.client.routing.ConsistentHashRoutingService
 
stopService() - Method in class org.apache.distributedlog.client.routing.RegionsRoutingService
 
stopService() - Method in interface org.apache.distributedlog.client.routing.RoutingService
Stop routing service.
stopService() - Method in class org.apache.distributedlog.client.routing.SingleHostRoutingService
 
storeMaxLogSegmentSequenceNumber(Transaction<Object>, LogMetadata, Versioned<Long>, Transaction.OpListener<Version>) - Method in interface org.apache.distributedlog.logsegment.LogSegmentMetadataStore
Store the maximum log segment sequence number on path.
storeMaxTxnId(Transaction<Object>, LogMetadataForWriter, Versioned<Long>, Transaction.OpListener<Version>) - Method in interface org.apache.distributedlog.logsegment.LogSegmentMetadataStore
Store the maximum transaction id for path
STREAM_NOT_READY - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
stream exists but is not ready (recovering etc.).
STREAM_UNAVAILABLE - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
streamFailfast(boolean) - Method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Set failfast stream exception handling enabled.
streamName - Variable in class org.apache.distributedlog.logsegment.PerStreamLogSegmentCache
 
streamNameRegex(String) - Method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Set the regex to match stream names that the client cares about.
StreamNotReadyException - Exception in org.apache.distributedlog.exceptions
Exception is thrown when a log stream is not ready on server side for serving the write requests.
StreamNotReadyException(String) - Constructor for exception org.apache.distributedlog.exceptions.StreamNotReadyException
 
streamOpCRC32(String) - Static method in class org.apache.distributedlog.protocol.util.ProtocolUtils
Generate crc32 for any op which only passes a stream name.
streams(List<String>) - Method in class org.apache.distributedlog.client.DistributedLogMultiStreamWriter.Builder
Set the list of streams to write to.
streamStatsReceiver(StatsReceiver) - Method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Stream Stats Receiver to expose per stream stats.
StreamUnavailableException - Exception in org.apache.distributedlog.exceptions
Exception thrown when a stream is not available for serving traffic.
StreamUnavailableException(String) - Constructor for exception org.apache.distributedlog.exceptions.StreamUnavailableException
 
streamUnavailableHeader() - Static method in class org.apache.distributedlog.service.ResponseUtils
 
stringToType(String) - Static method in class org.apache.distributedlog.io.CompressionUtils
Compression type value from string.
SubscriptionsStore - Interface in org.apache.distributedlog.api.subscription
Store to manage subscriptions
SubscriptionsStore - Interface in org.apache.distributedlog.subscription
Store to manage subscriptions.
SubscriptionStateStore - Interface in org.apache.distributedlog.api.subscription
 
SUCCESS - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
successHeader() - Static method in class org.apache.distributedlog.service.ResponseUtils
 
supportsEnvelopedEntries(int) - Static method in class org.apache.distributedlog.LogSegmentMetadata
Whether the provided version supports enveloping entries before writing to bookkeeper.
supportsLogSegmentSequenceNo() - Method in class org.apache.distributedlog.LogSegmentMetadata
 
supportsLogSegmentSequenceNo(int) - Static method in class org.apache.distributedlog.LogSegmentMetadata
Whether the provided version supports log segment sequence number.
supportsSequenceId() - Method in class org.apache.distributedlog.LogSegmentMetadata
 
supportsSequenceId(int) - Static method in class org.apache.distributedlog.LogSegmentMetadata
Whether the provided version supports sequence id.

T

teardown() - Method in class org.apache.distributedlog.LocalDLMEmulator
 
testCompressLZ4() - Method in class org.apache.distributedlog.tests.CompressionBenchmark
 
testCompressNone() - Method in class org.apache.distributedlog.tests.CompressionBenchmark
 
testDecompressLZ4() - Method in class org.apache.distributedlog.tests.CompressionBenchmark
 
testDecompressNone() - Method in class org.apache.distributedlog.tests.CompressionBenchmark
 
TestName - Class in org.apache.distributedlog.client.routing
A Name implementation for testing purpose.
TestName() - Constructor for class org.apache.distributedlog.client.routing.TestName
 
thriftmux(boolean) - Method in class org.apache.distributedlog.service.DistributedLogClientBuilder
Set thriftmux enabled.
thriftmux(boolean) - Method in class org.apache.distributedlog.service.DistributedLogCluster.Builder
Enable thriftmux for the dl server.
TimeBasedRollingPolicy - Class in org.apache.distributedlog.logsegment
 
TimeBasedRollingPolicy(long) - Constructor for class org.apache.distributedlog.logsegment.TimeBasedRollingPolicy
 
toLockId(InetSocketAddress, int) - Static method in class org.apache.distributedlog.service.DLSocketAddress
 
TOO_LARGE_RECORD - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
TOO_MANY_STREAMS - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
TooManyStreamsException - Exception in org.apache.distributedlog.exceptions
Signals that a server has been serving too many streams.
TooManyStreamsException(String) - Constructor for exception org.apache.distributedlog.exceptions.TooManyStreamsException
 
toString() - Method in class org.apache.distributedlog.client.routing.RoutingService.RoutingContext
 
toString() - Method in class org.apache.distributedlog.DLSN
 
toString() - Method in class org.apache.distributedlog.LogRecordWithDLSN
 
toString() - Method in class org.apache.distributedlog.LogSegmentMetadata
 
toString() - Method in class org.apache.distributedlog.metadata.DLMetadata
 
toString() - Method in class org.apache.distributedlog.service.DLSocketAddress
 
toString(InetSocketAddress) - Static method in class org.apache.distributedlog.service.DLSocketAddress
Convert inet socket address to the string representation.
transaction() - Method in interface org.apache.distributedlog.logsegment.LogSegmentMetadataStore
Start the transaction on changing log segment metadata store.
transaction() - Method in class org.apache.distributedlog.metadata.DryrunLogSegmentMetadataStoreUpdater
 
transaction() - Method in class org.apache.distributedlog.metadata.LogSegmentMetadataStoreUpdater
 
transaction() - Method in interface org.apache.distributedlog.metadata.MetadataUpdater
Start a transaction on metadata updates
TRANSACTION_OUT_OF_ORDER - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
TransactionIdOutOfOrderException - Exception in org.apache.distributedlog.exceptions
An exception is thrown when a log writer attempts to write a record with out-of-order transaction id.
TransactionIdOutOfOrderException(long, long) - Constructor for exception org.apache.distributedlog.exceptions.TransactionIdOutOfOrderException
 
TransactionIdOutOfOrderException(long) - Constructor for exception org.apache.distributedlog.exceptions.TransactionIdOutOfOrderException
 
truncate(DLSN) - Method in interface org.apache.distributedlog.api.AsyncLogWriter
Truncate the log until dlsn.
truncate(DLSN) - Method in interface org.apache.distributedlog.AsyncLogWriter
Truncate the log until dlsn.
truncate(String, DLSN) - Method in class org.apache.distributedlog.client.DistributedLogClientImpl
 
truncate(String, DLSN) - Method in interface org.apache.distributedlog.service.DistributedLogClient
Truncate the stream to a given dlsn.
truncate(String, String, WriteContext) - Method in class org.apache.distributedlog.service.DistributedLogServiceImpl
 
TRUNCATED_TRANSACTION - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
truncateOpCRC32(String, DLSN) - Static method in class org.apache.distributedlog.protocol.util.ProtocolUtils
Generate crc32 for TruncateOp.
tryLock(long, TimeUnit) - Method in interface org.apache.distributedlog.lock.SessionLock
Acquire the lock if it is free within given waiting time.
TwitterFutureUtils - Class in org.apache.distributedlog.protocol.util
Utils for Twitter's Future.
TwitterServerSetWatcher - Class in org.apache.distributedlog.client.routing
Twitter ServerSet based watcher.
TwitterServerSetWatcher(ServerSet, boolean) - Constructor for class org.apache.distributedlog.client.routing.TwitterServerSetWatcher
Construct a ServerSet based watcher.
two(StatsLogger, StatsLogger) - Static method in class org.apache.distributedlog.common.stats.BroadCastStatsLogger
Create a broadcast stats logger of two stats loggers `first` and `second`.

U

UNASSIGNED_LOGSEGMENT_SEQNO - Static variable in class org.apache.distributedlog.DistributedLogConstants
 
UNASSIGNED_SEQUENCE_ID - Static variable in class org.apache.distributedlog.DistributedLogConstants
 
unbind(URI) - Static method in class org.apache.distributedlog.metadata.DLMetadata
 
UNEXPECTED - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
UnexpectedException - Exception in org.apache.distributedlog.exceptions
An UnexpectedException is thrown when encountering unexpected conditions.
UnexpectedException() - Constructor for exception org.apache.distributedlog.exceptions.UnexpectedException
 
UnexpectedException(String) - Constructor for exception org.apache.distributedlog.exceptions.UnexpectedException
 
UnexpectedException(String, Throwable) - Constructor for exception org.apache.distributedlog.exceptions.UnexpectedException
 
UNKNOWN_CLIENT_ID - Static variable in class org.apache.distributedlog.DistributedLogConstants
 
UNLIMITED_PERMIT_MANAGER - Static variable in interface org.apache.distributedlog.common.util.PermitManager
 
unlock() - Method in interface org.apache.distributedlog.lock.SessionLock
Release a claimed lock.
unregister(Watcher) - Method in class org.apache.distributedlog.ZooKeeperClient
Clients can attempt to unregister a top-level Watcher that has previously been registered.
unregisterListener(LogSegmentListener) - Method in interface org.apache.distributedlog.api.DistributedLogManager
Unregister listener on log segment updates from this stream.
unregisterListener(RoutingService.RoutingListener) - Method in class org.apache.distributedlog.client.routing.RegionsRoutingService
 
unregisterListener(RoutingService.RoutingListener) - Method in interface org.apache.distributedlog.client.routing.RoutingService
Unregister routing listener.
unregisterListener(RoutingService.RoutingListener) - Method in class org.apache.distributedlog.client.routing.SingleHostRoutingService
 
unregisterListener(ConfigurationListener) - Method in class org.apache.distributedlog.common.config.ConfigurationSubscription
 
unregisterListener(LogSegmentListener) - Method in interface org.apache.distributedlog.DistributedLogManager
Unregister listener on log segment updates from this stream.
unregisterListener(LogSegmentListener) - Method in class org.apache.distributedlog.DistributedLogManagerImpl
 
unregisterListener(LogSegmentEntryReader.StateChangeListener) - Method in interface org.apache.distributedlog.logsegment.LogSegmentEntryReader
Unregister the state change listener
unregisterListener(NamespaceListener) - Method in class org.apache.distributedlog.namespace.NamespaceWatcher
Unregister listener from the namespace watcher.
unregisterLogSegmentListener(String, LogSegmentNamesListener) - Method in interface org.apache.distributedlog.logsegment.LogSegmentMetadataStore
Unregister a log segment listener on log segment changes under logSegmentsPath.
UNRESOLVED_LEDGER_ID - Static variable in class org.apache.distributedlog.DistributedLogConstants
 
UNSUPPORTED_METADATA_VERSION - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
UnsupportedMetadataVersionException - Exception in org.apache.distributedlog.exceptions
Exception is thrown when found unsupported metadata version.
UnsupportedMetadataVersionException(String) - Constructor for exception org.apache.distributedlog.exceptions.UnsupportedMetadataVersionException
 
update(Set<String>, Map<String, LogSegmentMetadata>) - Method in class org.apache.distributedlog.logsegment.PerStreamLogSegmentCache
Update the log segment cache with removed/added segments.
update(URI) - Method in class org.apache.distributedlog.metadata.DLMetadata
 
updateLastRecord(LogSegmentMetadata, LogRecordWithDLSN) - Method in class org.apache.distributedlog.metadata.LogSegmentMetadataStoreUpdater
 
updateLastRecord(LogSegmentMetadata, LogRecordWithDLSN) - Method in interface org.apache.distributedlog.metadata.MetadataUpdater
Update the log segment metadata with correct last record.
updateLogSegment(Transaction<Object>, LogSegmentMetadata) - Method in interface org.apache.distributedlog.logsegment.LogSegmentMetadataStore
Update a log segment segment under transaction txn.
updateOwner(String, SocketAddress) - Method in class org.apache.distributedlog.client.ownership.OwnershipCache
Update ownership of stream to addr.
updateSegmentMetadata(LogSegmentMetadata) - Method in class org.apache.distributedlog.metadata.LogSegmentMetadataStoreUpdater
 
uri(URI) - Method in class org.apache.distributedlog.api.namespace.NamespaceBuilder
Namespace Location.
uri - Variable in class org.apache.distributedlog.metadata.LogMetadata
 
uri(URI) - Method in class org.apache.distributedlog.namespace.DistributedLogNamespaceBuilder
Namespace Location.
uri(URI) - Method in class org.apache.distributedlog.service.DistributedLogClientBuilder
URI to access proxy services.
uri(URI) - Method in class org.apache.distributedlog.ZooKeeperClientBuilder
Set DistributedLog URI.

V

validate() - Method in class org.apache.distributedlog.DistributedLogConfiguration
Validate the configuration
validateLogSegmentSequenceNumber - Variable in class org.apache.distributedlog.logsegment.PerStreamLogSegmentCache
 
value(T) - Static method in class org.apache.distributedlog.common.concurrent.FutureUtils
 
value - Variable in enum org.apache.distributedlog.LogSegmentMetadata.LogSegmentMetadataVersion
 
valueOf(String) - Static method in enum org.apache.distributedlog.feature.CoreFeatureKeys
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.distributedlog.io.CompressionCodec.Type
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.distributedlog.LogSegmentMetadata.LogSegmentMetadataVersion
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.distributedlog.LogSegmentMetadata.TruncationStatus
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.distributedlog.namespace.NamespaceDriver.Role
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.distributedlog.service.ServerFeatureKeys
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.distributedlog.feature.CoreFeatureKeys
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.distributedlog.io.CompressionCodec.Type
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.distributedlog.LogSegmentMetadata.LogSegmentMetadataVersion
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.distributedlog.LogSegmentMetadata.TruncationStatus
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.distributedlog.namespace.NamespaceDriver.Role
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.distributedlog.service.ServerFeatureKeys
Returns an array containing the constants of this enum type, in the order they are declared.
version - Variable in class org.apache.distributedlog.LogSegmentMetadata.LogSegmentMetadataBuilder
 
VERSION0 - Static variable in class org.apache.distributedlog.DLSN
 
VERSION1 - Static variable in class org.apache.distributedlog.DLSN
 
VERSION_PATH - Static variable in class org.apache.distributedlog.metadata.LogMetadata
 
Void() - Static method in class org.apache.distributedlog.common.concurrent.FutureUtils
 
VoidFunctions - Class in org.apache.distributedlog.common.functions
Functions for transforming structures related to Void.
VoidFunctions() - Constructor for class org.apache.distributedlog.common.functions.VoidFunctions
 

W

waitForAcquireQuietly() - Method in class org.apache.distributedlog.lock.LockWaiter
Wait for the acquire result.
watch(ServerSetWatcher.ServerSetMonitor) - Method in interface org.apache.distributedlog.client.routing.ServerSetWatcher
Registers a monitor to receive change notices for this server set as long as this jvm process is alive.
watch(ServerSetWatcher.ServerSetMonitor) - Method in class org.apache.distributedlog.client.routing.TwitterServerSetWatcher
Registers a monitor to receive change notices for this server set as long as this jvm process is alive.
watchNamespaceChanges() - Method in class org.apache.distributedlog.namespace.NamespaceWatcher
Watch the namespace changes.
whenCompleteAsync(CompletableFuture<T>, BiConsumer<? super T, ? super Throwable>, OrderedScheduler, Object) - Static method in class org.apache.distributedlog.common.concurrent.FutureUtils
Completing the future in the thread in the scheduler identified by the scheduleKey.
within(CompletableFuture<T>, long, TimeUnit, Throwable, OrderedScheduler, Object) - Static method in class org.apache.distributedlog.common.concurrent.FutureUtils
Raise an exception to the promise within a given timeout period.
write(LogRecord) - Method in interface org.apache.distributedlog.api.AsyncLogWriter
Write a log record to the stream.
write(LogRecord) - Method in interface org.apache.distributedlog.api.LogWriter
Write a log record to the stream.
write(byte[]) - Method in class org.apache.distributedlog.AppendOnlyStreamWriter
 
write(LogRecord) - Method in interface org.apache.distributedlog.AsyncLogWriter
Write a log record to the stream.
write(String, ByteBuffer) - Method in class org.apache.distributedlog.client.DistributedLogClientImpl
 
write(ByteBuffer) - Method in class org.apache.distributedlog.client.DistributedLogMultiStreamWriter
 
write(LogRecord) - Method in interface org.apache.distributedlog.logsegment.LogSegmentWriter
This isn't a simple synchronous version of asyncWrite.
write(ZooKeeperClient) - Method in class org.apache.distributedlog.LogSegmentMetadata
 
write(LogRecord) - Method in interface org.apache.distributedlog.LogWriter
Write a log record to the stream.
write(String, ByteBuffer) - Method in interface org.apache.distributedlog.service.DistributedLogClient
Write data to a given stream.
write(String, ByteBuffer) - Method in class org.apache.distributedlog.service.DistributedLogServiceImpl
 
write(ResponseHeader) - Static method in class org.apache.distributedlog.service.ResponseUtils
 
WRITE_CANCELLED_EXCEPTION - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
WRITE_EXCEPTION - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
writeBulk(List<LogRecord>) - Method in interface org.apache.distributedlog.api.AsyncLogWriter
Write log records to the stream in bulk.
writeBulk(List<LogRecord>) - Method in interface org.apache.distributedlog.api.LogWriter
Deprecated.
writeBulk(List<LogRecord>) - Method in interface org.apache.distributedlog.AsyncLogWriter
Write log records to the stream in bulk.
writeBulk(String, List<ByteBuffer>) - Method in class org.apache.distributedlog.client.DistributedLogClientImpl
 
writeBulk(List<LogRecord>) - Method in interface org.apache.distributedlog.LogWriter
Deprecated.
writeBulk(String, List<ByteBuffer>) - Method in interface org.apache.distributedlog.service.DistributedLogClient
Write data in bulk to a given stream.
writeBulkWithContext(String, List<ByteBuffer>, WriteContext) - Method in class org.apache.distributedlog.service.DistributedLogServiceImpl
 
WriteCancelledException - Exception in org.apache.distributedlog.exceptions
Signals when a write request is cancelled.
WriteCancelledException(String, Throwable) - Constructor for exception org.apache.distributedlog.exceptions.WriteCancelledException
 
WriteCancelledException(String, String) - Constructor for exception org.apache.distributedlog.exceptions.WriteCancelledException
 
WriteCancelledException(String) - Constructor for exception org.apache.distributedlog.exceptions.WriteCancelledException
 
writeDenied() - Static method in class org.apache.distributedlog.service.ResponseUtils
 
WriteException - Exception in org.apache.distributedlog.exceptions
An exception on writing log records.
WriteException(String, String) - Constructor for exception org.apache.distributedlog.exceptions.WriteException
 
writeOp(LogRecord) - Method in class org.apache.distributedlog.LogRecord.Writer
Write an operation to the output stream.
writeOpCRC32(String, ByteBuf) - Static method in class org.apache.distributedlog.protocol.util.ProtocolUtils
Generate crc32 for WriteOp.
writeOpCRC32(String, ByteBuffer) - Static method in class org.apache.distributedlog.protocol.util.ProtocolUtils
Generate crc32 for WriteOp.
Writer(ByteBuf) - Constructor for class org.apache.distributedlog.LogRecord.Writer
 
writeRecord(LogRecord, CompletableFuture<DLSN>) - Method in interface org.apache.distributedlog.Entry.Writer
Write a LogRecord to this record set.
writeRecord(ByteBuffer, CompletableFuture<DLSN>) - Method in interface org.apache.distributedlog.LogRecordSet.Writer
Write a LogRecord to this record set.
writeRecordSet(String, LogRecordSetBuffer) - Method in class org.apache.distributedlog.client.DistributedLogClientImpl
 
writeRecordSet(String, LogRecordSetBuffer) - Method in interface org.apache.distributedlog.service.DistributedLogClient
Write record set to a given stream.
WriterTest - Class in org.apache.distributedlog.tests.backward
A test program to write records.
WriterTest() - Constructor for class org.apache.distributedlog.tests.backward.WriterTest
 
writeSuccess() - Static method in class org.apache.distributedlog.service.ResponseUtils
 
writeWithContext(String, ByteBuffer, WriteContext) - Method in class org.apache.distributedlog.service.DistributedLogServiceImpl
 

Z

ZK_CONNECTION_EXCEPTION_RESULT_CODE - Static variable in class org.apache.distributedlog.DistributedLogConstants
 
zkAclId(String) - Method in class org.apache.distributedlog.ZooKeeperClientBuilder
* Build zookeeper client with given zk acl digest id zkAclId.
zkc(ZooKeeperClient) - Method in class org.apache.distributedlog.BookKeeperClientBuilder
Set the zkc used to build bookkeeper client.
zkc(ZooKeeperClient) - Method in class org.apache.distributedlog.ZooKeeperClientBuilder
Build zookeeper client using existing zkc client.
ZKDistributedLock - Class in org.apache.distributedlog.lock
Distributed lock, using ZooKeeper.
ZKDistributedLock(OrderedScheduler, SessionLockFactory, String, long, StatsLogger) - Constructor for class org.apache.distributedlog.lock.ZKDistributedLock
 
ZKException - Exception in org.apache.distributedlog.exceptions
TODO: move ZKException to distributedlog-protocol
ZKException(String, KeeperException.Code) - Constructor for exception org.apache.distributedlog.exceptions.ZKException
 
ZKException(String, KeeperException) - Constructor for exception org.apache.distributedlog.exceptions.ZKException
 
zkHost(String) - Method in class org.apache.distributedlog.LocalDLMEmulator.Builder
 
zkPath - Variable in class org.apache.distributedlog.LogSegmentMetadata.LogSegmentMetadataBuilder
 
zkPort(int) - Method in class org.apache.distributedlog.LocalDLMEmulator.Builder
 
zkPort(int) - Method in class org.apache.distributedlog.service.DistributedLogCluster.Builder
ZooKeeper server port to listen on.
zkServers(String) - Method in class org.apache.distributedlog.BookKeeperClientBuilder
Set the zookeeper servers that bookkeeper client would connect to.
zkServers(String) - Method in class org.apache.distributedlog.service.DistributedLogCluster.Builder
ZooKeeper server to run.
zkServers(String) - Method in class org.apache.distributedlog.ZooKeeperClientBuilder
Set ZooKeeper Connect String.
ZKSessionLockFactory - Class in org.apache.distributedlog.lock
Factory to create zookeeper based locks.
ZKSessionLockFactory(ZooKeeperClient, String, OrderedScheduler, int, long, long, StatsLogger) - Constructor for class org.apache.distributedlog.lock.ZKSessionLockFactory
 
zkTimeoutSec(int) - Method in class org.apache.distributedlog.LocalDLMEmulator.Builder
 
ZOOKEEPER_ERROR - Static variable in interface org.apache.distributedlog.exceptions.StatusCode
 
ZooKeeperClient - Class in org.apache.distributedlog
ZooKeeper Client wrapper over ZooKeeperClient.
ZooKeeperClient.Credentials - Interface in org.apache.distributedlog
 
ZooKeeperClient.DigestCredentials - Class in org.apache.distributedlog
 
ZooKeeperClient.ZooKeeperConnectionException - Exception in org.apache.distributedlog
Indicates an error connecting to a zookeeper cluster.
ZooKeeperClient.ZooKeeperSessionExpireNotifier - Interface in org.apache.distributedlog
 
ZooKeeperClientBuilder - Class in org.apache.distributedlog
Builder to build zookeeper client.
ZooKeeperConnectionException(String) - Constructor for exception org.apache.distributedlog.ZooKeeperClient.ZooKeeperConnectionException
 
ZooKeeperConnectionException(String, Throwable) - Constructor for exception org.apache.distributedlog.ZooKeeperClient.ZooKeeperConnectionException
 
A B C D E F G H I J L M N O P R S T U V W Z 
Skip navigation links

Copyright © 2016-2018 The Apache Software Foundation. All Rights Reserved.