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