Path	Lines of Code
bookkeeper-benchmark/conf/log4j2.xml	24
bookkeeper-benchmark/src/main/java/org/apache/bookkeeper/benchmark/BenchBookie.java	203
bookkeeper-benchmark/src/main/java/org/apache/bookkeeper/benchmark/BenchReadThroughputLatency.java	256
bookkeeper-benchmark/src/main/java/org/apache/bookkeeper/benchmark/BenchThroughputLatency.java	387
bookkeeper-benchmark/src/main/java/org/apache/bookkeeper/benchmark/TestClient.java	242
bookkeeper-benchmark/src/main/java/org/apache/bookkeeper/benchmark/package-info.java	1
bookkeeper-common-allocator/src/main/java/org/apache/bookkeeper/common/allocator/ByteBufAllocatorBuilder.java	20
bookkeeper-common-allocator/src/main/java/org/apache/bookkeeper/common/allocator/ByteBufAllocatorWithOomHandler.java	6
bookkeeper-common-allocator/src/main/java/org/apache/bookkeeper/common/allocator/LeakDetectionPolicy.java	20
bookkeeper-common-allocator/src/main/java/org/apache/bookkeeper/common/allocator/OutOfMemoryPolicy.java	5
bookkeeper-common-allocator/src/main/java/org/apache/bookkeeper/common/allocator/PoolingPolicy.java	5
bookkeeper-common-allocator/src/main/java/org/apache/bookkeeper/common/allocator/impl/ByteBufAllocatorBuilderImpl.java	63
bookkeeper-common-allocator/src/main/java/org/apache/bookkeeper/common/allocator/impl/ByteBufAllocatorImpl.java	168
bookkeeper-common-allocator/src/main/java/org/apache/bookkeeper/common/allocator/impl/package-info.java	1
bookkeeper-common-allocator/src/main/java/org/apache/bookkeeper/common/allocator/package-info.java	1
bookkeeper-common-allocator/src/main/java/org/apache/bookkeeper/common/util/ShutdownUtil.java	44
bookkeeper-common-allocator/src/main/java/org/apache/bookkeeper/common/util/package-info.java	1
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/annotation/InterfaceAudience.java	18
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/annotation/InterfaceStability.java	13
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/annotation/package-info.java	1
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/collections/BatchedArrayBlockingQueue.java	306
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/collections/BatchedBlockingQueue.java	8
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/collections/BlockingMpscQueue.java	131
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/collections/BusyWait.java	30
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/collections/GrowableMpScArrayConsumerBlockingQueue.java	235
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/collections/RecyclableArrayList.java	40
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/collections/package-info.java	1
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/component/AbstractComponent.java	16
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/component/AbstractLifecycleComponent.java	94
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/component/AutoCloseableLifecycleComponent.java	73
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/component/ComponentInfoPublisher.java	89
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/component/ComponentStarter.java	48
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/component/Lifecycle.java	108
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/component/LifecycleComponent.java	15
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/component/LifecycleComponentStack.java	111
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/component/LifecycleListener.java	9
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/component/RxSchedulerLifecycleComponent.java	32
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/component/package-info.java	1
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/concurrent/FutureEventListener.java	19
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/concurrent/FutureUtils.java	260
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/concurrent/package-info.java	1
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/conf/ComponentConfiguration.java	232
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/conf/ConcurrentConfiguration.java	38
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/conf/ConfigDef.java	228
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/conf/ConfigException.java	10
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/conf/ConfigKey.java	185
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/conf/ConfigKeyGroup.java	47
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/conf/Type.java	21
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/conf/Validator.java	9
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/conf/package-info.java	1
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/conf/validators/ClassValidator.java	45
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/conf/validators/NullValidator.java	13
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/conf/validators/RangeValidator.java	44
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/conf/validators/package-info.java	1
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/net/ServiceURI.java	117
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/net/package-info.java	1
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/package-info.java	1
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/stats/BroadCastStatsLogger.java	146
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/stats/OpStatsListener.java	28
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/stats/package-info.java	1
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/Backoff.java	150
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/BoundedExecutorService.java	74
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/BoundedScheduledExecutorService.java	101
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/ExceptionMessageHelper.java	23
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/ExecutorUtils.java	14
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/JsonUtil.java	27
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/LogExceptionRunnable.java	25
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/MathUtils.java	27
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/MdcUtils.java	12
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/MemoryLimitController.java	51
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/OrderedExecutor.java	513
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/OrderedScheduler.java	182
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/Recyclable.java	4
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/ReferenceCounted.java	5
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/ReflectionUtils.java	82
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/Retries.java	79
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/SafeRunnable.java	35
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/SharedResourceManager.java	93
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/SingleThreadExecutor.java	301
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/SingleThreadSafeScheduledExecutorService.java	47
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/StreamUtil.java	38
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/Watchable.java	41
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/Watcher.java	4
bookkeeper-common/src/main/java/org/apache/bookkeeper/common/util/package-info.java	1
bookkeeper-dist/src/assemble/bin-all.xml	100
bookkeeper-dist/src/assemble/bin-server.xml	86
bookkeeper-dist/src/assemble/bkctl.xml	103
bookkeeper-dist/src/assemble/src.xml	51
bookkeeper-http/http-server/src/main/java/org/apache/bookkeeper/http/AbstractHttpHandlerFactory.java	11
bookkeeper-http/http-server/src/main/java/org/apache/bookkeeper/http/HttpRouter.java	81
bookkeeper-http/http-server/src/main/java/org/apache/bookkeeper/http/HttpServer.java	64
bookkeeper-http/http-server/src/main/java/org/apache/bookkeeper/http/HttpServerConfiguration.java	48
bookkeeper-http/http-server/src/main/java/org/apache/bookkeeper/http/HttpServerLoader.java	37
bookkeeper-http/http-server/src/main/java/org/apache/bookkeeper/http/HttpServiceProvider.java	6
bookkeeper-http/http-server/src/main/java/org/apache/bookkeeper/http/NullHttpServiceProvider.java	22
bookkeeper-http/http-server/src/main/java/org/apache/bookkeeper/http/package-info.java	1
bookkeeper-http/http-server/src/main/java/org/apache/bookkeeper/http/service/ErrorHttpService.java	13
bookkeeper-http/http-server/src/main/java/org/apache/bookkeeper/http/service/HeartbeatService.java	9
bookkeeper-http/http-server/src/main/java/org/apache/bookkeeper/http/service/HttpEndpointService.java	4
bookkeeper-http/http-server/src/main/java/org/apache/bookkeeper/http/service/HttpServiceRequest.java	40
bookkeeper-http/http-server/src/main/java/org/apache/bookkeeper/http/service/HttpServiceResponse.java	33
bookkeeper-http/http-server/src/main/java/org/apache/bookkeeper/http/service/NullHttpService.java	12
bookkeeper-http/http-server/src/main/java/org/apache/bookkeeper/http/service/package-info.java	1
bookkeeper-http/servlet-http-server/src/main/java/org/apache/bookkeeper/http/servlet/BookieHttpServiceServlet.java	96
bookkeeper-http/servlet-http-server/src/main/java/org/apache/bookkeeper/http/servlet/BookieServletHttpServer.java	57
bookkeeper-http/servlet-http-server/src/main/java/org/apache/bookkeeper/http/servlet/package-info.java	1
bookkeeper-http/vertx-http-server/src/main/java/org/apache/bookkeeper/http/vertx/VertxAbstractHandler.java	65
bookkeeper-http/vertx-http-server/src/main/java/org/apache/bookkeeper/http/vertx/VertxHttpHandlerFactory.java	21
bookkeeper-http/vertx-http-server/src/main/java/org/apache/bookkeeper/http/vertx/VertxHttpServer.java	122
bookkeeper-http/vertx-http-server/src/main/java/org/apache/bookkeeper/http/vertx/package-info.java	1
bookkeeper-proto/src/main/proto/BookkeeperProtocol.proto	203
bookkeeper-proto/src/main/proto/DataFormats.proto	121
bookkeeper-proto/src/main/proto/DbLedgerStorageDataFormats.proto	29
bookkeeper-server/src/main/java/org/apache/bookkeeper/auth/AuthCallbacks.java	6
bookkeeper-server/src/main/java/org/apache/bookkeeper/auth/AuthProviderFactoryFactory.java	71
bookkeeper-server/src/main/java/org/apache/bookkeeper/auth/AuthToken.java	14
bookkeeper-server/src/main/java/org/apache/bookkeeper/auth/BookKeeperPrincipal.java	36
bookkeeper-server/src/main/java/org/apache/bookkeeper/auth/BookieAuthProvider.java	17
bookkeeper-server/src/main/java/org/apache/bookkeeper/auth/ClientAuthProvider.java	18
bookkeeper-server/src/main/java/org/apache/bookkeeper/auth/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/AbstractLogCompactor.java	52
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/BookKeeperServerStats.java	127
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/Bookie.java	71
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/BookieCriticalThread.java	19
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/BookieException.java	253
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/BookieFileChannel.java	12
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/BookieImpl.java	987
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/BookieResources.java	77
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/BookieShell.java	2313
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/BookieStateManager.java	345
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/BookieStatus.java	159
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/BookieThread.java	24
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/BufferedChannel.java	153
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/BufferedChannelBase.java	23
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/BufferedReadChannel.java	74
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/CacheCallback.java	6
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/CheckpointSource.java	50
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/CheckpointSourceList.java	81
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/Checkpointer.java	14
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/CompactableLedgerStorage.java	8
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/Cookie.java	352
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/CookieValidation.java	7
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/DefaultEntryLogger.java	1053
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/DefaultFileChannel.java	47
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/DefaultFileChannelProvider.java	17
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/EntryKey.java	44
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/EntryKeyValue.java	49
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/EntryLocation.java	29
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/EntryLogCompactor.java	80
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/EntryLogManager.java	19
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/EntryLogManagerBase.java	113
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/EntryLogManagerForEntryLogPerLedger.java	478
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/EntryLogManagerForSingleEntryLog.java	196
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/EntryLogMetadata.java	139
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/EntryLogMetadataMap.java	16
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/EntryLoggerAllocator.java	195
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/EntryMemTable.java	327
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/EntryMemTableWithParallelFlusher.java	92
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/ExitCode.java	9
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/FileChannelProvider.java	23
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/FileInfo.java	426
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/FileInfoBackingCache.java	123
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/FileSystemUpgrade.java	332
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/GarbageCollectionStatus.java	18
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/GarbageCollector.java	7
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/GarbageCollectorThread.java	649
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/HandleFactory.java	8
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/HandleFactoryImpl.java	59
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/InMemoryEntryLogMetadataMap.java	45
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/IndexInMemPageMgr.java	459
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/IndexPersistenceMgr.java	559
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/InterleavedLedgerStorage.java	569
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/InterleavedStorageRegenerateIndexOp.java	197
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/Journal.java	926
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/JournalAliveListener.java	4
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/JournalChannel.java	224
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/LEPStateChangeCallback.java	7
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/LastAddConfirmedUpdateNotification.java	39
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/LedgerCache.java	59
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/LedgerCacheImpl.java	171
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/LedgerDescriptor.java	47
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/LedgerDescriptorImpl.java	125
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/LedgerDescriptorReadOnlyImpl.java	20
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/LedgerDirsManager.java	245
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/LedgerDirsMonitor.java	191
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/LedgerEntryPage.java	251
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/LedgerStorage.java	134
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/LedgerStorageFactory.java	12
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/LegacyCookieValidation.java	212
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/LocalBookieEnsemblePlacementPolicy.java	94
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/LogMark.java	48
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/ReadOnlyBookie.java	35
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/ReadOnlyDefaultEntryLogger.java	17
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/ReadOnlyFileInfo.java	9
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/ScanAndCompareGarbageCollector.java	249
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/ScrubberStats.java	7
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/ShortReadException.java	11
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/SkipListArena.java	109
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/SkipListFlusher.java	6
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/SlowBufferedChannel.java	56
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/SortedLedgerStorage.java	349
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/StateManager.java	24
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/SyncThread.java	169
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/TransactionalEntryLogCompactor.java	232
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/UncleanShutdownDetection.java	7
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/UncleanShutdownDetectionImpl.java	79
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/datainteg/DataIntegrityCheck.java	8
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/datainteg/DataIntegrityCheckImpl.java	450
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/datainteg/DataIntegrityCookieValidation.java	125
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/datainteg/DataIntegrityService.java	77
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/datainteg/EntryCopier.java	10
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/datainteg/EntryCopierImpl.java	228
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/datainteg/Events.java	30
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/datainteg/MetadataAsyncIterator.java	95
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/datainteg/WriteSets.java	55
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/datainteg/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/stats/BookieStats.java	100
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/stats/EntryMemTableStats.java	64
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/stats/GarbageCollectorStats.java	215
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/stats/IndexInMemPageMgrStats.java	31
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/stats/IndexPersistenceMgrStats.java	69
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/stats/JournalStats.java	197
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/stats/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/CompactionEntryLog.java	14
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/EntryLogIds.java	5
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/EntryLogScanner.java	7
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/EntryLogger.java	29
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/directentrylogger/Buffer.java	161
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/directentrylogger/BufferPool.java	38
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/directentrylogger/DirectCompactionEntryLog.java	223
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/directentrylogger/DirectEntryLogger.java	423
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/directentrylogger/DirectEntryLoggerStats.java	133
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/directentrylogger/DirectReader.java	275
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/directentrylogger/DirectWriter.java	263
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/directentrylogger/EntryLogIdsImpl.java	53
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/directentrylogger/Events.java	18
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/directentrylogger/Header.java	60
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/directentrylogger/LogMetadata.java	140
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/directentrylogger/LogReader.java	16
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/directentrylogger/LogReaderScan.java	34
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/directentrylogger/LogWriter.java	13
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/directentrylogger/WriterWithMetadata.java	46
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/directentrylogger/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/ArrayGroupSort.java	76
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/ArrayUtil.java	39
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/DbLedgerStorage.java	526
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/DbLedgerStorageStats.java	236
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/EntryLocationIndex.java	185
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/EntryLocationIndexStats.java	51
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/KeyValueStorage.java	35
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/KeyValueStorageFactory.java	13
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/KeyValueStorageRocksDB.java	556
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/LedgerMetadataIndex.java	331
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/LedgerMetadataIndexStats.java	36
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/LedgersIndexCheckOp.java	81
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/LedgersIndexRebuildOp.java	175
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/LocationsIndexRebuildOp.java	119
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/LongPairWrapper.java	35
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/LongWrapper.java	33
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/PersistentEntryLogMetadataMap.java	214
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/ReadCache.java	148
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/SingleDirectoryDbLedgerStorage.java	967
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/TransientLedgerInfo.java	105
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/WriteCache.java	206
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/AsyncCallback.java	73
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/BKException.java	305
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/BatchedReadOp.java	243
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/BookKeeper.java	948
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/BookKeeperAdmin.java	1161
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/BookKeeperClientStats.java	94
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/BookieAddressResolverDisabled.java	14
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/BookieInfoReader.java	320
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/BookieWatcher.java	24
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/BookieWatcherImpl.java	274
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/BookiesHealthInfo.java	6
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/BookiesListener.java	8
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/ClientContext.java	18
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/ClientInternalConf.java	78
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/DefaultBookieAddressResolver.java	50
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/DefaultEnsemblePlacementPolicy.java	184
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/DefaultSpeculativeRequestExecutionPolicy.java	72
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/DistributionSchedule.java	76
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/DynamicWeightedRandomSelectionImpl.java	113
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/EnsemblePlacementPolicy.java	113
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/EnsembleUtils.java	66
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/ExplicitLacFlushPolicy.java	113
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/ForceLedgerOp.java	79
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/ITopologyAwareEnsemblePlacementPolicy.java	51
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerChecker.java	354
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerCreateOp.java	367
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerDeleteOp.java	89
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerEntry.java	46
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerFragment.java	142
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerFragmentReplicator.java	493
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerHandle.java	1449
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerHandleAdv.java	145
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerMetadataBuilder.java	156
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerMetadataImpl.java	215
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerMetadataUtils.java	42
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerOpenOp.java	224
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerRecoveryOp.java	159
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/ListenerBasedPendingReadOp.java	45
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/MetadataUpdateLoop.java	138
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/PendingAddOp.java	336
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/PendingReadLacOp.java	98
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/PendingReadOp.java	296
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/PendingWriteLacOp.java	74
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/RackChangeNotifier.java	6
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/RackawareEnsemblePlacementPolicy.java	254
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/RackawareEnsemblePlacementPolicyImpl.java	1087
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/ReadLastConfirmedAndEntryOp.java	462
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/ReadLastConfirmedOp.java	115
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/ReadOnlyLedgerHandle.java	270
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/ReadOpBase.java	186
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/RegionAwareEnsemblePlacementPolicy.java	556
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/RoundRobinDistributionSchedule.java	378
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/SpeculativeRequestExecutionPolicy.java	7
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/SpeculativeRequestExecutor.java	5
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/SyncCallbackUtils.java	145
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/SyncCounter.java	47
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/TopologyAwareEnsemblePlacementPolicy.java	688
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/TryReadLastConfirmedOp.java	79
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/UpdateLedgerOp.java	118
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/WeightedRandomSelection.java	12
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/WeightedRandomSelectionImpl.java	125
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/ZoneawareEnsemblePlacementPolicy.java	99
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/ZoneawareEnsemblePlacementPolicyImpl.java	763
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/api/BKException.java	215
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/api/BookKeeper.java	21
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/api/BookKeeperBuilder.java	21
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/api/CreateAdvBuilder.java	8
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/api/CreateBuilder.java	21
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/api/DeleteBuilder.java	8
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/api/DigestType.java	11
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/api/ForceableHandle.java	9
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/api/Handle.java	16
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/api/LastConfirmedAndEntry.java	8
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/api/LedgerEntries.java	10
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/api/LedgerEntry.java	18
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/api/LedgerMetadata.java	34
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/api/LedgersIterator.java	6
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/api/ListLedgersResult.java	5
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/api/ListLedgersResultBuilder.java	7
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/api/OpBuilder.java	10
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/api/OpenBuilder.java	12
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/api/ReadHandle.java	53
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/api/WriteAdvHandle.java	37
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/api/WriteFlag.java	26
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/api/WriteHandle.java	41
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/api/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/impl/BookKeeperBuilderImpl.java	52
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/impl/BookKeeperClientStatsImpl.java	260
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/impl/LastConfirmedAndEntryImpl.java	54
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/impl/LedgerEntriesImpl.java	58
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/impl/LedgerEntryImpl.java	99
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/impl/OpenBuilderBase.java	42
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/impl/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/client/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/conf/AbstractConfiguration.java	523
bookkeeper-server/src/main/java/org/apache/bookkeeper/conf/ClientConfiguration.java	714
bookkeeper-server/src/main/java/org/apache/bookkeeper/conf/Configurable.java	10
bookkeeper-server/src/main/java/org/apache/bookkeeper/conf/ServerConfiguration.java	1524
bookkeeper-server/src/main/java/org/apache/bookkeeper/conf/UncheckedConfigurationException.java	15
bookkeeper-server/src/main/java/org/apache/bookkeeper/conf/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/discover/BookieServiceInfo.java	96
bookkeeper-server/src/main/java/org/apache/bookkeeper/discover/BookieServiceInfoUtils.java	18
bookkeeper-server/src/main/java/org/apache/bookkeeper/discover/RegistrationClient.java	35
bookkeeper-server/src/main/java/org/apache/bookkeeper/discover/RegistrationManager.java	29
bookkeeper-server/src/main/java/org/apache/bookkeeper/discover/ZKRegistrationClient.java	410
bookkeeper-server/src/main/java/org/apache/bookkeeper/discover/ZKRegistrationManager.java	482
bookkeeper-server/src/main/java/org/apache/bookkeeper/discover/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/feature/CacheableFeatureProvider.java	51
bookkeeper-server/src/main/java/org/apache/bookkeeper/feature/Feature.java	7
bookkeeper-server/src/main/java/org/apache/bookkeeper/feature/FeatureProvider.java	5
bookkeeper-server/src/main/java/org/apache/bookkeeper/feature/FixedValueFeature.java	25
bookkeeper-server/src/main/java/org/apache/bookkeeper/feature/SettableFeature.java	15
bookkeeper-server/src/main/java/org/apache/bookkeeper/feature/SettableFeatureProvider.java	17
bookkeeper-server/src/main/java/org/apache/bookkeeper/feature/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/AbstractHierarchicalLedgerManager.java	135
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/AbstractZkLedgerManager.java	523
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/AbstractZkLedgerManagerFactory.java	256
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/CleanupLedgerManager.java	212
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/FlatLedgerManager.java	86
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/FlatLedgerManagerFactory.java	59
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/HierarchicalLedgerManager.java	86
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/HierarchicalLedgerManagerFactory.java	21
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/LayoutManager.java	18
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/LedgerAuditorManager.java	12
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/LedgerIdGenerator.java	6
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/LedgerLayout.java	64
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/LedgerManager.java	47
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/LedgerManagerFactory.java	24
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/LedgerMetadataSerDe.java	410
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/LedgerUnderreplicationManager.java	57
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/LegacyHierarchicalLedgerManager.java	181
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/LegacyHierarchicalLedgerManagerFactory.java	62
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/LongHierarchicalLedgerManager.java	187
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/LongHierarchicalLedgerManagerFactory.java	8
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/LongZkLedgerIdGenerator.java	238
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/MSLedgerManagerFactory.java	662
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/MetadataBookieDriver.java	30
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/MetadataClientDriver.java	38
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/MetadataDrivers.java	265
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/NullMetadataBookieDriver.java	311
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/UnderreplicatedLedger.java	26
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/ZkLayoutManager.java	66
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/ZkLedgerAuditorManager.java	199
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/ZkLedgerIdGenerator.java	98
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/ZkLedgerUnderreplicationManager.java	961
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/exceptions/Code.java	10
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/exceptions/MetadataException.java	19
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/exceptions/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/zk/ZKMetadataBookieDriver.java	52
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/zk/ZKMetadataClientDriver.java	85
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/zk/ZKMetadataDriverBase.java	303
bookkeeper-server/src/main/java/org/apache/bookkeeper/meta/zk/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/metastore/InMemoryMetaStore.java	43
bookkeeper-server/src/main/java/org/apache/bookkeeper/metastore/InMemoryMetastoreCursor.java	66
bookkeeper-server/src/main/java/org/apache/bookkeeper/metastore/InMemoryMetastoreTable.java	315
bookkeeper-server/src/main/java/org/apache/bookkeeper/metastore/MSException.java	142
bookkeeper-server/src/main/java/org/apache/bookkeeper/metastore/MSWatchedEvent.java	16
bookkeeper-server/src/main/java/org/apache/bookkeeper/metastore/MetaStore.java	10
bookkeeper-server/src/main/java/org/apache/bookkeeper/metastore/MetastoreCallback.java	4
bookkeeper-server/src/main/java/org/apache/bookkeeper/metastore/MetastoreCursor.java	30
bookkeeper-server/src/main/java/org/apache/bookkeeper/metastore/MetastoreException.java	13
bookkeeper-server/src/main/java/org/apache/bookkeeper/metastore/MetastoreFactory.java	12
bookkeeper-server/src/main/java/org/apache/bookkeeper/metastore/MetastoreScannableTable.java	20
bookkeeper-server/src/main/java/org/apache/bookkeeper/metastore/MetastoreTable.java	18
bookkeeper-server/src/main/java/org/apache/bookkeeper/metastore/MetastoreTableItem.java	22
bookkeeper-server/src/main/java/org/apache/bookkeeper/metastore/MetastoreUtils.java	89
bookkeeper-server/src/main/java/org/apache/bookkeeper/metastore/MetastoreWatcher.java	4
bookkeeper-server/src/main/java/org/apache/bookkeeper/metastore/Value.java	110
bookkeeper-server/src/main/java/org/apache/bookkeeper/metastore/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/net/AbstractDNSToSwitchMapping.java	67
bookkeeper-server/src/main/java/org/apache/bookkeeper/net/BookieId.java	47
bookkeeper-server/src/main/java/org/apache/bookkeeper/net/BookieNode.java	27
bookkeeper-server/src/main/java/org/apache/bookkeeper/net/BookieSocketAddress.java	87
bookkeeper-server/src/main/java/org/apache/bookkeeper/net/CachedDNSToSwitchMapping.java	75
bookkeeper-server/src/main/java/org/apache/bookkeeper/net/CommonConfigurationKeys.java	6
bookkeeper-server/src/main/java/org/apache/bookkeeper/net/DNS.java	183
bookkeeper-server/src/main/java/org/apache/bookkeeper/net/DNSToSwitchMapping.java	14
bookkeeper-server/src/main/java/org/apache/bookkeeper/net/NetUtils.java	44
bookkeeper-server/src/main/java/org/apache/bookkeeper/net/NetworkTopology.java	18
bookkeeper-server/src/main/java/org/apache/bookkeeper/net/NetworkTopologyImpl.java	591
bookkeeper-server/src/main/java/org/apache/bookkeeper/net/Node.java	13
bookkeeper-server/src/main/java/org/apache/bookkeeper/net/NodeBase.java	109
bookkeeper-server/src/main/java/org/apache/bookkeeper/net/ScriptBasedMapping.java	159
bookkeeper-server/src/main/java/org/apache/bookkeeper/net/StabilizeNetworkTopology.java	112
bookkeeper-server/src/main/java/org/apache/bookkeeper/net/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/processor/RequestProcessor.java	7
bookkeeper-server/src/main/java/org/apache/bookkeeper/processor/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/AuthHandler.java	395
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BKStats.java	143
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BatchedReadEntryProcessor.java	83
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieAddressResolver.java	16
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieClient.java	68
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieClientImpl.java	593
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieConnectionPeer.java	3
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieNettyServer.java	429
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieProtoEncoding.java	519
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieProtocol.java	429
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieRequestHandler.java	75
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieRequestProcessor.java	614
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieServer.java	209
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookkeeperInternalCallbacks.java	187
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/ByteStringUtil.java	42
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/ClientConnectionPeer.java	3
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/ConnectionPeer.java	12
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/DefaultPerChannelBookieClientPool.java	127
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/ForceLedgerProcessorV3.java	97
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/GetBookieInfoProcessorV3.java	71
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/GetListOfEntriesOfLedgerProcessorV3.java	73
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/LocalBookiesRegistry.java	18
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/LongPollReadEntryProcessorV3.java	172
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/PacketProcessorBase.java	163
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/PacketProcessorBaseV3.java	99
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/PerChannelBookieClient.java	2358
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/PerChannelBookieClientFactory.java	9
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/PerChannelBookieClientPool.java	15
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/ReadEntryProcessor.java	186
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/ReadEntryProcessorV3.java	262
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/ReadLacProcessorV3.java	97
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/ReadLastConfirmedAndEntryContext.java	35
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/RequestStats.java	326
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/RequestUtils.java	76
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/ResponseBuilder.java	30
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/SimpleBookieServiceInfoProvider.java	26
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/WriteEntryProcessor.java	120
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/WriteEntryProcessorV3.java	150
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/WriteLacProcessorV3.java	120
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/checksum/CRC32CDigestManager.java	35
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/checksum/CRC32DigestManager.java	50
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/checksum/DigestManager.java	273
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/checksum/DirectMemoryCRC32Digest.java	65
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/checksum/DummyDigestManager.java	30
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/checksum/MacDigestManager.java	79
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/checksum/StandardCRC32Digest.java	21
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/checksum/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/Auditor.java	552
bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/AuditorBookieCheckTask.java	140
bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/AuditorCheckAllLedgersTask.java	244
bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/AuditorElector.java	190
bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/AuditorPlacementPolicyCheckTask.java	272
bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/AuditorReplicasCheckTask.java	622
bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/AuditorStats.java	245
bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/AuditorTask.java	110
bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/AutoRecoveryMain.java	275
bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/BookieLedgerIndexer.java	86
bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/ReplicationEnableCb.java	23
bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/ReplicationException.java	61
bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/ReplicationStats.java	42
bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/ReplicationWorker.java	655
bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/sasl/JAASCredentialsContainer.java	13
bookkeeper-server/src/main/java/org/apache/bookkeeper/sasl/SASLBookieAuthProvider.java	47
bookkeeper-server/src/main/java/org/apache/bookkeeper/sasl/SASLBookieAuthProviderFactory.java	172
bookkeeper-server/src/main/java/org/apache/bookkeeper/sasl/SASLClientAuthProvider.java	74
bookkeeper-server/src/main/java/org/apache/bookkeeper/sasl/SASLClientProviderFactory.java	124
bookkeeper-server/src/main/java/org/apache/bookkeeper/sasl/SaslClientState.java	156
bookkeeper-server/src/main/java/org/apache/bookkeeper/sasl/SaslConstants.java	50
bookkeeper-server/src/main/java/org/apache/bookkeeper/sasl/SaslServerState.java	198
bookkeeper-server/src/main/java/org/apache/bookkeeper/sasl/TGTRefreshThread.java	214
bookkeeper-server/src/main/java/org/apache/bookkeeper/sasl/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/EmbeddedServer.java	467
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/Main.java	249
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/component/ServerLifecycleComponent.java	40
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/component/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/conf/BookieConfiguration.java	13
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/conf/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/BKHttpServiceProvider.java	210
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/AutoRecoveryStatusService.java	73
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/BookieInfoService.java	36
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/BookieIsReadyService.java	32
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/BookieSanityService.java	64
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/BookieStateReadOnlyService.java	55
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/BookieStateService.java	44
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/ClusterInfoService.java	84
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/ConfigurationService.java	45
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/DecommissionService.java	70
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/DeleteLedgerService.java	52
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/ExpandStorageService.java	76
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/GCDetailsService.java	44
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/GetLastLogMarkService.java	69
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/GetLedgerMetaService.java	52
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/ListBookieInfoService.java	80
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/ListBookiesService.java	66
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/ListDiskFilesService.java	82
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/ListLedgerService.java	110
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/ListUnderReplicatedLedgerService.java	110
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/LostBookieRecoveryDelayService.java	66
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/MetricsService.java	49
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/ReadLedgerEntryService.java	78
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/RecoveryBookieService.java	87
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/ResumeCompactionService.java	60
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/SuspendCompactionService.java	73
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/TriggerAuditService.java	44
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/TriggerGCService.java	75
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/TriggerLocationCompactService.java	96
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/WhoIsAuditorService.java	51
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/http/service/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/service/AutoRecoveryService.java	36
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/service/BookieService.java	88
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/service/HttpService.java	52
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/service/ScrubberService.java	104
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/service/StatsProviderService.java	31
bookkeeper-server/src/main/java/org/apache/bookkeeper/server/service/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/shims/zk/ZooKeeperServerShim.java	8
bookkeeper-server/src/main/java/org/apache/bookkeeper/shims/zk/ZooKeeperServerShimFactory.java	11
bookkeeper-server/src/main/java/org/apache/bookkeeper/shims/zk/ZooKeeperServerShimImpl.java	37
bookkeeper-server/src/main/java/org/apache/bookkeeper/shims/zk/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/streaming/LedgerInputStream.java	101
bookkeeper-server/src/main/java/org/apache/bookkeeper/streaming/LedgerOutputStream.java	82
bookkeeper-server/src/main/java/org/apache/bookkeeper/streaming/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/tls/BookieAuthZFactory.java	94
bookkeeper-server/src/main/java/org/apache/bookkeeper/tls/FileModifiedTimeUpdater.java	39
bookkeeper-server/src/main/java/org/apache/bookkeeper/tls/SecurityException.java	13
bookkeeper-server/src/main/java/org/apache/bookkeeper/tls/SecurityHandlerFactory.java	17
bookkeeper-server/src/main/java/org/apache/bookkeeper/tls/SecurityProviderFactoryFactory.java	24
bookkeeper-server/src/main/java/org/apache/bookkeeper/tls/TLSContextFactory.java	445
bookkeeper-server/src/main/java/org/apache/bookkeeper/tls/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/autorecovery/ListUnderReplicatedCommand.java	141
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/autorecovery/LostBookieRecoveryDelayCommand.java	81
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/autorecovery/QueryAutoRecoveryStatusCommand.java	109
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/autorecovery/ToggleCommand.java	85
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/autorecovery/TriggerAuditCommand.java	39
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/autorecovery/WhoIsAuditorCommand.java	57
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/autorecovery/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookie/CheckDBLedgersIndexCommand.java	47
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookie/ConvertToDBStorageCommand.java	83
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookie/ConvertToInterleavedStorageCommand.java	132
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookie/FlipBookieIdCommand.java	127
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookie/FormatCommand.java	67
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookie/FormatUtil.java	61
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookie/InitCommand.java	28
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookie/LastMarkCommand.java	51
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookie/LedgerCommand.java	148
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookie/ListActiveLedgersCommand.java	141
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookie/ListFilesOnDiscCommand.java	73
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookie/ListLedgersCommand.java	140
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookie/LocalConsistencyCheckCommand.java	49
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookie/ReadJournalCommand.java	160
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookie/ReadLedgerCommand.java	175
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookie/ReadLogCommand.java	199
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookie/ReadLogMetadataCommand.java	104
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookie/RebuildDBLedgerLocationsIndexCommand.java	29
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookie/RebuildDBLedgersIndexCommand.java	43
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookie/RegenerateInterleavedStorageIndexFileCommand.java	91
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookie/SanityTestCommand.java	168
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookie/UpdateBookieInLedgerCommand.java	136
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookie/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookies/ClusterInfoCommand.java	101
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookies/DecommissionCommand.java	86
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookies/EndpointInfoCommand.java	88
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookies/InfoCommand.java	83
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookies/InitCommand.java	28
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookies/InstanceIdCommand.java	37
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookies/ListBookiesCommand.java	104
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookies/MetaFormatCommand.java	41
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookies/NukeExistingClusterCommand.java	52
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookies/RecoverCommand.java	224
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookies/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/client/DeleteLedgerCommand.java	90
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/client/LedgerMetaDataCommand.java	118
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/client/SimpleTestCommand.java	130
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/client/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/cookie/AdminCommand.java	270
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/cookie/CookieCommand.java	90
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/cookie/CreateCookieCommand.java	71
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/cookie/DeleteCookieCommand.java	62
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/cookie/GenerateCookieCommand.java	107
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/cookie/GetCookieCommand.java	69
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/cookie/UpdateCookieCommand.java	73
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/cookie/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/health/SwitchOfHealthCheckCommand.java	75
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/health/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/commands/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/helpers/BookieCommand.java	26
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/helpers/BookieShellCommand.java	34
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/helpers/ClientCommand.java	46
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/helpers/CommandHelpers.java	39
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/helpers/DiscoveryCommand.java	48
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/helpers/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/tools/cli/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/AvailabilityOfEntriesOfLedger.java	345
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/BookKeeperConstants.java	28
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/ByteBufList.java	152
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/ByteBufVisitor.java	851
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/CertUtils.java	74
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/DiskChecker.java	166
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/EntryFormatter.java	35
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/EventLoopUtil.java	62
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/HardLink.java	433
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/HexDumpEntryFormatter.java	27
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/IOUtils.java	73
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/IteratorUtility.java	108
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/LedgerDirUtil.java	69
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/LedgerIdFormatter.java	68
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/LocalBookKeeper.java	461
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/NettyChannelUtil.java	14
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/OrderedGenericCallback.java	49
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/PageCacheUtil.java	55
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/PortManager.java	17
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/SafeRunnable.java	25
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/Shell.java	248
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/SnapshotMap.java	67
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/StringEntryFormatter.java	19
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/StringUtils.java	85
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/SubTreeCache.java	81
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/Tool.java	6
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/ZeroBuffer.java	28
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/ZkUtils.java	180
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/collections/ConcurrentLongHashMap.java	523
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/collections/ConcurrentLongHashSet.java	416
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/collections/ConcurrentLongLongHashMap.java	679
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/collections/ConcurrentLongLongPairHashMap.java	527
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/collections/ConcurrentOpenHashMap.java	494
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/collections/ConcurrentOpenHashSet.java	404
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/collections/SynchronizedHashMultiMap.java	41
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/collections/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/util/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/verifier/BookkeeperVerifier.java	525
bookkeeper-server/src/main/java/org/apache/bookkeeper/verifier/BookkeeperVerifierMain.java	141
bookkeeper-server/src/main/java/org/apache/bookkeeper/verifier/DirectBookkeeperDriver.java	83
bookkeeper-server/src/main/java/org/apache/bookkeeper/verifier/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/versioning/LongVersion.java	42
bookkeeper-server/src/main/java/org/apache/bookkeeper/versioning/Version.java	25
bookkeeper-server/src/main/java/org/apache/bookkeeper/versioning/Versioned.java	9
bookkeeper-server/src/main/java/org/apache/bookkeeper/versioning/package-info.java	1
bookkeeper-server/src/main/java/org/apache/bookkeeper/zookeeper/BoundExponentialBackoffRetryPolicy.java	12
bookkeeper-server/src/main/java/org/apache/bookkeeper/zookeeper/ExponentialBackOffWithDeadlinePolicy.java	38
bookkeeper-server/src/main/java/org/apache/bookkeeper/zookeeper/ExponentialBackoffRetryPolicy.java	20
bookkeeper-server/src/main/java/org/apache/bookkeeper/zookeeper/RetryPolicy.java	5
bookkeeper-server/src/main/java/org/apache/bookkeeper/zookeeper/ZooKeeperClient.java	1096
bookkeeper-server/src/main/java/org/apache/bookkeeper/zookeeper/ZooKeeperWatcherBase.java	136
bookkeeper-server/src/main/java/org/apache/bookkeeper/zookeeper/ZooWorker.java	90
bookkeeper-server/src/main/java/org/apache/bookkeeper/zookeeper/package-info.java	1
bookkeeper-server/src/main/resources/log4j2.xml	13
bookkeeper-slogger/api/src/main/java/org/apache/bookkeeper/slogger/AbstractSlogger.java	216
bookkeeper-slogger/api/src/main/java/org/apache/bookkeeper/slogger/ConsoleSlogger.java	95
bookkeeper-slogger/api/src/main/java/org/apache/bookkeeper/slogger/NullSlogger.java	39
bookkeeper-slogger/api/src/main/java/org/apache/bookkeeper/slogger/Sloggable.java	4
bookkeeper-slogger/api/src/main/java/org/apache/bookkeeper/slogger/SloggableAccumulator.java	4
bookkeeper-slogger/api/src/main/java/org/apache/bookkeeper/slogger/Slogger.java	20
bookkeeper-slogger/api/src/main/java/org/apache/bookkeeper/slogger/package-info.java	1
bookkeeper-slogger/slf4j/src/main/java/org/apache/bookkeeper/slogger/slf4j/Slf4jSlogger.java	75
bookkeeper-slogger/slf4j/src/main/java/org/apache/bookkeeper/slogger/slf4j/package-info.java	1
buildtools/src/main/resources/bookkeeper/findbugsExclude.xml	264
buildtools/src/main/resources/bookkeeper/suppressions.xml	21
buildtools/src/main/resources/distributedlog/findbugsExclude.xml	145
buildtools/src/main/resources/distributedlog/suppressions.xml	18
buildtools/src/main/resources/ide/eclipse/formatter.xml	269
buildtools/src/main/resources/log4j2.xml	16
circe-checksum/src/main/circe/cpp/crc32c_sse42.cpp	178
circe-checksum/src/main/circe/cpp/crc32c_sse42_jni.cpp	57
circe-checksum/src/main/circe/cpp/gf2.hpp	105
circe-checksum/src/main/circe/include/crc32c_sse42.hpp	17
circe-checksum/src/main/circe/include/int_types.h	18
circe-checksum/src/main/java/com/scurrilous/circe/CommonHashes.java	52
circe-checksum/src/main/java/com/scurrilous/circe/Hash.java	6
circe-checksum/src/main/java/com/scurrilous/circe/HashParameters.java	4
circe-checksum/src/main/java/com/scurrilous/circe/HashProvider.java	10
circe-checksum/src/main/java/com/scurrilous/circe/HashProviders.java	57
circe-checksum/src/main/java/com/scurrilous/circe/HashSupport.java	57
circe-checksum/src/main/java/com/scurrilous/circe/Hashes.java	27
circe-checksum/src/main/java/com/scurrilous/circe/IncrementalIntHash.java	8
circe-checksum/src/main/java/com/scurrilous/circe/IncrementalLongHash.java	8
circe-checksum/src/main/java/com/scurrilous/circe/StatefulHash.java	17
circe-checksum/src/main/java/com/scurrilous/circe/StatefulIntHash.java	4
circe-checksum/src/main/java/com/scurrilous/circe/StatefulLongHash.java	4
circe-checksum/src/main/java/com/scurrilous/circe/StatelessHash.java	4
circe-checksum/src/main/java/com/scurrilous/circe/StatelessIntHash.java	10
circe-checksum/src/main/java/com/scurrilous/circe/StatelessLongHash.java	10
circe-checksum/src/main/java/com/scurrilous/circe/checksum/Crc32cIntChecksum.java	33
circe-checksum/src/main/java/com/scurrilous/circe/checksum/Crc32cSse42Provider.java	34
circe-checksum/src/main/java/com/scurrilous/circe/checksum/IntHash.java	10
circe-checksum/src/main/java/com/scurrilous/circe/checksum/Java8IntHash.java	37
circe-checksum/src/main/java/com/scurrilous/circe/checksum/Java9IntHash.java	100
circe-checksum/src/main/java/com/scurrilous/circe/checksum/JniIntHash.java	37
circe-checksum/src/main/java/com/scurrilous/circe/crc/AbstractIntCrc.java	36
circe-checksum/src/main/java/com/scurrilous/circe/crc/AbstractLongCrc.java	36
circe-checksum/src/main/java/com/scurrilous/circe/crc/JavaCrc32.java	68
circe-checksum/src/main/java/com/scurrilous/circe/crc/NormalByteCrc.java	23
circe-checksum/src/main/java/com/scurrilous/circe/crc/NormalIntCrc.java	24
circe-checksum/src/main/java/com/scurrilous/circe/crc/NormalLongCrc.java	24
circe-checksum/src/main/java/com/scurrilous/circe/crc/ReflectedIntCrc.java	24
circe-checksum/src/main/java/com/scurrilous/circe/crc/ReflectedLongCrc.java	24
circe-checksum/src/main/java/com/scurrilous/circe/crc/Sse42Crc32C.java	82
circe-checksum/src/main/java/com/scurrilous/circe/crc/StandardCrcProvider.java	54
circe-checksum/src/main/java/com/scurrilous/circe/crc/package-info.java	1
circe-checksum/src/main/java/com/scurrilous/circe/impl/AbstractHashProvider.java	104
circe-checksum/src/main/java/com/scurrilous/circe/impl/AbstractIncrementalIntHash.java	64
circe-checksum/src/main/java/com/scurrilous/circe/impl/AbstractIncrementalLongHash.java	64
circe-checksum/src/main/java/com/scurrilous/circe/impl/AbstractStatefulHash.java	82
circe-checksum/src/main/java/com/scurrilous/circe/impl/AbstractStatelessIntHash.java	42
circe-checksum/src/main/java/com/scurrilous/circe/impl/AbstractStatelessLongHash.java	42
circe-checksum/src/main/java/com/scurrilous/circe/impl/DirectByteBufferAccess.java	5
circe-checksum/src/main/java/com/scurrilous/circe/impl/DirectByteBufferAccessLoader.java	17
circe-checksum/src/main/java/com/scurrilous/circe/impl/HashCache.java	11
circe-checksum/src/main/java/com/scurrilous/circe/impl/HashCacheLoader.java	20
circe-checksum/src/main/java/com/scurrilous/circe/impl/IncrementalIntStatefulHash.java	60
circe-checksum/src/main/java/com/scurrilous/circe/impl/IncrementalLongStatefulHash.java	60
circe-checksum/src/main/java/com/scurrilous/circe/impl/IntStatefulLongHash.java	80
circe-checksum/src/main/java/com/scurrilous/circe/impl/IntStatelessLongHash.java	43
circe-checksum/src/main/java/com/scurrilous/circe/impl/package-info.java	1
circe-checksum/src/main/java/com/scurrilous/circe/package-info.java	1
circe-checksum/src/main/java/com/scurrilous/circe/params/CrcParameters.java	79
circe-checksum/src/main/java/com/scurrilous/circe/params/MurmurHash3Parameters.java	23
circe-checksum/src/main/java/com/scurrilous/circe/params/MurmurHash3Variant.java	13
circe-checksum/src/main/java/com/scurrilous/circe/params/SimpleHashParameters.java	33
circe-checksum/src/main/java/com/scurrilous/circe/params/SipHash24Parameters.java	23
circe-checksum/src/main/java/com/scurrilous/circe/params/package-info.java	1
conf/log4j2.cli.xml	33
conf/log4j2.shell.xml	38
conf/log4j2.xml	45
cpu-affinity/src/main/affinity/cpp/affinity_jni.c	51
cpu-affinity/src/main/java/org/apache/bookkeeper/common/util/affinity/CpuAffinity.java	9
cpu-affinity/src/main/java/org/apache/bookkeeper/common/util/affinity/impl/CpuAffinityImpl.java	142
cpu-affinity/src/main/java/org/apache/bookkeeper/common/util/affinity/impl/CpuAffinityJni.java	9
cpu-affinity/src/main/java/org/apache/bookkeeper/common/util/affinity/impl/IsolatedProcessors.java	55
cpu-affinity/src/main/java/org/apache/bookkeeper/common/util/affinity/impl/ProcessorsInfo.java	54
cpu-affinity/src/main/java/org/apache/bookkeeper/common/util/affinity/impl/package-info.java	1
cpu-affinity/src/main/java/org/apache/bookkeeper/common/util/affinity/package-info.java	1
deploy/docker-compose/compose/Chart.yaml	10
deploy/docker-compose/compose/values.yaml	16
deploy/kubernetes/gke/bookkeeper.yaml	103
deploy/kubernetes/gke/zookeeper.yaml	162
dev/bk-merge-pr3.py	541
docker/scripts/apply-config-from-env.py	54
metadata-drivers/etcd/src/main/java/io/etcd/jetcd/impl/EtcdClientUtils.java	12
metadata-drivers/etcd/src/main/java/io/etcd/jetcd/impl/EtcdConnectionManager.java	31
metadata-drivers/etcd/src/main/java/io/etcd/jetcd/impl/package-info.java	1
metadata-drivers/etcd/src/main/java/org/apache/bookkeeper/metadata/etcd/Etcd64bitIdGenerator.java	102
metadata-drivers/etcd/src/main/java/org/apache/bookkeeper/metadata/etcd/EtcdBookieRegister.java	179
metadata-drivers/etcd/src/main/java/org/apache/bookkeeper/metadata/etcd/EtcdConstants.java	16
metadata-drivers/etcd/src/main/java/org/apache/bookkeeper/metadata/etcd/EtcdLayoutManager.java	77
metadata-drivers/etcd/src/main/java/org/apache/bookkeeper/metadata/etcd/EtcdLedgerManager.java	425
metadata-drivers/etcd/src/main/java/org/apache/bookkeeper/metadata/etcd/EtcdLedgerManagerFactory.java	89
metadata-drivers/etcd/src/main/java/org/apache/bookkeeper/metadata/etcd/EtcdMetadataBookieDriver.java	64
metadata-drivers/etcd/src/main/java/org/apache/bookkeeper/metadata/etcd/EtcdMetadataClientDriver.java	51
metadata-drivers/etcd/src/main/java/org/apache/bookkeeper/metadata/etcd/EtcdMetadataDriverBase.java	88
metadata-drivers/etcd/src/main/java/org/apache/bookkeeper/metadata/etcd/EtcdRegistrationClient.java	132
metadata-drivers/etcd/src/main/java/org/apache/bookkeeper/metadata/etcd/EtcdRegistrationManager.java	500
metadata-drivers/etcd/src/main/java/org/apache/bookkeeper/metadata/etcd/EtcdUtils.java	153
metadata-drivers/etcd/src/main/java/org/apache/bookkeeper/metadata/etcd/EtcdWatchClient.java	303
metadata-drivers/etcd/src/main/java/org/apache/bookkeeper/metadata/etcd/EtcdWatcher.java	81
metadata-drivers/etcd/src/main/java/org/apache/bookkeeper/metadata/etcd/LedgerMetadataConsumer.java	44
metadata-drivers/etcd/src/main/java/org/apache/bookkeeper/metadata/etcd/helpers/KeyIterator.java	38
metadata-drivers/etcd/src/main/java/org/apache/bookkeeper/metadata/etcd/helpers/KeySetReader.java	235
metadata-drivers/etcd/src/main/java/org/apache/bookkeeper/metadata/etcd/helpers/KeyStream.java	89
metadata-drivers/etcd/src/main/java/org/apache/bookkeeper/metadata/etcd/helpers/RevisionedConsumer.java	42
metadata-drivers/etcd/src/main/java/org/apache/bookkeeper/metadata/etcd/helpers/ValueStream.java	263
metadata-drivers/etcd/src/main/java/org/apache/bookkeeper/metadata/etcd/helpers/package-info.java	1
metadata-drivers/etcd/src/main/java/org/apache/bookkeeper/metadata/etcd/package-info.java	1
microbenchmarks/src/main/java/org/apache/bookkeeper/bookie/GroupSortBenchmark.java	78
microbenchmarks/src/main/java/org/apache/bookkeeper/bookie/package-info.java	1
microbenchmarks/src/main/java/org/apache/bookkeeper/common/MpScQueueBenchmark.java	91
microbenchmarks/src/main/java/org/apache/bookkeeper/common/OrderedExecutorBenchmark.java	51
microbenchmarks/src/main/java/org/apache/bookkeeper/common/package-info.java	1
microbenchmarks/src/main/java/org/apache/bookkeeper/proto/ProtocolBenchmark.java	134
microbenchmarks/src/main/java/org/apache/bookkeeper/proto/checksum/DigestManagerBenchmark.java	58
microbenchmarks/src/main/java/org/apache/bookkeeper/proto/checksum/DigestTypeBenchmark.java	119
microbenchmarks/src/main/java/org/apache/bookkeeper/proto/checksum/package-info.java	1
microbenchmarks/src/main/java/org/apache/bookkeeper/proto/package-info.java	1
microbenchmarks/src/main/java/org/apache/bookkeeper/stats/StatsLoggerBenchmark.java	55
microbenchmarks/src/main/java/org/apache/bookkeeper/stats/codahale/TimerBenchmark.java	136
microbenchmarks/src/main/java/org/apache/bookkeeper/stats/codahale/package-info.java	1
microbenchmarks/src/main/java/org/apache/bookkeeper/stats/package-info.java	1
native-io/src/main/java/org/apache/bookkeeper/common/util/nativeio/NativeIO.java	22
native-io/src/main/java/org/apache/bookkeeper/common/util/nativeio/NativeIOException.java	16
native-io/src/main/java/org/apache/bookkeeper/common/util/nativeio/NativeIOImpl.java	44
native-io/src/main/java/org/apache/bookkeeper/common/util/nativeio/NativeIOJni.java	28
native-io/src/main/java/org/apache/bookkeeper/common/util/nativeio/package-info.java	1
native-io/src/main/native-io-jni/cpp/native_io_jni.c	190
native-library-common/src/main/java/org/apache/bookkeeper/common/util/nativelib/NativeUtils.java	67
native-library-common/src/main/java/org/apache/bookkeeper/common/util/nativelib/package-info.java	1
site3/website/babel.config.js	3
site3/website/docusaurus.config.js	264
site3/website/scripts/replace.js	40
site3/website/src/components/RecentReleases/index.js	33
site3/website/src/pages/index.js	34
site3/website/src/sass/index.scss	36
site3/website/src/theme/DocVersionBanner/index.js	3
src/owasp-dependency-check-suppressions.xml	70
stats/bookkeeper-stats-api/src/main/java/org/apache/bookkeeper/stats/AlertStatsLogger.java	46
stats/bookkeeper-stats-api/src/main/java/org/apache/bookkeeper/stats/CachingStatsLogger.java	83
stats/bookkeeper-stats-api/src/main/java/org/apache/bookkeeper/stats/CachingStatsProvider.java	35
stats/bookkeeper-stats-api/src/main/java/org/apache/bookkeeper/stats/Counter.java	10
stats/bookkeeper-stats-api/src/main/java/org/apache/bookkeeper/stats/Gauge.java	5
stats/bookkeeper-stats-api/src/main/java/org/apache/bookkeeper/stats/NullStatsLogger.java	81
stats/bookkeeper-stats-api/src/main/java/org/apache/bookkeeper/stats/NullStatsProvider.java	17
stats/bookkeeper-stats-api/src/main/java/org/apache/bookkeeper/stats/OpStatsData.java	42
stats/bookkeeper-stats-api/src/main/java/org/apache/bookkeeper/stats/OpStatsLogger.java	10
stats/bookkeeper-stats-api/src/main/java/org/apache/bookkeeper/stats/Stats.java	42
stats/bookkeeper-stats-api/src/main/java/org/apache/bookkeeper/stats/StatsLogger.java	20
stats/bookkeeper-stats-api/src/main/java/org/apache/bookkeeper/stats/StatsProvider.java	16
stats/bookkeeper-stats-api/src/main/java/org/apache/bookkeeper/stats/ThreadRegistry.java	79
stats/bookkeeper-stats-api/src/main/java/org/apache/bookkeeper/stats/annotations/StatsDoc.java	14
stats/bookkeeper-stats-api/src/main/java/org/apache/bookkeeper/stats/annotations/package-info.java	1
stats/bookkeeper-stats-api/src/main/java/org/apache/bookkeeper/stats/package-info.java	1
stats/bookkeeper-stats-providers/codahale-metrics-provider/src/main/java/org/apache/bookkeeper/stats/codahale/CodahaleMetricsProvider.java	122
stats/bookkeeper-stats-providers/codahale-metrics-provider/src/main/java/org/apache/bookkeeper/stats/codahale/CodahaleOpStatsLogger.java	48
stats/bookkeeper-stats-providers/codahale-metrics-provider/src/main/java/org/apache/bookkeeper/stats/codahale/CodahaleStatsLogger.java	90
stats/bookkeeper-stats-providers/codahale-metrics-provider/src/main/java/org/apache/bookkeeper/stats/codahale/FastCodahaleMetricsProvider.java	11
stats/bookkeeper-stats-providers/codahale-metrics-provider/src/main/java/org/apache/bookkeeper/stats/codahale/FastCodahaleStatsLogger.java	62
stats/bookkeeper-stats-providers/codahale-metrics-provider/src/main/java/org/apache/bookkeeper/stats/codahale/FastSnapshot.java	83
stats/bookkeeper-stats-providers/codahale-metrics-provider/src/main/java/org/apache/bookkeeper/stats/codahale/FastTimer.java	288
stats/bookkeeper-stats-providers/codahale-metrics-provider/src/main/java/org/apache/bookkeeper/stats/codahale/package-info.java	1
stats/bookkeeper-stats-providers/otel-metrics-provider/src/main/java/org/apache/bookkeeper/stats/otel/OtelCounter.java	38
stats/bookkeeper-stats-providers/otel-metrics-provider/src/main/java/org/apache/bookkeeper/stats/otel/OtelMetricsProvider.java	109
stats/bookkeeper-stats-providers/otel-metrics-provider/src/main/java/org/apache/bookkeeper/stats/otel/OtelOpStatsLogger.java	43
stats/bookkeeper-stats-providers/otel-metrics-provider/src/main/java/org/apache/bookkeeper/stats/otel/OtelStatsLogger.java	68
stats/bookkeeper-stats-providers/otel-metrics-provider/src/main/java/org/apache/bookkeeper/stats/otel/ScopeContext.java	10
stats/bookkeeper-stats-providers/otel-metrics-provider/src/main/java/org/apache/bookkeeper/stats/otel/package-info.java	1
stats/bookkeeper-stats-providers/prometheus-metrics-provider/src/main/java/org/apache/bookkeeper/stats/prometheus/DataSketchesOpStatsLogger.java	152
stats/bookkeeper-stats-providers/prometheus-metrics-provider/src/main/java/org/apache/bookkeeper/stats/prometheus/LongAdderCounter.java	48
stats/bookkeeper-stats-providers/prometheus-metrics-provider/src/main/java/org/apache/bookkeeper/stats/prometheus/PrometheusMetricsProvider.java	187
stats/bookkeeper-stats-providers/prometheus-metrics-provider/src/main/java/org/apache/bookkeeper/stats/prometheus/PrometheusServlet.java	31
stats/bookkeeper-stats-providers/prometheus-metrics-provider/src/main/java/org/apache/bookkeeper/stats/prometheus/PrometheusStatsLogger.java	62
stats/bookkeeper-stats-providers/prometheus-metrics-provider/src/main/java/org/apache/bookkeeper/stats/prometheus/PrometheusTextFormat.java	170
stats/bookkeeper-stats-providers/prometheus-metrics-provider/src/main/java/org/apache/bookkeeper/stats/prometheus/ScopeContext.java	29
stats/bookkeeper-stats-providers/prometheus-metrics-provider/src/main/java/org/apache/bookkeeper/stats/prometheus/SimpleGauge.java	17
stats/bookkeeper-stats-providers/prometheus-metrics-provider/src/main/java/org/apache/bookkeeper/stats/prometheus/ThreadScopedDataSketchesStatsLogger.java	90
stats/bookkeeper-stats-providers/prometheus-metrics-provider/src/main/java/org/apache/bookkeeper/stats/prometheus/ThreadScopedLongAdderCounter.java	70
stats/bookkeeper-stats-providers/prometheus-metrics-provider/src/main/java/org/apache/bookkeeper/stats/prometheus/package-info.java	1
stats/utils/src/main/java/org/apache/bookkeeper/stats/utils/StatsDocGenerator.java	235
stats/utils/src/main/java/org/apache/bookkeeper/stats/utils/package-info.java	1
stream/api/src/main/java/org/apache/bookkeeper/api/StorageClient.java	16
stream/api/src/main/java/org/apache/bookkeeper/api/exceptions/ApiException.java	12
stream/api/src/main/java/org/apache/bookkeeper/api/exceptions/package-info.java	1
stream/api/src/main/java/org/apache/bookkeeper/api/kv/PTable.java	7
stream/api/src/main/java/org/apache/bookkeeper/api/kv/PTableBase.java	43
stream/api/src/main/java/org/apache/bookkeeper/api/kv/PTableReadView.java	87
stream/api/src/main/java/org/apache/bookkeeper/api/kv/PTableWriteView.java	237
stream/api/src/main/java/org/apache/bookkeeper/api/kv/Table.java	7
stream/api/src/main/java/org/apache/bookkeeper/api/kv/TableReadView.java	69
stream/api/src/main/java/org/apache/bookkeeper/api/kv/TableWriteView.java	222
stream/api/src/main/java/org/apache/bookkeeper/api/kv/Txn.java	11
stream/api/src/main/java/org/apache/bookkeeper/api/kv/exceptions/KvApiException.java	20
stream/api/src/main/java/org/apache/bookkeeper/api/kv/exceptions/package-info.java	1
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/op/CompareOpImpl.java	47
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/op/DeleteOpImpl.java	42
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/op/IncrementOpImpl.java	48
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/op/OpFactoryImpl.java	134
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/op/PutOpImpl.java	50
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/op/RangeOpImpl.java	42
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/op/TxnOpBuilderImpl.java	68
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/op/TxnOpImpl.java	56
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/op/package-info.java	1
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/options/DeleteOptionBuilderImpl.java	50
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/options/DeleteOptionImpl.java	35
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/options/IncrementOptionBuilderImpl.java	39
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/options/IncrementOptionImpl.java	32
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/options/OptionFactoryImpl.java	77
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/options/PutOptionBuilderImpl.java	39
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/options/PutOptionImpl.java	28
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/options/RangeOptionBuilderImpl.java	62
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/options/RangeOptionImpl.java	53
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/options/package-info.java	1
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/package-info.java	1
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/result/DeleteResultImpl.java	45
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/result/IncrementResultImpl.java	34
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/result/KeyValueFactory.java	16
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/result/KeyValueImpl.java	54
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/result/PutResultImpl.java	38
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/result/RangeResultImpl.java	49
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/result/ResultFactory.java	66
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/result/ResultImpl.java	44
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/result/TxnResultImpl.java	36
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/result/package-info.java	1
stream/api/src/main/java/org/apache/bookkeeper/api/kv/op/CompareOp.java	14
stream/api/src/main/java/org/apache/bookkeeper/api/kv/op/CompareResult.java	11
stream/api/src/main/java/org/apache/bookkeeper/api/kv/op/CompareTarget.java	7
stream/api/src/main/java/org/apache/bookkeeper/api/kv/op/DeleteOp.java	6
stream/api/src/main/java/org/apache/bookkeeper/api/kv/op/IncrementOp.java	11
stream/api/src/main/java/org/apache/bookkeeper/api/kv/op/Op.java	10
stream/api/src/main/java/org/apache/bookkeeper/api/kv/op/OpFactory.java	22
stream/api/src/main/java/org/apache/bookkeeper/api/kv/op/OpType.java	13
stream/api/src/main/java/org/apache/bookkeeper/api/kv/op/PutOp.java	11
stream/api/src/main/java/org/apache/bookkeeper/api/kv/op/RangeOp.java	10
stream/api/src/main/java/org/apache/bookkeeper/api/kv/op/TxnOp.java	7
stream/api/src/main/java/org/apache/bookkeeper/api/kv/op/TxnOpBuilder.java	7
stream/api/src/main/java/org/apache/bookkeeper/api/kv/op/package-info.java	1
stream/api/src/main/java/org/apache/bookkeeper/api/kv/options/Builder.java	4
stream/api/src/main/java/org/apache/bookkeeper/api/kv/options/DeleteOption.java	5
stream/api/src/main/java/org/apache/bookkeeper/api/kv/options/DeleteOptionBuilder.java	5
stream/api/src/main/java/org/apache/bookkeeper/api/kv/options/IncrementOption.java	4
stream/api/src/main/java/org/apache/bookkeeper/api/kv/options/IncrementOptionBuilder.java	4
stream/api/src/main/java/org/apache/bookkeeper/api/kv/options/Option.java	5
stream/api/src/main/java/org/apache/bookkeeper/api/kv/options/OptionFactory.java	7
stream/api/src/main/java/org/apache/bookkeeper/api/kv/options/Options.java	168
stream/api/src/main/java/org/apache/bookkeeper/api/kv/options/PutOption.java	4
stream/api/src/main/java/org/apache/bookkeeper/api/kv/options/PutOptionBuilder.java	4
stream/api/src/main/java/org/apache/bookkeeper/api/kv/options/RangeOption.java	11
stream/api/src/main/java/org/apache/bookkeeper/api/kv/options/RangeOptionBuilder.java	11
stream/api/src/main/java/org/apache/bookkeeper/api/kv/options/package-info.java	1
stream/api/src/main/java/org/apache/bookkeeper/api/kv/package-info.java	1
stream/api/src/main/java/org/apache/bookkeeper/api/kv/result/Code.java	17
stream/api/src/main/java/org/apache/bookkeeper/api/kv/result/DeleteResult.java	7
stream/api/src/main/java/org/apache/bookkeeper/api/kv/result/IncrementResult.java	4
stream/api/src/main/java/org/apache/bookkeeper/api/kv/result/KeyValue.java	12
stream/api/src/main/java/org/apache/bookkeeper/api/kv/result/PutResult.java	4
stream/api/src/main/java/org/apache/bookkeeper/api/kv/result/RangeResult.java	8
stream/api/src/main/java/org/apache/bookkeeper/api/kv/result/Result.java	10
stream/api/src/main/java/org/apache/bookkeeper/api/kv/result/TxnResult.java	6
stream/api/src/main/java/org/apache/bookkeeper/api/kv/result/package-info.java	1
stream/api/src/main/java/org/apache/bookkeeper/api/package-info.java	1
stream/api/src/main/java/org/apache/bookkeeper/api/stream/Position.java	7
stream/api/src/main/java/org/apache/bookkeeper/api/stream/package-info.java	1
stream/bk-grpc-name-resolver/src/main/java/org/apache/bookkeeper/grpc/resolver/BKRegistrationNameResolver.java	104
stream/bk-grpc-name-resolver/src/main/java/org/apache/bookkeeper/grpc/resolver/BKRegistrationNameResolverProvider.java	52
stream/bk-grpc-name-resolver/src/main/java/org/apache/bookkeeper/grpc/resolver/package-info.java	1
stream/clients/java/all/src/main/java/org/apache/bookkeeper/clients/SimpleClientBase.java	56
stream/clients/java/all/src/main/java/org/apache/bookkeeper/clients/SimpleStorageClientImpl.java	99
stream/clients/java/all/src/main/java/org/apache/bookkeeper/clients/StorageClientBuilder.java	52
stream/clients/java/all/src/main/java/org/apache/bookkeeper/clients/StorageClientImpl.java	128
stream/clients/java/all/src/main/java/org/apache/bookkeeper/clients/admin/SimpleStorageAdminClientImpl.java	126
stream/clients/java/all/src/main/java/org/apache/bookkeeper/clients/admin/StorageAdminClient.java	27
stream/clients/java/all/src/main/java/org/apache/bookkeeper/clients/admin/StorageAdminClientImpl.java	93
stream/clients/java/all/src/main/java/org/apache/bookkeeper/clients/admin/package-info.java	1
stream/clients/java/all/src/main/java/org/apache/bookkeeper/clients/package-info.java	1
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/config/StorageClientSettings.java	37
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/config/package-info.java	1
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/exceptions/ClientException.java	13
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/exceptions/InternalServerException.java	13
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/exceptions/InvalidNamespaceNameException.java	7
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/exceptions/InvalidStreamNameException.java	7
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/exceptions/NamespaceExistsException.java	7
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/exceptions/NamespaceNotFoundException.java	7
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/exceptions/StorageContainerException.java	13
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/exceptions/StreamExistsException.java	7
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/exceptions/StreamNotFoundException.java	7
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/exceptions/package-info.java	1
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/channel/StorageServerChannel.java	146
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/channel/StorageServerChannelManager.java	130
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/channel/package-info.java	1
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/container/StorageContainerChannel.java	156
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/container/StorageContainerChannelFactory.java	5
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/container/StorageContainerChannelManager.java	49
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/container/StorageContainerClientInterceptor.java	51
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/container/StorageContainerInfo.java	20
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/container/StorageContainerManager.java	42
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/container/package-info.java	1
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/LocationClientImpl.java	97
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/MetaRangeClientImpl.java	53
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/ProtocolInternalUtils.java	89
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/RootRangeClientImpl.java	190
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/RootRangeClientImplWithRetries.java	100
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/StorageServerClientManagerImpl.java	121
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/StreamMetadataCache.java	33
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/api/HashStreamRanges.java	10
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/api/LocationClient.java	11
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/api/MetaRangeClient.java	7
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/api/RootRangeClient.java	20
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/api/StorageServerClientManager.java	13
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/api/StreamRanges.java	30
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/api/package-info.java	1
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/mr/MetaRangeRequestProcessor.java	53
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/mr/package-info.java	1
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/package-info.java	1
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/routing/RangeRouter.java	76
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/routing/package-info.java	1
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/resolver/EndpointResolver.java	8
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/resolver/package-info.java	1
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/utils/ClientConstants.java	20
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/utils/ClientResources.java	90
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/utils/GrpcChannels.java	46
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/utils/GrpcUtils.java	34
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/utils/ListenableFutureRpcProcessor.java	98
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/utils/NetUtils.java	71
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/utils/RetryUtils.java	76
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/utils/RpcUtils.java	55
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/utils/package-info.java	1
stream/clients/java/kv/src/main/java/org/apache/bookkeeper/clients/impl/kv/ByteBufTableImpl.java	56
stream/clients/java/kv/src/main/java/org/apache/bookkeeper/clients/impl/kv/DeleteRequestProcessor.java	51
stream/clients/java/kv/src/main/java/org/apache/bookkeeper/clients/impl/kv/IncrementRequestProcessor.java	51
stream/clients/java/kv/src/main/java/org/apache/bookkeeper/clients/impl/kv/KvUtils.java	265
stream/clients/java/kv/src/main/java/org/apache/bookkeeper/clients/impl/kv/PByteBufSimpleTableImpl.java	267
stream/clients/java/kv/src/main/java/org/apache/bookkeeper/clients/impl/kv/PByteBufTableImpl.java	254
stream/clients/java/kv/src/main/java/org/apache/bookkeeper/clients/impl/kv/PByteBufTableRangeImpl.java	227
stream/clients/java/kv/src/main/java/org/apache/bookkeeper/clients/impl/kv/PutRequestProcessor.java	51
stream/clients/java/kv/src/main/java/org/apache/bookkeeper/clients/impl/kv/RangeRequestProcessor.java	51
stream/clients/java/kv/src/main/java/org/apache/bookkeeper/clients/impl/kv/TableRangeFactory.java	17
stream/clients/java/kv/src/main/java/org/apache/bookkeeper/clients/impl/kv/TxnRequestProcessor.java	51
stream/clients/java/kv/src/main/java/org/apache/bookkeeper/clients/impl/kv/interceptors/package-info.java	1
stream/clients/java/kv/src/main/java/org/apache/bookkeeper/clients/impl/kv/package-info.java	1
stream/clients/python/bookkeeper/__init__.py	6
stream/clients/python/bookkeeper/admin/__init__.py	5
stream/clients/python/bookkeeper/admin/client.py	28
stream/clients/python/bookkeeper/admin/exceptions.py	5
stream/clients/python/bookkeeper/admin/namespace.py	73
stream/clients/python/bookkeeper/admin/namespaces.py	65
stream/clients/python/bookkeeper/common/__init__.py	1
stream/clients/python/bookkeeper/common/constants.py	53
stream/clients/python/bookkeeper/common/datetime_helpers.py	86
stream/clients/python/bookkeeper/common/exceptions.py	178
stream/clients/python/bookkeeper/common/future/__init__.py	4
stream/clients/python/bookkeeper/common/future/_helpers.py	13
stream/clients/python/bookkeeper/common/future/base.py	31
stream/clients/python/bookkeeper/common/future/polling.py	64
stream/clients/python/bookkeeper/common/general_helpers.py	8
stream/clients/python/bookkeeper/common/grpc_helpers.py	137
stream/clients/python/bookkeeper/common/method.py	53
stream/clients/python/bookkeeper/common/protobuf_helpers.py	143
stream/clients/python/bookkeeper/common/retry.py	113
stream/clients/python/bookkeeper/common/router/__init__.py	4
stream/clients/python/bookkeeper/common/router/router.py	10
stream/clients/python/bookkeeper/common/service_uri.py	17
stream/clients/python/bookkeeper/common/timeout.py	68
stream/clients/python/bookkeeper/common/util.py	15
stream/clients/python/bookkeeper/kv/__init__.py	5
stream/clients/python/bookkeeper/kv/client.py	32
stream/clients/python/bookkeeper/kv/exceptions.py	5
stream/clients/python/bookkeeper/kv/futures.py	54
stream/clients/python/bookkeeper/kv/table.py	114
stream/clients/python/bookkeeper/proto/__init__.py	1
stream/clients/python/bookkeeper/proto/kv_rpc_pb2_grpc.py	83
stream/clients/python/bookkeeper/proto/storage_pb2_grpc.py	146
stream/clients/python/bookkeeper/types.py	44
stream/clients/python/nox.py	51
stream/clients/python/noxfile.py	53
stream/clients/python/pylint.config.py	4
stream/clients/python/setup.cfg	2
stream/clients/python/setup.py	57
stream/common/src/main/java/org/apache/bookkeeper/common/coder/ByteArrayCoder.java	28
stream/common/src/main/java/org/apache/bookkeeper/common/coder/Coder.java	26
stream/common/src/main/java/org/apache/bookkeeper/common/coder/StringUtf8Coder.java	32
stream/common/src/main/java/org/apache/bookkeeper/common/coder/VarIntCoder.java	41
stream/common/src/main/java/org/apache/bookkeeper/common/coder/package-info.java	1
stream/common/src/main/java/org/apache/bookkeeper/common/exceptions/ObjectClosedException.java	7
stream/common/src/main/java/org/apache/bookkeeper/common/exceptions/package-info.java	1
stream/common/src/main/java/org/apache/bookkeeper/common/grpc/netty/IdentityBinaryMarshaller.java	17
stream/common/src/main/java/org/apache/bookkeeper/common/grpc/netty/IdentityInputStreamMarshaller.java	18
stream/common/src/main/java/org/apache/bookkeeper/common/grpc/netty/LongBinaryMarshaller.java	18
stream/common/src/main/java/org/apache/bookkeeper/common/grpc/netty/package-info.java	1
stream/common/src/main/java/org/apache/bookkeeper/common/grpc/package-info.java	1
stream/common/src/main/java/org/apache/bookkeeper/common/grpc/proxy/ChannelFinder.java	8
stream/common/src/main/java/org/apache/bookkeeper/common/grpc/proxy/ProxyCall.java	88
stream/common/src/main/java/org/apache/bookkeeper/common/grpc/proxy/ProxyHandlerRegistry.java	76
stream/common/src/main/java/org/apache/bookkeeper/common/grpc/proxy/ProxyServerCallHandler.java	30
stream/common/src/main/java/org/apache/bookkeeper/common/grpc/proxy/package-info.java	1
stream/common/src/main/java/org/apache/bookkeeper/common/grpc/stats/ClientStats.java	83
stream/common/src/main/java/org/apache/bookkeeper/common/grpc/stats/MonitoringClientCall.java	24
stream/common/src/main/java/org/apache/bookkeeper/common/grpc/stats/MonitoringClientCallListener.java	39
stream/common/src/main/java/org/apache/bookkeeper/common/grpc/stats/MonitoringClientInterceptor.java	48
stream/common/src/main/java/org/apache/bookkeeper/common/grpc/stats/MonitoringServerCall.java	31
stream/common/src/main/java/org/apache/bookkeeper/common/grpc/stats/MonitoringServerCallListener.java	25
stream/common/src/main/java/org/apache/bookkeeper/common/grpc/stats/MonitoringServerInterceptor.java	51
stream/common/src/main/java/org/apache/bookkeeper/common/grpc/stats/ServerStats.java	83
stream/common/src/main/java/org/apache/bookkeeper/common/grpc/stats/package-info.java	1
stream/common/src/main/java/org/apache/bookkeeper/common/hash/Murmur3.java	293
stream/common/src/main/java/org/apache/bookkeeper/common/hash/MurmurHash.java	89
stream/common/src/main/java/org/apache/bookkeeper/common/hash/package-info.java	1
stream/common/src/main/java/org/apache/bookkeeper/common/kv/KV.java	9
stream/common/src/main/java/org/apache/bookkeeper/common/kv/KVImpl.java	22
stream/common/src/main/java/org/apache/bookkeeper/common/kv/package-info.java	1
stream/common/src/main/java/org/apache/bookkeeper/common/resolver/AbstractNameResolver.java	87
stream/common/src/main/java/org/apache/bookkeeper/common/resolver/NameResolverFactoryProvider.java	6
stream/common/src/main/java/org/apache/bookkeeper/common/resolver/NameResolverProviderFactory.java	32
stream/common/src/main/java/org/apache/bookkeeper/common/resolver/ServiceNameResolverProvider.java	92
stream/common/src/main/java/org/apache/bookkeeper/common/resolver/StaticNameResolver.java	29
stream/common/src/main/java/org/apache/bookkeeper/common/resolver/package-info.java	1
stream/common/src/main/java/org/apache/bookkeeper/common/router/AbstractHashRouter.java	21
stream/common/src/main/java/org/apache/bookkeeper/common/router/ByteBufHashRouter.java	14
stream/common/src/main/java/org/apache/bookkeeper/common/router/BytesHashRouter.java	13
stream/common/src/main/java/org/apache/bookkeeper/common/router/HashRouter.java	3
stream/common/src/main/java/org/apache/bookkeeper/common/router/IntHashRouter.java	14
stream/common/src/main/java/org/apache/bookkeeper/common/router/Router.java	5
stream/common/src/main/java/org/apache/bookkeeper/common/router/StringUtf8HashRouter.java	20
stream/common/src/main/java/org/apache/bookkeeper/common/router/package-info.java	1
stream/common/src/main/java/org/apache/bookkeeper/common/util/AbstractAutoAsyncCloseable.java	27
stream/common/src/main/java/org/apache/bookkeeper/common/util/AsyncCloseable.java	5
stream/common/src/main/java/org/apache/bookkeeper/common/util/AutoAsyncCloseable.java	16
stream/common/src/main/java/org/apache/bookkeeper/common/util/Bytes.java	28
stream/common/src/main/java/org/apache/bookkeeper/common/util/CompletableRunnable.java	6
stream/common/src/main/java/org/apache/bookkeeper/common/util/ExceptionUtils.java	31
stream/common/src/main/java/org/apache/bookkeeper/common/util/ExceptionalFunction.java	17
stream/common/src/main/java/org/apache/bookkeeper/common/util/IRevisioned.java	5
stream/common/src/main/java/org/apache/bookkeeper/common/util/ListenableFutures.java	58
stream/common/src/main/java/org/apache/bookkeeper/common/util/Recycled.java	4
stream/common/src/main/java/org/apache/bookkeeper/common/util/Revisioned.java	11
stream/common/src/main/java/org/apache/bookkeeper/common/util/VarInt.java	61
stream/common/src/main/java/org/apache/bookkeeper/common/util/package-info.java	1
stream/conf/log4j2.cli.xml	29
stream/conf/log4j2.xml	29
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/annotations/DistributedLogAnnotations.java	4
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/annotations/package-info.java	1
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/concurrent/AsyncSemaphore.java	83
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/concurrent/package-info.java	1
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/config/ConcurrentBaseConfiguration.java	5
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/config/ConcurrentConstConfiguration.java	10
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/config/ConfigurationListener.java	4
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/config/ConfigurationSubscription.java	146
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/config/FileConfigurationBuilder.java	6
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/config/PropertiesConfigurationBuilder.java	15
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/config/package-info.java	1
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/functions/VoidFunctions.java	7
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/functions/package-info.java	1
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/package-info.java	1
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/rate/MovingAverageRate.java	6
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/rate/MovingAverageRateFactory.java	33
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/rate/SampledMovingAverageRate.java	58
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/rate/package-info.java	1
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/stats/BroadCastStatsLogger.java	146
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/stats/OpStatsListener.java	28
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/stats/package-info.java	1
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/util/BitMaskUtils.java	12
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/util/ByteBufUtils.java	12
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/util/MathUtil.java	10
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/util/Permit.java	5
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/util/PermitLimiter.java	18
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/util/PermitManager.java	32
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/util/ReferenceCounted.java	5
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/util/SchedulerUtils.java	20
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/util/Sequencer.java	4
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/util/Sizable.java	4
stream/distributedlog/common/src/main/java/org/apache/distributedlog/common/util/package-info.java	1
stream/distributedlog/common/src/main/java/org/apache/distributedlog/io/Abortable.java	5
stream/distributedlog/common/src/main/java/org/apache/distributedlog/io/Abortables.java	90
stream/distributedlog/common/src/main/java/org/apache/distributedlog/io/AsyncAbortable.java	9
stream/distributedlog/common/src/main/java/org/apache/distributedlog/io/AsyncCloseable.java	11
stream/distributedlog/common/src/main/java/org/apache/distributedlog/io/AsyncDeleteable.java	5
stream/distributedlog/common/src/main/java/org/apache/distributedlog/io/CompressionCodec.java	28
stream/distributedlog/common/src/main/java/org/apache/distributedlog/io/CompressionUtils.java	20
stream/distributedlog/common/src/main/java/org/apache/distributedlog/io/IdentityCompressionCodec.java	32
stream/distributedlog/common/src/main/java/org/apache/distributedlog/io/LZ4CompressionCodec.java	48
stream/distributedlog/common/src/main/java/org/apache/distributedlog/io/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/bookkeeper/client/BookKeeperAccessor.java	15
stream/distributedlog/core/src/main/java/org/apache/bookkeeper/client/LedgerReader.java	186
stream/distributedlog/core/src/main/java/org/apache/bookkeeper/client/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/AppendOnlyStreamReader.java	132
stream/distributedlog/core/src/main/java/org/apache/distributedlog/AppendOnlyStreamWriter.java	77
stream/distributedlog/core/src/main/java/org/apache/distributedlog/AsyncNotification.java	5
stream/distributedlog/core/src/main/java/org/apache/distributedlog/BKAbstractLogWriter.java	470
stream/distributedlog/core/src/main/java/org/apache/distributedlog/BKAsyncLogReader.java	599
stream/distributedlog/core/src/main/java/org/apache/distributedlog/BKAsyncLogWriter.java	396
stream/distributedlog/core/src/main/java/org/apache/distributedlog/BKDistributedLogManager.java	767
stream/distributedlog/core/src/main/java/org/apache/distributedlog/BKDistributedLogNamespace.java	237
stream/distributedlog/core/src/main/java/org/apache/distributedlog/BKLogHandler.java	542
stream/distributedlog/core/src/main/java/org/apache/distributedlog/BKLogReadHandler.java	279
stream/distributedlog/core/src/main/java/org/apache/distributedlog/BKLogSegmentWriter.java	1044
stream/distributedlog/core/src/main/java/org/apache/distributedlog/BKLogWriteHandler.java	1057
stream/distributedlog/core/src/main/java/org/apache/distributedlog/BKSyncLogReader.java	226
stream/distributedlog/core/src/main/java/org/apache/distributedlog/BKSyncLogWriter.java	59
stream/distributedlog/core/src/main/java/org/apache/distributedlog/BKTransmitPacket.java	34
stream/distributedlog/core/src/main/java/org/apache/distributedlog/BookKeeperClient.java	242
stream/distributedlog/core/src/main/java/org/apache/distributedlog/BookKeeperClientBuilder.java	90
stream/distributedlog/core/src/main/java/org/apache/distributedlog/DistributedLogConfiguration.java	1286
stream/distributedlog/core/src/main/java/org/apache/distributedlog/DistributedLogConstants.java	44
stream/distributedlog/core/src/main/java/org/apache/distributedlog/Entry.java	79
stream/distributedlog/core/src/main/java/org/apache/distributedlog/EntryBuffer.java	11
stream/distributedlog/core/src/main/java/org/apache/distributedlog/EntryPosition.java	36
stream/distributedlog/core/src/main/java/org/apache/distributedlog/EnvelopedEntry.java	47
stream/distributedlog/core/src/main/java/org/apache/distributedlog/EnvelopedEntryReader.java	110
stream/distributedlog/core/src/main/java/org/apache/distributedlog/EnvelopedEntryWriter.java	174
stream/distributedlog/core/src/main/java/org/apache/distributedlog/LocalDLMEmulator.java	287
stream/distributedlog/core/src/main/java/org/apache/distributedlog/LogSegmentMetadata.java	925
stream/distributedlog/core/src/main/java/org/apache/distributedlog/MaxLogSegmentSequenceNo.java	43
stream/distributedlog/core/src/main/java/org/apache/distributedlog/MaxTxId.java	43
stream/distributedlog/core/src/main/java/org/apache/distributedlog/ReadAheadEntryReader.java	790
stream/distributedlog/core/src/main/java/org/apache/distributedlog/ReadUtils.java	510
stream/distributedlog/core/src/main/java/org/apache/distributedlog/WriteLimiter.java	37
stream/distributedlog/core/src/main/java/org/apache/distributedlog/ZooKeeperClient.java	260
stream/distributedlog/core/src/main/java/org/apache/distributedlog/ZooKeeperClientBuilder.java	111
stream/distributedlog/core/src/main/java/org/apache/distributedlog/acl/AccessControlManager.java	9
stream/distributedlog/core/src/main/java/org/apache/distributedlog/acl/DefaultAccessControlManager.java	29
stream/distributedlog/core/src/main/java/org/apache/distributedlog/acl/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/admin/DistributedLogAdmin.java	792
stream/distributedlog/core/src/main/java/org/apache/distributedlog/admin/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/api/AsyncLogReader.java	16
stream/distributedlog/core/src/main/java/org/apache/distributedlog/api/AsyncLogWriter.java	19
stream/distributedlog/core/src/main/java/org/apache/distributedlog/api/DistributedLogManager.java	72
stream/distributedlog/core/src/main/java/org/apache/distributedlog/api/LogReader.java	16
stream/distributedlog/core/src/main/java/org/apache/distributedlog/api/LogWriter.java	18
stream/distributedlog/core/src/main/java/org/apache/distributedlog/api/MetadataAccessor.java	15
stream/distributedlog/core/src/main/java/org/apache/distributedlog/api/namespace/Namespace.java	44
stream/distributedlog/core/src/main/java/org/apache/distributedlog/api/namespace/NamespaceBuilder.java	154
stream/distributedlog/core/src/main/java/org/apache/distributedlog/api/namespace/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/api/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/api/subscription/SubscriptionStateStore.java	8
stream/distributedlog/core/src/main/java/org/apache/distributedlog/api/subscription/SubscriptionsStore.java	11
stream/distributedlog/core/src/main/java/org/apache/distributedlog/api/subscription/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/auditor/DLAuditor.java	555
stream/distributedlog/core/src/main/java/org/apache/distributedlog/auditor/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/bk/DynamicQuorumConfigProvider.java	12
stream/distributedlog/core/src/main/java/org/apache/distributedlog/bk/ImmutableQuorumConfigProvider.java	11
stream/distributedlog/core/src/main/java/org/apache/distributedlog/bk/LedgerAllocator.java	7
stream/distributedlog/core/src/main/java/org/apache/distributedlog/bk/LedgerAllocatorDelegator.java	44
stream/distributedlog/core/src/main/java/org/apache/distributedlog/bk/LedgerAllocatorPool.java	376
stream/distributedlog/core/src/main/java/org/apache/distributedlog/bk/LedgerAllocatorUtils.java	17
stream/distributedlog/core/src/main/java/org/apache/distributedlog/bk/LedgerMetadata.java	43
stream/distributedlog/core/src/main/java/org/apache/distributedlog/bk/QuorumConfig.java	61
stream/distributedlog/core/src/main/java/org/apache/distributedlog/bk/QuorumConfigProvider.java	4
stream/distributedlog/core/src/main/java/org/apache/distributedlog/bk/SimpleLedgerAllocator.java	427
stream/distributedlog/core/src/main/java/org/apache/distributedlog/bk/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/callback/LogSegmentListener.java	7
stream/distributedlog/core/src/main/java/org/apache/distributedlog/callback/LogSegmentNamesListener.java	7
stream/distributedlog/core/src/main/java/org/apache/distributedlog/callback/NamespaceListener.java	7
stream/distributedlog/core/src/main/java/org/apache/distributedlog/callback/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/config/DynamicConfigurationFactory.java	64
stream/distributedlog/core/src/main/java/org/apache/distributedlog/config/DynamicDistributedLogConfiguration.java	218
stream/distributedlog/core/src/main/java/org/apache/distributedlog/config/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/exceptions/ZKException.java	25
stream/distributedlog/core/src/main/java/org/apache/distributedlog/exceptions/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/feature/AbstractFeatureProvider.java	63
stream/distributedlog/core/src/main/java/org/apache/distributedlog/feature/ConfigurationFeatureProvider.java	47
stream/distributedlog/core/src/main/java/org/apache/distributedlog/feature/CoreFeatureKeys.java	6
stream/distributedlog/core/src/main/java/org/apache/distributedlog/feature/DefaultFeatureProvider.java	22
stream/distributedlog/core/src/main/java/org/apache/distributedlog/feature/DynamicConfigurationFeatureProvider.java	103
stream/distributedlog/core/src/main/java/org/apache/distributedlog/feature/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/function/GetLastTxIdFunction.java	17
stream/distributedlog/core/src/main/java/org/apache/distributedlog/function/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/impl/BKNamespaceDriver.java	499
stream/distributedlog/core/src/main/java/org/apache/distributedlog/impl/ZKLogMetadataStore.java	102
stream/distributedlog/core/src/main/java/org/apache/distributedlog/impl/ZKLogSegmentFilters.java	55
stream/distributedlog/core/src/main/java/org/apache/distributedlog/impl/ZKLogSegmentMetadataStore.java	417
stream/distributedlog/core/src/main/java/org/apache/distributedlog/impl/ZKMetadataAccessor.java	202
stream/distributedlog/core/src/main/java/org/apache/distributedlog/impl/ZKNamespaceWatcher.java	100
stream/distributedlog/core/src/main/java/org/apache/distributedlog/impl/acl/ZKAccessControl.java	189
stream/distributedlog/core/src/main/java/org/apache/distributedlog/impl/acl/ZKAccessControlManager.java	327
stream/distributedlog/core/src/main/java/org/apache/distributedlog/impl/acl/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/impl/federated/FederatedZKLogMetadataStore.java	621
stream/distributedlog/core/src/main/java/org/apache/distributedlog/impl/federated/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/impl/logsegment/BKLogSegmentAllocator.java	50
stream/distributedlog/core/src/main/java/org/apache/distributedlog/impl/logsegment/BKLogSegmentEntryReader.java	694
stream/distributedlog/core/src/main/java/org/apache/distributedlog/impl/logsegment/BKLogSegmentEntryStore.java	242
stream/distributedlog/core/src/main/java/org/apache/distributedlog/impl/logsegment/BKLogSegmentEntryWriter.java	33
stream/distributedlog/core/src/main/java/org/apache/distributedlog/impl/logsegment/BKLogSegmentRandomAccessEntryReader.java	98
stream/distributedlog/core/src/main/java/org/apache/distributedlog/impl/logsegment/BKUtils.java	32
stream/distributedlog/core/src/main/java/org/apache/distributedlog/impl/logsegment/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/impl/metadata/BKDLConfig.java	253
stream/distributedlog/core/src/main/java/org/apache/distributedlog/impl/metadata/ZKLogStreamMetadataStore.java	820
stream/distributedlog/core/src/main/java/org/apache/distributedlog/impl/metadata/ZkMetadataResolver.java	48
stream/distributedlog/core/src/main/java/org/apache/distributedlog/impl/metadata/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/impl/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/impl/subscription/ZKSubscriptionStateStore.java	86
stream/distributedlog/core/src/main/java/org/apache/distributedlog/impl/subscription/ZKSubscriptionsStore.java	115
stream/distributedlog/core/src/main/java/org/apache/distributedlog/impl/subscription/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/injector/AsyncFailureInjector.java	46
stream/distributedlog/core/src/main/java/org/apache/distributedlog/injector/AsyncRandomFailureInjector.java	141
stream/distributedlog/core/src/main/java/org/apache/distributedlog/injector/FailureInjector.java	9
stream/distributedlog/core/src/main/java/org/apache/distributedlog/injector/RandomDelayFailureInjector.java	32
stream/distributedlog/core/src/main/java/org/apache/distributedlog/injector/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/limiter/ChainedRequestLimiter.java	45
stream/distributedlog/core/src/main/java/org/apache/distributedlog/limiter/ComposableRequestLimiter.java	41
stream/distributedlog/core/src/main/java/org/apache/distributedlog/limiter/GuavaRateLimiter.java	30
stream/distributedlog/core/src/main/java/org/apache/distributedlog/limiter/RateLimiter.java	19
stream/distributedlog/core/src/main/java/org/apache/distributedlog/limiter/RequestLimiter.java	5
stream/distributedlog/core/src/main/java/org/apache/distributedlog/limiter/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/lock/DistributedLock.java	9
stream/distributedlog/core/src/main/java/org/apache/distributedlog/lock/DistributedLockContext.java	19
stream/distributedlog/core/src/main/java/org/apache/distributedlog/lock/EpochChangedException.java	8
stream/distributedlog/core/src/main/java/org/apache/distributedlog/lock/LockAction.java	5
stream/distributedlog/core/src/main/java/org/apache/distributedlog/lock/LockClosedException.java	13
stream/distributedlog/core/src/main/java/org/apache/distributedlog/lock/LockListener.java	4
stream/distributedlog/core/src/main/java/org/apache/distributedlog/lock/LockSessionExpiredException.java	11
stream/distributedlog/core/src/main/java/org/apache/distributedlog/lock/LockStateChangedException.java	12
stream/distributedlog/core/src/main/java/org/apache/distributedlog/lock/LockTimeoutException.java	9
stream/distributedlog/core/src/main/java/org/apache/distributedlog/lock/LockWaiter.java	45
stream/distributedlog/core/src/main/java/org/apache/distributedlog/lock/NopDistributedLock.java	22
stream/distributedlog/core/src/main/java/org/apache/distributedlog/lock/SessionLock.java	15
stream/distributedlog/core/src/main/java/org/apache/distributedlog/lock/SessionLockFactory.java	5
stream/distributedlog/core/src/main/java/org/apache/distributedlog/lock/ZKDistributedLock.java	405
stream/distributedlog/core/src/main/java/org/apache/distributedlog/lock/ZKSessionLock.java	952
stream/distributedlog/core/src/main/java/org/apache/distributedlog/lock/ZKSessionLockFactory.java	95
stream/distributedlog/core/src/main/java/org/apache/distributedlog/lock/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentEntryReader.java	22
stream/distributedlog/core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentEntryStore.java	26
stream/distributedlog/core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentEntryWriter.java	13
stream/distributedlog/core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentFilter.java	11
stream/distributedlog/core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentMetadataCache.java	51
stream/distributedlog/core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentMetadataStore.java	37
stream/distributedlog/core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentRandomAccessEntryReader.java	9
stream/distributedlog/core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentWriter.java	18
stream/distributedlog/core/src/main/java/org/apache/distributedlog/logsegment/PerStreamLogSegmentCache.java	152
stream/distributedlog/core/src/main/java/org/apache/distributedlog/logsegment/RollingPolicy.java	5
stream/distributedlog/core/src/main/java/org/apache/distributedlog/logsegment/SizeBasedRollingPolicy.java	12
stream/distributedlog/core/src/main/java/org/apache/distributedlog/logsegment/TimeBasedRollingPolicy.java	22
stream/distributedlog/core/src/main/java/org/apache/distributedlog/logsegment/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/metadata/DLConfig.java	6
stream/distributedlog/core/src/main/java/org/apache/distributedlog/metadata/DLMetadata.java	164
stream/distributedlog/core/src/main/java/org/apache/distributedlog/metadata/DryrunLogSegmentMetadataStoreUpdater.java	27
stream/distributedlog/core/src/main/java/org/apache/distributedlog/metadata/LogMetadata.java	70
stream/distributedlog/core/src/main/java/org/apache/distributedlog/metadata/LogMetadataForReader.java	25
stream/distributedlog/core/src/main/java/org/apache/distributedlog/metadata/LogMetadataForWriter.java	28
stream/distributedlog/core/src/main/java/org/apache/distributedlog/metadata/LogMetadataStore.java	14
stream/distributedlog/core/src/main/java/org/apache/distributedlog/metadata/LogSegmentMetadataStoreUpdater.java	120
stream/distributedlog/core/src/main/java/org/apache/distributedlog/metadata/LogStreamMetadataStore.java	28
stream/distributedlog/core/src/main/java/org/apache/distributedlog/metadata/MetadataResolver.java	6
stream/distributedlog/core/src/main/java/org/apache/distributedlog/metadata/MetadataUpdater.java	21
stream/distributedlog/core/src/main/java/org/apache/distributedlog/metadata/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/namespace/NamespaceDriver.java	43
stream/distributedlog/core/src/main/java/org/apache/distributedlog/namespace/NamespaceDriverManager.java	111
stream/distributedlog/core/src/main/java/org/apache/distributedlog/namespace/NamespaceWatcher.java	16
stream/distributedlog/core/src/main/java/org/apache/distributedlog/namespace/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/net/DNSResolver.java	53
stream/distributedlog/core/src/main/java/org/apache/distributedlog/net/DNSResolverForRacks.java	26
stream/distributedlog/core/src/main/java/org/apache/distributedlog/net/DNSResolverForRows.java	31
stream/distributedlog/core/src/main/java/org/apache/distributedlog/net/NetUtils.java	33
stream/distributedlog/core/src/main/java/org/apache/distributedlog/net/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/selector/FirstDLSNNotLessThanSelector.java	20
stream/distributedlog/core/src/main/java/org/apache/distributedlog/selector/FirstRecordSelector.java	20
stream/distributedlog/core/src/main/java/org/apache/distributedlog/selector/FirstTxIdNotLessThanSelector.java	24
stream/distributedlog/core/src/main/java/org/apache/distributedlog/selector/LastRecordSelector.java	13
stream/distributedlog/core/src/main/java/org/apache/distributedlog/selector/LogRecordSelector.java	6
stream/distributedlog/core/src/main/java/org/apache/distributedlog/selector/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/thrift/AccessControlEntry.java	653
stream/distributedlog/core/src/main/java/org/apache/distributedlog/thrift/BKDLConfigFormat.java	1145
stream/distributedlog/core/src/main/java/org/apache/distributedlog/thrift/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/tools/DistributedLogTool.java	2280
stream/distributedlog/core/src/main/java/org/apache/distributedlog/tools/Tool.java	156
stream/distributedlog/core/src/main/java/org/apache/distributedlog/tools/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/util/Allocator.java	10
stream/distributedlog/core/src/main/java/org/apache/distributedlog/util/CommandLineUtils.java	31
stream/distributedlog/core/src/main/java/org/apache/distributedlog/util/ConfUtils.java	25
stream/distributedlog/core/src/main/java/org/apache/distributedlog/util/DLUtils.java	220
stream/distributedlog/core/src/main/java/org/apache/distributedlog/util/FailpointUtils.java	98
stream/distributedlog/core/src/main/java/org/apache/distributedlog/util/RetryPolicyUtils.java	9
stream/distributedlog/core/src/main/java/org/apache/distributedlog/util/SimplePermitLimiter.java	76
stream/distributedlog/core/src/main/java/org/apache/distributedlog/util/TimeSequencer.java	14
stream/distributedlog/core/src/main/java/org/apache/distributedlog/util/Transaction.java	17
stream/distributedlog/core/src/main/java/org/apache/distributedlog/util/Utils.java	493
stream/distributedlog/core/src/main/java/org/apache/distributedlog/util/package-info.java	1
stream/distributedlog/core/src/main/java/org/apache/distributedlog/zk/DefaultZKOp.java	27
stream/distributedlog/core/src/main/java/org/apache/distributedlog/zk/LimitedPermitManager.java	155
stream/distributedlog/core/src/main/java/org/apache/distributedlog/zk/ZKOp.java	27
stream/distributedlog/core/src/main/java/org/apache/distributedlog/zk/ZKTransaction.java	80
stream/distributedlog/core/src/main/java/org/apache/distributedlog/zk/ZKVersionedSetOp.java	45
stream/distributedlog/core/src/main/java/org/apache/distributedlog/zk/ZKWatcherManager.java	163
stream/distributedlog/core/src/main/java/org/apache/distributedlog/zk/package-info.java	1
stream/distributedlog/core/src/main/thrift/metadata.thrift	20
stream/distributedlog/io/dlfs/src/main/java/org/apache/distributedlog/fs/DLFileSystem.java	262
stream/distributedlog/io/dlfs/src/main/java/org/apache/distributedlog/fs/DLInputStream.java	178
stream/distributedlog/io/dlfs/src/main/java/org/apache/distributedlog/fs/DLOutputStream.java	101
stream/distributedlog/io/dlfs/src/main/java/org/apache/distributedlog/fs/package-info.java	1
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/DLSN.java	131
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/EnvelopedRecordSetReader.java	90
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/EnvelopedRecordSetWriter.java	126
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/LogRecord.java	322
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/LogRecordSet.java	62
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/LogRecordSetBuffer.java	9
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/LogRecordWithDLSN.java	44
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/RecordStream.java	6
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/TransmitListener.java	6
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/AlreadyClosedException.java	7
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/AlreadyTruncatedTransactionException.java	7
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/BKTransmitException.java	12
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/ChecksumFailedException.java	7
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/DLClientClosedException.java	10
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/DLException.java	25
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/DLIllegalStateException.java	10
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/DLInterruptedException.java	10
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/EndOfLogSegmentException.java	7
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/EndOfStreamException.java	7
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/FlushException.java	22
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/IdleReaderException.java	8
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/InternalServerException.java	13
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/InvalidEnvelopedEntryException.java	7
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/InvalidStreamNameException.java	10
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/LockCancelledException.java	7
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/LockingException.java	16
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/LogEmptyException.java	7
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/LogExistsException.java	7
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/LogNotFoundException.java	7
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/LogReadException.java	7
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/LogRecordTooLongException.java	7
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/LogSegmentIsTruncatedException.java	8
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/LogSegmentNotFoundException.java	7
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/MetadataException.java	10
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/NotYetImplementedException.java	7
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/OverCapacityException.java	10
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/OwnershipAcquireFailedException.java	13
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/ReadCancelledException.java	8
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/RegionUnavailableException.java	7
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/RequestDeniedException.java	8
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/RetryableReadException.java	10
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/ServiceUnavailableException.java	7
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/StatusCode.java	43
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/StreamNotReadyException.java	7
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/StreamUnavailableException.java	7
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/TooManyStreamsException.java	7
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/TransactionIdOutOfOrderException.java	19
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/UnexpectedException.java	13
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/UnsupportedMetadataVersionException.java	7
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/WriteCancelledException.java	18
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/WriteException.java	12
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/exceptions/package-info.java	1
stream/distributedlog/protocol/src/main/java/org/apache/distributedlog/package-info.java	1
stream/proto/src/main/java/org/apache/bookkeeper/stream/protocol/ProtocolConstants.java	78
stream/proto/src/main/java/org/apache/bookkeeper/stream/protocol/RangeId.java	31
stream/proto/src/main/java/org/apache/bookkeeper/stream/protocol/package-info.java	1
stream/proto/src/main/java/org/apache/bookkeeper/stream/protocol/util/ProtoUtils.java	194
stream/proto/src/main/java/org/apache/bookkeeper/stream/protocol/util/StorageContainerPlacementPolicy.java	9
stream/proto/src/main/java/org/apache/bookkeeper/stream/protocol/util/package-info.java	1
stream/proto/src/main/proto/cluster.proto	31
stream/proto/src/main/proto/common.proto	25
stream/proto/src/main/proto/kv.proto	57
stream/proto/src/main/proto/kv_rpc.proto	271
stream/proto/src/main/proto/kv_store.proto	62
stream/proto/src/main/proto/storage.proto	183
stream/proto/src/main/proto/stream.proto	178
stream/server/src/main/java/org/apache/bookkeeper/stream/cluster/StandaloneStarter.java	138
stream/server/src/main/java/org/apache/bookkeeper/stream/cluster/StreamCluster.java	246
stream/server/src/main/java/org/apache/bookkeeper/stream/cluster/StreamClusterSpec.java	30
stream/server/src/main/java/org/apache/bookkeeper/stream/cluster/package-info.java	1
stream/server/src/main/java/org/apache/bookkeeper/stream/server/ExitCode.java	14
stream/server/src/main/java/org/apache/bookkeeper/stream/server/StorageServer.java	343
stream/server/src/main/java/org/apache/bookkeeper/stream/server/StreamStorageLifecycleComponent.java	32
stream/server/src/main/java/org/apache/bookkeeper/stream/server/conf/BookieConfiguration.java	11
stream/server/src/main/java/org/apache/bookkeeper/stream/server/conf/DLConfiguration.java	12
stream/server/src/main/java/org/apache/bookkeeper/stream/server/conf/StorageServerConfiguration.java	20
stream/server/src/main/java/org/apache/bookkeeper/stream/server/conf/package-info.java	1
stream/server/src/main/java/org/apache/bookkeeper/stream/server/exceptions/StorageServerRuntimeException.java	14
stream/server/src/main/java/org/apache/bookkeeper/stream/server/exceptions/package-info.java	1
stream/server/src/main/java/org/apache/bookkeeper/stream/server/grpc/GrpcServer.java	98
stream/server/src/main/java/org/apache/bookkeeper/stream/server/grpc/GrpcServerSpec.java	23
stream/server/src/main/java/org/apache/bookkeeper/stream/server/grpc/GrpcStorageContainerService.java	45
stream/server/src/main/java/org/apache/bookkeeper/stream/server/grpc/package-info.java	1
stream/server/src/main/java/org/apache/bookkeeper/stream/server/package-info.java	1
stream/server/src/main/java/org/apache/bookkeeper/stream/server/service/BookieService.java	156
stream/server/src/main/java/org/apache/bookkeeper/stream/server/service/BookieWatchService.java	64
stream/server/src/main/java/org/apache/bookkeeper/stream/server/service/ClusterControllerService.java	37
stream/server/src/main/java/org/apache/bookkeeper/stream/server/service/CuratorProviderService.java	49
stream/server/src/main/java/org/apache/bookkeeper/stream/server/service/DLNamespaceProviderService.java	105
stream/server/src/main/java/org/apache/bookkeeper/stream/server/service/GrpcService.java	34
stream/server/src/main/java/org/apache/bookkeeper/stream/server/service/RegistrationServiceProvider.java	99
stream/server/src/main/java/org/apache/bookkeeper/stream/server/service/RegistrationStateService.java	84
stream/server/src/main/java/org/apache/bookkeeper/stream/server/service/StatsProviderService.java	32
stream/server/src/main/java/org/apache/bookkeeper/stream/server/service/StorageService.java	41
stream/server/src/main/java/org/apache/bookkeeper/stream/server/service/package-info.java	1
stream/src/main/resources/distributedlog/findbugsExclude.xml	152
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/StateStores.java	31
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/AsyncStateStore.java	20
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/StateStore.java	16
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/StateStoreBuilder.java	4
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/StateStoreSpec.java	39
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/checkpoint/CheckpointStore.java	18
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/checkpoint/package-info.java	1
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/exceptions/InvalidStateStoreException.java	13
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/exceptions/MVCCStoreException.java	21
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/exceptions/StateStoreClosedException.java	7
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/exceptions/StateStoreException.java	13
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/exceptions/StateStoreRuntimeException.java	13
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/exceptions/package-info.java	1
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/kv/KVAsyncReadOnlyStore.java	4
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/kv/KVAsyncStore.java	4
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/kv/KVAsyncStoreReadView.java	5
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/kv/KVAsyncStoreWriteView.java	7
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/kv/KVIterator.java	11
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/kv/KVMulti.java	11
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/kv/KVStore.java	8
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/kv/KVStoreReadView.java	9
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/kv/KVStoreWriteView.java	11
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/kv/package-info.java	1
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/mvcc/MVCCAsyncStore.java	443
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/mvcc/MVCCAsyncStoreReadView.java	16
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/mvcc/MVCCAsyncStoreWriteView.java	34
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/mvcc/MVCCStore.java	10
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/mvcc/MVCCStoreReadView.java	10
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/mvcc/MVCCStoreWriteView.java	15
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/mvcc/package-info.java	1
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/package-info.java	1
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/Bytes.java	39
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/Constants.java	17
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/journal/AbstractStateStoreWithJournal.java	467
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/journal/CommandProcessor.java	5
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/journal/package-info.java	1
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/kv/KVCommandProcessor.java	66
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/kv/KVUtils.java	75
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/kv/RocksdbKVAsyncStore.java	132
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/kv/RocksdbKVStore.java	601
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/kv/package-info.java	1
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/MVCCAsyncBytesStoreImpl.java	112
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/MVCCCommandProcessor.java	133
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/MVCCRecord.java	110
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/MVCCRecordCoder.java	94
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/MVCCStoreImpl.java	908
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/MVCCStores.java	15
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/MVCCUtils.java	272
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/op/proto/ProtoCompareImpl.java	101
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/op/proto/ProtoDeleteOpImpl.java	79
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/op/proto/ProtoIncrementOpImpl.java	62
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/op/proto/ProtoPutOpImpl.java	81
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/op/proto/ProtoRangeOpImpl.java	103
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/op/proto/ProtoTxnOpImpl.java	92
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/op/proto/package-info.java	1
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/package-info.java	1
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/package-info.java	1
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/rocksdb/RocksConstants.java	19
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/rocksdb/RocksUtils.java	51
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/rocksdb/checkpoint/CheckpointFile.java	201
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/rocksdb/checkpoint/CheckpointInfo.java	114
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/rocksdb/checkpoint/RocksCheckpointer.java	130
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/rocksdb/checkpoint/RocksdbCheckpointTask.java	171
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/rocksdb/checkpoint/RocksdbRestoreTask.java	61
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/rocksdb/checkpoint/dlog/DLCheckpointStore.java	129
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/rocksdb/checkpoint/dlog/DLInputStream.java	168
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/rocksdb/checkpoint/dlog/DLOutputStream.java	101
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/rocksdb/checkpoint/dlog/package-info.java	1
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/rocksdb/checkpoint/fs/FSCheckpointManager.java	74
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/rocksdb/checkpoint/fs/package-info.java	1
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/rocksdb/checkpoint/package-info.java	1
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/rocksdb/package-info.java	1
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/package-info.java	1
stream/statelib/src/main/proto/kv.proto	51
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/StorageContainerStore.java	9
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/cluster/ClusterController.java	5
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/cluster/ClusterControllerLeader.java	6
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/cluster/ClusterControllerLeaderSelector.java	7
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/cluster/ClusterInitializer.java	6
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/cluster/ClusterMetadataStore.java	20
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/cluster/package-info.java	1
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/kv/TableStore.java	19
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/kv/package-info.java	1
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/metadata/MetaRangeStore.java	7
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/metadata/RangeStoreService.java	10
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/metadata/RootRangeStore.java	22
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/metadata/package-info.java	1
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/metadata/stream/MetaRange.java	17
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/metadata/stream/package-info.java	1
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/package-info.java	1
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/sc/StorageContainer.java	11
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/sc/StorageContainerFactory.java	5
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/sc/StorageContainerManager.java	5
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/sc/StorageContainerManagerFactory.java	6
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/sc/StorageContainerRegistry.java	14
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/sc/StorageContainerRoutingService.java	5
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/sc/StorageContainerService.java	9
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/sc/StorageContainerServiceFactory.java	6
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/sc/package-info.java	1
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/service/RangeStoreServiceFactory.java	7
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/service/package-info.java	1
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/conf/StorageConfiguration.java	64
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/conf/package-info.java	1
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/exceptions/DataRangeNotFoundException.java	7
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/exceptions/StorageContainerNotFoundException.java	7
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/exceptions/StorageException.java	10
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/exceptions/StorageRuntimeException.java	13
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/exceptions/package-info.java	1
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/package-info.java	1
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/StorageConstants.java	33
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/StorageContainerStoreBuilder.java	91
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/StorageResources.java	77
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/StorageResourcesSpec.java	20
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/AsyncOperationProcessor.java	41
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/StorageContainerStoreImpl.java	132
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/cluster/ClusterControllerImpl.java	33
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/cluster/ClusterControllerLeaderImpl.java	138
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/cluster/InMemClusterMetadataStore.java	68
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/cluster/ZkClusterControllerLeaderSelector.java	65
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/cluster/ZkClusterControllerLeaderSelectorListener.java	21
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/cluster/ZkClusterInitializer.java	61
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/cluster/ZkClusterMetadataStore.java	174
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/cluster/package-info.java	1
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/grpc/GrpcMetaRangeService.java	30
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/grpc/GrpcRootRangeService.java	102
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/grpc/GrpcServices.java	14
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/grpc/GrpcTableService.java	106
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/grpc/handler/ResponseHandler.java	26
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/grpc/handler/package-info.java	1
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/grpc/package-info.java	1
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/kv/TableStoreCache.java	69
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/kv/TableStoreFactory.java	6
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/kv/TableStoreImpl.java	278
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/kv/TableStoreUtils.java	253
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/kv/package-info.java	1
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/metadata/CreateNamespaceProcessor.java	31
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/metadata/DeleteNamespaceProcessor.java	31
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/metadata/MetaRangeStoreFactory.java	7
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/metadata/MetaRangeStoreImpl.java	100
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/metadata/RootRangeStoreFactory.java	7
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/metadata/RootRangeStoreImpl.java	576
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/metadata/package-info.java	1
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/metadata/stream/MetaRangeImpl.java	384
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/metadata/stream/package-info.java	1
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/package-info.java	1
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/routing/RangeRoutingTable.java	5
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/routing/RangeRoutingTableImpl.java	65
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/routing/RoutingHeaderProxyInterceptor.java	222
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/routing/StorageContainerProxyChannelManager.java	5
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/routing/StorageContainerProxyChannelManagerImpl.java	27
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/routing/package-info.java	1
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/sc/Channel404.java	43
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/sc/DefaultStorageContainerController.java	156
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/sc/DefaultStorageContainerFactory.java	15
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/sc/LocalStorageContainerManager.java	52
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/sc/StorageContainer404.java	31
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/sc/StorageContainerController.java	10
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/sc/StorageContainerImpl.java	87
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/sc/StorageContainerPlacementPolicyImpl.java	21
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/sc/StorageContainerRegistryImpl.java	126
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/sc/ZkStorageContainerManager.java	265
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/sc/package-info.java	1
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/service/FailRequestRangeStoreService.java	102
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/service/RangeStoreContainerServiceFactoryImpl.java	19
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/service/RangeStoreContainerServiceImpl.java	27
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/service/RangeStoreServiceFactoryImpl.java	43
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/service/RangeStoreServiceImpl.java	267
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/service/package-info.java	1
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/store/MVCCStoreFactory.java	9
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/store/MVCCStoreFactoryImpl.java	239
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/store/package-info.java	1
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/package-info.java	1
stream/tests-common/src/main/proto/proto2_coder_test_messages.proto	43
stream/tests-common/src/main/proto/rpc.proto	36
testtools/src/main/resources/log4j2.xml	14
tools/framework/src/main/java/org/apache/bookkeeper/tools/common/BKCommand.java	69
tools/framework/src/main/java/org/apache/bookkeeper/tools/common/BKCommandCategories.java	6
tools/framework/src/main/java/org/apache/bookkeeper/tools/common/BKFlags.java	25
tools/framework/src/main/java/org/apache/bookkeeper/tools/common/package-info.java	1
tools/framework/src/main/java/org/apache/bookkeeper/tools/framework/Cli.java	184
tools/framework/src/main/java/org/apache/bookkeeper/tools/framework/CliCommand.java	46
tools/framework/src/main/java/org/apache/bookkeeper/tools/framework/CliCommandGroup.java	47
tools/framework/src/main/java/org/apache/bookkeeper/tools/framework/CliFlags.java	16
tools/framework/src/main/java/org/apache/bookkeeper/tools/framework/CliSpec.java	184
tools/framework/src/main/java/org/apache/bookkeeper/tools/framework/Command.java	17
tools/framework/src/main/java/org/apache/bookkeeper/tools/framework/CommandGroup.java	3
tools/framework/src/main/java/org/apache/bookkeeper/tools/framework/CommandUtils.java	185
tools/framework/src/main/java/org/apache/bookkeeper/tools/framework/HelpCommand.java	38
tools/framework/src/main/java/org/apache/bookkeeper/tools/framework/package-info.java	1
tools/ledger/src/main/java/org/apache/bookkeeper/tools/cli/BKCtl.java	31
tools/ledger/src/main/java/org/apache/bookkeeper/tools/cli/commands/AutoRecoveryCommandGroup.java	28
tools/ledger/src/main/java/org/apache/bookkeeper/tools/cli/commands/BookieCommandGroup.java	59
tools/ledger/src/main/java/org/apache/bookkeeper/tools/cli/commands/BookieIdCommandGroup.java	21
tools/ledger/src/main/java/org/apache/bookkeeper/tools/cli/commands/BookiesCommandGroup.java	35
tools/ledger/src/main/java/org/apache/bookkeeper/tools/cli/commands/CookieCommandGroup.java	29
tools/ledger/src/main/java/org/apache/bookkeeper/tools/cli/commands/HealthCheckCommandGroup.java	19
tools/ledger/src/main/java/org/apache/bookkeeper/tools/cli/commands/LedgerCommandGroup.java	25
tools/ledger/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookieid/SearchReplaceBookieIdCommand.java	95
tools/ledger/src/main/java/org/apache/bookkeeper/tools/cli/commands/bookieid/package-info.java	1
tools/ledger/src/main/java/org/apache/bookkeeper/tools/cli/commands/package-info.java	1
tools/ledger/src/main/java/org/apache/bookkeeper/tools/cli/package-info.java	1
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/BKPerf.java	24
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/DlogPerfCommandGroup.java	22
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/JournalPerfCommandGroup.java	18
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/PerfCommandGroup.java	6
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/TablePerfCommandGroup.java	18
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/dlog/PerfReader.java	86
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/dlog/PerfReaderBase.java	149
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/dlog/PerfSegmentReader.java	165
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/dlog/PerfWriter.java	343
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/dlog/ReadCommand.java	32
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/dlog/SegmentReadCommand.java	32
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/dlog/WriteCommand.java	32
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/dlog/package-info.java	1
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/journal/AppendCommand.java	28
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/journal/JournalWriter.java	433
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/journal/package-info.java	1
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/package-info.java	1
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/table/BenchmarkCommand.java	33
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/table/BenchmarkTask.java	44
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/table/IncrementRandomTask.java	23
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/table/IncrementSequentialTask.java	23
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/table/IncrementTask.java	74
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/table/KeyGenerator.java	34
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/table/PerfClient.java	308
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/table/WriteRandomTask.java	23
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/table/WriteSequentialTask.java	23
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/table/WriteTask.java	81
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/table/package-info.java	1
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/utils/PaddingDecimalFormat.java	51
tools/perf/src/main/java/org/apache/bookkeeper/tools/perf/utils/package-info.java	1
tools/stream/src/main/java/org/apache/bookkeeper/stream/cli/ClusterCommandGroup.java	20
tools/stream/src/main/java/org/apache/bookkeeper/stream/cli/Commands.java	12
tools/stream/src/main/java/org/apache/bookkeeper/stream/cli/NamespaceCommandGroup.java	24
tools/stream/src/main/java/org/apache/bookkeeper/stream/cli/TableAdminCommandGroup.java	24
tools/stream/src/main/java/org/apache/bookkeeper/stream/cli/TableCommandGroup.java	26
tools/stream/src/main/java/org/apache/bookkeeper/stream/cli/commands/AbstractStreamCommand.java	33
tools/stream/src/main/java/org/apache/bookkeeper/stream/cli/commands/AdminCommand.java	39
tools/stream/src/main/java/org/apache/bookkeeper/stream/cli/commands/ClientCommand.java	41
tools/stream/src/main/java/org/apache/bookkeeper/stream/cli/commands/cluster/InitClusterCommand.java	201
tools/stream/src/main/java/org/apache/bookkeeper/stream/cli/commands/cluster/package-info.java	1
tools/stream/src/main/java/org/apache/bookkeeper/stream/cli/commands/namespace/CreateNamespaceCommand.java	48
tools/stream/src/main/java/org/apache/bookkeeper/stream/cli/commands/namespace/DeleteNamespaceCommand.java	40
tools/stream/src/main/java/org/apache/bookkeeper/stream/cli/commands/namespace/GetNamespaceCommand.java	42
tools/stream/src/main/java/org/apache/bookkeeper/stream/cli/commands/namespace/package-info.java	1
tools/stream/src/main/java/org/apache/bookkeeper/stream/cli/commands/package-info.java	1
tools/stream/src/main/java/org/apache/bookkeeper/stream/cli/commands/table/CreateTableCommand.java	67
tools/stream/src/main/java/org/apache/bookkeeper/stream/cli/commands/table/DelCommand.java	47
tools/stream/src/main/java/org/apache/bookkeeper/stream/cli/commands/table/DeleteTableCommand.java	46
tools/stream/src/main/java/org/apache/bookkeeper/stream/cli/commands/table/GetCommand.java	65
tools/stream/src/main/java/org/apache/bookkeeper/stream/cli/commands/table/GetTableCommand.java	53
tools/stream/src/main/java/org/apache/bookkeeper/stream/cli/commands/table/IncrementCommand.java	43
tools/stream/src/main/java/org/apache/bookkeeper/stream/cli/commands/table/PutCommand.java	43
tools/stream/src/main/java/org/apache/bookkeeper/stream/cli/commands/table/package-info.java	1
tools/stream/src/main/java/org/apache/bookkeeper/stream/cli/package-info.java	1