public class SyncReadListener extends AnalysisEventListener<java.lang.Object>
构造器和说明 |
---|
SyncReadListener() |
限定符和类型 | 方法和说明 |
---|---|
void |
doAfterAllAnalysed(AnalysisContext context)
if have something to do after all analysis
|
java.util.List<java.lang.Object> |
getList() |
void |
invoke(java.lang.Object object,
AnalysisContext context)
When analysis one row trigger invoke function.
|
void |
setList(java.util.List<java.lang.Object> list) |
hasNext, invokeHead, invokeHeadMap, onException
public void invoke(java.lang.Object object, AnalysisContext context)
ReadListener
object
- one row value. Is is same as AnalysisContext.readRowHolder()
context
- analysis contextpublic void doAfterAllAnalysed(AnalysisContext context)
ReadListener
context
- AnalysisContextpublic java.util.List<java.lang.Object> getList()
public void setList(java.util.List<java.lang.Object> list)