You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2015/11/20 16:19:04 UTC
flink git commit: [doc] Fix Documentation formatting for recently
added ExecutionEnvironment.readSequenceFile()
Repository: flink
Updated Branches:
refs/heads/master 5864e4fd4 -> a7111cdd0
[doc] Fix Documentation formatting for recently added ExecutionEnvironment.readSequenceFile()
This closes #1389.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a7111cdd
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a7111cdd
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a7111cdd
Branch: refs/heads/master
Commit: a7111cdd0ef71afa902474240f46cd14758a11d4
Parents: 5864e4f
Author: smarthi <sm...@apache.org>
Authored: Fri Nov 20 09:34:55 2015 -0500
Committer: Till Rohrmann <tr...@apache.org>
Committed: Fri Nov 20 16:18:54 2015 +0100
----------------------------------------------------------------------
docs/apis/programming_guide.md | 14 +++++++++-----
1 file changed, 9 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/a7111cdd/docs/apis/programming_guide.md
----------------------------------------------------------------------
diff --git a/docs/apis/programming_guide.md b/docs/apis/programming_guide.md
index 8248f5d..fe3edaa 100644
--- a/docs/apis/programming_guide.md
+++ b/docs/apis/programming_guide.md
@@ -1790,10 +1790,12 @@ DataSet<Person>> csvInput = env.readCsvFile("hdfs:///the/CSV/file")
// read a file from the specified path of type TextInputFormat
-DataSet<Tuple2<LongWritable, Text>> tuples = env.readHadoopFile(new TextInputFormat(), LongWritable.class, Text.class, "hdfs://nnHost:nnPort/path/to/file");
+DataSet<Tuple2<LongWritable, Text>> tuples =
+ env.readHadoopFile(new TextInputFormat(), LongWritable.class, Text.class, "hdfs://nnHost:nnPort/path/to/file");
// read a file from the specified path of type SequenceFileInputFormat
-DataSet<Tuple2<IntWritable, Text>> tuples = env.readSequenceFile(IntWritable.class, Text.class, "hdfs://nnHost:nnPort/path/to/file");
+DataSet<Tuple2<IntWritable, Text>> tuples =
+ env.readSequenceFile(IntWritable.class, Text.class, "hdfs://nnHost:nnPort/path/to/file");
// creates a set from some given elements
DataSet<String> value = env.fromElements("Foo", "bar", "foobar", "fubar");
@@ -1948,14 +1950,16 @@ val values = env.fromElements("Foo", "bar", "foobar", "fubar")
// generate a number sequence
val numbers = env.generateSequence(1, 10000000);
-{% endhighlight %}
// read a file from the specified path of type TextInputFormat
-val tuples = env.readHadoopFile(new TextInputFormat, classOf[LongWritable], classOf[Text], "hdfs://nnHost:nnPort/path/to/file")
+val tuples = env.readHadoopFile(new TextInputFormat, classOf[LongWritable],
+ classOf[Text], "hdfs://nnHost:nnPort/path/to/file")
// 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.readSequenceFile(classOf[IntWritable], classOf[Text],
+ "hdfs://nnHost:nnPort/path/to/file")
+{% endhighlight %}
#### Configuring CSV Parsing