Repository: samza Updated Branches: refs/heads/master 40f74308f -> b7219e976
Cleaning the docs, these create confusion for other reviewers bharathkk for review Author: Sanil Jain <[email protected]> Reviewers: Bharath Kumarasubramanian <[email protected]> Closes #641 from Sanil15/SAMZA-1886 Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/b7219e97 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/b7219e97 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/b7219e97 Branch: refs/heads/master Commit: b7219e976c74a52fffc4864548249ef7101cd584 Parents: 40f7430 Author: Sanil Jain <[email protected]> Authored: Wed Sep 19 10:08:20 2018 -0700 Committer: Prateek Maheshwari <[email protected]> Committed: Wed Sep 19 10:08:20 2018 -0700 ---------------------------------------------------------------------- .../java/org/apache/samza/system/inmemory/InMemoryManager.java | 6 +----- .../org/apache/samza/system/inmemory/InMemorySystemAdmin.java | 4 ---- .../apache/samza/system/inmemory/InMemorySystemConsumer.java | 4 ---- .../apache/samza/system/inmemory/InMemorySystemFactory.java | 4 ---- .../apache/samza/system/inmemory/InMemorySystemProducer.java | 4 ---- 5 files changed, 1 insertion(+), 21 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/b7219e97/samza-core/src/main/java/org/apache/samza/system/inmemory/InMemoryManager.java ---------------------------------------------------------------------- diff --git a/samza-core/src/main/java/org/apache/samza/system/inmemory/InMemoryManager.java b/samza-core/src/main/java/org/apache/samza/system/inmemory/InMemoryManager.java index a704bc4..8463e56 100644 --- a/samza-core/src/main/java/org/apache/samza/system/inmemory/InMemoryManager.java +++ b/samza-core/src/main/java/org/apache/samza/system/inmemory/InMemoryManager.java @@ -37,10 +37,6 @@ import org.apache.samza.system.SystemStreamPartition; import org.slf4j.Logger; import org.slf4j.LoggerFactory; - -/** - * Initial draft of in-memory manager. It is test only and not meant for production use right now. - */ class InMemoryManager { private static final Logger LOG = LoggerFactory.getLogger(InMemoryManager.class); private static final int DEFAULT_PARTITION_COUNT = 1; @@ -125,7 +121,7 @@ class InMemoryManager { Map<String, Map<SystemStreamPartition, List<IncomingMessageEnvelope>>> result = bufferedMessages.entrySet() .stream() - .filter(entry -> systemName.equals(entry.getKey().getSystem()) + .filter(entry -> systemName.equals(entry.getKey().getSystem()) && streamNames.contains(entry.getKey().getStream())) .collect(Collectors.groupingBy(entry -> entry.getKey().getStream(), Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue))); http://git-wip-us.apache.org/repos/asf/samza/blob/b7219e97/samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemAdmin.java ---------------------------------------------------------------------- diff --git a/samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemAdmin.java b/samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemAdmin.java index 65f45a0..8e5f732 100644 --- a/samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemAdmin.java +++ b/samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemAdmin.java @@ -28,10 +28,6 @@ import org.apache.samza.system.SystemAdmin; import org.apache.samza.system.SystemStreamMetadata; import org.apache.samza.system.SystemStreamPartition; - -/** - * Initial draft of in-memory {@link SystemAdmin}. It is test only and not meant for production use right now. - */ public class InMemorySystemAdmin implements SystemAdmin { private final InMemoryManager inMemoryManager; private final String systemName; http://git-wip-us.apache.org/repos/asf/samza/blob/b7219e97/samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemConsumer.java ---------------------------------------------------------------------- diff --git a/samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemConsumer.java b/samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemConsumer.java index 08540ae..dcab001 100644 --- a/samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemConsumer.java +++ b/samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemConsumer.java @@ -30,10 +30,6 @@ import org.apache.samza.system.SystemStreamPartition; import org.slf4j.Logger; import org.slf4j.LoggerFactory; - -/** - * Initial draft of in-memory {@link SystemConsumer}. It is test only and not meant for production use right now. - */ public class InMemorySystemConsumer implements SystemConsumer { private static final Logger LOG = LoggerFactory.getLogger(InMemorySystemConsumer.class); http://git-wip-us.apache.org/repos/asf/samza/blob/b7219e97/samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemFactory.java ---------------------------------------------------------------------- diff --git a/samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemFactory.java b/samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemFactory.java index bb41a4e..6782c95 100644 --- a/samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemFactory.java +++ b/samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemFactory.java @@ -28,10 +28,6 @@ import org.apache.samza.system.SystemConsumer; import org.apache.samza.system.SystemFactory; import org.apache.samza.system.SystemProducer; - -/** - * Initial draft of in-memory {@link SystemFactory}. It is test only and not meant for production use right now. - */ public class InMemorySystemFactory implements SystemFactory { private static final ConcurrentHashMap<String, InMemoryManager> IN_MEMORY_MANAGERS = new ConcurrentHashMap<>(); http://git-wip-us.apache.org/repos/asf/samza/blob/b7219e97/samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemProducer.java ---------------------------------------------------------------------- diff --git a/samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemProducer.java b/samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemProducer.java index 052e72b..cd5e649 100644 --- a/samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemProducer.java +++ b/samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemProducer.java @@ -27,10 +27,6 @@ import org.apache.samza.system.SystemStreamPartition; import org.slf4j.Logger; import org.slf4j.LoggerFactory; - -/** - * Initial draft of in-memory {@link SystemProducer}. It is test only and not meant for production use right now. - */ public class InMemorySystemProducer implements SystemProducer { private static final Logger LOG = LoggerFactory.getLogger(InMemorySystemProducer.class); private final InMemoryManager memoryManager;
