SPARK-4817[STREAMING]Print the specified number of data and handle all of the elements in RDD

[surq]

Dstream.print function:Print 10 elements and handle 11 elements.
A new function based on Dstream.print function is presented:
the new function:
Print the specified number of data and handle all of the elements in RDD.
there is a work scene:
val dstream = stream.map->filter->mapPartitions->print
the data after filter need update database in mapPartitions,but don't need print each data,only need to print the top 20 for view the data processing.

[srowen]

You should put SPARK-XXXX [STREAMING] in the title. But your original JIRA was a duplicate of https://issues.apache.org/jira/browse/SPARK-3325 so perhaps you can connect this to that JIRA.

[SparkQA]

Test build #24306 has started for PR 3662 at commit 4e3f715.

• This patch merges cleanly.

[SparkQA]

Test build #24306 has finished for PR 3662 at commit 4e3f715.

• This patch passes all tests.
• This patch merges cleanly.
• This patch adds no public classes.

[AmplabJenkins]

Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/24306/
Test PASSed.

[SparkQA]

Test build #24358 has started for PR 3662 at commit 411b287.

• This patch merges cleanly.

[SparkQA]

Test build #24358 has finished for PR 3662 at commit 411b287.

• This patch passes all tests.
• This patch merges cleanly.
• This patch adds no public classes.

[AmplabJenkins]

Test PASSed.
Refer to this link for build results (access rights to CI server needed):
https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/24358/
Test PASSed.

[tdas]

As I commented on the JIRA, this isnt right way to do what you are trying to achieve. The JIRA has already been closed, so mind closing this PR?