public class CaptureCollector extends Object implements TridentCollector
Constructor and Description |
---|
CaptureCollector() |
Modifier and Type | Method and Description |
---|---|
void |
emit(List<Object> values) |
void |
reportError(Throwable t) |
void |
setCollector(TridentCollector coll) |
public void setCollector(TridentCollector coll)
public void emit(List<Object> values)
emit
in interface TridentCollector
public void reportError(Throwable t)
reportError
in interface TridentCollector
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.