You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2016/02/01 11:24:19 UTC
[10/12] ignite git commit: Merge remote-tracking branch
'remotes/origin/master' into ignite-2224
Merge remote-tracking branch 'remotes/origin/master' into ignite-2224
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/fdafe285
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/fdafe285
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/fdafe285
Branch: refs/heads/ignite-2224
Commit: fdafe2858ce784ca7a6fcc2c63b2069431f01755
Parents: e7caaa0 4e61602
Author: sboikov <sb...@gridgain.com>
Authored: Mon Feb 1 09:39:37 2016 +0300
Committer: sboikov <sb...@gridgain.com>
Committed: Mon Feb 1 09:39:37 2016 +0300
----------------------------------------------------------------------
.../org/apache/ignite/internal/IgnitionEx.java | 4 +-
.../processors/cache/CacheOperationContext.java | 43 ++-
.../processors/cache/GridCacheAdapter.java | 8 +-
.../processors/cache/GridCacheProxyImpl.java | 11 +-
.../processors/cache/IgniteCacheProxy.java | 43 ++-
.../dht/atomic/GridDhtAtomicCache.java | 103 ++++-
.../dht/atomic/GridNearAtomicUpdateFuture.java | 4 +-
.../processors/cache/dr/GridCacheDrInfo.java | 49 ++-
.../transactions/IgniteTxLocalAdapter.java | 81 ++--
.../cache/version/GridCacheVersionManager.java | 23 +-
.../GridCacheRebalancingSyncSelfTest.java | 8 +
.../testframework/junits/GridAbstractTest.java | 3 +
modules/kafka/README.txt | 111 +++++-
modules/kafka/pom.xml | 69 ++--
.../ignite/stream/kafka/KafkaStreamer.java | 2 +-
.../kafka/connect/IgniteSinkConnector.java | 91 +++++
.../kafka/connect/IgniteSinkConstants.java | 38 ++
.../stream/kafka/connect/IgniteSinkTask.java | 165 ++++++++
.../kafka/IgniteKafkaStreamerSelfTestSuite.java | 9 +-
.../stream/kafka/KafkaEmbeddedBroker.java | 387 -------------------
.../kafka/KafkaIgniteStreamerSelfTest.java | 13 +-
.../ignite/stream/kafka/SimplePartitioner.java | 53 ---
.../ignite/stream/kafka/TestKafkaBroker.java | 237 ++++++++++++
.../kafka/connect/IgniteSinkConnectorTest.java | 250 ++++++++++++
.../kafka/src/test/resources/example-ignite.xml | 71 ++++
.../commands/top/VisorTopologyCommand.scala | 5 +-
.../apache/ignite/yarn/ApplicationMaster.java | 12 +-
.../apache/ignite/yarn/ClusterProperties.java | 144 ++++---
.../yarn/IgniteApplicationMasterSelfTest.java | 52 +++
parent/pom.xml | 120 +++---
pom.xml | 16 -
31 files changed, 1516 insertions(+), 709 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/fdafe285/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/fdafe285/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProxyImpl.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/fdafe285/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/fdafe285/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/fdafe285/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxLocalAdapter.java
----------------------------------------------------------------------