You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by vf...@apache.org on 2015/11/25 20:08:03 UTC
[50/50] [abbrv] incubator-geode git commit: Merge branch 'develop'
into feature/GEODE-78
Merge branch 'develop' into feature/GEODE-78
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/f29845a0
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/f29845a0
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/f29845a0
Branch: refs/heads/feature/GEODE-78
Commit: f29845a0cd308dec2f51f8642477f90ebb461c23
Parents: ee567c3 17fdf57
Author: Vince Ford <vf...@apache.org>
Authored: Mon Oct 12 16:12:10 2015 -0700
Committer: Vince Ford <vf...@apache.org>
Committed: Mon Oct 12 16:12:10 2015 -0700
----------------------------------------------------------------------
README.md | 2 +-
build.gradle | 20 +-
docker/Dockerfile | 56 +
docker/README.md | 67 +
etc/eclipseFormatterProfile.xml | 11 +-
gemfire-assembly/build.gradle | 3 +-
.../src/test/java/AgentUtilJUnitTest.java | 109 -
.../management/internal/AgentUtilJUnitTest.java | 106 +
gemfire-core/build.gradle | 30 +-
.../com/gemstone/gemfire/DataSerializer.java | 11 +-
.../gemfire/admin/GemFireMemberStatus.java | 13 +-
.../gemfire/admin/SystemMemberBridgeServer.java | 5 +-
.../gemfire/admin/SystemMemberCache.java | 27 -
.../DistributedSystemHealthMonitor.java | 2 +-
.../admin/internal/SystemMemberCacheImpl.java | 17 +-
.../jmx/internal/SystemMemberCacheJmxImpl.java | 13 -
.../gemfire/cache/AttributesFactory.java | 31 -
.../java/com/gemstone/gemfire/cache/Cache.java | 27 -
.../gemfire/cache/DiskStoreFactory.java | 15 +-
.../gemfire/cache/DynamicRegionFactory.java | 121 +-
.../gemstone/gemfire/cache/EvictionAction.java | 3 +-
.../gemfire/cache/EvictionAlgorithm.java | 3 +-
.../gemstone/gemfire/cache/RegionService.java | 2 +-
.../cache/client/ClientCacheFactory.java | 18 +-
.../gemfire/cache/client/PoolFactory.java | 28 +-
.../cache/client/internal/AbstractOp.java | 2 +-
.../cache/client/internal/BridgePoolImpl.java | 479 -----
.../internal/BridgeServerLoadMessage.java | 99 -
.../client/internal/CacheServerLoadMessage.java | 99 +
.../client/internal/ConnectionFactoryImpl.java | 7 +-
.../cache/client/internal/ConnectionImpl.java | 6 +-
.../cache/client/internal/DestroyOp.java | 5 -
.../client/internal/EndpointManagerImpl.java | 8 +-
.../internal/ExplicitConnectionSourceImpl.java | 85 +-
.../gemfire/cache/client/internal/GetOp.java | 5 -
.../gemfire/cache/client/internal/PoolImpl.java | 14 +-
.../gemfire/cache/client/internal/PutOp.java | 5 -
.../cache/client/internal/QueueManagerImpl.java | 14 +-
.../cache/client/internal/QueueStateImpl.java | 6 +-
.../internal/RegisterDataSerializersOp.java | 8 +-
.../internal/RegisterInstantiatorsOp.java | 8 +-
.../client/internal/ServerRegionProxy.java | 44 +-
.../internal/FunctionServiceManager.java | 3 +-
.../cache/hdfs/HDFSEventQueueAttributes.java | 72 -
.../hdfs/HDFSEventQueueAttributesFactory.java | 160 --
.../gemstone/gemfire/cache/hdfs/HDFSStore.java | 381 +++-
.../gemfire/cache/hdfs/HDFSStoreFactory.java | 271 +--
.../gemfire/cache/hdfs/HDFSStoreMutator.java | 315 ++-
.../internal/HDFSEventQueueAttributesImpl.java | 179 --
.../hdfs/internal/HDFSIntegrationUtil.java | 121 +-
.../hdfs/internal/HDFSStoreConfigHolder.java | 658 +++---
.../cache/hdfs/internal/HDFSStoreCreation.java | 189 +-
.../hdfs/internal/HDFSStoreFactoryImpl.java | 2 +
.../cache/hdfs/internal/HDFSStoreImpl.java | 87 +-
.../hdfs/internal/HDFSStoreMutatorImpl.java | 279 +--
.../SizeTieredHdfsCompactionConfigHolder.java | 74 -
.../internal/hoplog/HDFSCompactionManager.java | 27 +-
.../hoplog/HDFSUnsortedHoplogOrganizer.java | 10 +-
.../hoplog/HdfsSortedOplogOrganizer.java | 22 +-
.../cache/operations/GetOperationContext.java | 7 +-
.../operations/KeyValueOperationContext.java | 70 +-
.../internal/GetOperationContextImpl.java | 16 +-
.../cache/query/internal/CompiledSelect.java | 39 +-
.../cache/query/internal/DefaultQuery.java | 9 +-
.../cache/query/internal/RuntimeIterator.java | 3 -
.../query/internal/index/AbstractIndex.java | 4 +-
.../query/internal/index/AbstractMapIndex.java | 6 +-
.../internal/index/CompactMapRangeIndex.java | 7 +-
.../index/FunctionalIndexCreationHelper.java | 1 -
.../cache/query/internal/index/HashIndex.java | 11 +
.../query/internal/index/PartitionedIndex.java | 16 +-
.../gemfire/cache/server/ServerLoadProbe.java | 10 +-
.../gemfire/cache/server/ServerMetrics.java | 10 +-
.../cache/server/internal/LoadMonitor.java | 12 +-
.../gemfire/cache/util/BridgeClient.java | 156 --
.../gemfire/cache/util/BridgeLoader.java | 607 ------
.../gemfire/cache/util/BridgeMembership.java | 55 -
.../cache/util/BridgeMembershipEvent.java | 23 -
.../cache/util/BridgeMembershipListener.java | 41 -
.../util/BridgeMembershipListenerAdapter.java | 43 -
.../gemfire/cache/util/BridgeServer.java | 442 ----
.../gemfire/cache/util/BridgeWriter.java | 795 -------
.../cache/util/BridgeWriterException.java | 48 -
.../util/EndpointDoesNotExistException.java | 34 -
.../gemfire/cache/util/EndpointException.java | 61 -
.../cache/util/EndpointExistsException.java | 28 -
.../cache/util/EndpointInUseException.java | 27 -
.../util/IncompatibleVersionException.java | 47 -
.../util/ServerRefusedConnectionException.java | 36 -
.../UniversalMembershipListenerAdapter.java | 352 ---
.../cache/util/UnknownVersionException.java | 39 -
.../gemfire/cache/util/VersionException.java | 45 -
.../gemstone/gemfire/cache/util/package.html | 3 -
.../gemfire/distributed/DistributedSystem.java | 44 +-
.../gemfire/distributed/ServerLauncher.java | 4 +-
.../internal/AbstractDistributionConfig.java | 21 +-
.../internal/DistributionConfig.java | 12 +
.../internal/DistributionConfigImpl.java | 15 +-
.../FunctionExecutionPooledExecutor.java | 7 +-
.../internal/InternalDistributedSystem.java | 12 +-
.../internal/PooledExecutorWithDMStats.java | 7 +-
.../distributed/internal/ServerLocator.java | 10 +-
.../jgroup/JGroupMembershipManager.java | 8 +-
.../gemstone/gemfire/internal/DSFIDFactory.java | 12 +-
.../internal/DataSerializableFixedID.java | 6 +-
.../internal/InternalDataSerializer.java | 33 +-
.../gemstone/gemfire/internal/NanoTimer.java | 37 +-
.../gemfire/internal/SharedLibrary.java | 20 +-
.../gemstone/gemfire/internal/SocketCloser.java | 241 +++
.../gemfire/internal/SocketCreator.java | 98 -
.../internal/admin/ClientStatsManager.java | 7 -
.../gemfire/internal/admin/GemFireVM.java | 2 +-
.../admin/remote/BridgeServerResponse.java | 18 +-
.../admin/remote/DurableClientInfoResponse.java | 4 +-
.../admin/remote/RemoteBridgeServer.java | 10 +-
.../internal/admin/remote/RemoteCacheInfo.java | 6 +-
.../internal/admin/remote/RemoteGemFireVM.java | 2 +-
.../internal/cache/AbstractBridgeServer.java | 425 ----
.../internal/cache/AbstractCacheServer.java | 398 ++++
.../gemfire/internal/cache/AbstractRegion.java | 54 +-
.../internal/cache/AbstractRegionEntry.java | 2 +-
.../gemfire/internal/cache/BridgeObserver.java | 89 -
.../internal/cache/BridgeObserverAdapter.java | 107 -
.../internal/cache/BridgeObserverHolder.java | 53 -
.../internal/cache/BridgeRegionEventImpl.java | 108 -
.../internal/cache/BridgeServerAdvisor.java | 165 --
.../internal/cache/BridgeServerImpl.java | 816 -------
.../gemfire/internal/cache/BucketAdvisor.java | 2 +-
.../gemfire/internal/cache/BucketRegion.java | 10 +
.../gemfire/internal/cache/CacheConfig.java | 12 +-
.../internal/cache/CacheServerAdvisor.java | 164 ++
.../gemfire/internal/cache/CacheServerImpl.java | 812 +++++++
.../internal/cache/ClientRegionEventImpl.java | 108 +
.../internal/cache/ClientServerObserver.java | 90 +
.../cache/ClientServerObserverAdapter.java | 107 +
.../cache/ClientServerObserverHolder.java | 53 +
.../internal/cache/DestroyRegionOperation.java | 6 +-
.../gemfire/internal/cache/DiskEntry.java | 29 +-
.../gemfire/internal/cache/DiskRegion.java | 9 +
.../gemfire/internal/cache/DiskRegionStats.java | 22 +
.../cache/DistTXAdjunctCommitMessage.java | 35 +
.../internal/cache/DistTXCommitMessage.java | 12 +-
.../gemfire/internal/cache/DistTXState.java | 77 +-
.../DistTXStateProxyImplOnCoordinator.java | 28 +-
.../cache/DistributedCacheOperation.java | 10 +-
.../cache/DistributedClearOperation.java | 6 +-
.../internal/cache/DistributedRegion.java | 6 -
.../gemfire/internal/cache/EntryEventImpl.java | 10 +-
.../gemfire/internal/cache/ExpiryTask.java | 46 +-
.../cache/FindDurableQueueProcessor.java | 4 +-
.../internal/cache/GemFireCacheImpl.java | 101 +-
.../gemfire/internal/cache/GridAdvisor.java | 6 +-
.../gemfire/internal/cache/LocalRegion.java | 80 +-
.../cache/MinimumSystemRequirements.java | 4 +-
.../internal/cache/PartitionedRegion.java | 19 +-
.../internal/cache/PartitionedRegionStats.java | 12 +-
.../gemfire/internal/cache/PoolFactoryImpl.java | 174 +-
.../gemfire/internal/cache/PoolManagerImpl.java | 19 -
.../gemfire/internal/cache/RegionEventImpl.java | 2 +-
.../internal/cache/RegionIdleExpiryTask.java | 5 +-
.../internal/cache/RegionTTLExpiryTask.java | 2 +-
.../internal/cache/RemoteOperationMessage.java | 2 +
.../internal/cache/RemotePutMessage.java | 56 +-
.../gemfire/internal/cache/TXCommitMessage.java | 109 +-
.../gemfire/internal/cache/TXEntryState.java | 19 +-
.../gemfire/internal/cache/TXManagerImpl.java | 11 +-
.../gemfire/internal/cache/TXRegionState.java | 50 +-
.../cache/control/HeapMemoryMonitor.java | 14 +-
.../cache/control/InternalResourceManager.java | 15 +-
.../internal/cache/control/MemoryEvent.java | 9 +-
.../cache/control/OffHeapMemoryMonitor.java | 88 +-
.../control/PartitionRebalanceDetailsImpl.java | 8 +-
.../cache/control/RebalanceOperationImpl.java | 157 +-
.../cache/control/RebalanceResultsImpl.java | 16 +-
.../cache/control/ResourceManagerStats.java | 13 +
.../internal/cache/doc-files/properties.html | 4 +-
.../cache/execute/InternalFunctionService.java | 4 +-
.../internal/cache/ha/HARegionQueue.java | 6 +-
.../internal/cache/partitioned/GetMessage.java | 6 +
.../cache/partitioned/PartitionMessage.java | 4 +-
.../PartitionedRegionObserverHolder.java | 2 +-
.../PartitionedRegionRebalanceOp.java | 100 +-
.../cache/partitioned/PutAllPRMessage.java | 37 +
.../internal/cache/partitioned/PutMessage.java | 21 +-
.../partitioned/rebalance/BucketOperator.java | 46 +-
.../rebalance/ParallelBucketOperator.java | 151 ++
.../rebalance/PartitionedRegionLoadModel.java | 45 +-
.../rebalance/SatisfyRedundancy.java | 7 +-
.../rebalance/SatisfyRedundancyFPR.java | 1 +
.../rebalance/SimulatedBucketOperator.java | 11 +-
.../internal/cache/tier/ConnectionProxy.java | 160 +-
.../cache/tier/InternalBridgeMembership.java | 715 ------
.../cache/tier/InternalClientMembership.java | 617 ++++++
.../cache/tier/sockets/AcceptorImpl.java | 20 +-
.../cache/tier/sockets/CacheClientNotifier.java | 26 +-
.../cache/tier/sockets/CacheClientProxy.java | 38 +-
.../cache/tier/sockets/CacheClientUpdater.java | 12 +-
.../tier/sockets/ClientBlacklistProcessor.java | 4 +-
.../RemoveClientFromBlacklistMessage.java | 4 +-
.../cache/tier/sockets/ServerConnection.java | 8 +-
.../doc-files/communication-architecture.fig | 4 +-
.../internal/cache/tx/DistTxEntryEvent.java | 70 +-
.../AbstractGatewaySenderEventProcessor.java | 1 +
.../cache/wan/GatewaySenderAdvisor.java | 1 -
.../parallel/ParallelGatewaySenderQueue.java | 41 +-
.../wan/serial/SerialGatewaySenderQueue.java | 2 +
.../cache/xmlcache/BridgeServerCreation.java | 249 ---
.../internal/cache/xmlcache/CacheCreation.java | 49 +-
.../cache/xmlcache/CacheServerCreation.java | 238 ++
.../cache/xmlcache/CacheXmlGenerator.java | 41 +-
.../internal/cache/xmlcache/CacheXmlParser.java | 152 +-
.../cache/xmlcache/ClientCacheCreation.java | 5 -
.../xmlcache/RegionAttributesCreation.java | 9 -
.../gemfire/internal/i18n/LocalizedStrings.java | 22 +-
.../internal/i18n/ParentLocalizedStrings.java | 81 +-
.../gemfire/internal/lang/StringUtils.java | 364 +++-
.../gemfire/internal/lang/SystemUtils.java | 35 +-
.../gemfire/internal/logging/LogService.java | 56 +-
.../internal/logging/log4j/Configurator.java | 73 +-
.../internal/logging/log4j/FastLogger.java | 50 +-
.../offheap/OffHeapCachedDeserializable.java | 27 +-
.../offheap/SimpleMemoryAllocatorImpl.java | 46 +-
.../gemfire/internal/offheap/StoredObject.java | 26 +-
.../internal/redis/ByteArrayWrapper.java | 11 +-
.../internal/redis/ByteToCommandDecoder.java | 57 +-
.../gemstone/gemfire/internal/redis/Coder.java | 228 +-
.../gemfire/internal/redis/Command.java | 25 +-
.../gemfire/internal/redis/DoubleWrapper.java | 14 +-
.../internal/redis/ExecutionHandlerContext.java | 202 +-
.../gemfire/internal/redis/Executor.java | 2 +-
.../gemfire/internal/redis/Extendable.java | 6 +-
.../internal/redis/RedisCommandType.java | 21 +
.../gemfire/internal/redis/RedisConstants.java | 6 +-
.../gemfire/internal/redis/RedisDataType.java | 9 -
.../gemfire/internal/redis/RegionCache.java | 410 ----
.../internal/redis/RegionCreationException.java | 9 +-
.../gemfire/internal/redis/RegionProvider.java | 538 +++++
.../redis/executor/AbstractExecutor.java | 12 +-
.../redis/executor/AbstractScanExecutor.java | 2 +-
.../internal/redis/executor/AuthExecutor.java | 38 +
.../internal/redis/executor/DBSizeExecutor.java | 2 +-
.../internal/redis/executor/DelExecutor.java | 2 +-
.../internal/redis/executor/EchoExecutor.java | 2 +-
.../internal/redis/executor/ExistsExecutor.java | 2 +-
.../redis/executor/ExpirationExecutor.java | 6 +-
.../redis/executor/ExpireAtExecutor.java | 4 +-
.../internal/redis/executor/ExpireExecutor.java | 4 +-
.../redis/executor/FlushAllExecutor.java | 15 +-
.../internal/redis/executor/KeysExecutor.java | 7 +-
.../internal/redis/executor/ListQuery.java | 12 +-
.../redis/executor/PersistExecutor.java | 2 +-
.../internal/redis/executor/PingExecutor.java | 2 +-
.../internal/redis/executor/QuitExecutor.java | 2 +-
.../internal/redis/executor/ScanExecutor.java | 4 +-
.../internal/redis/executor/SortedSetQuery.java | 36 +-
.../internal/redis/executor/TTLExecutor.java | 4 +-
.../internal/redis/executor/TypeExecutor.java | 2 +-
.../internal/redis/executor/UnkownExecutor.java | 2 +-
.../redis/executor/hash/HDelExecutor.java | 2 +-
.../redis/executor/hash/HGetAllExecutor.java | 7 +-
.../redis/executor/hash/HKeysExecutor.java | 7 +-
.../redis/executor/hash/HScanExecutor.java | 5 +-
.../redis/executor/hash/HValsExecutor.java | 9 +-
.../redis/executor/hash/HashExecutor.java | 4 +-
.../redis/executor/hll/HllExecutor.java | 2 +-
.../redis/executor/hll/PFAddExecutor.java | 2 +-
.../redis/executor/hll/PFCountExecutor.java | 2 +-
.../redis/executor/hll/PFMergeExecutor.java | 4 +-
.../redis/executor/list/LIndexExecutor.java | 4 +-
.../redis/executor/list/LLenExecutor.java | 2 +-
.../redis/executor/list/LRangeExecutor.java | 10 +-
.../redis/executor/list/LRemExecutor.java | 4 +-
.../redis/executor/list/LSetExecutor.java | 4 +-
.../redis/executor/list/LTrimExecutor.java | 26 +-
.../redis/executor/list/ListExecutor.java | 26 +-
.../redis/executor/list/PopExecutor.java | 23 +-
.../redis/executor/list/PushExecutor.java | 2 +-
.../redis/executor/list/PushXExecutor.java | 2 +-
.../org/apache/hadoop/fs/GlobPattern.java | 164 --
.../redis/executor/set/SAddExecutor.java | 2 +-
.../redis/executor/set/SCardExecutor.java | 2 +-
.../redis/executor/set/SIsMemberExecutor.java | 2 +-
.../redis/executor/set/SMembersExecutor.java | 7 +-
.../redis/executor/set/SMoveExecutor.java | 2 +-
.../redis/executor/set/SPopExecutor.java | 4 +-
.../redis/executor/set/SRandMemberExecutor.java | 4 +-
.../redis/executor/set/SRemExecutor.java | 2 +-
.../redis/executor/set/SScanExecutor.java | 4 +-
.../redis/executor/set/SetOpExecutor.java | 9 +-
.../executor/sortedset/SortedSetExecutor.java | 4 +-
.../executor/sortedset/ZRangeByLexExecutor.java | 2 -
.../sortedset/ZRangeByScoreExecutor.java | 3 +-
.../redis/executor/sortedset/ZRemExecutor.java | 2 +-
.../sortedset/ZRemRangeByLexExecutor.java | 3 +-
.../sortedset/ZRemRangeByRankExecutor.java | 4 +-
.../sortedset/ZRemRangeByScoreExecutor.java | 4 +-
.../redis/executor/sortedset/ZScanExecutor.java | 5 +-
.../redis/executor/string/AppendExecutor.java | 2 +-
.../redis/executor/string/BitCountExecutor.java | 2 +-
.../redis/executor/string/BitOpExecutor.java | 2 +-
.../redis/executor/string/BitPosExecutor.java | 2 +-
.../redis/executor/string/DecrByExecutor.java | 2 +-
.../redis/executor/string/DecrExecutor.java | 4 +-
.../redis/executor/string/GetBitExecutor.java | 2 +-
.../redis/executor/string/GetExecutor.java | 2 +-
.../redis/executor/string/GetRangeExecutor.java | 2 +-
.../redis/executor/string/GetSetExecutor.java | 2 +-
.../redis/executor/string/IncrByExecutor.java | 2 +-
.../executor/string/IncrByFloatExecutor.java | 2 +-
.../redis/executor/string/IncrExecutor.java | 2 +-
.../redis/executor/string/MGetExecutor.java | 2 +-
.../redis/executor/string/MSetExecutor.java | 2 +-
.../redis/executor/string/MSetNXExecutor.java | 2 +-
.../redis/executor/string/SetBitExecutor.java | 2 +-
.../redis/executor/string/SetEXExecutor.java | 4 +-
.../redis/executor/string/SetExecutor.java | 4 +-
.../redis/executor/string/SetNXExecutor.java | 2 +-
.../redis/executor/string/SetRangeExecutor.java | 4 +-
.../redis/executor/string/StringExecutor.java | 4 +-
.../redis/executor/string/StrlenExecutor.java | 2 +-
.../redis/org/apache/hadoop/fs/GlobPattern.java | 164 ++
.../size/ReflectionSingleObjectSizer.java | 4 +-
.../gemfire/internal/tcp/Connection.java | 130 +-
.../gemfire/internal/tcp/ConnectionTable.java | 95 +-
.../gemfire/internal/tcp/MsgOutputStream.java | 4 +-
.../gfsh/aggregator/AggregateFunction.java | 67 -
.../tools/gfsh/aggregator/AggregateResults.java | 126 --
.../aggregator/AggregatorPartitionFunction.java | 54 -
.../tools/gfsh/app/CommandExecutable.java | 8 -
.../gemfire/internal/tools/gfsh/app/Gfsh.java | 2027 ------------------
.../internal/tools/gfsh/app/GfshVersion.java | 455 ----
.../internal/tools/gfsh/app/Nextable.java | 8 -
.../tools/gfsh/app/ServerExecutable.java | 11 -
.../app/aggregator/AggregateFunctionTask.java | 62 -
.../tools/gfsh/app/aggregator/Aggregator.java | 549 -----
.../app/aggregator/AggregatorException.java | 50 -
.../gfsh/app/aggregator/AggregatorPeer.java | 254 ---
.../functions/util/LocalRegionInfoFunction.java | 235 --
.../functions/util/RegionCreateFunction.java | 81 -
.../functions/util/RegionDestroyFunction.java | 86 -
.../tools/gfsh/app/cache/CacheBase.java | 178 --
.../gfsh/app/cache/InstantiatorClassLoader.java | 101 -
.../tools/gfsh/app/cache/data/GenericMap.java | 196 --
.../gfsh/app/cache/data/GenericMessage.java | 807 -------
.../app/cache/data/InvalidTypeException.java | 28 -
.../tools/gfsh/app/cache/data/ListMap.java | 197 --
.../gfsh/app/cache/data/ListMapMessage.java | 615 ------
.../tools/gfsh/app/cache/data/ListMessage.java | 594 -----
.../tools/gfsh/app/cache/data/Listable.java | 45 -
.../tools/gfsh/app/cache/data/MapMessage.java | 629 ------
.../tools/gfsh/app/cache/data/Mappable.java | 50 -
.../tools/gfsh/app/cache/index/EntryMap.java | 80 -
.../tools/gfsh/app/cache/index/IndexInfo.java | 52 -
.../tools/gfsh/app/cache/index/Indexer.java | 13 -
.../gfsh/app/cache/index/IndexerManager.java | 32 -
.../gfsh/app/cache/index/LookupService.java | 352 ---
.../app/cache/index/LookupServiceException.java | 64 -
.../gfsh/app/cache/index/task/ForceGCTask.java | 32 -
.../app/cache/index/task/IndexInfoTask.java | 131 --
.../app/cache/index/task/QuerySizeTask.java | 134 --
.../gfsh/app/cache/index/task/QueryTask.java | 323 ---
.../tools/gfsh/app/command/CommandClient.java | 417 ----
.../gfsh/app/command/CommandException.java | 31 -
.../app/command/CommandResultsListener.java | 15 -
.../tools/gfsh/app/command/task/EchoTask.java | 63 -
.../task/PartitionedRegionAttributeTask.java | 205 --
.../gfsh/app/command/task/QueryResults.java | 123 --
.../tools/gfsh/app/command/task/QueryTask.java | 522 -----
.../task/RefreshAggregatorRegionTask.java | 53 -
.../gfsh/app/command/task/RegionClearTask.java | 85 -
.../gfsh/app/command/task/RegionCreateTask.java | 162 --
.../app/command/task/RegionDestroyTask.java | 97 -
.../gfsh/app/command/task/RegionPathTask.java | 156 --
.../gfsh/app/command/task/RegionSizeTask.java | 70 -
.../gfsh/app/command/task/data/MemberInfo.java | 79 -
.../task/data/PartitionAttributeInfo.java | 124 --
.../command/task/data/RegionAttributeInfo.java | 286 ---
.../internal/tools/gfsh/app/commands/bcp.java | 527 -----
.../internal/tools/gfsh/app/commands/cd.java | 79 -
.../tools/gfsh/app/commands/classloader.java | 323 ---
.../internal/tools/gfsh/app/commands/clear.java | 197 --
.../tools/gfsh/app/commands/connect.java | 124 --
.../internal/tools/gfsh/app/commands/db.java | 312 ---
.../internal/tools/gfsh/app/commands/debug.java | 48 -
.../tools/gfsh/app/commands/deploy.java | 271 ---
.../internal/tools/gfsh/app/commands/echo.java | 59 -
.../internal/tools/gfsh/app/commands/fetch.java | 48 -
.../internal/tools/gfsh/app/commands/gc.java | 93 -
.../internal/tools/gfsh/app/commands/get.java | 143 --
.../internal/tools/gfsh/app/commands/help.java | 40 -
.../internal/tools/gfsh/app/commands/index.java | 395 ----
.../internal/tools/gfsh/app/commands/key.java | 67 -
.../internal/tools/gfsh/app/commands/local.java | 101 -
.../internal/tools/gfsh/app/commands/ls.java | 584 -----
.../internal/tools/gfsh/app/commands/mkdir.java | 253 ---
.../internal/tools/gfsh/app/commands/next.java | 63 -
.../tools/gfsh/app/commands/optional/look.java | 166 --
.../tools/gfsh/app/commands/optional/perf.java | 150 --
.../internal/tools/gfsh/app/commands/pr.java | 209 --
.../tools/gfsh/app/commands/property.java | 85 -
.../internal/tools/gfsh/app/commands/put.java | 490 -----
.../internal/tools/gfsh/app/commands/pwd.java | 37 -
.../tools/gfsh/app/commands/rebalance.java | 186 --
.../tools/gfsh/app/commands/refresh.java | 67 -
.../internal/tools/gfsh/app/commands/rm.java | 175 --
.../internal/tools/gfsh/app/commands/rmdir.java | 249 ---
.../tools/gfsh/app/commands/select.java | 139 --
.../internal/tools/gfsh/app/commands/show.java | 240 ---
.../internal/tools/gfsh/app/commands/size.java | 281 ---
.../internal/tools/gfsh/app/commands/value.java | 48 -
.../internal/tools/gfsh/app/commands/which.java | 189 --
.../internal/tools/gfsh/app/commands/zone.java | 49 -
.../tools/gfsh/app/function/GfshData.java | 86 -
.../tools/gfsh/app/function/GfshFunction.java | 149 --
.../tools/gfsh/app/function/command/clear.java | 95 -
.../tools/gfsh/app/function/command/deploy.java | 111 -
.../tools/gfsh/app/function/command/gc.java | 49 -
.../tools/gfsh/app/function/command/index.java | 199 --
.../tools/gfsh/app/function/command/ls.java | 80 -
.../tools/gfsh/app/function/command/pr.java | 118 -
.../gfsh/app/function/command/rebalance.java | 129 --
.../tools/gfsh/app/function/command/rm.java | 43 -
.../tools/gfsh/app/function/command/which.java | 159 --
.../tools/gfsh/app/misc/util/ClassFinder.java | 209 --
.../gfsh/app/misc/util/DataSerializerEx.java | 98 -
.../app/misc/util/QueueDispatcherListener.java | 11 -
.../app/misc/util/QueueDispatcherThread.java | 87 -
.../gfsh/app/misc/util/ReflectionUtil.java | 303 ---
.../tools/gfsh/app/misc/util/StringUtil.java | 142 --
.../app/misc/util/SystemClassPathManager.java | 171 --
.../gfsh/app/pogo/InvalidKeyException.java | 34 -
.../internal/tools/gfsh/app/pogo/KeyType.java | 96 -
.../tools/gfsh/app/pogo/KeyTypeManager.java | 199 --
.../internal/tools/gfsh/app/pogo/MapLite.java | 1136 ----------
.../tools/gfsh/app/pogo/MapLiteSerializer.java | 338 ---
.../internal/tools/gfsh/app/util/DBUtil.java | 1094 ----------
.../tools/gfsh/app/util/DBUtilException.java | 48 -
.../tools/gfsh/app/util/GfshResultsBag.java | 600 ------
.../tools/gfsh/app/util/ObjectUtil.java | 164 --
.../tools/gfsh/app/util/OutputUtil.java | 255 ---
.../internal/tools/gfsh/app/util/PrintUtil.java | 1683 ---------------
.../tools/gfsh/app/util/SimplePrintUtil.java | 1366 ------------
.../tools/gfsh/command/AbstractCommandTask.java | 136 --
.../tools/gfsh/command/CommandResults.java | 119 -
.../tools/gfsh/command/CommandTask.java | 23 -
.../internal/tools/gfsh/util/RegionUtil.java | 829 -------
.../internal/beans/CacheServerBridge.java | 20 +-
.../beans/GatewayReceiverMBeanBridge.java | 4 +-
.../internal/beans/ManagementAdapter.java | 42 +-
.../internal/beans/MemberMBeanBridge.java | 11 +-
.../management/internal/beans/ServerBridge.java | 6 +-
.../cli/commands/HDFSStoreCommands.java | 81 +-
.../cli/commands/LauncherLifecycleCommands.java | 5 +
.../internal/cli/commands/QueueCommands.java | 4 +-
.../cli/functions/AlterHDFSStoreFunction.java | 24 +-
.../cli/functions/ContunuousQueryFunction.java | 4 +-
.../CreateAsyncEventQueueFunction.java | 8 +-
.../cli/functions/CreateHDFSStoreFunction.java | 20 +-
.../functions/GetMemberInformationFunction.java | 4 +-
.../internal/cli/i18n/CliStrings.java | 8 +-
.../controllers/QueueCommandsController.java | 6 +-
.../web/controllers/WanCommandsController.java | 2 +-
.../management/membership/ClientMembership.java | 8 +-
.../pdx/ReflectionBasedAutoSerializer.java | 9 +
.../pdx/internal/AutoSerializableManager.java | 8 -
.../gemfire/pdx/internal/TypeRegistry.java | 19 +-
.../gemfire/redis/GemFireRedisServer.java | 155 +-
.../util/concurrent/SynchronousQueueNoSpin.java | 1144 ----------
.../gemfire/cache/cache-9.0.xsd | 26 -
.../batterytest/greplogs/ExpectedStrings.java | 4 +-
.../com/gemstone/gemfire/TXExpiryJUnitTest.java | 505 +++--
.../cache/AttributesFactoryJUnitTest.java | 18 -
.../gemfire/cache/Bug52289JUnitTest.java | 81 +
.../gemstone/gemfire/cache/ClientHelper.java | 1 -
.../cache/ClientServerTimeSyncDUnitTest.java | 9 +-
.../cache/ConnectionPoolAndLoaderDUnitTest.java | 4 +-
.../gemfire/cache/RegionFactoryJUnitTest.java | 19 +-
.../internal/AutoConnectionSourceDUnitTest.java | 23 +-
.../AutoConnectionSourceWithUDPDUnitTest.java | 4 +-
.../internal/ConnectionPoolImplJUnitTest.java | 11 +-
.../internal/LocatorLoadBalancingDUnitTest.java | 10 +-
.../cache/client/internal/LocatorTestBase.java | 12 +-
.../ColocatedRegionWithHDFSDUnitTest.java | 20 +-
.../hdfs/internal/HDFSConfigJUnitTest.java | 146 +-
.../internal/HdfsStoreMutatorJUnitTest.java | 147 +-
.../hdfs/internal/RegionRecoveryDUnitTest.java | 415 ++++
.../internal/RegionWithHDFSBasicDUnitTest.java | 1594 ++++++++++++++
.../RegionWithHDFSOffHeapBasicDUnitTest.java | 114 +
...RegionWithHDFSPersistenceBasicDUnitTest.java | 77 +
.../hdfs/internal/RegionWithHDFSTestBase.java | 44 +-
.../internal/hoplog/BaseHoplogTestCase.java | 7 +-
.../hoplog/HDFSCacheLoaderJUnitTest.java | 4 +-
.../hoplog/HDFSCompactionManagerJUnitTest.java | 8 +-
.../HDFSUnsortedHoplogOrganizerJUnitTest.java | 2 +-
.../HdfsSortedOplogOrganizerJUnitTest.java | 10 +-
.../hoplog/TieredCompactionJUnitTest.java | 25 +-
.../hoplog/mapreduce/HoplogUtilJUnitTest.java | 7 +-
.../management/MemoryThresholdsDUnitTest.java | 4 +-
.../MemoryThresholdsOffHeapDUnitTest.java | 94 +-
.../PutOperationContextJUnitTest.java | 248 +++
.../GetOperationContextImplJUnitTest.java | 275 +++
.../gemfire/cache/query/QueryJUnitTest.java | 91 +
.../query/dunit/CloseCacheAuthorization.java | 2 -
.../query/dunit/PdxStringQueryDUnitTest.java | 16 +-
.../query/dunit/QueryUsingPoolDUnitTest.java | 12 +-
.../cache/query/dunit/RemoteQueryDUnitTest.java | 90 +-
...esourceManagerWithQueryMonitorDUnitTest.java | 4 +-
.../cache/query/functional/GroupByTestImpl.java | 2 +-
.../query/functional/StructSetOrResultsSet.java | 260 +--
...rrentIndexInitOnOverflowRegionDUnitTest.java | 4 +-
.../index/CopyOnReadIndexDUnitTest.java | 68 +-
.../index/CopyOnReadIndexJUnitTest.java | 5 +-
.../internal/index/HashIndexJUnitTest.java | 20 +-
.../query/internal/index/IndexUseJUnitTest.java | 52 +
.../MapRangeIndexMaintenanceJUnitTest.java | 50 +
.../internal/index/RangeIndexAPIJUnitTest.java | 32 +-
.../query/partitioned/PRQueryDUnitTest.java | 8 +-
.../query/partitioned/PRQueryJUnitTest.java | 30 +
.../cache30/BridgeMembershipDUnitTest.java | 1597 --------------
.../BridgeMembershipSelectorDUnitTest.java | 16 -
.../gemfire/cache30/BridgeTestCase.java | 376 ----
.../gemfire/cache30/BridgeWriterDUnitTest.java | 418 ----
.../cache30/BridgeWriterSelectorDUnitTest.java | 16 -
.../gemfire/cache30/Bug38741DUnitTest.java | 10 +-
.../gemfire/cache30/CacheLoaderTestCase.java | 2 +-
.../gemstone/gemfire/cache30/CacheTestCase.java | 27 +-
.../gemfire/cache30/CacheXml30DUnitTest.java | 127 --
.../gemfire/cache30/CacheXml40DUnitTest.java | 8 +-
.../gemfire/cache30/CacheXml41DUnitTest.java | 28 +-
.../gemfire/cache30/CacheXml45DUnitTest.java | 4 +-
.../gemfire/cache30/CacheXml51DUnitTest.java | 8 +-
.../gemfire/cache30/CacheXml57DUnitTest.java | 1 -
.../cache30/ClientMembershipDUnitTest.java | 1642 ++++++++++++++
.../ClientMembershipSelectorDUnitTest.java | 16 +
.../ClientRegisterInterestDUnitTest.java | 418 ++++
...ClientRegisterInterestSelectorDUnitTest.java | 16 +
.../gemfire/cache30/ClientServerTestCase.java | 376 ++++
.../DistributedNoAckRegionDUnitTest.java | 14 +
.../gemfire/cache30/MultiVMRegionTestCase.java | 376 ++--
.../PartitionedRegionCompressionDUnitTest.java | 4 -
.../gemfire/cache30/RegionTestCase.java | 944 ++++----
.../gemfire/cache30/TestCacheCallback.java | 13 +-
.../AbstractServerLauncherJUnitTestCase.java | 4 +-
.../LocatorLauncherRemoteFileJUnitTest.java | 8 +-
.../LocatorLauncherRemoteJUnitTest.java | 57 +-
.../ServerLauncherLocalJUnitTest.java | 51 +-
.../ServerLauncherRemoteFileJUnitTest.java | 2 -
.../ServerLauncherRemoteJUnitTest.java | 10 +-
.../ServerLauncherWithSpringJUnitTest.java | 5 +
.../internal/ProductUseLogDUnitTest.java | 2 +-
.../gemfire/disttx/CacheMapDistTXDUnitTest.java | 9 +-
.../gemfire/disttx/DistTXDebugDUnitTest.java | 8 +-
.../disttx/DistTXDistributedTestSuite.java | 5 +-
.../gemfire/disttx/DistTXOrderDUnitTest.java | 13 +-
.../disttx/DistTXPersistentDebugDUnitTest.java | 4 -
.../disttx/DistTXRestrictionsDUnitTest.java | 1 -
.../disttx/DistTXWithDeltaDUnitTest.java | 22 +
.../disttx/DistributedTransactionDUnitTest.java | 814 ++++++-
.../gemfire/disttx/PRDistTXDUnitTest.java | 49 +
.../disttx/PRDistTXWithVersionsDUnitTest.java | 50 +
.../gemstone/gemfire/internal/FDDUnitTest.java | 12 +-
.../gemfire/internal/NanoTimer2JUnitTest.java | 79 -
.../gemfire/internal/NanoTimerJUnitTest.java | 121 +-
.../gemfire/internal/SocketCloserJUnitTest.java | 180 ++
.../internal/SocketCloserWithWaitJUnitTest.java | 22 +
.../internal/cache/Bug34011JUnitTest.java | 199 --
.../internal/cache/Bug39079DUnitTest.java | 6 +-
.../internal/cache/Bug41957DUnitTest.java | 6 +-
.../cache/ChunkValueWrapperJUnitTest.java | 2 +-
...ssagesRegionCreationAndDestroyJUnitTest.java | 10 +-
.../cache/ClientServerGetAllDUnitTest.java | 41 +-
.../cache/ClientServerTransactionDUnitTest.java | 195 +-
.../cache/ConcurrentMapOpsDUnitTest.java | 75 +-
.../ConcurrentRegionOperationsJUnitTest.java | 7 +-
.../cache/DeltaPropagationDUnitTest.java | 8 +-
.../cache/DeltaPropagationStatsDUnitTest.java | 2 +-
.../internal/cache/DiskRegionJUnitTest.java | 39 +-
.../internal/cache/EventTrackerDUnitTest.java | 8 +-
.../internal/cache/GridAdvisorDUnitTest.java | 106 +-
.../internal/cache/HABug36773DUnitTest.java | 8 +-
.../HAOverflowMemObjectSizerDUnitTest.java | 12 +-
.../cache/HDFSRegionOperationsJUnitTest.java | 5 +-
.../cache/OldValueImporterTestBase.java | 165 ++
.../PartitionedRegionSingleHopDUnitTest.java | 4 -
.../cache/PartitionedRegionStatsJUnitTest.java | 320 ++-
.../cache/PartitionedRegionTestHelper.java | 3 +-
.../cache/RemotePutReplyMessageJUnitTest.java | 37 +
.../cache/RemoteTransactionDUnitTest.java | 181 +-
.../control/RebalanceOperationDUnitTest.java | 468 +++-
.../cache/execute/Bug51193DUnitTest.java | 4 +-
.../execute/SingleHopGetAllPutAllDUnitTest.java | 18 +-
.../internal/cache/functions/TestFunction.java | 10 +-
.../cache/ha/Bug36853EventsExpiryDUnitTest.java | 9 +-
.../internal/cache/ha/Bug48571DUnitTest.java | 2 +-
.../cache/ha/EventIdOptimizationDUnitTest.java | 12 +-
.../internal/cache/ha/FailoverDUnitTest.java | 22 +-
.../internal/cache/ha/HABugInPutDUnitTest.java | 8 +-
.../internal/cache/ha/HAClearDUnitTest.java | 10 +-
.../cache/ha/HAConflationDUnitTest.java | 8 +-
.../internal/cache/ha/HADuplicateDUnitTest.java | 10 +-
.../cache/ha/HAEventIdPropagationDUnitTest.java | 10 +-
.../internal/cache/ha/HAGIIDUnitTest.java | 14 +-
.../cache/ha/HARQueueNewImplDUnitTest.java | 66 +-
.../cache/ha/HASlowReceiverDUnitTest.java | 10 +-
.../ha/OperationsPropagationDUnitTest.java | 8 +-
.../internal/cache/ha/PutAllDUnitTest.java | 12 +-
.../cache/ha/StatsBugDUnitDisabledTest.java | 14 +-
.../cache/partitioned/Bug43684DUnitTest.java | 4 +-
.../PartitionedRegionLoadModelJUnitTest.java | 97 +-
...tentColocatedPartitionedRegionDUnitTest.java | 2 +-
.../PutPutReplyMessageJUnitTest.java | 38 +
.../fixed/FixedPartitioningTestBase.java | 6 +-
.../tier/sockets/AcceptorImplJUnitTest.java | 62 +-
...rdCompatibilityCommandDUnitDisabledTest.java | 235 --
...CompatibilityHandshakeDUnitDisabledTest.java | 218 --
...mpatibilityHigherVersionClientDUnitTest.java | 4 +-
...rdCompatibilityMessageDUnitDisabledTest.java | 299 ---
.../BridgeServerMaxConnectionsJUnitTest.java | 221 --
...geServerSelectorMaxConnectionsJUnitTest.java | 19 -
.../tier/sockets/BridgeWriterMiscDUnitTest.java | 1384 ------------
.../BridgeWriterMiscSelectorDUnitTest.java | 27 -
.../cache/tier/sockets/Bug36269DUnitTest.java | 4 +-
.../cache/tier/sockets/Bug36457DUnitTest.java | 18 +-
.../cache/tier/sockets/Bug36805DUnitTest.java | 6 +-
.../cache/tier/sockets/Bug36995DUnitTest.java | 11 +-
.../cache/tier/sockets/Bug37210DUnitTest.java | 10 +-
.../CacheServerMaxConnectionsJUnitTest.java | 220 ++
...heServerSelectorMaxConnectionsJUnitTest.java | 19 +
.../cache/tier/sockets/CacheServerTestUtil.java | 51 +-
.../CacheServerTransactionsDUnitTest.java | 4 +-
.../tier/sockets/ClearPropagationDUnitTest.java | 4 +-
.../tier/sockets/ClientConflationDUnitTest.java | 20 +-
.../sockets/ClientHealthMonitorJUnitTest.java | 6 +-
.../sockets/ClientInterestNotifyDUnitTest.java | 14 +-
.../tier/sockets/ClientServerMiscDUnitTest.java | 1381 ++++++++++++
.../ClientServerMiscSelectorDUnitTest.java | 27 +
.../cache/tier/sockets/ConflationDUnitTest.java | 24 +-
.../tier/sockets/ConnectionProxyJUnitTest.java | 257 +--
.../DataSerializerPropogationDUnitTest.java | 36 +-
.../DestroyEntryPropagationDUnitTest.java | 12 +-
.../DurableClientReconnectDUnitTest.java | 10 +-
.../sockets/DurableClientStatsDUnitTest.java | 10 +-
.../sockets/DurableRegistrationDUnitTest.java | 8 +-
.../sockets/DurableResponseMatrixDUnitTest.java | 10 +-
.../sockets/EventIDVerificationDUnitTest.java | 10 +-
.../ForceInvalidateEvictionDUnitTest.java | 10 +-
.../cache/tier/sockets/HAInterestBaseTest.java | 1447 ++++++-------
.../sockets/HAInterestDistributedTestCase.java | 15 +
.../tier/sockets/HAInterestPart1DUnitTest.java | 210 +-
.../tier/sockets/HAInterestPart2DUnitTest.java | 514 +++--
.../sockets/HAStartupAndFailoverDUnitTest.java | 81 +-
.../tier/sockets/InterestListDUnitTest.java | 4 +-
.../sockets/InterestListEndpointDUnitTest.java | 18 +-
.../sockets/InterestListFailoverDUnitTest.java | 6 +-
.../sockets/InterestListRecoveryDUnitTest.java | 10 +-
.../sockets/InterestResultPolicyDUnitTest.java | 4 +-
.../tier/sockets/RedundancyLevelJUnitTest.java | 14 +-
.../sockets/RedundancyLevelPart1DUnitTest.java | 4 +-
.../sockets/RedundancyLevelPart3DUnitTest.java | 6 +-
.../tier/sockets/RedundancyLevelTestBase.java | 51 +-
.../tier/sockets/RegionCloseDUnitTest.java | 14 +-
...erInterestBeforeRegionCreationDUnitTest.java | 6 +-
.../sockets/RegisterInterestKeysDUnitTest.java | 4 +-
.../sockets/ReliableMessagingDUnitTest.java | 24 +-
.../internal/cache/tier/sockets/TestPut.java | 53 -
.../sockets/UpdatePropagationDUnitTest.java | 10 +-
...UpdatesFromNonInterestEndPointDUnitTest.java | 4 +-
.../compression/SnappyCompressorJUnitTest.java | 2 +-
.../internal/lang/StringUtilsJUnitTest.java | 33 +
.../DistributedSystemLogFileJUnitTest.java | 20 +-
.../logging/LogServiceIntegrationJUnitTest.java | 209 ++
.../LogServiceIntegrationTestSupport.java | 24 +
.../internal/logging/LogServiceJUnitTest.java | 190 +-
.../LogServiceUserDirIntegrationJUnitTest.java | 70 +
.../logging/LoggingIntegrationTestSuite.java | 15 +
.../internal/logging/LoggingUnitTestSuite.java | 13 +
.../log4j/FastLoggerIntegrationJUnitTest.java | 557 +++++
.../logging/log4j/FastLoggerJUnitTest.java | 274 +--
.../FastLoggerWithDefaultConfigJUnitTest.java | 74 +
.../log4j/Log4jIntegrationTestSuite.java | 12 +
.../logging/log4j/Log4jUnitTestSuite.java | 16 +
.../offheap/OffHeapValidationJUnitTest.java | 45 +-
.../OffHeapWriteObjectAsByteArrayJUnitTest.java | 101 +
.../internal/size/ObjectSizerJUnitTest.java | 14 +-
...ersalMembershipListenerAdapterDUnitTest.java | 32 +-
.../commands/HDFSStoreCommandsJUnitTest.java | 124 +-
.../AlterHDFSStoreFunctionJUnitTest.java | 146 +-
.../CreateHDFSStoreFunctionJUnitTest.java | 156 +-
.../DescribeHDFSStoreFunctionJUnitTest.java | 98 +-
.../WanCommandsControllerJUnitTest.java | 124 ++
.../gemfire/pdx/AutoSerializableJUnitTest.java | 2 +-
.../gemfire/pdx/ByteSourceJUnitTest.java | 4 +-
.../pdx/PdxFormatterPutGetJUnitTest.java | 4 +-
.../gemstone/gemfire/redis/AuthJUnitTest.java | 144 ++
.../gemfire/redis/ConcurrentStartTest.java | 58 +
.../gemstone/gemfire/redis/HashesJUnitTest.java | 175 ++
.../gemstone/gemfire/redis/ListsJUnitTest.java | 238 ++
.../gemfire/redis/RedisDistDUnitTest.java | 234 ++
.../gemstone/gemfire/redis/SetsJUnitTest.java | 242 +++
.../gemfire/redis/SortedSetsJUnitTest.java | 414 ++++
.../gemfire/redis/StringsJunitTest.java | 296 +++
.../gemfire/test/golden/ExecutableProcess.java | 8 +
.../gemfire/test/golden/FailOutputTestCase.java | 22 +-
.../golden/FailWithErrorInOutputJUnitTest.java | 18 +-
.../FailWithExtraLineInOutputJUnitTest.java | 41 +-
...WithLineMissingFromEndOfOutputJUnitTest.java | 39 +-
...hLineMissingFromMiddleOfOutputJUnitTest.java | 39 +-
.../FailWithLoggerErrorInOutputJUnitTest.java | 18 +-
.../FailWithLoggerFatalInOutputJUnitTest.java | 18 +-
.../FailWithLoggerWarnInOutputJUnitTest.java | 18 +-
.../golden/FailWithProblemInOutputTestCase.java | 30 +-
.../golden/FailWithSevereInOutputJUnitTest.java | 18 +-
...hTimeoutOfWaitForOutputToMatchJUnitTest.java | 42 +-
.../FailWithWarningInOutputJUnitTest.java | 18 +-
.../gemfire/test/golden/GoldenComparator.java | 64 +-
.../test/golden/GoldenStringComparator.java | 5 +-
.../gemfire/test/golden/GoldenTestCase.java | 108 +-
.../golden/GoldenTestFrameworkTestSuite.java | 27 +
.../gemfire/test/golden/PassJUnitTest.java | 50 +-
.../golden/PassWithExpectedErrorJUnitTest.java | 18 +-
.../golden/PassWithExpectedProblemTestCase.java | 58 +-
.../golden/PassWithExpectedSevereJUnitTest.java | 18 +-
.../PassWithExpectedWarningJUnitTest.java | 18 +-
.../test/golden/RegexGoldenComparator.java | 10 +-
.../test/golden/StringGoldenComparator.java | 4 +-
.../process/ProcessTestFrameworkTestSuite.java | 12 +
.../gemfire/test/process/ProcessWrapper.java | 251 ++-
.../test/process/ProcessWrapperJUnitTest.java | 19 +-
.../test/java/dunit/DistributedTestCase.java | 88 +-
.../java/dunit/standalone/DUnitLauncher.java | 8 +-
.../gemfire/codeAnalysis/excludedClasses.txt | 2 +-
.../sanctionedDataSerializables.txt | 30 +-
.../codeAnalysis/sanctionedSerializables.txt | 16 +-
.../tier/sockets/RedundancyLevelJUnitTest.xml | 21 +-
.../gemfire/test/golden/log4j2-test.xml | 18 +
.../gemstone/org/jgroups/protocols/FRAG2.java | 2 +-
.../gemstone/org/jgroups/protocols/SMACK.java | 3 +-
.../gemstone/org/jgroups/protocols/UDP_NIO.java | 4 +-
.../org/jgroups/protocols/VIEW_ENFORCER.java | 2 +-
gemfire-rebalancer/build.gradle | 12 +
.../gemfire/cache/util/AutoBalancer.java | 512 +++++
.../cache/util/AutoBalancerJUnitTest.java | 772 +++++++
gemfire-spark-connector/.gitignore | 1 +
gemfire-spark-connector/README.md | 32 +
gemfire-spark-connector/doc/10_demos.md | 84 +
gemfire-spark-connector/doc/1_building.md | 34 +
gemfire-spark-connector/doc/2_quick.md | 178 ++
gemfire-spark-connector/doc/3_connecting.md | 55 +
gemfire-spark-connector/doc/4_loading.md | 108 +
gemfire-spark-connector/doc/5_rdd_join.md | 237 ++
gemfire-spark-connector/doc/6_save_rdd.md | 81 +
gemfire-spark-connector/doc/7_save_dstream.md | 68 +
gemfire-spark-connector/doc/8_oql.md | 58 +
gemfire-spark-connector/doc/9_java_api.md | 129 ++
.../connector/internal/RegionMetadata.java | 77 +
.../gemfirefunctions/QueryFunction.java | 83 +
.../RetrieveRegionFunction.java | 192 ++
.../RetrieveRegionMetadataFunction.java | 102 +
.../StructStreamingResultSender.java | 203 ++
.../gemfire/spark/connector/Employee.java | 38 +
.../spark/connector/JavaApiIntegrationTest.java | 408 ++++
.../gemfire/spark/connector/Portfolio.java | 93 +
.../gemfire/spark/connector/Position.java | 57 +
.../src/it/resources/test-regions.xml | 32 +
.../src/it/resources/test-retrieve-regions.xml | 40 +
.../spark/connector/BasicIntegrationTest.scala | 582 +++++
.../RDDJoinRegionIntegrationTest.scala | 284 +++
.../RetrieveRegionIntegrationTest.scala | 237 ++
.../gemfire/spark/connector/package.scala | 13 +
.../connector/testkit/GemFireCluster.scala | 31 +
.../spark/connector/testkit/GemFireRunner.scala | 132 ++
.../spark/connector/testkit/IOUtils.scala | 78 +
.../spark/streaming/ManualClockHelper.scala | 12 +
.../spark/streaming/TestInputDStream.scala | 28 +
.../javaapi/GemFireJavaDStreamFunctions.java | 70 +
.../GemFireJavaPairDStreamFunctions.java | 61 +
.../javaapi/GemFireJavaPairRDDFunctions.java | 222 ++
.../javaapi/GemFireJavaRDDFunctions.java | 162 ++
.../javaapi/GemFireJavaSQLContextFunctions.java | 33 +
.../GemFireJavaSparkContextFunctions.java | 71 +
.../connector/javaapi/GemFireJavaUtil.java | 106 +
.../spark/connector/GemFireConnection.scala | 51 +
.../spark/connector/GemFireConnectionConf.scala | 57 +
.../connector/GemFireConnectionManager.scala | 15 +
.../connector/GemFireFunctionDeployer.scala | 65 +
.../connector/GemFireKryoRegistrator.scala | 13 +
.../connector/GemFirePairRDDFunctions.scala | 124 ++
.../spark/connector/GemFireRDDFunctions.scala | 104 +
.../connector/GemFireSQLContextFunctions.scala | 26 +
.../GemFireSparkContextFunctions.scala | 23 +
.../internal/DefaultGemFireConnection.scala | 148 ++
.../DefaultGemFireConnectionManager.scala | 61 +
.../connector/internal/LocatorHelper.scala | 119 +
.../StructStreamingResultCollector.scala | 136 ++
.../connector/internal/oql/QueryParser.scala | 42 +
.../spark/connector/internal/oql/QueryRDD.scala | 67 +
.../internal/oql/QueryResultCollector.scala | 53 +
.../connector/internal/oql/RDDConverter.scala | 24 +
.../connector/internal/oql/RowBuilder.scala | 22 +
.../connector/internal/oql/SchemaBuilder.scala | 57 +
.../internal/oql/UndefinedSerializer.scala | 30 +
.../connector/internal/rdd/GemFireJoinRDD.scala | 51 +
.../internal/rdd/GemFireOuterJoinRDD.scala | 53 +
.../internal/rdd/GemFireRDDPartition.scala | 20 +
.../internal/rdd/GemFireRDDPartitioner.scala | 43 +
.../rdd/GemFireRDDPartitionerImpl.scala | 73 +
.../internal/rdd/GemFireRDDWriter.scala | 66 +
.../internal/rdd/GemFireRegionRDD.scala | 122 ++
.../javaapi/GemFireJavaRegionRDD.scala | 10 +
.../spark/connector/javaapi/JavaAPIHelper.scala | 37 +
.../gemfire/spark/connector/package.scala | 53 +
.../streaming/GemFireDStreamFunctions.scala | 73 +
.../spark/connector/streaming/package.scala | 16 +
.../gemfire/spark/connector/JavaAPITest.java | 147 ++
.../connector/GemFireFunctionDeployerTest.scala | 42 +
.../DefaultGemFireConnectionManagerTest.scala | 66 +
...tStreamingResultSenderAndCollectorTest.scala | 238 ++
.../internal/oql/QueryParserTest.scala | 67 +
.../connector/ConnectorImplicitsTest.scala | 34 +
.../connector/GemFireConnectionConfTest.scala | 84 +
.../connector/GemFireDStreamFunctionsTest.scala | 63 +
.../connector/GemFireRDDFunctionsTest.scala | 123 ++
.../spark/connector/LocatorHelperTest.scala | 152 ++
.../rdd/GemFireRDDPartitionerTest.scala | 174 ++
.../connector/rdd/GemFireRegionRDDTest.scala | 101 +
.../basic-demos/src/main/java/demo/Emp.java | 79 +
.../src/main/java/demo/OQLJavaDemo.java | 43 +
.../src/main/java/demo/PairRDDSaveJavaDemo.java | 70 +
.../src/main/java/demo/RDDSaveJavaDemo.java | 69 +
.../src/main/java/demo/RegionToRDDJavaDemo.java | 41 +
.../src/main/scala/demo/NetworkWordCount.scala | 59 +
.../project/Dependencies.scala | 29 +
.../project/GemFireSparkBuild.scala | 60 +
gemfire-spark-connector/project/Settings.scala | 41 +
.../project/build.properties | 1 +
gemfire-spark-connector/project/plugins.sbt | 8 +
gemfire-spark-connector/scalastyle-config.xml | 117 +
settings.gradle | 1 +
838 files changed, 35115 insertions(+), 50912 deletions(-)
----------------------------------------------------------------------