Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-2160

Change Streaming Source Interface to run(Context)/cancel()

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 0.9
    • Component/s: None
    • Labels:
      None

      Description

      This will make the source interface more extensible in the future without breaking existing sources (after the change). Right now, the context would have methods for element emission and for retrieving the checkpoint lock for checkpointed sources. In the future this can be extended to allow emission of elements with timestamp and for dealing with watermark emission.

        Attachments

          Activity

            People

            • Assignee:
              aljoscha Aljoscha Krettek
              Reporter:
              aljoscha Aljoscha Krettek
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: