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 <[email protected]> Authored: Tue Aug 25 15:35:31 2015 -0700 Committer: Chetan Narsude <[email protected]> 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(-) ----------------------------------------------------------------------
