diff --git a/docs/dev/batch/index.md b/docs/dev/batch/index.md index 521f4624b1a961990fa15a601ff996713e09a679..934cb2b1a70126a7bb490d6b28753979ce275061 100644 --- a/docs/dev/batch/index.md +++ b/docs/dev/batch/index.md @@ -1028,8 +1028,8 @@ val values = env.fromElements("Foo", "bar", "foobar", "fubar") val numbers = env.generateSequence(1, 10000000) // read a file from the specified path of type SequenceFileInputFormat -val tuples = env.readSequenceFile(classOf[IntWritable], classOf[Text], - "hdfs://nnHost:nnPort/path/to/file") +val tuples = env.createInput(HadoopInputs.readSequenceFile(classOf[IntWritable], classOf[Text], + "hdfs://nnHost:nnPort/path/to/file")) {% endhighlight %}