Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

Remove internal method with incorrect implementation

  • Loading branch information...
commit 6dd0ed0b6669f5b843c29ee3a3f899de7b72a579 1 parent a7f86ac
@matthieumorel matthieumorel authored
View
23 subprojects/s4-core/src/main/java/org/apache/s4/core/Stream.java
@@ -46,7 +46,6 @@
final static private String DEFAULT_SEPARATOR = "^";
final static private int CAPACITY = 1000;
- private static int idCounter = 0;
private String name;
protected Key<T> key;
private ProcessingElement[] targetPEs;
@@ -139,27 +138,15 @@ public void start() {
}
/**
- * Send events from this stream to a PE.
- *
- * @param pe
- * a target PE.
- *
- * @return the stream object
- */
- public Stream<T> 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<T> setPEs(ProcessingElement[] pes) {
+ public Stream<T> setPEs(ProcessingElement... pes) {
this.targetPEs = pes;
return this;
}
@@ -320,7 +307,7 @@ public void run() {
}
}
- public Stream<T> register() {
+ Stream<T> register() {
app.addStream(this);
return this;
}
View
2  subprojects/s4-edsl/src/main/java/org/apache/s4/edsl/AppBuilder.java
@@ -123,7 +123,7 @@ App buildApp() {
for (StreamBuilder<? extends Event> sb : streamBuilders) {
for (String peName : sb.pes) {
ProcessingElement pe = getPE(peName);
- sb.stream.setPE(pe);
+ sb.stream.setPEs(pe);
}
}
Please sign in to comment.
Something went wrong with that request. Please try again.