You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by pm...@apache.org on 2018/10/30 02:52:08 UTC
samza git commit: Add physical name support for
InMemoryStreamDescriptors
Repository: samza
Updated Branches:
refs/heads/master ea0bec4a8 -> 64c82634c
Add physical name support for InMemoryStreamDescriptors
Author: Sanil15 <sa...@gmail.com>
Reviewers: Prateek Maheshwari <pm...@apache.org>
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 <sa...@gmail.com>
Authored: Mon Oct 29 19:52:04 2018 -0700
Committer: Prateek Maheshwari <pm...@apache.org>
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;
+ }
}