Repository: samza Updated Branches: refs/heads/master ea0bec4a8 -> 64c82634c
Add physical name support for InMemoryStreamDescriptors Author: Sanil15 <[email protected]> Reviewers: Prateek Maheshwari <[email protected]> Closes #781 from Sanil15/SAMZA-1970 Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/64c82634 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/64c82634 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/64c82634 Branch: refs/heads/master Commit: 64c82634c33c067e2245315b1aa826057f9a2875 Parents: ea0bec4 Author: Sanil15 <[email protected]> Authored: Mon Oct 29 19:52:04 2018 -0700 Committer: Prateek Maheshwari <[email protected]> Committed: Mon Oct 29 19:52:04 2018 -0700 ---------------------------------------------------------------------- .../framework/system/descriptors/InMemoryInputDescriptor.java | 5 +++++ .../framework/system/descriptors/InMemoryOutputDescriptor.java | 5 +++++ 2 files changed, 10 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/64c82634/samza-test/src/main/java/org/apache/samza/test/framework/system/descriptors/InMemoryInputDescriptor.java ---------------------------------------------------------------------- diff --git a/samza-test/src/main/java/org/apache/samza/test/framework/system/descriptors/InMemoryInputDescriptor.java b/samza-test/src/main/java/org/apache/samza/test/framework/system/descriptors/InMemoryInputDescriptor.java index c446083..f2214de 100644 --- a/samza-test/src/main/java/org/apache/samza/test/framework/system/descriptors/InMemoryInputDescriptor.java +++ b/samza-test/src/main/java/org/apache/samza/test/framework/system/descriptors/InMemoryInputDescriptor.java @@ -39,4 +39,9 @@ public class InMemoryInputDescriptor<StreamMessageType> InMemoryInputDescriptor(String streamId, InMemorySystemDescriptor systemDescriptor) { super(streamId, new NoOpSerde<>(), systemDescriptor, null); } + + public InMemoryInputDescriptor withPhysicalName(String physicalName) { + withPhysicalName(physicalName); + return this; + } } http://git-wip-us.apache.org/repos/asf/samza/blob/64c82634/samza-test/src/main/java/org/apache/samza/test/framework/system/descriptors/InMemoryOutputDescriptor.java ---------------------------------------------------------------------- diff --git a/samza-test/src/main/java/org/apache/samza/test/framework/system/descriptors/InMemoryOutputDescriptor.java b/samza-test/src/main/java/org/apache/samza/test/framework/system/descriptors/InMemoryOutputDescriptor.java index 26c64f3..7c38aa6 100644 --- a/samza-test/src/main/java/org/apache/samza/test/framework/system/descriptors/InMemoryOutputDescriptor.java +++ b/samza-test/src/main/java/org/apache/samza/test/framework/system/descriptors/InMemoryOutputDescriptor.java @@ -43,4 +43,9 @@ public class InMemoryOutputDescriptor<StreamMessageType> InMemoryOutputDescriptor(String streamId, SystemDescriptor systemDescriptor) { super(streamId, new NoOpSerde<>(), systemDescriptor); } + + public InMemoryOutputDescriptor withPhysicalName(String physicalName) { + withPhysicalName(physicalName); + return this; + } }
