junzhong qin created FLINK-31749:
------------------------------------
Summary: The Using Hadoop OutputFormats example is not avaliable
for DataStream
Key: FLINK-31749
URL: https://issues.apache.org/jira/browse/FLINK-31749
Project: Flink
Issue Type: Improvement
Components: Documentation
Affects Versions: 1.15.4, 1.17.0
Reporter: junzhong qin
The following example shows how to use Hadoop’s {{TextOutputFormat from the
doc:
https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/connectors/datastream/formats/hadoop/#using-hadoop-outputformats
. But the DataStream has no outpu()).}}
{code:java}
// Obtain the result we want to emit
DataStream<Tuple2<Text, IntWritable>> hadoopResult = [...]
// Set up the Hadoop TextOutputFormat.
HadoopOutputFormat<Text, IntWritable> hadoopOF =
// create the Flink wrapper.
new HadoopOutputFormat<Text, IntWritable>(
// set the Hadoop OutputFormat and specify the job.
new TextOutputFormat<Text, IntWritable>(), job
);
hadoopOF.getConfiguration().set("mapreduce.output.textoutputformat.separator",
" ");
TextOutputFormat.setOutputPath(job, new Path(outputPath));
// Emit data using the Hadoop TextOutputFormat.
hadoopResult.output(hadoopOF); {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
