You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bookkeeper.apache.org by si...@apache.org on 2018/01/31 19:00:53 UTC
[bookkeeper] branch master updated (8a25353 -> 937de49)
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 8a25353 Increase job timeout to 200 mins
add 7e63cff DL-124: Use Java8 Future rather than twitter Future
add 6a8ed75 Issue 141: graduation changes, remove/change incubate related things
add f528fb3 DL-2: DistributedLog should work with the official apache bookkeeper
add 25abd36 DL-45: DL should allow ByteBuf based API to avoid copying bytes array
add 7da9187 ISSUE #166: Code cleanup for 0.5.0 release
add 1459adb [maven-release-plugin] prepare branch release-0.5.0
add fae15d4 [maven-release-plugin] prepare for next development iteration
add b685290 ISSUE164: Move findbug settings files to distributedlog-build-tools
add fdf74ac Move distributedlog-common module
add 0459390 Merge branch 'master' of /Users/sijie/Workspaces/bookkeeper/../distributedlog_merge into copy_distributedlog
add 7e7fcf6 Initial Check-in for distributedlog oss
add 25af8e2 DL-1: Clean up the distributedlog pom files
add b9247a1 DL-32: Fix Findbug warnings
add 3a00259 DL-127: Fix coverall report
add 6fb1a5d DL-28: using /* */ style comment to avoid scrooge windows platform issue
add a6a4635 DL-129: Enable checkstyle plugin for distributedlog-protocol module
add 7f2b59a DL-101: Improve session expire handling on fetching log segments for readers
add 2cdd371 DL-102: Add routing service to write proxy server side
add a5e892f DL-195: ReadAhead Improvement (part 1) - Interface for LogSegmentEntryReader and LogSegmentEntryWriter
add 714ae49 DL-159: ReadAhead Improvement (part 2) - New ReadAhead Reader using the LogSegmentEntryReader interface
add ef1ca0e DL-165: Add TestTimedOutTestsListener to dump timed out cases thread dump
add e0e819b DL-4: Repackage the source under apache namespace
add 9d1f3bd DL-176: Rename the DL artifact from com.twitter to org.apache.distributedlog
add 965c82d DL-83: Add javadoc to website
add c248f9d DL-28: changed // comments to /* */
add 9bfb2a2 DL-170: All dependency versions should be defined in the parent pom
add b7d2875 [maven-release-plugin] prepare branch release-0.4.0-incubating
add a1e1bb1 [maven-release-plugin] prepare for next development iteration
add b90ad5d DL-205: Remove StatusCode dependency on DLException
add 1bf73e9 DL-124: Use Java8 Future rather than twitter Future
add ab11ad8 Issue 141: graduation changes, remove/change incubate related things
add 075d5b0 DL-2: DistributedLog should work with the official apache bookkeeper
add 813c675 DL-45: DL should allow ByteBuf based API to avoid copying bytes array
add 8c83387 ISSUE #166: Code cleanup for 0.5.0 release
add b9af3d5 [maven-release-plugin] prepare for next development iteration
add e5cd0fe ISSUE #181: Enable LogRecord ByteBuf based constructor public
add 9d0f5b0 Avoid copying bytebuf for constructing log record to write
add ff6ec19 ISSUE164: Move findbug settings files to distributedlog-build-tools
add f74b328 Move distributedlog-protocol module
add f6fcf82 Merge branch 'master' of /Users/sijie/Workspaces/bookkeeper/../distributedlog_merge into copy_distributedlog
add 5a71ed8 Initial Check-in for distributedlog oss
add 0897352 Fixes #14: remove concurrency from ConfigurationSubscription tests (#16)
add 5c768b0 Add documents on running distributedlog in distributed mode
add 88f134e Added vagrant files to start 3 ZK nodes and 3 BK nodes with writeproxy
add 8ad9b29 Vagrant based solution to create multi-node deployment (#34)
add bb31fd7 Merge remote-tracking branch 'origin/master' into dockerize
add bf0f60c DL-20: Validate bk read timeout in configuration
add b99cee8 DL-21: Fix DL flaky test cases
add 55937e0 DL-1: Clean up the distributedlog pom files
add e39e3b0 DL-31: Provide flag to disable zk based distributed lock
add 18ad45f DL-36: travis ci build failed with assembly plugin
add a1890ec Mark some dl tests as flaky
add 941bd8d Add infinite retry policy to zookeeper client used by tests
add 2b2f33f DL-32: Fix Findbug warnings
add baa0afc Fix deadlock on BKSyncLogReaderDLSN
add aebd680 Update a couple of scripts
add 2717eb4 DL-49: Support building project with scala 2.10 and 2.11
add 8a4f4a6 DL-127: Fix coverall report
add 13b890b Clean up and fix a few shell scripts
add 0451d59 DL-141: Fix broken scripts in tutorials and add integration test to travis ci
add 7b5dc62 DL-86: Improve handling of lock conflicts in zk session lock
add db17ed7 DL-87: Introduce periodic keepalive control record in writer
add b06b537 DL-88: remove watches when unregister children watches
add 6aa61c9 DL-90: Don't use stack and codec together for configuring thriftmux
add 8b05fe3 DL-136: Avoid empty catch blocks
add 64bcb21 DL-123: Every tests should have timeout
add 715fa5c DL-122: Use assertions from Junit rather than assert() for tests
add 77de65e DL-91: Be able to close writer within a timeout duration
add ed4d2bf DL-97: Remove unused methods in BKLogHandler
add ef4572a DL-145: the write requests should be error out immediately even if the rolling writer still be creating
add 3953dfb DL-155: fix flaky TestAsyncReaderLock#testReaderLockMultiReadersScenario
add 30742c0 DL-150: Ensure namespace path is created for TestZKLogMetadataForWriter
add ff21a47 DL-151: TestBKLogReadHandler#testGetFirstDLSNWithOpenLedger is flaky
add 0377137 DL-101: Improve session expire handling on fetching log segments for readers
add fdee736 DL-102: Add routing service to write proxy server side
add 9eabddb DL-104: BKClientReadTimeout can be equal to getReadLACLongPollTimeout so current config validates
add 1eb1b1e DL-105: Make compression stats available per stream
add b42a8c3 DL-106: Use namespace after it is closed will throw AlreadyClosedException
add 13a7381 DL-107: Added unregistering gauges for distributedlog-core and distributedlog-benchmark
add 0d424a1 DL-108: Log rate limiting more clearly
add 35587d3 DL-109: Add a tool to find the stream containing the given ledger
add b90cce8 DL-110: Write control record if necessary when roll a log segment
add ee11723 DL-111: ReadAhead Cache should cache entries rather than records
add c9e7626 DL-112: Improve SyncReader to access readahead cache directly
add 7c4476c DL-113: Improve the sync reader benchmark
add aa60a4e DL-114: Add namespace watch tool
add d606ee4 DL-115: fix force get log segment logic
add 68f7960 DL-116: Add tool for deleting subscriber from subscription store
add de4711d DL-117: Stream metadata store
add 3a51232 DL-118: Stream metadata store followup - rename ZKLogMetadata* to LogMetadata*
add 09a34b0 DL-119: Fix the logging on closing readahead worker
add da53069 DL-157: resource placement for write proxy
add fd08ced DL-158: update truncation status for all completed log segments
add e2c6bc0 DL-195: ReadAhead Improvement (part 1) - Interface for LogSegmentEntryReader and LogSegmentEntryWriter
add d7105aa DL-159: ReadAhead Improvement (part 2) - New ReadAhead Reader using the LogSegmentEntryReader interface
add 590805a DL-160: Remove 'DLSN' suffix from async and sync readers
add 1166e11 DL-161: Rename ledger id to log segment id
add a83b233 DL-162: Use log segment entry store interface
add d15bc06 DL-163: clean up direct zookeeper and bookkeeper usage and use metadata/data store abstraction
add da6cd40 DL-164: Create stream operation should not be submitted by StreamImpl
add c7e78df DL-140: Fix distributedlog-core findbug inconsistent synchronization warings
add 3319bc0 DL-165: Add TestTimedOutTestsListener to dump timed out cases thread dump
add 817989c DL-4: Repackage the source under apache namespace
add 6cd2512 DL-171: adding a short sleep to let the WriteCompleteListener have time to run before the final position be requested
add 361b423 DL-176: Rename the DL artifact from com.twitter to org.apache.distributedlog
add 4b6c849 DL-83: Add javadoc to website
add 8ba3c92 DL-170: All dependency versions should be defined in the parent pom
add c3077c4 Remove Xlint compiler arguments for building release
add eeb96c1 [maven-release-plugin] prepare branch release-0.4.0-incubating
add 5548c21 [maven-release-plugin] prepare for next development iteration
add 90e09af Fix the script to make sure binary package can execute scripts correctly
add 712d1cb DL-186: fix common.sh grep bug; kill MultiReader java process as expected
add b2285e6 DL-191: Fix license header issues
add 03c53f5 DL-184: reduce server_graceful_shutdown_period_ms from 35s to 20s, which is smaller than the default daemon stop timeout value
add 0dd0e4f DL-196: Remove 'Copyright 2017 The Apache Software Foundation' from license header
add ba3505e DL-173: changed FileUtils.deleteDirectory to FileUtils.forceDeleteOnExit so d…
add 6a80ebc DL-174: added getParent method to Utils to replace usage of File.getParent which changes / to \ on Windows
add bc97347 Remove package-info.java under com.twitter.distributedlog.subscription
add 8618b21 DL-205: Remove StatusCode dependency on DLException
add 83c527c DL-199: Be able to support filesystem-path like name
add 46e6b70 DL-204: Bump libthrift to latest version for distributedlog-core
add b4770a0 DL-124: Use Java8 Future rather than twitter Future
add d318022 Issue 141: graduation changes, remove/change incubate related things
add eaed168 DL-2: DistributedLog should work with the official apache bookkeeper
add 13f88fe DL-206: Delete the log should also delete the underline ledgers
add 0e76212 ISSUE #156: Provide a shading jar for distributedlog-core
add 5a5ad46 DL-45: DL should allow ByteBuf based API to avoid copying bytes array
add ae9dbfe ISSUE #166: Code cleanup for 0.5.0 release
add abb311c ISSUE #160: Introduce backward compatibility testing
add a5c061c [maven-release-plugin] prepare for next development iteration
add db06aca ISSUE #165: Enable checkstyle in core module
add 32ad7ba ISSUE #193: Shade Bookkeeper and unshade ZooKeeper in core module
add c2bf327 ISSUE #197: Provide a guide for running on k8s
add 4462bc3 ISSUE #213: Correct logger name in BKLogWriteHandler
add ecca567 ISSUE173: Implement AutoCloseable in BKDistributedLogNamespace
add 2de1f6d Fix the flaky test TestBKDistributedLogManager.deleteDuringRead
add b737e9c Issue 201: Fix the flaky test TestBKDistributedLogManager.deleteDuringRead
add 84ecaa8 ISSUE #207: Support getFirstLogRecord
add 9f55ccc ISSUE #211: Support listing logs by prefix
add 346e3a9 ISSUE164: Move findbug settings files to distributedlog-build-tools
add 6e7237c ISSUE #209: Support rename log
add dfe465c Issue 225: Create log should create missing path components
add 3a14990 ISSUE #224: listing logs should exclude <default>
add 54268ce ISSUE #226: ByteBuf.release() was not called before it's garbage-collected
add 030aefa Fix DistributedSchedule.WriteSet compilation issue
add f30766e Update exception handling in constructing bookkeeper client
add 89d45bc issue #236: shaded jar lose necessary bk jar to execute
add 089c2ef Make distributedlog compiled with latest bookkeeper version
add 57da05e Move distributedlog-core module
add 7d4ee6c Merge branch 'master' of /Users/sijie/Workspaces/bookkeeper/../distributedlog_merge into copy_distributedlog
add 26680c1 DLFS - A FileSystem API wrapper over dlog API
add d9f3961 Move distributedlog-io module
add 9f016a0 Merge branch 'master' of /Users/sijie/Workspaces/bookkeeper/../distributedlog_merge into copy_distributedlog
new 937de49 Merge remote-tracking branch 'apache/master' into copy_distributedlog
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:
.../distributedlog/distributedlog-common/pom.xml | 173 +
.../annotations/DistributedLogAnnotations.java | 35 +
.../common/annotations/package-info.java | 21 +
.../common/concurrent/AsyncSemaphore.java | 160 +
.../common/concurrent/FutureEventListener.java | 44 +
.../common/concurrent/FutureUtils.java | 376 ++
.../common/concurrent/package-info.java | 22 +
.../common/config/ConcurrentBaseConfiguration.java | 71 +
.../config/ConcurrentConstConfiguration.java | 32 +
.../common/config/ConfigurationListener.java | 32 +
.../common/config/ConfigurationSubscription.java | 187 +
.../common/config/FileConfigurationBuilder.java | 28 +
.../config/PropertiesConfigurationBuilder.java | 39 +
.../distributedlog/common/config/package-info.java | 21 +
.../common/functions/VoidFunctions.java | 31 +
.../common/functions/package-info.java | 21 +
.../apache/distributedlog/common/package-info.java | 22 +
.../common/rate/MovingAverageRate.java | 27 +
.../common/rate/MovingAverageRateFactory.java | 62 +
.../common/rate/SampledMovingAverageRate.java | 95 +
.../distributedlog/common/rate/package-info.java | 22 +
.../common/stats/BroadCastStatsLogger.java | 208 ++
.../common/stats/OpStatsListener.java | 54 +
.../distributedlog/common/stats/package-info.java | 21 +
.../distributedlog/common/util/BitMaskUtils.java | 57 +
.../distributedlog/common/util/ByteBufUtils.java | 37 +
.../distributedlog/common/util/MathUtil.java | 36 +
.../apache/distributedlog/common/util/Permit.java | 28 +
.../distributedlog/common/util/PermitLimiter.java | 57 +
.../distributedlog/common/util/PermitManager.java | 94 +
.../common/util/ReferenceCounted.java | 35 +
.../distributedlog/common/util/SchedulerUtils.java | 43 +
.../distributedlog/common/util/Sequencer.java | 31 +
.../apache/distributedlog/common/util/Sizable.java | 31 +
.../distributedlog/common/util/package-info.java | 22 +
.../org/apache/distributedlog/io/Abortable.java | 41 +
.../org/apache/distributedlog/io/Abortables.java | 185 +
.../apache/distributedlog/io/AsyncAbortable.java | 48 +
.../apache/distributedlog/io/AsyncCloseable.java | 46 +
.../apache/distributedlog/io/AsyncDeleteable.java | 34 +
.../apache/distributedlog/io/CompressionCodec.java | 80 +
.../apache/distributedlog/io/CompressionUtils.java | 55 +
.../io/IdentityCompressionCodec.java | 59 +
.../distributedlog/io/LZ4CompressionCodec.java | 88 +
.../org/apache/distributedlog/io/package-info.java | 21 +
.../distributedlog/util/OrderedScheduler.java | 353 ++
.../apache/distributedlog/util/package-info.java | 21 +
.../common/concurrent/TestFutureUtils.java | 386 +++
.../common/config/PropertiesWriter.java | 69 +
.../config/TestConcurrentBaseConfiguration.java | 47 +
.../config/TestConfigurationSubscription.java | 173 +
.../common/util/TestTimedOutTestsListener.java | 183 +
.../common/util/TimedOutTestsListener.java | 168 +
.../distributedlog/io/TestCompressionCodec.java | 101 +
.../distributedlog-core/bin/common.sh | 124 +
stream/distributedlog/distributedlog-core/bin/dlog | 72 +
.../distributedlog-core/conf/bookie.conf.template | 183 +
.../distributedlog-core/conf/distributedlog.conf | 125 +
.../distributedlog-core/conf/dlogenv.sh | 75 +
.../distributedlog-core/conf/log4j.properties | 56 +
.../distributedlog-core/conf/write_proxy.conf | 143 +
.../conf/zookeeper.conf.dynamic.template | 1 +
.../conf/zookeeper.conf.template | 82 +
stream/distributedlog/distributedlog-core/pom.xml | 514 +++
.../bookkeeper/client/BookKeeperAccessor.java | 40 +
.../org/apache/bookkeeper/client/LedgerReader.java | 231 ++
.../org/apache/bookkeeper/client/package-info.java | 22 +
.../distributedlog/AppendOnlyStreamReader.java | 202 ++
.../distributedlog/AppendOnlyStreamWriter.java | 108 +
.../apache/distributedlog/AsyncNotification.java | 32 +
.../apache/distributedlog/BKAbstractLogWriter.java | 552 +++
.../apache/distributedlog/BKAsyncLogReader.java | 764 +++++
.../apache/distributedlog/BKAsyncLogWriter.java | 531 +++
.../distributedlog/BKDistributedLogManager.java | 1096 ++++++
.../distributedlog/BKDistributedLogNamespace.java | 348 ++
.../org/apache/distributedlog/BKLogHandler.java | 724 ++++
.../apache/distributedlog/BKLogReadHandler.java | 411 +++
.../apache/distributedlog/BKLogSegmentWriter.java | 1362 ++++++++
.../apache/distributedlog/BKLogWriteHandler.java | 1338 ++++++++
.../org/apache/distributedlog/BKSyncLogReader.java | 291 ++
.../org/apache/distributedlog/BKSyncLogWriter.java | 113 +
.../apache/distributedlog/BKTransmitPacket.java | 89 +
.../apache/distributedlog/BookKeeperClient.java | 289 ++
.../distributedlog/BookKeeperClientBuilder.java | 217 ++
.../DistributedLogConfiguration.java | 3605 ++++++++++++++++++++
.../distributedlog/DistributedLogConstants.java | 71 +
.../main/java/org/apache/distributedlog/Entry.java | 230 ++
.../org/apache/distributedlog/EntryBuffer.java | 70 +
.../org/apache/distributedlog/EntryPosition.java | 63 +
.../org/apache/distributedlog/EnvelopedEntry.java | 110 +
.../distributedlog/EnvelopedEntryReader.java | 158 +
.../distributedlog/EnvelopedEntryWriter.java | 227 ++
.../apache/distributedlog/LocalDLMEmulator.java | 342 ++
.../apache/distributedlog/LogSegmentMetadata.java | 1154 +++++++
.../distributedlog/MaxLogSegmentSequenceNo.java | 73 +
.../java/org/apache/distributedlog/MaxTxId.java | 72 +
.../distributedlog/ReadAheadEntryReader.java | 988 ++++++
.../java/org/apache/distributedlog/ReadUtils.java | 767 +++++
.../org/apache/distributedlog/WriteLimiter.java | 62 +
.../org/apache/distributedlog/ZooKeeperClient.java | 410 +++
.../distributedlog/ZooKeeperClientBuilder.java | 235 ++
.../distributedlog/acl/AccessControlManager.java | 74 +
.../acl/DefaultAccessControlManager.java | 58 +
.../apache/distributedlog/acl/package-info.java | 21 +
.../distributedlog/admin/DistributedLogAdmin.java | 939 +++++
.../apache/distributedlog/admin/package-info.java | 21 +
.../apache/distributedlog/api/AsyncLogReader.java | 77 +
.../apache/distributedlog/api/AsyncLogWriter.java | 85 +
.../distributedlog/api/DistributedLogManager.java | 429 +++
.../org/apache/distributedlog/api/LogReader.java | 198 ++
.../org/apache/distributedlog/api/LogWriter.java | 79 +
.../distributedlog/api/MetadataAccessor.java | 52 +
.../distributedlog/api/namespace/Namespace.java | 217 ++
.../api/namespace/NamespaceBuilder.java | 280 ++
.../distributedlog/api/namespace/package-info.java | 22 +
.../apache/distributedlog/api/package-info.java | 25 +
.../api/subscription/SubscriptionStateStore.java | 42 +
.../api/subscription/SubscriptionsStore.java | 67 +
.../api/subscription/package-info.java | 23 +
.../apache/distributedlog/auditor/DLAuditor.java | 641 ++++
.../distributedlog/auditor/package-info.java | 23 +
.../bk/DynamicQuorumConfigProvider.java | 37 +
.../bk/ImmutableQuorumConfigProvider.java | 35 +
.../apache/distributedlog/bk/LedgerAllocator.java | 35 +
.../bk/LedgerAllocatorDelegator.java | 85 +
.../distributedlog/bk/LedgerAllocatorPool.java | 447 +++
.../distributedlog/bk/LedgerAllocatorUtils.java | 58 +
.../org/apache/distributedlog/bk/QuorumConfig.java | 92 +
.../distributedlog/bk/QuorumConfigProvider.java | 32 +
.../distributedlog/bk/SimpleLedgerAllocator.java | 520 +++
.../org/apache/distributedlog/bk/package-info.java | 24 +
.../callback/LogSegmentListener.java | 43 +
.../callback/LogSegmentNamesListener.java | 43 +
.../distributedlog/callback/NamespaceListener.java | 37 +
.../distributedlog/callback/package-info.java | 21 +
.../config/DynamicConfigurationFactory.java | 100 +
.../config/DynamicDistributedLogConfiguration.java | 362 ++
.../apache/distributedlog/config/package-info.java | 21 +
.../distributedlog/exceptions/ZKException.java | 53 +
.../distributedlog/exceptions/package-info.java | 21 +
.../feature/AbstractFeatureProvider.java | 107 +
.../feature/ConfigurationFeatureProvider.java | 77 +
.../distributedlog/feature/CoreFeatureKeys.java | 29 +
.../feature/DefaultFeatureProvider.java | 48 +
.../DynamicConfigurationFeatureProvider.java | 136 +
.../distributedlog/feature/package-info.java | 21 +
.../function/GetLastTxIdFunction.java | 42 +
.../distributedlog/function/package-info.java | 21 +
.../distributedlog/impl/BKNamespaceDriver.java | 654 ++++
.../distributedlog/impl/ZKLogMetadataStore.java | 131 +
.../distributedlog/impl/ZKLogSegmentFilters.java | 90 +
.../impl/ZKLogSegmentMetadataStore.java | 503 +++
.../distributedlog/impl/ZKMetadataAccessor.java | 268 ++
.../distributedlog/impl/ZKNamespaceWatcher.java | 134 +
.../distributedlog/impl/acl/ZKAccessControl.java | 237 ++
.../impl/acl/ZKAccessControlManager.java | 381 +++
.../distributedlog/impl/acl/package-info.java | 21 +
.../federated/FederatedZKLogMetadataStore.java | 766 +++++
.../impl/federated/package-info.java | 21 +
.../impl/logsegment/BKLogSegmentAllocator.java | 84 +
.../impl/logsegment/BKLogSegmentEntryReader.java | 880 +++++
.../impl/logsegment/BKLogSegmentEntryStore.java | 287 ++
.../impl/logsegment/BKLogSegmentEntryWriter.java | 63 +
.../BKLogSegmentRandomAccessEntryReader.java | 131 +
.../distributedlog/impl/logsegment/BKUtils.java | 71 +
.../impl/logsegment/package-info.java | 21 +
.../distributedlog/impl/metadata/BKDLConfig.java | 401 +++
.../impl/metadata/ZKLogStreamMetadataStore.java | 948 +++++
.../impl/metadata/ZkMetadataResolver.java | 75 +
.../distributedlog/impl/metadata/package-info.java | 21 +
.../apache/distributedlog/impl/package-info.java | 21 +
.../subscription/ZKSubscriptionStateStore.java | 119 +
.../impl/subscription/ZKSubscriptionsStore.java | 150 +
.../impl/subscription/package-info.java | 21 +
.../injector/AsyncFailureInjector.java | 131 +
.../injector/AsyncRandomFailureInjector.java | 189 +
.../distributedlog/injector/FailureInjector.java | 37 +
.../injector/RandomDelayFailureInjector.java | 60 +
.../distributedlog/injector/package-info.java | 21 +
.../limiter/ChainedRequestLimiter.java | 81 +
.../limiter/ComposableRequestLimiter.java | 73 +
.../distributedlog/limiter/GuavaRateLimiter.java | 58 +
.../apache/distributedlog/limiter/RateLimiter.java | 51 +
.../distributedlog/limiter/RequestLimiter.java | 26 +
.../distributedlog/limiter/package-info.java | 21 +
.../distributedlog/lock/DistributedLock.java | 54 +
.../lock/DistributedLockContext.java | 43 +
.../distributedlog/lock/EpochChangedException.java | 33 +
.../org/apache/distributedlog/lock/LockAction.java | 36 +
.../distributedlog/lock/LockClosedException.java | 37 +
.../apache/distributedlog/lock/LockListener.java | 28 +
.../lock/LockSessionExpiredException.java | 34 +
.../lock/LockStateChangedException.java | 36 +
.../distributedlog/lock/LockTimeoutException.java | 34 +
.../org/apache/distributedlog/lock/LockWaiter.java | 99 +
.../distributedlog/lock/NopDistributedLock.java | 52 +
.../apache/distributedlog/lock/SessionLock.java | 128 +
.../distributedlog/lock/SessionLockFactory.java | 38 +
.../distributedlog/lock/ZKDistributedLock.java | 531 +++
.../apache/distributedlog/lock/ZKSessionLock.java | 1358 ++++++++
.../distributedlog/lock/ZKSessionLockFactory.java | 128 +
.../apache/distributedlog/lock/package-info.java | 21 +
.../logsegment/LogSegmentEntryReader.java | 114 +
.../logsegment/LogSegmentEntryStore.java | 72 +
.../logsegment/LogSegmentEntryWriter.java | 70 +
.../logsegment/LogSegmentFilter.java | 42 +
.../logsegment/LogSegmentMetadataCache.java | 99 +
.../logsegment/LogSegmentMetadataStore.java | 163 +
.../LogSegmentRandomAccessEntryReader.java | 46 +
.../logsegment/LogSegmentWriter.java | 85 +
.../logsegment/PerStreamLogSegmentCache.java | 247 ++
.../distributedlog/logsegment/RollingPolicy.java | 36 +
.../logsegment/SizeBasedRollingPolicy.java | 37 +
.../logsegment/TimeBasedRollingPolicy.java | 49 +
.../distributedlog/logsegment/package-info.java | 21 +
.../apache/distributedlog/metadata/DLConfig.java | 39 +
.../apache/distributedlog/metadata/DLMetadata.java | 225 ++
.../DryrunLogSegmentMetadataStoreUpdater.java | 55 +
.../distributedlog/metadata/LogMetadata.java | 175 +
.../metadata/LogMetadataForReader.java | 103 +
.../metadata/LogMetadataForWriter.java | 64 +
.../distributedlog/metadata/LogMetadataStore.java | 67 +
.../metadata/LogSegmentMetadataStoreUpdater.java | 179 +
.../metadata/LogStreamMetadataStore.java | 127 +
.../distributedlog/metadata/MetadataResolver.java | 51 +
.../distributedlog/metadata/MetadataUpdater.java | 120 +
.../distributedlog/metadata/package-info.java | 21 +
.../distributedlog/namespace/NamespaceDriver.java | 141 +
.../namespace/NamespaceDriverManager.java | 179 +
.../distributedlog/namespace/NamespaceWatcher.java | 61 +
.../distributedlog/namespace/package-info.java | 21 +
.../org/apache/distributedlog/net/DNSResolver.java | 114 +
.../distributedlog/net/DNSResolverForRacks.java | 66 +
.../distributedlog/net/DNSResolverForRows.java | 72 +
.../org/apache/distributedlog/net/NetUtils.java | 75 +
.../apache/distributedlog/net/package-info.java | 33 +
.../org/apache/distributedlog/package-info.java | 21 +
.../selector/FirstDLSNNotLessThanSelector.java | 46 +
.../selector/FirstRecordSelector.java | 46 +
.../selector/FirstTxIdNotLessThanSelector.java | 51 +
.../selector/LastRecordSelector.java | 38 +
.../distributedlog/selector/LogRecordSelector.java | 40 +
.../distributedlog/selector/package-info.java | 21 +
.../distributedlog/thrift/AccessControlEntry.java | 793 +++++
.../distributedlog/thrift/BKDLConfigFormat.java | 1335 ++++++++
.../apache/distributedlog/thrift/package-info.java | 21 +
.../distributedlog/tools/DistributedLogTool.java | 2647 ++++++++++++++
.../java/org/apache/distributedlog/tools/Tool.java | 246 ++
.../apache/distributedlog/tools/package-info.java | 21 +
.../org/apache/distributedlog/util/Allocator.java | 100 +
.../distributedlog/util/CommandLineUtils.java | 57 +
.../org/apache/distributedlog/util/ConfUtils.java | 68 +
.../org/apache/distributedlog/util/DLUtils.java | 371 ++
.../apache/distributedlog/util/FailpointUtils.java | 148 +
.../distributedlog/util/RetryPolicyUtils.java | 45 +
.../distributedlog/util/SimplePermitLimiter.java | 117 +
.../apache/distributedlog/util/TimeSequencer.java | 40 +
.../apache/distributedlog/util/Transaction.java | 97 +
.../java/org/apache/distributedlog/util/Utils.java | 750 ++++
.../apache/distributedlog/util/package-info.java | 21 +
.../org/apache/distributedlog/zk/DefaultZKOp.java | 55 +
.../distributedlog/zk/LimitedPermitManager.java | 196 ++
.../java/org/apache/distributedlog/zk/ZKOp.java | 64 +
.../apache/distributedlog/zk/ZKTransaction.java | 102 +
.../apache/distributedlog/zk/ZKVersionedSetOp.java | 71 +
.../apache/distributedlog/zk/ZKWatcherManager.java | 244 ++
.../org/apache/distributedlog/zk/package-info.java | 21 +
.../src/main/resources/config/decider.conf | 15 +
.../src/main/resources/config/decider.yml | 17 +
.../src/main/thrift/metadata.thrift | 39 +
.../org/apache/distributedlog/DLMTestUtil.java | 498 +++
.../distributedlog/NonBlockingReadsTestUtil.java | 147 +
.../distributedlog/TestAppendOnlyStreamReader.java | 204 ++
.../distributedlog/TestAppendOnlyStreamWriter.java | 339 ++
.../apache/distributedlog/TestAsyncBulkWrite.java | 350 ++
.../apache/distributedlog/TestAsyncReaderLock.java | 609 ++++
.../distributedlog/TestAsyncReaderWriter.java | 2220 ++++++++++++
.../TestBKDistributedLogManager.java | 1249 +++++++
.../TestBKDistributedLogNamespace.java | 474 +++
.../distributedlog/TestBKLogReadHandler.java | 400 +++
.../distributedlog/TestBKLogSegmentWriter.java | 784 +++++
.../distributedlog/TestBKLogWriteHandler.java | 91 +
.../apache/distributedlog/TestBKSyncLogReader.java | 308 ++
.../org/apache/distributedlog/TestDLMTestUtil.java | 71 +
.../distributedlog/TestDistributedLogBase.java | 255 ++
.../TestDistributedLogConfiguration.java | 134 +
.../java/org/apache/distributedlog/TestEntry.java | 355 ++
.../apache/distributedlog/TestEntryPosition.java | 59 +
.../distributedlog/TestInterleavedReaders.java | 344 ++
.../distributedlog/TestLogSegmentCreation.java | 110 +
.../distributedlog/TestLogSegmentMetadata.java | 159 +
.../apache/distributedlog/TestLogSegmentsZK.java | 250 ++
.../distributedlog/TestNonBlockingReads.java | 349 ++
.../TestNonBlockingReadsMultiReader.java | 172 +
.../distributedlog/TestReadAheadEntryReader.java | 467 +++
.../org/apache/distributedlog/TestReadUtils.java | 345 ++
.../java/org/apache/distributedlog/TestReader.java | 202 ++
.../apache/distributedlog/TestRollLogSegments.java | 437 +++
.../org/apache/distributedlog/TestSequenceID.java | 254 ++
.../org/apache/distributedlog/TestTruncate.java | 347 ++
.../apache/distributedlog/TestWriteLimiter.java | 206 ++
.../apache/distributedlog/TestZooKeeperClient.java | 461 +++
.../distributedlog/TestZooKeeperClientBuilder.java | 57 +
.../distributedlog/ZooKeeperClientUtils.java | 94 +
.../distributedlog/ZooKeeperClusterTestCase.java | 55 +
.../distributedlog/acl/TestZKAccessControl.java | 159 +
.../acl/TestZKAccessControlManager.java | 180 +
.../org/apache/distributedlog/admin/TestDLCK.java | 168 +
.../admin/TestDistributedLogAdmin.java | 195 ++
.../distributedlog/bk/TestLedgerAllocator.java | 392 +++
.../distributedlog/bk/TestLedgerAllocatorPool.java | 316 ++
.../distributedlog/config/PropertiesWriter.java | 69 +
.../config/TestDynamicConfigurationFactory.java | 103 +
.../TestDynamicDistributedLogConfiguration.java | 266 ++
.../feature/TestConfigurationFeatureProvider.java | 65 +
.../TestDynamicConfigurationFeatureProvider.java | 183 +
.../impl/TestZKLogMetadataStore.java | 125 +
.../impl/TestZKLogSegmentFilters.java | 79 +
.../impl/TestZKLogSegmentMetadataStore.java | 834 +++++
.../impl/TestZKNamespaceWatcher.java | 185 +
.../federated/TestFederatedZKLogMetadataStore.java | 445 +++
.../logsegment/TestBKLogSegmentEntryReader.java | 561 +++
.../metadata/TestZKLogStreamMetadataStore.java | 582 ++++
.../TestZKLogStreamMetadataStoreUtils.java | 212 ++
.../impl/metadata/TestZkMetadataResolver.java | 208 ++
.../distributedlog/limiter/TestRequestLimiter.java | 64 +
.../distributedlog/lock/TestDistributedLock.java | 832 +++++
.../distributedlog/lock/TestZKSessionLock.java | 1234 +++++++
.../logsegment/TestPerStreamLogSegmentCache.java | 187 +
.../logsegment/TestRollingPolicy.java | 63 +
.../distributedlog/metadata/TestDLMetadata.java | 200 ++
.../distributedlog/metadata/TestLogMetadata.java | 64 +
.../TestLogSegmentMetadataStoreUpdater.java | 291 ++
.../namespace/TestNamespaceBuilder.java | 127 +
.../apache/distributedlog/net/TestDNSResolver.java | 99 +
.../apache/distributedlog/net/TestNetUtils.java | 81 +
.../selector/TestLogRecordSelectors.java | 128 +
.../tools/TestDistributedLogTool.java | 245 ++
.../apache/distributedlog/util/TestConfUtils.java | 56 +
.../apache/distributedlog/util/TestDLUtils.java | 308 ++
.../distributedlog/util/TestPermitManager.java | 97 +
.../distributedlog/util/TestTimeSequencer.java | 46 +
.../org/apache/distributedlog/util/TestUtils.java | 155 +
.../distributedlog/zk/TestZKTransaction.java | 98 +
.../distributedlog/zk/TestZKVersionedSetOp.java | 87 +
.../distributedlog/zk/TestZKWatcherManager.java | 84 +
.../src/test/resources/bk_server.conf | 145 +
.../src/test/resources/log4j.properties | 51 +
.../distributedlog/distributedlog-io/dlfs/pom.xml | 117 +
.../org/apache/distributedlog/fs/DLFileSystem.java | 330 ++
.../apache/distributedlog/fs/DLInputStream.java | 244 ++
.../apache/distributedlog/fs/DLOutputStream.java | 140 +
.../org/apache/distributedlog/fs/package-info.java | 22 +
.../org/apache/distributedlog/fs/TestDLFSBase.java | 59 +
.../apache/distributedlog/fs/TestDLFileSystem.java | 229 ++
.../dlfs/src/test/resources/dlfs.conf | 27 +
stream/distributedlog/distributedlog-io/pom.xml | 38 +
.../distributedlog/distributedlog-protocol/pom.xml | 116 +
.../main/java/org/apache/distributedlog/DLSN.java | 266 ++
.../distributedlog/EnvelopedRecordSetReader.java | 126 +
.../distributedlog/EnvelopedRecordSetWriter.java | 170 +
.../java/org/apache/distributedlog/LogRecord.java | 648 ++++
.../org/apache/distributedlog/LogRecordSet.java | 150 +
.../apache/distributedlog/LogRecordSetBuffer.java | 65 +
.../apache/distributedlog/LogRecordWithDLSN.java | 119 +
.../org/apache/distributedlog/RecordStream.java | 42 +
.../apache/distributedlog/TransmitListener.java | 54 +
.../exceptions/AlreadyClosedException.java | 32 +
.../AlreadyTruncatedTransactionException.java | 30 +
.../exceptions/BKTransmitException.java | 40 +
.../exceptions/ChecksumFailedException.java | 30 +
.../exceptions/DLClientClosedException.java | 34 +
.../distributedlog/exceptions/DLException.java | 58 +
.../exceptions/DLIllegalStateException.java | 34 +
.../exceptions/DLInterruptedException.java | 34 +
.../exceptions/EndOfLogSegmentException.java | 30 +
.../exceptions/EndOfStreamException.java | 30 +
.../distributedlog/exceptions/FlushException.java | 49 +
.../exceptions/IdleReaderException.java | 34 +
.../exceptions/InternalServerException.java | 38 +
.../exceptions/InvalidEnvelopedEntryException.java | 30 +
.../exceptions/InvalidStreamNameException.java | 34 +
.../exceptions/LockCancelledException.java | 31 +
.../exceptions/LockingException.java | 42 +
.../exceptions/LogEmptyException.java | 30 +
.../exceptions/LogExistsException.java | 29 +
.../exceptions/LogNotFoundException.java | 30 +
.../exceptions/LogReadException.java | 31 +
.../exceptions/LogRecordTooLongException.java | 32 +
.../exceptions/LogSegmentIsTruncatedException.java | 31 +
.../exceptions/LogSegmentNotFoundException.java | 30 +
.../exceptions/MetadataException.java | 34 +
.../exceptions/NotYetImplementedException.java | 30 +
.../exceptions/OverCapacityException.java | 37 +
.../OwnershipAcquireFailedException.java | 38 +
.../exceptions/ReadCancelledException.java | 31 +
.../exceptions/RegionUnavailableException.java | 32 +
.../exceptions/RequestDeniedException.java | 31 +
.../exceptions/RetryableReadException.java | 34 +
.../exceptions/ServiceUnavailableException.java | 30 +
.../distributedlog/exceptions/StatusCode.java | 122 +
.../exceptions/StreamNotReadyException.java | 30 +
.../exceptions/StreamUnavailableException.java | 30 +
.../exceptions/TooManyStreamsException.java | 30 +
.../TransactionIdOutOfOrderException.java | 45 +
.../exceptions/UnexpectedException.java | 38 +
.../UnsupportedMetadataVersionException.java | 30 +
.../exceptions/WriteCancelledException.java | 43 +
.../distributedlog/exceptions/WriteException.java | 31 +
.../distributedlog/exceptions/package-info.java | 21 +
.../org/apache/distributedlog/package-info.java | 21 +
.../java/org/apache/distributedlog/TestDLSN.java | 64 +
.../apache/distributedlog/TestLogRecordSet.java | 173 +
.../src/test/resources/log4j.properties | 51 +
414 files changed, 77831 insertions(+)
create mode 100644 stream/distributedlog/distributedlog-common/pom.xml
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/annotations/DistributedLogAnnotations.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/annotations/package-info.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/concurrent/AsyncSemaphore.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/concurrent/FutureEventListener.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/concurrent/FutureUtils.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/concurrent/package-info.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/config/ConcurrentBaseConfiguration.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/config/ConcurrentConstConfiguration.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/config/ConfigurationListener.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/config/ConfigurationSubscription.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/config/FileConfigurationBuilder.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/config/PropertiesConfigurationBuilder.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/config/package-info.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/functions/VoidFunctions.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/functions/package-info.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/package-info.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/rate/MovingAverageRate.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/rate/MovingAverageRateFactory.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/rate/SampledMovingAverageRate.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/rate/package-info.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/stats/BroadCastStatsLogger.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/stats/OpStatsListener.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/stats/package-info.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/util/BitMaskUtils.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/util/ByteBufUtils.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/util/MathUtil.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/util/Permit.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/util/PermitLimiter.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/util/PermitManager.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/util/ReferenceCounted.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/util/SchedulerUtils.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/util/Sequencer.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/util/Sizable.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/common/util/package-info.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/io/Abortable.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/io/Abortables.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/io/AsyncAbortable.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/io/AsyncCloseable.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/io/AsyncDeleteable.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/io/CompressionCodec.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/io/CompressionUtils.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/io/IdentityCompressionCodec.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/io/LZ4CompressionCodec.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/io/package-info.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/util/OrderedScheduler.java
create mode 100644 stream/distributedlog/distributedlog-common/src/main/java/org/apache/distributedlog/util/package-info.java
create mode 100644 stream/distributedlog/distributedlog-common/src/test/java/org/apache/distributedlog/common/concurrent/TestFutureUtils.java
create mode 100644 stream/distributedlog/distributedlog-common/src/test/java/org/apache/distributedlog/common/config/PropertiesWriter.java
create mode 100644 stream/distributedlog/distributedlog-common/src/test/java/org/apache/distributedlog/common/config/TestConcurrentBaseConfiguration.java
create mode 100644 stream/distributedlog/distributedlog-common/src/test/java/org/apache/distributedlog/common/config/TestConfigurationSubscription.java
create mode 100644 stream/distributedlog/distributedlog-common/src/test/java/org/apache/distributedlog/common/util/TestTimedOutTestsListener.java
create mode 100644 stream/distributedlog/distributedlog-common/src/test/java/org/apache/distributedlog/common/util/TimedOutTestsListener.java
create mode 100644 stream/distributedlog/distributedlog-common/src/test/java/org/apache/distributedlog/io/TestCompressionCodec.java
create mode 100755 stream/distributedlog/distributedlog-core/bin/common.sh
create mode 100755 stream/distributedlog/distributedlog-core/bin/dlog
create mode 100644 stream/distributedlog/distributedlog-core/conf/bookie.conf.template
create mode 100644 stream/distributedlog/distributedlog-core/conf/distributedlog.conf
create mode 100644 stream/distributedlog/distributedlog-core/conf/dlogenv.sh
create mode 100644 stream/distributedlog/distributedlog-core/conf/log4j.properties
create mode 100644 stream/distributedlog/distributedlog-core/conf/write_proxy.conf
create mode 100644 stream/distributedlog/distributedlog-core/conf/zookeeper.conf.dynamic.template
create mode 100644 stream/distributedlog/distributedlog-core/conf/zookeeper.conf.template
create mode 100644 stream/distributedlog/distributedlog-core/pom.xml
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/bookkeeper/client/BookKeeperAccessor.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/bookkeeper/client/LedgerReader.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/bookkeeper/client/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/AppendOnlyStreamReader.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/AppendOnlyStreamWriter.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/AsyncNotification.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/BKAbstractLogWriter.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/BKAsyncLogReader.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/BKAsyncLogWriter.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/BKDistributedLogManager.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/BKDistributedLogNamespace.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/BKLogHandler.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/BKLogReadHandler.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/BKLogSegmentWriter.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/BKLogWriteHandler.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/BKSyncLogReader.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/BKSyncLogWriter.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/BKTransmitPacket.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/BookKeeperClient.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/BookKeeperClientBuilder.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/DistributedLogConfiguration.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/DistributedLogConstants.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/Entry.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/EntryBuffer.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/EntryPosition.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/EnvelopedEntry.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/EnvelopedEntryReader.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/EnvelopedEntryWriter.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/LocalDLMEmulator.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/LogSegmentMetadata.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/MaxLogSegmentSequenceNo.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/MaxTxId.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/ReadAheadEntryReader.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/ReadUtils.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/WriteLimiter.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/ZooKeeperClient.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/ZooKeeperClientBuilder.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/acl/AccessControlManager.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/acl/DefaultAccessControlManager.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/acl/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/admin/DistributedLogAdmin.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/admin/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/api/AsyncLogReader.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/api/AsyncLogWriter.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/api/DistributedLogManager.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/api/LogReader.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/api/LogWriter.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/api/MetadataAccessor.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/api/namespace/Namespace.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/api/namespace/NamespaceBuilder.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/api/namespace/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/api/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/api/subscription/SubscriptionStateStore.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/api/subscription/SubscriptionsStore.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/api/subscription/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/auditor/DLAuditor.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/auditor/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/bk/DynamicQuorumConfigProvider.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/bk/ImmutableQuorumConfigProvider.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/bk/LedgerAllocator.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/bk/LedgerAllocatorDelegator.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/bk/LedgerAllocatorPool.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/bk/LedgerAllocatorUtils.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/bk/QuorumConfig.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/bk/QuorumConfigProvider.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/bk/SimpleLedgerAllocator.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/bk/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/callback/LogSegmentListener.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/callback/LogSegmentNamesListener.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/callback/NamespaceListener.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/callback/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/config/DynamicConfigurationFactory.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/config/DynamicDistributedLogConfiguration.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/config/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/exceptions/ZKException.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/exceptions/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/feature/AbstractFeatureProvider.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/feature/ConfigurationFeatureProvider.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/feature/CoreFeatureKeys.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/feature/DefaultFeatureProvider.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/feature/DynamicConfigurationFeatureProvider.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/feature/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/function/GetLastTxIdFunction.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/function/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/impl/BKNamespaceDriver.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/impl/ZKLogMetadataStore.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/impl/ZKLogSegmentFilters.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/impl/ZKLogSegmentMetadataStore.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/impl/ZKMetadataAccessor.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/impl/ZKNamespaceWatcher.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/impl/acl/ZKAccessControl.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/impl/acl/ZKAccessControlManager.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/impl/acl/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/impl/federated/FederatedZKLogMetadataStore.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/impl/federated/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/impl/logsegment/BKLogSegmentAllocator.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/impl/logsegment/BKLogSegmentEntryReader.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/impl/logsegment/BKLogSegmentEntryStore.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/impl/logsegment/BKLogSegmentEntryWriter.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/impl/logsegment/BKLogSegmentRandomAccessEntryReader.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/impl/logsegment/BKUtils.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/impl/logsegment/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/impl/metadata/BKDLConfig.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/impl/metadata/ZKLogStreamMetadataStore.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/impl/metadata/ZkMetadataResolver.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/impl/metadata/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/impl/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/impl/subscription/ZKSubscriptionStateStore.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/impl/subscription/ZKSubscriptionsStore.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/impl/subscription/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/injector/AsyncFailureInjector.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/injector/AsyncRandomFailureInjector.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/injector/FailureInjector.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/injector/RandomDelayFailureInjector.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/injector/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/limiter/ChainedRequestLimiter.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/limiter/ComposableRequestLimiter.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/limiter/GuavaRateLimiter.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/limiter/RateLimiter.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/limiter/RequestLimiter.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/limiter/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/lock/DistributedLock.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/lock/DistributedLockContext.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/lock/EpochChangedException.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/lock/LockAction.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/lock/LockClosedException.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/lock/LockListener.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/lock/LockSessionExpiredException.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/lock/LockStateChangedException.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/lock/LockTimeoutException.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/lock/LockWaiter.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/lock/NopDistributedLock.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/lock/SessionLock.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/lock/SessionLockFactory.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/lock/ZKDistributedLock.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/lock/ZKSessionLock.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/lock/ZKSessionLockFactory.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/lock/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentEntryReader.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentEntryStore.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentEntryWriter.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentFilter.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentMetadataCache.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentMetadataStore.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentRandomAccessEntryReader.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/LogSegmentWriter.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/PerStreamLogSegmentCache.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/RollingPolicy.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/SizeBasedRollingPolicy.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/TimeBasedRollingPolicy.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/logsegment/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/metadata/DLConfig.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/metadata/DLMetadata.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/metadata/DryrunLogSegmentMetadataStoreUpdater.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/metadata/LogMetadata.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/metadata/LogMetadataForReader.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/metadata/LogMetadataForWriter.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/metadata/LogMetadataStore.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/metadata/LogSegmentMetadataStoreUpdater.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/metadata/LogStreamMetadataStore.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/metadata/MetadataResolver.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/metadata/MetadataUpdater.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/metadata/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/namespace/NamespaceDriver.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/namespace/NamespaceDriverManager.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/namespace/NamespaceWatcher.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/namespace/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/net/DNSResolver.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/net/DNSResolverForRacks.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/net/DNSResolverForRows.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/net/NetUtils.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/net/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/selector/FirstDLSNNotLessThanSelector.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/selector/FirstRecordSelector.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/selector/FirstTxIdNotLessThanSelector.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/selector/LastRecordSelector.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/selector/LogRecordSelector.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/selector/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/thrift/AccessControlEntry.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/thrift/BKDLConfigFormat.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/thrift/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/tools/DistributedLogTool.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/tools/Tool.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/tools/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/util/Allocator.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/util/CommandLineUtils.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/util/ConfUtils.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/util/DLUtils.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/util/FailpointUtils.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/util/RetryPolicyUtils.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/util/SimplePermitLimiter.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/util/TimeSequencer.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/util/Transaction.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/util/Utils.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/util/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/zk/DefaultZKOp.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/zk/LimitedPermitManager.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/zk/ZKOp.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/zk/ZKTransaction.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/zk/ZKVersionedSetOp.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/zk/ZKWatcherManager.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/java/org/apache/distributedlog/zk/package-info.java
create mode 100644 stream/distributedlog/distributedlog-core/src/main/resources/config/decider.conf
create mode 100644 stream/distributedlog/distributedlog-core/src/main/resources/config/decider.yml
create mode 100644 stream/distributedlog/distributedlog-core/src/main/thrift/metadata.thrift
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/DLMTestUtil.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/NonBlockingReadsTestUtil.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestAppendOnlyStreamReader.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestAppendOnlyStreamWriter.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestAsyncBulkWrite.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestAsyncReaderLock.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestAsyncReaderWriter.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestBKDistributedLogManager.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestBKDistributedLogNamespace.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestBKLogReadHandler.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestBKLogSegmentWriter.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestBKLogWriteHandler.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestBKSyncLogReader.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestDLMTestUtil.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestDistributedLogBase.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestDistributedLogConfiguration.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestEntry.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestEntryPosition.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestInterleavedReaders.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestLogSegmentCreation.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestLogSegmentMetadata.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestLogSegmentsZK.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestNonBlockingReads.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestNonBlockingReadsMultiReader.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestReadAheadEntryReader.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestReadUtils.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestReader.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestRollLogSegments.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestSequenceID.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestTruncate.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestWriteLimiter.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestZooKeeperClient.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/TestZooKeeperClientBuilder.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/ZooKeeperClientUtils.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/ZooKeeperClusterTestCase.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/acl/TestZKAccessControl.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/acl/TestZKAccessControlManager.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/admin/TestDLCK.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/admin/TestDistributedLogAdmin.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/bk/TestLedgerAllocator.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/bk/TestLedgerAllocatorPool.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/config/PropertiesWriter.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/config/TestDynamicConfigurationFactory.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/config/TestDynamicDistributedLogConfiguration.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/feature/TestConfigurationFeatureProvider.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/feature/TestDynamicConfigurationFeatureProvider.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/impl/TestZKLogMetadataStore.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/impl/TestZKLogSegmentFilters.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/impl/TestZKLogSegmentMetadataStore.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/impl/TestZKNamespaceWatcher.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/impl/federated/TestFederatedZKLogMetadataStore.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/impl/logsegment/TestBKLogSegmentEntryReader.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/impl/metadata/TestZKLogStreamMetadataStore.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/impl/metadata/TestZKLogStreamMetadataStoreUtils.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/impl/metadata/TestZkMetadataResolver.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/limiter/TestRequestLimiter.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/lock/TestDistributedLock.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/lock/TestZKSessionLock.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/logsegment/TestPerStreamLogSegmentCache.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/logsegment/TestRollingPolicy.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/metadata/TestDLMetadata.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/metadata/TestLogMetadata.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/metadata/TestLogSegmentMetadataStoreUpdater.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/namespace/TestNamespaceBuilder.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/net/TestDNSResolver.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/net/TestNetUtils.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/selector/TestLogRecordSelectors.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/tools/TestDistributedLogTool.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/util/TestConfUtils.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/util/TestDLUtils.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/util/TestPermitManager.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/util/TestTimeSequencer.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/util/TestUtils.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/zk/TestZKTransaction.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/zk/TestZKVersionedSetOp.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/java/org/apache/distributedlog/zk/TestZKWatcherManager.java
create mode 100644 stream/distributedlog/distributedlog-core/src/test/resources/bk_server.conf
create mode 100644 stream/distributedlog/distributedlog-core/src/test/resources/log4j.properties
create mode 100644 stream/distributedlog/distributedlog-io/dlfs/pom.xml
create mode 100644 stream/distributedlog/distributedlog-io/dlfs/src/main/java/org/apache/distributedlog/fs/DLFileSystem.java
create mode 100644 stream/distributedlog/distributedlog-io/dlfs/src/main/java/org/apache/distributedlog/fs/DLInputStream.java
create mode 100644 stream/distributedlog/distributedlog-io/dlfs/src/main/java/org/apache/distributedlog/fs/DLOutputStream.java
create mode 100644 stream/distributedlog/distributedlog-io/dlfs/src/main/java/org/apache/distributedlog/fs/package-info.java
create mode 100644 stream/distributedlog/distributedlog-io/dlfs/src/test/java/org/apache/distributedlog/fs/TestDLFSBase.java
create mode 100644 stream/distributedlog/distributedlog-io/dlfs/src/test/java/org/apache/distributedlog/fs/TestDLFileSystem.java
create mode 100644 stream/distributedlog/distributedlog-io/dlfs/src/test/resources/dlfs.conf
create mode 100644 stream/distributedlog/distributedlog-io/pom.xml
create mode 100644 stream/distributedlog/distributedlog-protocol/pom.xml
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/DLSN.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/EnvelopedRecordSetReader.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/EnvelopedRecordSetWriter.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/LogRecord.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/LogRecordSet.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/LogRecordSetBuffer.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/LogRecordWithDLSN.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/RecordStream.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/TransmitListener.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/AlreadyClosedException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/AlreadyTruncatedTransactionException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/BKTransmitException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/ChecksumFailedException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/DLClientClosedException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/DLException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/DLIllegalStateException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/DLInterruptedException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/EndOfLogSegmentException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/EndOfStreamException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/FlushException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/IdleReaderException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/InternalServerException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/InvalidEnvelopedEntryException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/InvalidStreamNameException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/LockCancelledException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/LockingException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/LogEmptyException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/LogExistsException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/LogNotFoundException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/LogReadException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/LogRecordTooLongException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/LogSegmentIsTruncatedException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/LogSegmentNotFoundException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/MetadataException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/NotYetImplementedException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/OverCapacityException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/OwnershipAcquireFailedException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/ReadCancelledException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/RegionUnavailableException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/RequestDeniedException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/RetryableReadException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/ServiceUnavailableException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/StatusCode.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/StreamNotReadyException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/StreamUnavailableException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/TooManyStreamsException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/TransactionIdOutOfOrderException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/UnexpectedException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/UnsupportedMetadataVersionException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/WriteCancelledException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/WriteException.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/exceptions/package-info.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/main/java/org/apache/distributedlog/package-info.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/test/java/org/apache/distributedlog/TestDLSN.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/test/java/org/apache/distributedlog/TestLogRecordSet.java
create mode 100644 stream/distributedlog/distributedlog-protocol/src/test/resources/log4j.properties
--
To stop receiving notification emails like this one, please contact
sijie@apache.org.
[bookkeeper] 01/01: Merge remote-tracking branch 'apache/master'
into copy_distributedlog
Posted by si...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
sijie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/bookkeeper.git
commit 937de490b8e2df9ea0e247f15b481015afa21c54
Merge: 9f016a0 8a25353
Author: Sijie Guo <si...@apache.org>
AuthorDate: Wed Jan 31 10:59:04 2018 -0800
Merge remote-tracking branch 'apache/master' into copy_distributedlog
.test-infra/jenkins/common_job_properties.groovy | 2 +-
.../jenkins/job_bookkeeper_precommit_java8.groovy | 2 +-
.../jenkins/job_bookkeeper_precommit_java9.groovy | 2 +-
bookkeeper-server/pom.xml | 38 +++-
.../org/apache/bookkeeper/bookie/BookieShell.java | 9 +-
.../bookkeeper/client/BookKeeperClientStats.java | 5 +
.../bookkeeper/conf/AbstractConfiguration.java | 29 ++-
.../bookkeeper/conf/ClientConfiguration.java | 76 +++++--
.../bookkeeper/conf/ServerConfiguration.java | 29 ++-
.../apache/bookkeeper/proto/BookieNettyServer.java | 1 +
.../org/apache/bookkeeper/proto/BookieServer.java | 26 +++
.../bookkeeper/proto/PerChannelBookieClient.java | 72 ++++++-
.../apache/bookkeeper/tls/TLSContextFactory.java | 221 ++++++++++++++++-----
.../bookie/BookieInitializationTest.java | 101 ++++++++++
.../org/apache/bookkeeper/test/PortManager.java | 23 +--
.../java/org/apache/bookkeeper/tls/TestTLS.java | 144 +++++++++++---
bookkeeper-server/src/test/resources/cacerts | Bin 110225 -> 0 bytes
.../src/test/resources/client-cert.pem | 32 +++
.../src/test/resources/client-key.jks | Bin 0 -> 3941 bytes
.../src/test/resources/client-key.p12 | Bin 0 -> 4189 bytes
.../src/test/resources/client-key.pem | 52 +++++
bookkeeper-server/src/test/resources/client.jks | Bin 1416 -> 0 bytes
.../src/test/resources/generateKeysAndCerts.sh | 76 +++++++
.../src/test/resources/server-cert.pem | 32 +++
.../src/test/resources/server-key.jks | Bin 0 -> 3941 bytes
.../src/test/resources/server-key.p12 | Bin 0 -> 4189 bytes
.../src/test/resources/server-key.pem | 52 +++++
bookkeeper-server/src/test/resources/server.jks | Bin 1393 -> 0 bytes
.../src/test/resources/trustStorePassword.txt | 1 -
.../prometheus/PrometheusMetricsProvider.java | 25 ++-
.../prometheus/TestPrometheusMetricsProvider.java | 23 +++
.../twitter/finagle/FinagleStatsProvider.java | 22 +-
site/docs/4.6.1/api/ledger-api.md | 63 ++++++
site/docs/4.6.1/overview/releaseNotes.md | 17 +-
site/releases.md | 9 +
.../{ => current-server-old-clients}/pom.xml | 28 ++-
.../backwardcompat/TestCompatOldClients.groovy | 174 ++++++++++++++++
.../src/test/resources/arquillian.xml | 28 +++
.../TestCompatHierarchicalLedgerManager.groovy | 61 +++---
.../TestCompatUpgradeWithHostnameBookieId.groovy | 98 +++++----
...mpatUpgradeOldServerInClusterWithCookies.groovy | 67 ++++---
tests/backward-compat/pom.xml | 1 +
.../TestCompatRecoveryNoPassword.groovy | 177 +++++++++--------
.../TestCompatUpgradeDirect.groovy | 113 ++++++-----
.../{ => backwardcompat}/TestCompatUpgrade.groovy | 82 ++++----
.../bookkeeper/tests/BookKeeperClusterUtils.java | 17 ++
46 files changed, 1604 insertions(+), 426 deletions(-)
--
To stop receiving notification emails like this one, please contact
sijie@apache.org.