You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by th...@apache.org on 2015/08/26 01:24:02 UTC
[10/10] incubator-apex-core git commit: Merge pull request #113 from
ishark/Apex-2-3.1.0
Merge pull request #113 from ishark/Apex-2-3.1.0
APEX-2 #resolve Support for persist operation for Stream Meta object.…
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/commit/f28d8d74
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/f28d8d74
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/f28d8d74
Branch: refs/heads/devel-3
Commit: f28d8d742e96168f18ddbe3479d472fc9d79cc13
Parents: 9116c70 f68d249
Author: Chetan Narsude <ch...@datatorrent.com>
Authored: Tue Aug 25 15:35:31 2015 -0700
Committer: Chetan Narsude <ch...@datatorrent.com>
Committed: Tue Aug 25 15:35:31 2015 -0700
----------------------------------------------------------------------
api/src/main/java/com/datatorrent/api/DAG.java | 32 +
.../stram/engine/StreamingContainer.java | 17 +-
.../plan/logical/DefaultKryoStreamCodec.java | 87 ++
.../stram/plan/logical/LogicalPlan.java | 200 +++-
.../StreamCodecWrapperForPersistance.java | 89 ++
.../stram/plan/physical/PhysicalPlan.java | 110 ++-
.../stram/stream/BufferServerSubscriber.java | 68 +-
.../stram/stream/PartitionAwareSink.java | 8 +-
.../PartitionAwareSinkForPersistence.java | 45 +
.../stram/plan/StreamPersistanceTests.java | 988 +++++++++++++++++++
10 files changed, 1626 insertions(+), 18 deletions(-)
----------------------------------------------------------------------