diff --git a/docs/apis/batch/index.md b/docs/apis/batch/index.md index ff53219173a2a57221aa9f31ea85776eb51a6d1a..653e5d7c3a2fed42c76206e562bb242a65c111bb 100644 --- a/docs/apis/batch/index.md +++ b/docs/apis/batch/index.md @@ -174,8 +174,8 @@ data.flatMap(new FlatMapFunction() { MapPartition -

Transforms a parallel partition in a single function call. The function get the partition - as an `Iterable` stream and can produce an arbitrary number of result values. The number of +

Transforms a parallel partition in a single function call. The function gets the partition + as an Iterable stream and can produce an arbitrary number of result values. The number of elements in each partition depends on the degree-of-parallelism and previous operations.

{% highlight java %} data.mapPartition(new MapPartitionFunction() { @@ -301,7 +301,7 @@ result = input1.join(input2, JoinHint.BROADCAST_HASH_FIRST) OuterJoin - Performs a left, right, or full outer join on two data sets. Outer joins are similar to regular (inner) joins and create all pairs of elements that are equal on their keys. In addition, records of the "outer" side (left, right, or both in case of full) are preserved if no matching key is found in the other side. Matching pairs of elements (or one element and a `null` value for the other input) are given to a JoinFunction to turn the pair of elements into a single element, or to a FlatJoinFunction to turn the pair of elements into arbitrarily many (including none) elements. See the keys section to learn how to define join keys. + Performs a left, right, or full outer join on two data sets. Outer joins are similar to regular (inner) joins and create all pairs of elements that are equal on their keys. In addition, records of the "outer" side (left, right, or both in case of full) are preserved if no matching key is found in the other side. Matching pairs of elements (or one element and a null value for the other input) are given to a JoinFunction to turn the pair of elements into a single element, or to a FlatJoinFunction to turn the pair of elements into arbitrarily many (including none) elements. See the keys section to learn how to define join keys. {% highlight java %} input1.leftOuterJoin(input2) // rightOuterJoin or fullOuterJoin for right or full outer joins .where(0) // key of the first input (tuple field 0) @@ -1067,12 +1067,12 @@ The following table lists the currently supported compression methods. DEFLATE - `.deflate` + .deflate no GZip - `.gz`, `.gzip` + .gz, .gzip no