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

Add open and close methods to manage IF lifecycle

    Details

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

      Description

      At the moment the opening and closing of an inputFormat are not managed, although open() could be (improperly IMHO) simulated by configure().
      This limits the possibility to reuse expensive resources (like database connections) and manage their release.

      Probably the best option would be to add 2 methods (i.e. openInputformat() and closeInputFormat() ) to RichInputFormat*

      • NOTE: the best option from a "semantic" point of view would be to rename the current open() and close() to openSplit() and closeSplit() respectively while using open() and close() methods for the IF lifecycle management, but this would cause a backward compatibility issue...

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                f.pompermaier Flavio Pompermaier
                Reporter:
                f.pompermaier Flavio Pompermaier
              • Votes:
                1 Vote for this issue
                Watchers:
                5 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: