geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bschucha...@apache.org
Subject [50/50] [abbrv] incubator-geode git commit: Merge remote-tracking branch 'origin/develop' into feature/GEODE-77
Date Mon, 27 Jul 2015 23:20:13 GMT
Merge remote-tracking branch 'origin/develop' into feature/GEODE-77


Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/17a1f4dd
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/17a1f4dd
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/17a1f4dd

Branch: refs/heads/feature/GEODE-77
Commit: 17a1f4dd79dca1ca99e495e0dab37495380b398f
Parents: d2a942e b387e35
Author: Bruce Schuchardt <bschuchardt@pivotal.io>
Authored: Mon Jul 27 16:16:50 2015 -0700
Committer: Bruce Schuchardt <bschuchardt@pivotal.io>
Committed: Mon Jul 27 16:16:50 2015 -0700

----------------------------------------------------------------------
 build.gradle                                    |    6 +-
 etc/eclipseFormatterProfile.xml                 |   11 +-
 .../gemstone/gemfire/cache/RegionService.java   |    2 +-
 .../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/query/internal/CompiledSelect.java    |    5 +-
 .../query/internal/index/AbstractIndex.java     |    4 +-
 .../cache/query/internal/index/HashIndex.java   |   11 +
 .../gemfire/distributed/DistributedSystem.java  |    6 +
 .../internal/AbstractDistributionConfig.java    |   21 +-
 .../internal/DistributionConfig.java            |   12 +
 .../internal/DistributionConfigImpl.java        |   16 +-
 .../gemfire/internal/cache/AbstractRegion.java  |    2 +-
 .../internal/cache/AbstractRegionEntry.java     |    2 +-
 .../gemfire/internal/cache/BucketRegion.java    |   10 +
 .../gemfire/internal/cache/DiskEntry.java       |   29 +-
 .../gemfire/internal/cache/DiskRegion.java      |    9 +
 .../gemfire/internal/cache/DiskRegionStats.java |   22 +
 .../gemfire/internal/cache/EntryEventImpl.java  |    8 +-
 .../gemfire/internal/cache/ExpiryTask.java      |    6 +-
 .../internal/cache/GemFireCacheImpl.java        |    2 +-
 .../gemfire/internal/cache/LocalRegion.java     |   19 +-
 .../internal/cache/PartitionedRegion.java       |   11 +-
 .../internal/cache/PartitionedRegionStats.java  |   12 +-
 .../internal/cache/RegionIdleExpiryTask.java    |    2 +-
 .../internal/cache/RegionTTLExpiryTask.java     |    2 +-
 .../cache/control/InternalResourceManager.java  |   15 +-
 .../control/PartitionRebalanceDetailsImpl.java  |    8 +-
 .../cache/control/RebalanceOperationImpl.java   |  157 +-
 .../cache/control/RebalanceResultsImpl.java     |   16 +-
 .../PartitionedRegionRebalanceOp.java           |  100 +-
 .../partitioned/rebalance/BucketOperator.java   |   46 +-
 .../rebalance/ParallelBucketOperator.java       |  145 ++
 .../rebalance/PartitionedRegionLoadModel.java   |   45 +-
 .../rebalance/SatisfyRedundancy.java            |    7 +-
 .../rebalance/SatisfyRedundancyFPR.java         |    1 +
 .../rebalance/SimulatedBucketOperator.java      |   11 +-
 .../internal/cache/xmlcache/CacheCreation.java  |    2 +-
 .../internal/cache/xmlcache/CacheXmlParser.java |  108 +-
 .../gemfire/internal/lang/StringUtils.java      |  364 +++-
 .../offheap/OffHeapCachedDeserializable.java    |    7 +-
 .../gemstone/gemfire/internal/redis/Coder.java  |   12 +-
 .../internal/redis/ExecutionHandlerContext.java |   66 +-
 .../internal/redis/RedisCommandType.java        |   21 +
 .../gemfire/internal/redis/RedisConstants.java  |    4 +
 .../internal/redis/executor/AuthExecutor.java   |   38 +
 .../internal/beans/MemberMBeanBridge.java       |   11 +-
 .../cli/commands/HDFSStoreCommands.java         |   81 +-
 .../cli/commands/LauncherLifecycleCommands.java |    5 +
 .../cli/functions/AlterHDFSStoreFunction.java   |   24 +-
 .../cli/functions/CreateHDFSStoreFunction.java  |   18 +-
 .../internal/cli/i18n/CliStrings.java           |    2 +
 .../gemfire/redis/GemFireRedisServer.java       |   14 +-
 .../gemfire/cache/RegionFactoryJUnitTest.java   |   19 +-
 .../ColocatedRegionWithHDFSDUnitTest.java       |   20 +-
 .../hdfs/internal/HDFSConfigJUnitTest.java      |  146 +-
 .../internal/HdfsStoreMutatorJUnitTest.java     |  147 +-
 .../hdfs/internal/RegionRecoveryDUnitTest.java  |  415 +++++
 .../internal/RegionWithHDFSBasicDUnitTest.java  | 1594 ++++++++++++++++++
 .../RegionWithHDFSOffHeapBasicDUnitTest.java    |  110 ++
 ...RegionWithHDFSPersistenceBasicDUnitTest.java |   77 +
 .../hdfs/internal/RegionWithHDFSTestBase.java   |   38 +-
 .../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 +-
 .../MemoryThresholdsOffHeapDUnitTest.java       |   48 +-
 .../internal/index/HashIndexJUnitTest.java      |   20 +-
 .../internal/index/RangeIndexAPIJUnitTest.java  |   32 +-
 .../query/partitioned/PRQueryDUnitTest.java     |    8 +-
 .../query/partitioned/PRQueryJUnitTest.java     |   30 +
 .../cache30/BridgeMembershipDUnitTest.java      |  109 +-
 .../gemfire/cache30/CacheLoaderTestCase.java    |    2 +-
 .../DistributedNoAckRegionDUnitTest.java        |   14 +
 .../gemfire/cache30/MultiVMRegionTestCase.java  |  270 ++-
 .../PartitionedRegionCompressionDUnitTest.java  |    4 -
 .../gemfire/cache30/RegionTestCase.java         |  801 ++++-----
 .../gemfire/cache30/TestCacheCallback.java      |   13 +-
 .../cache/ChunkValueWrapperJUnitTest.java       |    2 +-
 .../cache/HDFSRegionOperationsJUnitTest.java    |    5 +-
 .../cache/PartitionedRegionStatsJUnitTest.java  |  320 +++-
 .../cache/PartitionedRegionTestHelper.java      |    3 +-
 .../control/RebalanceOperationDUnitTest.java    |  460 ++++-
 .../execute/SingleHopGetAllPutAllDUnitTest.java |   18 +-
 .../PartitionedRegionLoadModelJUnitTest.java    |   97 +-
 .../cache/tier/sockets/HAInterestBaseTest.java  | 1435 +++++++---------
 .../sockets/HAInterestDistributedTestCase.java  |   15 +
 .../tier/sockets/HAInterestPart1DUnitTest.java  |  210 ++-
 .../tier/sockets/HAInterestPart2DUnitTest.java  |  506 +++---
 .../internal/lang/StringUtilsJUnitTest.java     |   33 +
 .../commands/HDFSStoreCommandsJUnitTest.java    |  124 +-
 .../AlterHDFSStoreFunctionJUnitTest.java        |  146 +-
 .../CreateHDFSStoreFunctionJUnitTest.java       |  156 +-
 .../DescribeHDFSStoreFunctionJUnitTest.java     |   98 +-
 .../gemstone/gemfire/redis/AuthJUnitTest.java   |  144 ++
 .../test/java/dunit/DistributedTestCase.java    |   15 +-
 .../sanctionedDataSerializables.txt             |    4 +-
 .../codeAnalysis/sanctionedSerializables.txt    |    6 +-
 .../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-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     |  121 ++
 .../spark/connector/GemFireRDDFunctions.scala   |  101 ++
 .../connector/GemFireSQLContextFunctions.scala  |   26 +
 .../GemFireSparkContextFunctions.scala          |   23 +
 .../internal/DefaultGemFireConnection.scala     |  128 ++
 .../DefaultGemFireConnectionManager.scala       |   61 +
 .../connector/internal/LocatorHelper.scala      |   30 +
 .../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       |   46 +
 .../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     |   75 +
 .../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 ++
 214 files changed, 15709 insertions(+), 4559 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/17a1f4dd/gemfire-core/src/main/java/com/gemstone/gemfire/internal/cache/LocalRegion.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/17a1f4dd/gemfire-core/src/main/java/com/gemstone/gemfire/internal/cache/PartitionedRegion.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/17a1f4dd/gemfire-core/src/test/java/com/gemstone/gemfire/internal/cache/partitioned/PartitionedRegionLoadModelJUnitTest.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/17a1f4dd/gemfire-core/src/test/java/dunit/DistributedTestCase.java
----------------------------------------------------------------------


Mime
View raw message