- SimpleOutput:简单的输出
BatchOutput:批量输出所需参数:
TimeIntervalOutput:以设定时间间隔输出所需参数:
- TimeIntervalBatchOutput:时间间隔、批量组合输出所需参数:
- DataSizeOutput:数据字节量输出【暂未实现】
- TimeIntervalDataSizeOutput:时间间隔、数据字节量批量组合输出【暂未实现】
实现方法说明:
父类方法:
super.writerWrappers:获取该输出所携带的写入者:
super.convertRecords(Writer writer, RecordWrapper recordWrapper): 封装了数据转换,主要是对数据的数据格式进行转换
AbstractCacheOutput:
AbstractOutput:
output(RecordWrapper recordWrapper):输出该数据到写入者。参数:RecordWrapper 为记录的包装,通过:recordWrapper.getRecordGroup().getRecords() 可拿到要写入的数据集合
AbstractCacheOutput: