Repository: samza Updated Branches: refs/heads/1.0.0 bdae04b09 -> 69d1807d5
Add physical name support for InMemoryStreamDescriptors Author: Sanil15 <[email protected]> Reviewers: Prateek Maheshwari <[email protected]> Closes #781 from Sanil15/SAMZA-1970 (cherry picked from commit 64c82634c33c067e2245315b1aa826057f9a2875) Signed-off-by: Prateek Maheshwari <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/69d1807d Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/69d1807d Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/69d1807d Branch: refs/heads/1.0.0 Commit: 69d1807d52a89ff04259347428531e7e57e02c13 Parents: bdae04b Author: Sanil15 <[email protected]> Authored: Mon Oct 29 19:52:04 2018 -0700 Committer: Prateek Maheshwari <[email protected]> Committed: Mon Oct 29 19:52:14 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/69d1807d/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/69d1807d/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; + } }
