[NEMO-268] Consider start/finish bundles in Transform

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.1
• Labels: pull-request-available
• Assignee: Unassigned
• Reporter: Tae-Geon Um
• Created: 05/Nov/18 11:44
• Updated: 25/Nov/18 23:27
• Resolved: 15/Nov/18 02:03

Description

In batch job, Transform starts bundle at start time, and finishes the bundle when the job is finished. In streaming, we should start/finish bundle every a (configurable) certain number of elements of a period.

Issue Links

• is related to: NEMO-247 UnboundedSource WindowedWordCount ITCase
• links to: GitHub Pull Request #152