[FLINK-3219] Implement DataSet.count using a single operator - ASF JIRA

XML

Word

Printable

JSON

Details

Type: Improvement
Status: Closed
Priority: Minor
Resolution: Fixed
Affects Version/s: None
Fix Version/s: 1.0.0
Component/s: None
Labels:
None

Description

DataSet.count is currently implemented using a FlatMapFunction followed by a DiscardingOutputFormat. As noted by StephanEwen in ~~FLINK-2716~~ this can be done with only a RichOutputFormat.

This change is also applicable to DataSet.collect and Utils.CollectHelper.

Attachments

Activity

People

Assignee:: Greg Hogan

Reporter:: Greg Hogan

Votes:: 0 Vote for this issue

Watchers:: 5 Start watching this issue

Dates

Created:: 11/Jan/16 18:17

Updated:: 15/Jan/16 13:51

Resolved:: 15/Jan/16 10:55