Sign in
apache
/
storm
/
refs/heads/0.7.0
/
.
/
src
/
jvm
/
backtype
/
storm
/
topology
/
IBasicOutputCollector.java
blob: cfc5b0d98b680ebf35edfe87d8ff4f5a220188b9 [
file
] [
log
] [
blame
]
package
backtype
.
storm
.
topology
;
import
java
.
util
.
List
;
public
interface
IBasicOutputCollector
{
List
<
Integer
>
emit
(
String
streamId
,
List
<
Object
>
tuple
);
void
emitDirect
(
int
taskId
,
String
streamId
,
List
<
Object
>
tuple
);
}