Access操作


Acces操作通过sparkjob.access.operations parameter. 多个Access操作以 ';' 分隔. 在下面的例子,我们将c1的缓存通过Access操作读入,然后由HDFSOutputConnector 写出到HDFS目录. 我们用的是Access的短名,全名是'com.exceeddata.ac.job.operation.Access'. 注:如果c1不存在,会有错误扔出。

JSON

{ "connector.hdfsout.output.path": "hdfs://master:9000/user/root/result/out/", "sparkjob.output.connectors": "com.exceeddata.ac.connector.hdfs.HDFSOutputConnector",

"sparkjob.access.operations": "Access?input=c1"

}