[GEARPUMP-203] Use DataSourceTask / DataSinkTask for DSL

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.8.1
• Fix Version/s: 0.8.2
• Component/s: streaming
• Assignee: Manu Zhang
• Reporter: Manu Zhang
• Created: 05/Sep/16 07:55
• Updated: 06/Sep/16 07:20
• Resolved: 06/Sep/16 07:20

Description

Currently, source operation in DSL will be translated to SourceTask allowing for a passed-in operation processing input data while DataSourceTask is default container running DataSource API without any processing. SinkTask and DataSinkTask are almost identical. We can improve the latter to account for both cases such that we don't keep two sets of implementations.

Issue Links

• links to: GitHub Pull Request #80