public class CloudAnalysisManager
extends java.lang.Object
构造器和说明 |
---|
CloudAnalysisManager() |
限定符和类型 | 方法和说明 |
---|---|
static java.util.Collection<AnalysisExportTask> |
getExporterTask()
获取所有导出任务
|
static void |
manual()
手动运行一次任务,其他情况下无需调用
|
static java.lang.String |
mergeFile(AnalysisFileFilter filter)
合并某些数据文件
|
static void |
registerExecutor(AnalysisRecordExecutor analysisRecordExecutor)
注册执行器
|
static void |
registerExportService(AnalysisExportTask task)
注册导出器
|
static void |
registerRecordService(AnalysisCollectTask task,
java.lang.String cron)
注册收集器
|
static void |
reset()
移除导出器
|
static void |
unregisterExecutor()
注销执行器
|
static void |
unregisterService(java.lang.String name)
注销导出/收集任务
|
public static void registerExecutor(AnalysisRecordExecutor analysisRecordExecutor)
analysisRecordExecutor
- 导出执行器public static void unregisterExecutor()
public static void registerRecordService(AnalysisCollectTask task, java.lang.String cron)
task
- 收集器cron
- cron表达式public static void registerExportService(AnalysisExportTask task)
task
- 导出器public static void unregisterService(java.lang.String name)
name
- 收集器/导出器名称public static java.util.Collection<AnalysisExportTask> getExporterTask()
public static void manual()
public static void reset()
public static java.lang.String mergeFile(AnalysisFileFilter filter) throws java.io.IOException
filter
- 文件过滤器java.io.IOException