diff --git a/subprojects/s4-core/src/main/java/org/apache/s4/core/Stream.java b/subprojects/s4-core/src/main/java/org/apache/s4/core/Stream.java index aa54dfc7..e5ef7751 100644 --- a/subprojects/s4-core/src/main/java/org/apache/s4/core/Stream.java +++ b/subprojects/s4-core/src/main/java/org/apache/s4/core/Stream.java @@ -46,7 +46,6 @@ public class Stream implements Runnable, Streamable { final static private String DEFAULT_SEPARATOR = "^"; final static private int CAPACITY = 1000; - private static int idCounter = 0; private String name; protected Key key; private ProcessingElement[] targetPEs; @@ -139,27 +138,15 @@ public Stream setKey(String keyName) { } /** - * Send events from this stream to a PE. - * - * @param pe - * a target PE. - * - * @return the stream object - */ - public Stream setPE(ProcessingElement pe) { - app.addStream(this); - return this; - } - - /** - * Send events from this stream to various PEs. + * Send events from this stream to one or more PEs. * * @param pes - * a target PE array. + * one or more target prototypes + * * * @return the stream object */ - public Stream setPEs(ProcessingElement[] pes) { + public Stream setPEs(ProcessingElement... pes) { this.targetPEs = pes; return this; } @@ -320,7 +307,7 @@ public void run() { } } - public Stream register() { + Stream register() { app.addStream(this); return this; } diff --git a/subprojects/s4-edsl/src/main/java/org/apache/s4/edsl/AppBuilder.java b/subprojects/s4-edsl/src/main/java/org/apache/s4/edsl/AppBuilder.java index fb40b432..4e007b0f 100644 --- a/subprojects/s4-edsl/src/main/java/org/apache/s4/edsl/AppBuilder.java +++ b/subprojects/s4-edsl/src/main/java/org/apache/s4/edsl/AppBuilder.java @@ -123,7 +123,7 @@ App buildApp() { for (StreamBuilder sb : streamBuilders) { for (String peName : sb.pes) { ProcessingElement pe = getPE(peName); - sb.stream.setPE(pe); + sb.stream.setPEs(pe); } }