Path	Lines of Code
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