You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2016/11/08 03:41:26 UTC
[27/50] incubator-beam git commit: Sorter: fix README to support
syntax highlighting
Sorter: fix README to support syntax highlighting
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0604d2bb
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0604d2bb
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/0604d2bb
Branch: refs/heads/gearpump-runner
Commit: 0604d2bb0a666787545b75b1a70ca2fe6496cddc
Parents: baa7fb0
Author: Dan Halperin <dh...@google.com>
Authored: Mon Nov 7 12:18:11 2016 -0800
Committer: Dan Halperin <dh...@google.com>
Committed: Mon Nov 7 13:31:47 2016 -0800
----------------------------------------------------------------------
sdks/java/extensions/sorter/README.md | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/0604d2bb/sdks/java/extensions/sorter/README.md
----------------------------------------------------------------------
diff --git a/sdks/java/extensions/sorter/README.md b/sdks/java/extensions/sorter/README.md
index 80d2a40..18bd0d2 100644
--- a/sdks/java/extensions/sorter/README.md
+++ b/sdks/java/extensions/sorter/README.md
@@ -28,7 +28,7 @@ This module provides the SortValues transform, which takes a `PCollection<KV<K,
* The user can customize the temporary location used if sorting requires spilling to disk and the maximum amount of memory to use by creating a custom instance of `BufferedExternalSorter.Options` to pass into `SortValues.create`.
##Using `SortValues`
-~~~~
+```java
PCollection<KV<String, KV<String, Integer>>> input = ...
// Group by primary key, bringing <SecondaryKey, Value> pairs for the same key together.
@@ -39,4 +39,4 @@ PCollection<KV<String, Iterable<KV<String, Integer>>>> grouped =
PCollection<KV<String, Iterable<KV<String, Integer>>>> groupedAndSorted =
grouped.apply(
SortValues.<String, String, Integer>create(new BufferedExternalSorter.Options()));
-~~~~
\ No newline at end of file
+```