com.fr.analysis.cloud

接口 AnalysisRecordExecutor

public interface AnalysisRecordExecutor

导出执行器

作者:

vito

方法概要

方法

限定符和类型	方法和说明
void	addExportTask(AnalysisExportTask exporter) 添加导出任务
void	addRecordTask(AnalysisCollectTask task, java.lang.String cron) 添加收集任务
boolean	checkExportTaskExist(java.lang.String name) 检查是否已经存在同名任务
boolean	checkRecordTaskExist(java.lang.String name) 检查是否已经存在同名任务
void	clean() 清除所有任务
java.util.Collection<AnalysisExportTask>	getExportTask() 获取所有导出任务
void	manual() 手动运行一次
void	removeTask(java.lang.String name) 移除一个任务

方法详细资料

getExportTask

java.util.Collection<AnalysisExportTask> getExportTask()

获取所有导出任务

返回:

导出任务列表

checkRecordTaskExist

boolean checkRecordTaskExist(java.lang.String name)

检查是否已经存在同名任务

参数:

name - 名称

返回:

是否已经注册

checkExportTaskExist

boolean checkExportTaskExist(java.lang.String name)

检查是否已经存在同名任务

参数:

name - 名称

返回:

是否已经注册

addRecordTask

void addRecordTask(AnalysisCollectTask task,
                 java.lang.String cron)

添加收集任务

参数:

task - 收集任务

cron - cron表达式

addExportTask

void addExportTask(AnalysisExportTask exporter)

添加导出任务

参数:

exporter - 导出器

manual

void manual()

手动运行一次

removeTask

void removeTask(java.lang.String name)

移除一个任务

参数:

name - 任务名称

clean

void clean()

清除所有任务