[bookkeeper] branch master updated (937de49 -> a7f3f20)

[sijie]

This is an automated email from the ASF dual-hosted git repository.

sijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/bookkeeper.git.


    from 937de49  Merge remote-tracking branch 'apache/master' into 
copy_distributedlog
     add d6f4aa0  remove "distributedlog_" from module names
     new a7f3f20  Merge branch 'master' into BP-26/distributedlog_merge

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 stream/distributedlog/{distributedlog-common => common}/pom.xml           | 0
 .../distributedlog/common/annotations/DistributedLogAnnotations.java      | 0
 .../java/org/apache/distributedlog/common/annotations/package-info.java   | 0
 .../java/org/apache/distributedlog/common/concurrent/AsyncSemaphore.java  | 0
 .../org/apache/distributedlog/common/concurrent/FutureEventListener.java  | 0
 .../java/org/apache/distributedlog/common/concurrent/FutureUtils.java     | 0
 .../java/org/apache/distributedlog/common/concurrent/package-info.java    | 0
 .../apache/distributedlog/common/config/ConcurrentBaseConfiguration.java  | 0
 .../apache/distributedlog/common/config/ConcurrentConstConfiguration.java | 0
 .../org/apache/distributedlog/common/config/ConfigurationListener.java    | 0
 .../apache/distributedlog/common/config/ConfigurationSubscription.java    | 0
 .../org/apache/distributedlog/common/config/FileConfigurationBuilder.java | 0
 .../distributedlog/common/config/PropertiesConfigurationBuilder.java      | 0
 .../main/java/org/apache/distributedlog/common/config/package-info.java   | 0
 .../java/org/apache/distributedlog/common/functions/VoidFunctions.java    | 0
 .../java/org/apache/distributedlog/common/functions/package-info.java     | 0
 .../src/main/java/org/apache/distributedlog/common/package-info.java      | 0
 .../java/org/apache/distributedlog/common/rate/MovingAverageRate.java     | 0
 .../org/apache/distributedlog/common/rate/MovingAverageRateFactory.java   | 0
 .../org/apache/distributedlog/common/rate/SampledMovingAverageRate.java   | 0
 .../src/main/java/org/apache/distributedlog/common/rate/package-info.java | 0
 .../java/org/apache/distributedlog/common/stats/BroadCastStatsLogger.java | 0
 .../main/java/org/apache/distributedlog/common/stats/OpStatsListener.java | 0
 .../main/java/org/apache/distributedlog/common/stats/package-info.java    | 0
 .../src/main/java/org/apache/distributedlog/common/util/BitMaskUtils.java | 0
 .../src/main/java/org/apache/distributedlog/common/util/ByteBufUtils.java | 0
 .../src/main/java/org/apache/distributedlog/common/util/MathUtil.java     | 0
 .../src/main/java/org/apache/distributedlog/common/util/Permit.java       | 0
 .../main/java/org/apache/distributedlog/common/util/PermitLimiter.java    | 0
 .../main/java/org/apache/distributedlog/common/util/PermitManager.java    | 0
 .../main/java/org/apache/distributedlog/common/util/ReferenceCounted.java | 0
 .../main/java/org/apache/distributedlog/common/util/SchedulerUtils.java   | 0
 .../src/main/java/org/apache/distributedlog/common/util/Sequencer.java    | 0
 .../src/main/java/org/apache/distributedlog/common/util/Sizable.java      | 0
 .../src/main/java/org/apache/distributedlog/common/util/package-info.java | 0
 .../src/main/java/org/apache/distributedlog/io/Abortable.java             | 0
 .../src/main/java/org/apache/distributedlog/io/Abortables.java            | 0
 .../src/main/java/org/apache/distributedlog/io/AsyncAbortable.java        | 0
 .../src/main/java/org/apache/distributedlog/io/AsyncCloseable.java        | 0
 .../src/main/java/org/apache/distributedlog/io/AsyncDeleteable.java       | 0
 .../src/main/java/org/apache/distributedlog/io/CompressionCodec.java      | 0
 .../src/main/java/org/apache/distributedlog/io/CompressionUtils.java      | 0
 .../main/java/org/apache/distributedlog/io/IdentityCompressionCodec.java  | 0
 .../src/main/java/org/apache/distributedlog/io/LZ4CompressionCodec.java   | 0
 .../src/main/java/org/apache/distributedlog/io/package-info.java          | 0
 .../src/main/java/org/apache/distributedlog/util/OrderedScheduler.java    | 0
 .../src/main/java/org/apache/distributedlog/util/package-info.java        | 0
 .../java/org/apache/distributedlog/common/concurrent/TestFutureUtils.java | 0
 .../java/org/apache/distributedlog/common/config/PropertiesWriter.java    | 0
 .../distributedlog/common/config/TestConcurrentBaseConfiguration.java     | 0
 .../distributedlog/common/config/TestConfigurationSubscription.java       | 0
 .../org/apache/distributedlog/common/util/TestTimedOutTestsListener.java  | 0
 .../java/org/apache/distributedlog/common/util/TimedOutTestsListener.java | 0
 .../src/test/java/org/apache/distributedlog/io/TestCompressionCodec.java  | 0
 stream/distributedlog/{distributedlog-core => core}/bin/common.sh         | 0
 stream/distributedlog/{distributedlog-core => core}/bin/dlog              | 0
 .../{distributedlog-core => core}/conf/bookie.conf.template               | 0
 .../distributedlog/{distributedlog-core => core}/conf/distributedlog.conf | 0
 stream/distributedlog/{distributedlog-core => core}/conf/dlogenv.sh       | 0
 stream/distributedlog/{distributedlog-core => core}/conf/log4j.properties | 0
 stream/distributedlog/{distributedlog-core => core}/conf/write_proxy.conf | 0
 .../{distributedlog-core => core}/conf/zookeeper.conf.dynamic.template    | 0
 .../{distributedlog-core => core}/conf/zookeeper.conf.template            | 0
 stream/distributedlog/{distributedlog-core => core}/pom.xml               | 0
 .../src/main/java/org/apache/bookkeeper/client/BookKeeperAccessor.java    | 0
 .../src/main/java/org/apache/bookkeeper/client/LedgerReader.java          | 0
 .../src/main/java/org/apache/bookkeeper/client/package-info.java          | 0
 .../src/main/java/org/apache/distributedlog/AppendOnlyStreamReader.java   | 0
 .../src/main/java/org/apache/distributedlog/AppendOnlyStreamWriter.java   | 0
 .../src/main/java/org/apache/distributedlog/AsyncNotification.java        | 0
 .../src/main/java/org/apache/distributedlog/BKAbstractLogWriter.java      | 0
 .../src/main/java/org/apache/distributedlog/BKAsyncLogReader.java         | 0
 .../src/main/java/org/apache/distributedlog/BKAsyncLogWriter.java         | 0
 .../src/main/java/org/apache/distributedlog/BKDistributedLogManager.java  | 0
 .../main/java/org/apache/distributedlog/BKDistributedLogNamespace.java    | 0
 .../src/main/java/org/apache/distributedlog/BKLogHandler.java             | 0
 .../src/main/java/org/apache/distributedlog/BKLogReadHandler.java         | 0
 .../src/main/java/org/apache/distributedlog/BKLogSegmentWriter.java       | 0
 .../src/main/java/org/apache/distributedlog/BKLogWriteHandler.java        | 0
 .../src/main/java/org/apache/distributedlog/BKSyncLogReader.java          | 0
 .../src/main/java/org/apache/distributedlog/BKSyncLogWriter.java          | 0
 .../src/main/java/org/apache/distributedlog/BKTransmitPacket.java         | 0
 .../src/main/java/org/apache/distributedlog/BookKeeperClient.java         | 0
 .../src/main/java/org/apache/distributedlog/BookKeeperClientBuilder.java  | 0
 .../main/java/org/apache/distributedlog/DistributedLogConfiguration.java  | 0
 .../src/main/java/org/apache/distributedlog/DistributedLogConstants.java  | 0
 .../src/main/java/org/apache/distributedlog/Entry.java                    | 0
 .../src/main/java/org/apache/distributedlog/EntryBuffer.java              | 0
 .../src/main/java/org/apache/distributedlog/EntryPosition.java            | 0
 .../src/main/java/org/apache/distributedlog/EnvelopedEntry.java           | 0
 .../src/main/java/org/apache/distributedlog/EnvelopedEntryReader.java     | 0
 .../src/main/java/org/apache/distributedlog/EnvelopedEntryWriter.java     | 0
 .../src/main/java/org/apache/distributedlog/LocalDLMEmulator.java         | 0
 .../src/main/java/org/apache/distributedlog/LogSegmentMetadata.java       | 0
 .../src/main/java/org/apache/distributedlog/MaxLogSegmentSequenceNo.java  | 0
 .../src/main/java/org/apache/distributedlog/MaxTxId.java                  | 0
 .../src/main/java/org/apache/distributedlog/ReadAheadEntryReader.java     | 0
 .../src/main/java/org/apache/distributedlog/ReadUtils.java                | 0
 .../src/main/java/org/apache/distributedlog/WriteLimiter.java             | 0
 .../src/main/java/org/apache/distributedlog/ZooKeeperClient.java          | 0
 .../src/main/java/org/apache/distributedlog/ZooKeeperClientBuilder.java   | 0
 .../src/main/java/org/apache/distributedlog/acl/AccessControlManager.java | 0
 .../java/org/apache/distributedlog/acl/DefaultAccessControlManager.java   | 0
 .../src/main/java/org/apache/distributedlog/acl/package-info.java         | 0
 .../main/java/org/apache/distributedlog/admin/DistributedLogAdmin.java    | 0
 .../src/main/java/org/apache/distributedlog/admin/package-info.java       | 0
 .../src/main/java/org/apache/distributedlog/api/AsyncLogReader.java       | 0
 .../src/main/java/org/apache/distributedlog/api/AsyncLogWriter.java       | 0
 .../main/java/org/apache/distributedlog/api/DistributedLogManager.java    | 0
 .../src/main/java/org/apache/distributedlog/api/LogReader.java            | 0
 .../src/main/java/org/apache/distributedlog/api/LogWriter.java            | 0
 .../src/main/java/org/apache/distributedlog/api/MetadataAccessor.java     | 0
 .../src/main/java/org/apache/distributedlog/api/namespace/Namespace.java  | 0
 .../java/org/apache/distributedlog/api/namespace/NamespaceBuilder.java    | 0
 .../main/java/org/apache/distributedlog/api/namespace/package-info.java   | 0
 .../src/main/java/org/apache/distributedlog/api/package-info.java         | 0
 .../apache/distributedlog/api/subscription/SubscriptionStateStore.java    | 0
 .../org/apache/distributedlog/api/subscription/SubscriptionsStore.java    | 0
 .../java/org/apache/distributedlog/api/subscription/package-info.java     | 0
 .../src/main/java/org/apache/distributedlog/auditor/DLAuditor.java        | 0
 .../src/main/java/org/apache/distributedlog/auditor/package-info.java     | 0
 .../java/org/apache/distributedlog/bk/DynamicQuorumConfigProvider.java    | 0
 .../java/org/apache/distributedlog/bk/ImmutableQuorumConfigProvider.java  | 0
 .../src/main/java/org/apache/distributedlog/bk/LedgerAllocator.java       | 0
 .../main/java/org/apache/distributedlog/bk/LedgerAllocatorDelegator.java  | 0
 .../src/main/java/org/apache/distributedlog/bk/LedgerAllocatorPool.java   | 0
 .../src/main/java/org/apache/distributedlog/bk/LedgerAllocatorUtils.java  | 0
 .../src/main/java/org/apache/distributedlog/bk/QuorumConfig.java          | 0
 .../src/main/java/org/apache/distributedlog/bk/QuorumConfigProvider.java  | 0
 .../src/main/java/org/apache/distributedlog/bk/SimpleLedgerAllocator.java | 0
 .../src/main/java/org/apache/distributedlog/bk/package-info.java          | 0
 .../main/java/org/apache/distributedlog/callback/LogSegmentListener.java  | 0
 .../java/org/apache/distributedlog/callback/LogSegmentNamesListener.java  | 0
 .../main/java/org/apache/distributedlog/callback/NamespaceListener.java   | 0
 .../src/main/java/org/apache/distributedlog/callback/package-info.java    | 0
 .../org/apache/distributedlog/config/DynamicConfigurationFactory.java     | 0
 .../apache/distributedlog/config/DynamicDistributedLogConfiguration.java  | 0
 .../src/main/java/org/apache/distributedlog/config/package-info.java      | 0
 .../src/main/java/org/apache/distributedlog/exceptions/ZKException.java   | 0
 .../src/main/java/org/apache/distributedlog/exceptions/package-info.java  | 0
 .../java/org/apache/distributedlog/feature/AbstractFeatureProvider.java   | 0
 .../org/apache/distributedlog/feature/ConfigurationFeatureProvider.java   | 0
 .../src/main/java/org/apache/distributedlog/feature/CoreFeatureKeys.java  | 0
 .../java/org/apache/distributedlog/feature/DefaultFeatureProvider.java    | 0
 .../distributedlog/feature/DynamicConfigurationFeatureProvider.java       | 0
 .../src/main/java/org/apache/distributedlog/feature/package-info.java     | 0
 .../main/java/org/apache/distributedlog/function/GetLastTxIdFunction.java | 0
 .../src/main/java/org/apache/distributedlog/function/package-info.java    | 0
 .../src/main/java/org/apache/distributedlog/impl/BKNamespaceDriver.java   | 0
 .../src/main/java/org/apache/distributedlog/impl/ZKLogMetadataStore.java  | 0
 .../src/main/java/org/apache/distributedlog/impl/ZKLogSegmentFilters.java | 0
 .../java/org/apache/distributedlog/impl/ZKLogSegmentMetadataStore.java    | 0
 .../src/main/java/org/apache/distributedlog/impl/ZKMetadataAccessor.java  | 0
 .../src/main/java/org/apache/distributedlog/impl/ZKNamespaceWatcher.java  | 0
 .../src/main/java/org/apache/distributedlog/impl/acl/ZKAccessControl.java | 0
 .../java/org/apache/distributedlog/impl/acl/ZKAccessControlManager.java   | 0
 .../src/main/java/org/apache/distributedlog/impl/acl/package-info.java    | 0
 .../apache/distributedlog/impl/federated/FederatedZKLogMetadataStore.java | 0
 .../main/java/org/apache/distributedlog/impl/federated/package-info.java  | 0
 .../org/apache/distributedlog/impl/logsegment/BKLogSegmentAllocator.java  | 0
 .../apache/distributedlog/impl/logsegment/BKLogSegmentEntryReader.java    | 0
 .../org/apache/distributedlog/impl/logsegment/BKLogSegmentEntryStore.java | 0
 .../apache/distributedlog/impl/logsegment/BKLogSegmentEntryWriter.java    | 0
 .../impl/logsegment/BKLogSegmentRandomAccessEntryReader.java              | 0
 .../src/main/java/org/apache/distributedlog/impl/logsegment/BKUtils.java  | 0
 .../main/java/org/apache/distributedlog/impl/logsegment/package-info.java | 0
 .../src/main/java/org/apache/distributedlog/impl/metadata/BKDLConfig.java | 0
 .../org/apache/distributedlog/impl/metadata/ZKLogStreamMetadataStore.java | 0
 .../java/org/apache/distributedlog/impl/metadata/ZkMetadataResolver.java  | 0
 .../main/java/org/apache/distributedlog/impl/metadata/package-info.java   | 0
 .../src/main/java/org/apache/distributedlog/impl/package-info.java        | 0
 .../apache/distributedlog/impl/subscription/ZKSubscriptionStateStore.java | 0
 .../org/apache/distributedlog/impl/subscription/ZKSubscriptionsStore.java | 0
 .../java/org/apache/distributedlog/impl/subscription/package-info.java    | 0
 .../java/org/apache/distributedlog/injector/AsyncFailureInjector.java     | 0
 .../org/apache/distributedlog/injector/AsyncRandomFailureInjector.java    | 0
 .../src/main/java/org/apache/distributedlog/injector/FailureInjector.java | 0
 .../org/apache/distributedlog/injector/RandomDelayFailureInjector.java    | 0
 .../src/main/java/org/apache/distributedlog/injector/package-info.java    | 0
 .../java/org/apache/distributedlog/limiter/ChainedRequestLimiter.java     | 0
 .../java/org/apache/distributedlog/limiter/ComposableRequestLimiter.java  | 0
 .../src/main/java/org/apache/distributedlog/limiter/GuavaRateLimiter.java | 0
 .../src/main/java/org/apache/distributedlog/limiter/RateLimiter.java      | 0
 .../src/main/java/org/apache/distributedlog/limiter/RequestLimiter.java   | 0
 .../src/main/java/org/apache/distributedlog/limiter/package-info.java     | 0
 .../src/main/java/org/apache/distributedlog/lock/DistributedLock.java     | 0
 .../main/java/org/apache/distributedlog/lock/DistributedLockContext.java  | 0
 .../main/java/org/apache/distributedlog/lock/EpochChangedException.java   | 0
 .../src/main/java/org/apache/distributedlog/lock/LockAction.java          | 0
 .../src/main/java/org/apache/distributedlog/lock/LockClosedException.java | 0
 .../src/main/java/org/apache/distributedlog/lock/LockListener.java        | 0
 .../java/org/apache/distributedlog/lock/LockSessionExpiredException.java  | 0
 .../java/org/apache/distributedlog/lock/LockStateChangedException.java    | 0
 .../main/java/org/apache/distributedlog/lock/LockTimeoutException.java    | 0
 .../src/main/java/org/apache/distributedlog/lock/LockWaiter.java          | 0
 .../src/main/java/org/apache/distributedlog/lock/NopDistributedLock.java  | 0
 .../src/main/java/org/apache/distributedlog/lock/SessionLock.java         | 0
 .../src/main/java/org/apache/distributedlog/lock/SessionLockFactory.java  | 0
 .../src/main/java/org/apache/distributedlog/lock/ZKDistributedLock.java   | 0
 .../src/main/java/org/apache/distributedlog/lock/ZKSessionLock.java       | 0
 .../main/java/org/apache/distributedlog/lock/ZKSessionLockFactory.java    | 0
 .../src/main/java/org/apache/distributedlog/lock/package-info.java        | 0
 .../java/org/apache/distributedlog/logsegment/LogSegmentEntryReader.java  | 0
 .../java/org/apache/distributedlog/logsegment/LogSegmentEntryStore.java   | 0
 .../java/org/apache/distributedlog/logsegment/LogSegmentEntryWriter.java  | 0
 .../main/java/org/apache/distributedlog/logsegment/LogSegmentFilter.java  | 0
 .../org/apache/distributedlog/logsegment/LogSegmentMetadataCache.java     | 0
 .../org/apache/distributedlog/logsegment/LogSegmentMetadataStore.java     | 0
 .../distributedlog/logsegment/LogSegmentRandomAccessEntryReader.java      | 0
 .../main/java/org/apache/distributedlog/logsegment/LogSegmentWriter.java  | 0
 .../org/apache/distributedlog/logsegment/PerStreamLogSegmentCache.java    | 0
 .../src/main/java/org/apache/distributedlog/logsegment/RollingPolicy.java | 0
 .../java/org/apache/distributedlog/logsegment/SizeBasedRollingPolicy.java | 0
 .../java/org/apache/distributedlog/logsegment/TimeBasedRollingPolicy.java | 0
 .../src/main/java/org/apache/distributedlog/logsegment/package-info.java  | 0
 .../src/main/java/org/apache/distributedlog/metadata/DLConfig.java        | 0
 .../src/main/java/org/apache/distributedlog/metadata/DLMetadata.java      | 0
 .../distributedlog/metadata/DryrunLogSegmentMetadataStoreUpdater.java     | 0
 .../src/main/java/org/apache/distributedlog/metadata/LogMetadata.java     | 0
 .../java/org/apache/distributedlog/metadata/LogMetadataForReader.java     | 0
 .../java/org/apache/distributedlog/metadata/LogMetadataForWriter.java     | 0
 .../main/java/org/apache/distributedlog/metadata/LogMetadataStore.java    | 0
 .../apache/distributedlog/metadata/LogSegmentMetadataStoreUpdater.java    | 0
 .../java/org/apache/distributedlog/metadata/LogStreamMetadataStore.java   | 0
 .../main/java/org/apache/distributedlog/metadata/MetadataResolver.java    | 0
 .../src/main/java/org/apache/distributedlog/metadata/MetadataUpdater.java | 0
 .../src/main/java/org/apache/distributedlog/metadata/package-info.java    | 0
 .../main/java/org/apache/distributedlog/namespace/NamespaceDriver.java    | 0
 .../java/org/apache/distributedlog/namespace/NamespaceDriverManager.java  | 0
 .../main/java/org/apache/distributedlog/namespace/NamespaceWatcher.java   | 0
 .../src/main/java/org/apache/distributedlog/namespace/package-info.java   | 0
 .../src/main/java/org/apache/distributedlog/net/DNSResolver.java          | 0
 .../src/main/java/org/apache/distributedlog/net/DNSResolverForRacks.java  | 0
 .../src/main/java/org/apache/distributedlog/net/DNSResolverForRows.java   | 0
 .../src/main/java/org/apache/distributedlog/net/NetUtils.java             | 0
 .../src/main/java/org/apache/distributedlog/net/package-info.java         | 0
 .../src/main/java/org/apache/distributedlog/package-info.java             | 0
 .../org/apache/distributedlog/selector/FirstDLSNNotLessThanSelector.java  | 0
 .../main/java/org/apache/distributedlog/selector/FirstRecordSelector.java | 0
 .../org/apache/distributedlog/selector/FirstTxIdNotLessThanSelector.java  | 0
 .../main/java/org/apache/distributedlog/selector/LastRecordSelector.java  | 0
 .../main/java/org/apache/distributedlog/selector/LogRecordSelector.java   | 0
 .../src/main/java/org/apache/distributedlog/selector/package-info.java    | 0
 .../main/java/org/apache/distributedlog/thrift/AccessControlEntry.java    | 0
 .../src/main/java/org/apache/distributedlog/thrift/BKDLConfigFormat.java  | 0
 .../src/main/java/org/apache/distributedlog/thrift/package-info.java      | 0
 .../src/main/java/org/apache/distributedlog/tools/DistributedLogTool.java | 0
 .../src/main/java/org/apache/distributedlog/tools/Tool.java               | 0
 .../src/main/java/org/apache/distributedlog/tools/package-info.java       | 0
 .../src/main/java/org/apache/distributedlog/util/Allocator.java           | 0
 .../src/main/java/org/apache/distributedlog/util/CommandLineUtils.java    | 0
 .../src/main/java/org/apache/distributedlog/util/ConfUtils.java           | 0
 .../src/main/java/org/apache/distributedlog/util/DLUtils.java             | 0
 .../src/main/java/org/apache/distributedlog/util/FailpointUtils.java      | 0
 .../src/main/java/org/apache/distributedlog/util/RetryPolicyUtils.java    | 0
 .../src/main/java/org/apache/distributedlog/util/SimplePermitLimiter.java | 0
 .../src/main/java/org/apache/distributedlog/util/TimeSequencer.java       | 0
 .../src/main/java/org/apache/distributedlog/util/Transaction.java         | 0
 .../src/main/java/org/apache/distributedlog/util/Utils.java               | 0
 .../src/main/java/org/apache/distributedlog/util/package-info.java        | 0
 .../src/main/java/org/apache/distributedlog/zk/DefaultZKOp.java           | 0
 .../src/main/java/org/apache/distributedlog/zk/LimitedPermitManager.java  | 0
 .../src/main/java/org/apache/distributedlog/zk/ZKOp.java                  | 0
 .../src/main/java/org/apache/distributedlog/zk/ZKTransaction.java         | 0
 .../src/main/java/org/apache/distributedlog/zk/ZKVersionedSetOp.java      | 0
 .../src/main/java/org/apache/distributedlog/zk/ZKWatcherManager.java      | 0
 .../src/main/java/org/apache/distributedlog/zk/package-info.java          | 0
 .../{distributedlog-core => core}/src/main/resources/config/decider.conf  | 0
 .../{distributedlog-core => core}/src/main/resources/config/decider.yml   | 0
 .../{distributedlog-core => core}/src/main/thrift/metadata.thrift         | 0
 .../src/test/java/org/apache/distributedlog/DLMTestUtil.java              | 0
 .../src/test/java/org/apache/distributedlog/NonBlockingReadsTestUtil.java | 0
 .../test/java/org/apache/distributedlog/TestAppendOnlyStreamReader.java   | 0
 .../test/java/org/apache/distributedlog/TestAppendOnlyStreamWriter.java   | 0
 .../src/test/java/org/apache/distributedlog/TestAsyncBulkWrite.java       | 0
 .../src/test/java/org/apache/distributedlog/TestAsyncReaderLock.java      | 0
 .../src/test/java/org/apache/distributedlog/TestAsyncReaderWriter.java    | 0
 .../test/java/org/apache/distributedlog/TestBKDistributedLogManager.java  | 0
 .../java/org/apache/distributedlog/TestBKDistributedLogNamespace.java     | 0
 .../src/test/java/org/apache/distributedlog/TestBKLogReadHandler.java     | 0
 .../src/test/java/org/apache/distributedlog/TestBKLogSegmentWriter.java   | 0
 .../src/test/java/org/apache/distributedlog/TestBKLogWriteHandler.java    | 0
 .../src/test/java/org/apache/distributedlog/TestBKSyncLogReader.java      | 0
 .../src/test/java/org/apache/distributedlog/TestDLMTestUtil.java          | 0
 .../src/test/java/org/apache/distributedlog/TestDistributedLogBase.java   | 0
 .../java/org/apache/distributedlog/TestDistributedLogConfiguration.java   | 0
 .../src/test/java/org/apache/distributedlog/TestEntry.java                | 0
 .../src/test/java/org/apache/distributedlog/TestEntryPosition.java        | 0
 .../src/test/java/org/apache/distributedlog/TestInterleavedReaders.java   | 0
 .../src/test/java/org/apache/distributedlog/TestLogSegmentCreation.java   | 0
 .../src/test/java/org/apache/distributedlog/TestLogSegmentMetadata.java   | 0
 .../src/test/java/org/apache/distributedlog/TestLogSegmentsZK.java        | 0
 .../src/test/java/org/apache/distributedlog/TestNonBlockingReads.java     | 0
 .../java/org/apache/distributedlog/TestNonBlockingReadsMultiReader.java   | 0
 .../src/test/java/org/apache/distributedlog/TestReadAheadEntryReader.java | 0
 .../src/test/java/org/apache/distributedlog/TestReadUtils.java            | 0
 .../src/test/java/org/apache/distributedlog/TestReader.java               | 0
 .../src/test/java/org/apache/distributedlog/TestRollLogSegments.java      | 0
 .../src/test/java/org/apache/distributedlog/TestSequenceID.java           | 0
 .../src/test/java/org/apache/distributedlog/TestTruncate.java             | 0
 .../src/test/java/org/apache/distributedlog/TestWriteLimiter.java         | 0
 .../src/test/java/org/apache/distributedlog/TestZooKeeperClient.java      | 0
 .../test/java/org/apache/distributedlog/TestZooKeeperClientBuilder.java   | 0
 .../src/test/java/org/apache/distributedlog/ZooKeeperClientUtils.java     | 0
 .../src/test/java/org/apache/distributedlog/ZooKeeperClusterTestCase.java | 0
 .../src/test/java/org/apache/distributedlog/acl/TestZKAccessControl.java  | 0
 .../java/org/apache/distributedlog/acl/TestZKAccessControlManager.java    | 0
 .../src/test/java/org/apache/distributedlog/admin/TestDLCK.java           | 0
 .../java/org/apache/distributedlog/admin/TestDistributedLogAdmin.java     | 0
 .../src/test/java/org/apache/distributedlog/bk/TestLedgerAllocator.java   | 0
 .../test/java/org/apache/distributedlog/bk/TestLedgerAllocatorPool.java   | 0
 .../src/test/java/org/apache/distributedlog/config/PropertiesWriter.java  | 0
 .../org/apache/distributedlog/config/TestDynamicConfigurationFactory.java | 0
 .../distributedlog/config/TestDynamicDistributedLogConfiguration.java     | 0
 .../apache/distributedlog/feature/TestConfigurationFeatureProvider.java   | 0
 .../distributedlog/feature/TestDynamicConfigurationFeatureProvider.java   | 0
 .../test/java/org/apache/distributedlog/impl/TestZKLogMetadataStore.java  | 0
 .../test/java/org/apache/distributedlog/impl/TestZKLogSegmentFilters.java | 0
 .../org/apache/distributedlog/impl/TestZKLogSegmentMetadataStore.java     | 0
 .../test/java/org/apache/distributedlog/impl/TestZKNamespaceWatcher.java  | 0
 .../distributedlog/impl/federated/TestFederatedZKLogMetadataStore.java    | 0
 .../distributedlog/impl/logsegment/TestBKLogSegmentEntryReader.java       | 0
 .../apache/distributedlog/impl/metadata/TestZKLogStreamMetadataStore.java | 0
 .../distributedlog/impl/metadata/TestZKLogStreamMetadataStoreUtils.java   | 0
 .../org/apache/distributedlog/impl/metadata/TestZkMetadataResolver.java   | 0
 .../test/java/org/apache/distributedlog/limiter/TestRequestLimiter.java   | 0
 .../src/test/java/org/apache/distributedlog/lock/TestDistributedLock.java | 0
 .../src/test/java/org/apache/distributedlog/lock/TestZKSessionLock.java   | 0
 .../apache/distributedlog/logsegment/TestPerStreamLogSegmentCache.java    | 0
 .../test/java/org/apache/distributedlog/logsegment/TestRollingPolicy.java | 0
 .../src/test/java/org/apache/distributedlog/metadata/TestDLMetadata.java  | 0
 .../src/test/java/org/apache/distributedlog/metadata/TestLogMetadata.java | 0
 .../distributedlog/metadata/TestLogSegmentMetadataStoreUpdater.java       | 0
 .../java/org/apache/distributedlog/namespace/TestNamespaceBuilder.java    | 0
 .../src/test/java/org/apache/distributedlog/net/TestDNSResolver.java      | 0
 .../src/test/java/org/apache/distributedlog/net/TestNetUtils.java         | 0
 .../java/org/apache/distributedlog/selector/TestLogRecordSelectors.java   | 0
 .../test/java/org/apache/distributedlog/tools/TestDistributedLogTool.java | 0
 .../src/test/java/org/apache/distributedlog/util/TestConfUtils.java       | 0
 .../src/test/java/org/apache/distributedlog/util/TestDLUtils.java         | 0
 .../src/test/java/org/apache/distributedlog/util/TestPermitManager.java   | 0
 .../src/test/java/org/apache/distributedlog/util/TestTimeSequencer.java   | 0
 .../src/test/java/org/apache/distributedlog/util/TestUtils.java           | 0
 .../src/test/java/org/apache/distributedlog/zk/TestZKTransaction.java     | 0
 .../src/test/java/org/apache/distributedlog/zk/TestZKVersionedSetOp.java  | 0
 .../src/test/java/org/apache/distributedlog/zk/TestZKWatcherManager.java  | 0
 .../{distributedlog-core => core}/src/test/resources/bk_server.conf       | 0
 .../{distributedlog-protocol => core}/src/test/resources/log4j.properties | 0
 stream/distributedlog/{distributedlog-io => io}/dlfs/pom.xml              | 0
 .../dlfs/src/main/java/org/apache/distributedlog/fs/DLFileSystem.java     | 0
 .../dlfs/src/main/java/org/apache/distributedlog/fs/DLInputStream.java    | 0
 .../dlfs/src/main/java/org/apache/distributedlog/fs/DLOutputStream.java   | 0
 .../dlfs/src/main/java/org/apache/distributedlog/fs/package-info.java     | 0
 .../dlfs/src/test/java/org/apache/distributedlog/fs/TestDLFSBase.java     | 0
 .../dlfs/src/test/java/org/apache/distributedlog/fs/TestDLFileSystem.java | 0
 .../{distributedlog-io => io}/dlfs/src/test/resources/dlfs.conf           | 0
 stream/distributedlog/{distributedlog-io => io}/pom.xml                   | 0
 stream/distributedlog/{distributedlog-protocol => protocol}/pom.xml       | 0
 .../src/main/java/org/apache/distributedlog/DLSN.java                     | 0
 .../src/main/java/org/apache/distributedlog/EnvelopedRecordSetReader.java | 0
 .../src/main/java/org/apache/distributedlog/EnvelopedRecordSetWriter.java | 0
 .../src/main/java/org/apache/distributedlog/LogRecord.java                | 0
 .../src/main/java/org/apache/distributedlog/LogRecordSet.java             | 0
 .../src/main/java/org/apache/distributedlog/LogRecordSetBuffer.java       | 0
 .../src/main/java/org/apache/distributedlog/LogRecordWithDLSN.java        | 0
 .../src/main/java/org/apache/distributedlog/RecordStream.java             | 0
 .../src/main/java/org/apache/distributedlog/TransmitListener.java         | 0
 .../java/org/apache/distributedlog/exceptions/AlreadyClosedException.java | 0
 .../distributedlog/exceptions/AlreadyTruncatedTransactionException.java   | 0
 .../java/org/apache/distributedlog/exceptions/BKTransmitException.java    | 0
 .../org/apache/distributedlog/exceptions/ChecksumFailedException.java     | 0
 .../org/apache/distributedlog/exceptions/DLClientClosedException.java     | 0
 .../src/main/java/org/apache/distributedlog/exceptions/DLException.java   | 0
 .../org/apache/distributedlog/exceptions/DLIllegalStateException.java     | 0
 .../java/org/apache/distributedlog/exceptions/DLInterruptedException.java | 0
 .../org/apache/distributedlog/exceptions/EndOfLogSegmentException.java    | 0
 .../java/org/apache/distributedlog/exceptions/EndOfStreamException.java   | 0
 .../main/java/org/apache/distributedlog/exceptions/FlushException.java    | 0
 .../java/org/apache/distributedlog/exceptions/IdleReaderException.java    | 0
 .../org/apache/distributedlog/exceptions/InternalServerException.java     | 0
 .../apache/distributedlog/exceptions/InvalidEnvelopedEntryException.java  | 0
 .../org/apache/distributedlog/exceptions/InvalidStreamNameException.java  | 0
 .../java/org/apache/distributedlog/exceptions/LockCancelledException.java | 0
 .../main/java/org/apache/distributedlog/exceptions/LockingException.java  | 0
 .../main/java/org/apache/distributedlog/exceptions/LogEmptyException.java | 0
 .../java/org/apache/distributedlog/exceptions/LogExistsException.java     | 0
 .../java/org/apache/distributedlog/exceptions/LogNotFoundException.java   | 0
 .../main/java/org/apache/distributedlog/exceptions/LogReadException.java  | 0
 .../org/apache/distributedlog/exceptions/LogRecordTooLongException.java   | 0
 .../apache/distributedlog/exceptions/LogSegmentIsTruncatedException.java  | 0
 .../org/apache/distributedlog/exceptions/LogSegmentNotFoundException.java | 0
 .../main/java/org/apache/distributedlog/exceptions/MetadataException.java | 0
 .../org/apache/distributedlog/exceptions/NotYetImplementedException.java  | 0
 .../java/org/apache/distributedlog/exceptions/OverCapacityException.java  | 0
 .../apache/distributedlog/exceptions/OwnershipAcquireFailedException.java | 0
 .../java/org/apache/distributedlog/exceptions/ReadCancelledException.java | 0
 .../org/apache/distributedlog/exceptions/RegionUnavailableException.java  | 0
 .../java/org/apache/distributedlog/exceptions/RequestDeniedException.java | 0
 .../java/org/apache/distributedlog/exceptions/RetryableReadException.java | 0
 .../org/apache/distributedlog/exceptions/ServiceUnavailableException.java | 0
 .../src/main/java/org/apache/distributedlog/exceptions/StatusCode.java    | 0
 .../org/apache/distributedlog/exceptions/StreamNotReadyException.java     | 0
 .../org/apache/distributedlog/exceptions/StreamUnavailableException.java  | 0
 .../org/apache/distributedlog/exceptions/TooManyStreamsException.java     | 0
 .../distributedlog/exceptions/TransactionIdOutOfOrderException.java       | 0
 .../java/org/apache/distributedlog/exceptions/UnexpectedException.java    | 0
 .../distributedlog/exceptions/UnsupportedMetadataVersionException.java    | 0
 .../org/apache/distributedlog/exceptions/WriteCancelledException.java     | 0
 .../main/java/org/apache/distributedlog/exceptions/WriteException.java    | 0
 .../src/main/java/org/apache/distributedlog/exceptions/package-info.java  | 0
 .../src/main/java/org/apache/distributedlog/package-info.java             | 0
 .../src/test/java/org/apache/distributedlog/TestDLSN.java                 | 0
 .../src/test/java/org/apache/distributedlog/TestLogRecordSet.java         | 0
 .../{distributedlog-core => protocol}/src/test/resources/log4j.properties | 0
 414 files changed, 0 insertions(+), 0 deletions(-)
 rename stream/distributedlog/{distributedlog-common => common}/pom.xml (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/annotations/DistributedLogAnnotations.java
 (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/annotations/package-info.java
 (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/concurrent/AsyncSemaphore.java
 (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/concurrent/FutureEventListener.java
 (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/concurrent/FutureUtils.java
 (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/concurrent/package-info.java
 (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/config/ConcurrentBaseConfiguration.java
 (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/config/ConcurrentConstConfiguration.java
 (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/config/ConfigurationListener.java
 (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/config/ConfigurationSubscription.java
 (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/config/FileConfigurationBuilder.java
 (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/config/PropertiesConfigurationBuilder.java
 (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/config/package-info.java 
(100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/functions/VoidFunctions.java
 (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/functions/package-info.java
 (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/package-info.java (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/rate/MovingAverageRate.java
 (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/rate/MovingAverageRateFactory.java
 (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/rate/SampledMovingAverageRate.java
 (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/rate/package-info.java 
(100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/stats/BroadCastStatsLogger.java
 (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/stats/OpStatsListener.java
 (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/stats/package-info.java 
(100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/util/BitMaskUtils.java 
(100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/util/ByteBufUtils.java 
(100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/util/MathUtil.java (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/util/Permit.java (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/util/PermitLimiter.java 
(100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/util/PermitManager.java 
(100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/util/ReferenceCounted.java
 (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/util/SchedulerUtils.java 
(100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/util/Sequencer.java 
(100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/util/Sizable.java (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/common/util/package-info.java 
(100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/io/Abortable.java (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/io/Abortables.java (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/io/AsyncAbortable.java (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/io/AsyncCloseable.java (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/io/AsyncDeleteable.java (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/io/CompressionCodec.java (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/io/CompressionUtils.java (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/io/IdentityCompressionCodec.java
 (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/io/LZ4CompressionCodec.java 
(100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/io/package-info.java (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/util/OrderedScheduler.java 
(100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/main/java/org/apache/distributedlog/util/package-info.java (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/test/java/org/apache/distributedlog/common/concurrent/TestFutureUtils.java
 (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/test/java/org/apache/distributedlog/common/config/PropertiesWriter.java
 (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/test/java/org/apache/distributedlog/common/config/TestConcurrentBaseConfiguration.java
 (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/test/java/org/apache/distributedlog/common/config/TestConfigurationSubscription.java
 (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/test/java/org/apache/distributedlog/common/util/TestTimedOutTestsListener.java
 (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/test/java/org/apache/distributedlog/common/util/TimedOutTestsListener.java
 (100%)
 rename stream/distributedlog/{distributedlog-common => 
common}/src/test/java/org/apache/distributedlog/io/TestCompressionCodec.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => core}/bin/common.sh (100%)
 rename stream/distributedlog/{distributedlog-core => core}/bin/dlog (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/conf/bookie.conf.template (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/conf/distributedlog.conf (100%)
 rename stream/distributedlog/{distributedlog-core => core}/conf/dlogenv.sh 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/conf/log4j.properties (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/conf/write_proxy.conf (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/conf/zookeeper.conf.dynamic.template (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/conf/zookeeper.conf.template (100%)
 rename stream/distributedlog/{distributedlog-core => core}/pom.xml (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/bookkeeper/client/BookKeeperAccessor.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/bookkeeper/client/LedgerReader.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/bookkeeper/client/package-info.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/AppendOnlyStreamReader.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/AppendOnlyStreamWriter.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/AsyncNotification.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/BKAbstractLogWriter.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/BKAsyncLogReader.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/BKAsyncLogWriter.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/BKDistributedLogManager.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/BKDistributedLogNamespace.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/BKLogHandler.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/BKLogReadHandler.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/BKLogSegmentWriter.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/BKLogWriteHandler.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/BKSyncLogReader.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/BKSyncLogWriter.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/BKTransmitPacket.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/BookKeeperClient.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/BookKeeperClientBuilder.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/DistributedLogConfiguration.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/DistributedLogConstants.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/Entry.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/EntryBuffer.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/EntryPosition.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/EnvelopedEntry.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/EnvelopedEntryReader.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/EnvelopedEntryWriter.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/LocalDLMEmulator.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/LogSegmentMetadata.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/MaxLogSegmentSequenceNo.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/MaxTxId.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/ReadAheadEntryReader.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/ReadUtils.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/WriteLimiter.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/ZooKeeperClient.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/ZooKeeperClientBuilder.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/acl/AccessControlManager.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/acl/DefaultAccessControlManager.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/acl/package-info.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/admin/DistributedLogAdmin.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/admin/package-info.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/api/AsyncLogReader.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/api/AsyncLogWriter.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/api/DistributedLogManager.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/api/LogReader.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/api/LogWriter.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/api/MetadataAccessor.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/api/namespace/Namespace.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/api/namespace/NamespaceBuilder.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/api/namespace/package-info.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/api/package-info.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/api/subscription/SubscriptionStateStore.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/api/subscription/SubscriptionsStore.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/api/subscription/package-info.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/auditor/DLAuditor.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/auditor/package-info.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/bk/DynamicQuorumConfigProvider.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/bk/ImmutableQuorumConfigProvider.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/bk/LedgerAllocator.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/bk/LedgerAllocatorDelegator.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/bk/LedgerAllocatorPool.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/bk/LedgerAllocatorUtils.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/bk/QuorumConfig.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/bk/QuorumConfigProvider.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/bk/SimpleLedgerAllocator.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/bk/package-info.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/callback/LogSegmentListener.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/callback/LogSegmentNamesListener.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/callback/NamespaceListener.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/callback/package-info.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/config/DynamicConfigurationFactory.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/config/DynamicDistributedLogConfiguration.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/config/package-info.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/exceptions/ZKException.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/exceptions/package-info.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/feature/AbstractFeatureProvider.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/feature/ConfigurationFeatureProvider.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/feature/CoreFeatureKeys.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/feature/DefaultFeatureProvider.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/feature/DynamicConfigurationFeatureProvider.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/feature/package-info.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/function/GetLastTxIdFunction.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/function/package-info.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/impl/BKNamespaceDriver.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/impl/ZKLogMetadataStore.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/impl/ZKLogSegmentFilters.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/impl/ZKLogSegmentMetadataStore.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/impl/ZKMetadataAccessor.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/impl/ZKNamespaceWatcher.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/impl/acl/ZKAccessControl.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/impl/acl/ZKAccessControlManager.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/impl/acl/package-info.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/impl/federated/FederatedZKLogMetadataStore.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/impl/federated/package-info.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/impl/logsegment/BKLogSegmentAllocator.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/impl/logsegment/BKLogSegmentEntryReader.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/impl/logsegment/BKLogSegmentEntryStore.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/impl/logsegment/BKLogSegmentEntryWriter.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/impl/logsegment/BKLogSegmentRandomAccessEntryReader.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/impl/logsegment/BKUtils.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/impl/logsegment/package-info.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/impl/metadata/BKDLConfig.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/impl/metadata/ZKLogStreamMetadataStore.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/impl/metadata/ZkMetadataResolver.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/impl/metadata/package-info.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/impl/package-info.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/impl/subscription/ZKSubscriptionStateStore.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/impl/subscription/ZKSubscriptionsStore.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/impl/subscription/package-info.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/injector/AsyncFailureInjector.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/injector/AsyncRandomFailureInjector.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/injector/FailureInjector.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/injector/RandomDelayFailureInjector.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/injector/package-info.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/limiter/ChainedRequestLimiter.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/limiter/ComposableRequestLimiter.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/limiter/GuavaRateLimiter.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/limiter/RateLimiter.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/limiter/RequestLimiter.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/limiter/package-info.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/lock/DistributedLock.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/lock/DistributedLockContext.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/lock/EpochChangedException.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/lock/LockAction.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/lock/LockClosedException.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/lock/LockListener.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/lock/LockSessionExpiredException.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/lock/LockStateChangedException.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/lock/LockTimeoutException.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/lock/LockWaiter.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/lock/NopDistributedLock.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/lock/SessionLock.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/lock/SessionLockFactory.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/lock/ZKDistributedLock.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/lock/ZKSessionLock.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/lock/ZKSessionLockFactory.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/lock/package-info.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/logsegment/LogSegmentEntryReader.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/logsegment/LogSegmentEntryStore.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/logsegment/LogSegmentEntryWriter.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/logsegment/LogSegmentFilter.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/logsegment/LogSegmentMetadataCache.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/logsegment/LogSegmentMetadataStore.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/logsegment/LogSegmentRandomAccessEntryReader.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/logsegment/LogSegmentWriter.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/logsegment/PerStreamLogSegmentCache.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/logsegment/RollingPolicy.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/logsegment/SizeBasedRollingPolicy.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/logsegment/TimeBasedRollingPolicy.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/logsegment/package-info.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/metadata/DLConfig.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/metadata/DLMetadata.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/metadata/DryrunLogSegmentMetadataStoreUpdater.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/metadata/LogMetadata.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/metadata/LogMetadataForReader.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/metadata/LogMetadataForWriter.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/metadata/LogMetadataStore.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/metadata/LogSegmentMetadataStoreUpdater.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/metadata/LogStreamMetadataStore.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/metadata/MetadataResolver.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/metadata/MetadataUpdater.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/metadata/package-info.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/namespace/NamespaceDriver.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/namespace/NamespaceDriverManager.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/namespace/NamespaceWatcher.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/namespace/package-info.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/net/DNSResolver.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/net/DNSResolverForRacks.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/net/DNSResolverForRows.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/net/NetUtils.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/net/package-info.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/package-info.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/selector/FirstDLSNNotLessThanSelector.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/selector/FirstRecordSelector.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/selector/FirstTxIdNotLessThanSelector.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/selector/LastRecordSelector.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/selector/LogRecordSelector.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/selector/package-info.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/thrift/AccessControlEntry.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/thrift/BKDLConfigFormat.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/thrift/package-info.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/tools/DistributedLogTool.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/tools/Tool.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/tools/package-info.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/util/Allocator.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/util/CommandLineUtils.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/util/ConfUtils.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/util/DLUtils.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/util/FailpointUtils.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/util/RetryPolicyUtils.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/util/SimplePermitLimiter.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/util/TimeSequencer.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/util/Transaction.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/util/Utils.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/util/package-info.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/zk/DefaultZKOp.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/zk/LimitedPermitManager.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/zk/ZKOp.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/zk/ZKTransaction.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/zk/ZKVersionedSetOp.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/zk/ZKWatcherManager.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/java/org/apache/distributedlog/zk/package-info.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/resources/config/decider.conf (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/resources/config/decider.yml (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/main/thrift/metadata.thrift (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/DLMTestUtil.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/NonBlockingReadsTestUtil.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestAppendOnlyStreamReader.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestAppendOnlyStreamWriter.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestAsyncBulkWrite.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestAsyncReaderLock.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestAsyncReaderWriter.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestBKDistributedLogManager.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestBKDistributedLogNamespace.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestBKLogReadHandler.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestBKLogSegmentWriter.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestBKLogWriteHandler.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestBKSyncLogReader.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestDLMTestUtil.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestDistributedLogBase.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestDistributedLogConfiguration.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestEntry.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestEntryPosition.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestInterleavedReaders.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestLogSegmentCreation.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestLogSegmentMetadata.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestLogSegmentsZK.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestNonBlockingReads.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestNonBlockingReadsMultiReader.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestReadAheadEntryReader.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestReadUtils.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestReader.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestRollLogSegments.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestSequenceID.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestTruncate.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestWriteLimiter.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestZooKeeperClient.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/TestZooKeeperClientBuilder.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/ZooKeeperClientUtils.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/ZooKeeperClusterTestCase.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/acl/TestZKAccessControl.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/acl/TestZKAccessControlManager.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/admin/TestDLCK.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/admin/TestDistributedLogAdmin.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/bk/TestLedgerAllocator.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/bk/TestLedgerAllocatorPool.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/config/PropertiesWriter.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/config/TestDynamicConfigurationFactory.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/config/TestDynamicDistributedLogConfiguration.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/feature/TestConfigurationFeatureProvider.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/feature/TestDynamicConfigurationFeatureProvider.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/impl/TestZKLogMetadataStore.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/impl/TestZKLogSegmentFilters.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/impl/TestZKLogSegmentMetadataStore.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/impl/TestZKNamespaceWatcher.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/impl/federated/TestFederatedZKLogMetadataStore.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/impl/logsegment/TestBKLogSegmentEntryReader.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/impl/metadata/TestZKLogStreamMetadataStore.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/impl/metadata/TestZKLogStreamMetadataStoreUtils.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/impl/metadata/TestZkMetadataResolver.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/limiter/TestRequestLimiter.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/lock/TestDistributedLock.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/lock/TestZKSessionLock.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/logsegment/TestPerStreamLogSegmentCache.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/logsegment/TestRollingPolicy.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/metadata/TestDLMetadata.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/metadata/TestLogMetadata.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/metadata/TestLogSegmentMetadataStoreUpdater.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/namespace/TestNamespaceBuilder.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/net/TestDNSResolver.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/net/TestNetUtils.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/selector/TestLogRecordSelectors.java
 (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/tools/TestDistributedLogTool.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/util/TestConfUtils.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/util/TestDLUtils.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/util/TestPermitManager.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/util/TestTimeSequencer.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/util/TestUtils.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/zk/TestZKTransaction.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/zk/TestZKVersionedSetOp.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/java/org/apache/distributedlog/zk/TestZKWatcherManager.java 
(100%)
 rename stream/distributedlog/{distributedlog-core => 
core}/src/test/resources/bk_server.conf (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
core}/src/test/resources/log4j.properties (100%)
 rename stream/distributedlog/{distributedlog-io => io}/dlfs/pom.xml (100%)
 rename stream/distributedlog/{distributedlog-io => 
io}/dlfs/src/main/java/org/apache/distributedlog/fs/DLFileSystem.java (100%)
 rename stream/distributedlog/{distributedlog-io => 
io}/dlfs/src/main/java/org/apache/distributedlog/fs/DLInputStream.java (100%)
 rename stream/distributedlog/{distributedlog-io => 
io}/dlfs/src/main/java/org/apache/distributedlog/fs/DLOutputStream.java (100%)
 rename stream/distributedlog/{distributedlog-io => 
io}/dlfs/src/main/java/org/apache/distributedlog/fs/package-info.java (100%)
 rename stream/distributedlog/{distributedlog-io => 
io}/dlfs/src/test/java/org/apache/distributedlog/fs/TestDLFSBase.java (100%)
 rename stream/distributedlog/{distributedlog-io => 
io}/dlfs/src/test/java/org/apache/distributedlog/fs/TestDLFileSystem.java (100%)
 rename stream/distributedlog/{distributedlog-io => 
io}/dlfs/src/test/resources/dlfs.conf (100%)
 rename stream/distributedlog/{distributedlog-io => io}/pom.xml (100%)
 rename stream/distributedlog/{distributedlog-protocol => protocol}/pom.xml 
(100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/DLSN.java (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/EnvelopedRecordSetReader.java 
(100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/EnvelopedRecordSetWriter.java 
(100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/LogRecord.java (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/LogRecordSet.java (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/LogRecordSetBuffer.java (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/LogRecordWithDLSN.java (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/RecordStream.java (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/TransmitListener.java (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/AlreadyClosedException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/AlreadyTruncatedTransactionException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/BKTransmitException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/ChecksumFailedException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/DLClientClosedException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/DLException.java 
(100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/DLIllegalStateException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/DLInterruptedException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/EndOfLogSegmentException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/EndOfStreamException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/FlushException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/IdleReaderException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/InternalServerException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/InvalidEnvelopedEntryException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/InvalidStreamNameException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/LockCancelledException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/LockingException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/LogEmptyException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/LogExistsException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/LogNotFoundException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/LogReadException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/LogRecordTooLongException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/LogSegmentIsTruncatedException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/LogSegmentNotFoundException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/MetadataException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/NotYetImplementedException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/OverCapacityException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/OwnershipAcquireFailedException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/ReadCancelledException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/RegionUnavailableException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/RequestDeniedException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/RetryableReadException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/ServiceUnavailableException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/StatusCode.java 
(100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/StreamNotReadyException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/StreamUnavailableException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/TooManyStreamsException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/TransactionIdOutOfOrderException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/UnexpectedException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/UnsupportedMetadataVersionException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/WriteCancelledException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/WriteException.java
 (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/exceptions/package-info.java 
(100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/main/java/org/apache/distributedlog/package-info.java (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/test/java/org/apache/distributedlog/TestDLSN.java (100%)
 rename stream/distributedlog/{distributedlog-protocol => 
protocol}/src/test/java/org/apache/distributedlog/TestLogRecordSet.java (100%)
 rename stream/distributedlog/{distributedlog-core => 
protocol}/src/test/resources/log4j.properties (100%)

-- 
To stop receiving notification emails like this one, please contact
si...@apache.org.