[FLINK-3407] Extend TwitterSource with interface StoppableFunction

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.1.0
• Component/s: Connectors / Common
• Assignee: Robert Metzger
• Reporter: Matthias J. Sax
• Created: 15/Feb/16 19:33
• Updated: 17/Mar/16 12:23
• Resolved: 17/Mar/16 12:23

Description

TwitterSource is not stoppable right now. To make it stoppable, is must implement StoppableFunction. Implementing method stop() must ensure, that the source stops receiving new Tweets and issues a final checkpoint. Afterwards, run() must return.

When implementing this, keep in mind, that the gathered checkpoint might later be used as a savepoint.