Date: Fri, 29 Mar 2024 07:47:33 +0100 (CET) Message-ID: <1410569169.123.1711694853615@vmisdata19.uni-oldenburg.de> Subject: Exported From Confluence MIME-Version: 1.0 Content-Type: multipart/related; boundary="----=_Part_122_1407768579.1711694853615" ------=_Part_122_1407768579.1711694853615 Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable Content-Location: file:///C:/exported.html
File reference to a Hadoop Filesystem (wrapper feature must be i= nstalled)
fs.default.name
: The name of the Hadoop f=
ilesystemFilename
: The path to the fileappend
: append values to end of file. If =
set to false (default) the values are overwritten.#PARSER= PQL #RUNQUERY input =3D ACCESS({source=3D'Source', wrapper=3D'GenericPull', transport=3D'hdfs', protocol=3D'csv', dataHandler=3D'Tuple', Internship 2015 options=3D[['fs.default.name','hdfs://master:9000'], ['username','hduser'],['Filename', '/user/sorted_data.csv'], ['append','false']], schema=3D[ ['1', 'String'], ['2', 'String'],})
output = =3D SENDER({sink=3D'Sink', wrapper=3D'GenericPush', transport=3D'hdfs', protocol=3D'CSV', dataHandler=3D'Tuple', options=3D[['fs.default.name','hdfs://master:9000'], ['username','hduser'],['Filename', '/user/sorted_data.csv'], ['append','false']] }, input)