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