This is an automated email from the ASF dual-hosted git repository.
jagadish pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git
The following commit(s) were added to refs/heads/master by this push:
new 43819f4 SAMZA-2232: Move StreamOperatorTaskFactory to samza-api
43819f4 is described below
commit 43819f4746a4cd01b2ece2a65d892fb8a30978e0
Author: mynameborat <[email protected]>
AuthorDate: Mon Jun 3 11:11:36 2019 -0700
SAMZA-2232: Move StreamOperatorTaskFactory to samza-api
Author: mynameborat <[email protected]>
Reviewers: Jagadish<[email protected]>
Closes #1061 from mynameborat/move-stream-operator-task-factory
---
.../java/org/apache/samza/task/StreamOperatorTaskFactory.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git
a/samza-core/src/main/java/org/apache/samza/task/StreamOperatorTaskFactory.java
b/samza-api/src/main/java/org/apache/samza/task/StreamOperatorTaskFactory.java
similarity index 65%
rename from
samza-core/src/main/java/org/apache/samza/task/StreamOperatorTaskFactory.java
rename to
samza-api/src/main/java/org/apache/samza/task/StreamOperatorTaskFactory.java
index 0f9cc3b..e73a490 100644
---
a/samza-core/src/main/java/org/apache/samza/task/StreamOperatorTaskFactory.java
+++
b/samza-api/src/main/java/org/apache/samza/task/StreamOperatorTaskFactory.java
@@ -20,11 +20,11 @@ package org.apache.samza.task;
/**
- * Build {@link StreamOperatorTask} instances.
+ * Build {@link AsyncStreamTask} instances.
* <p>
- * Implementations should return a new instance of {@link StreamOperatorTask}
for each {@link #createInstance()} invocation.
- * Note: It is not part of samza-api as it is a temporary hack introduced for
SAMZA-2172. It will eventually
- * go away with SAMZA-2203
+ * Implementations should return a new instance of {@link AsyncStreamTask} for
each {@link #createInstance()} invocation.
+ * Note: It returns an {@link AsyncStreamTask} since
<code>StreamOperatorTask</code> is not part of samza-api. It is
+ * a temporary hack introduced for SAMZA-2172 and will eventually go away with
SAMZA-2203
*/
-interface StreamOperatorTaskFactory extends TaskFactory<AsyncStreamTask> {
+public interface StreamOperatorTaskFactory extends
TaskFactory<AsyncStreamTask> {
}
