写出链接库


写出链接库通过sparkjob.output.connectors 参数定义。多个读入链接库以 ';' 分隔。在下面的例子,我们将c1的缓存读入,将结果通过HDFSOutputConnector 写出到HDFS目录。 HDFSOutputConnector的预设的id是"hdfsout".

JSON

{ "sparkjob.output.connectors": "HDFSOutputConnector?input=c2(output.path=/user/demo/output1, output.format=csv)", "sparkjob.access.operations": "Access?input=c1,output=c2"

}