Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-1465

No natural place to flush resources in FileBasedWriter

Details

    • Bug
    • Status: Resolved
    • P2
    • Resolution: Fixed
    • None
    • 0.6.0
    • sdk-java-core

    Description

      FileBasedWriter API does not have a natural place to flush resources opened by the writer.

      For example, if you create an OutputStream in your Writer using the FileBasedSink's channel and this OutputStream buffers outputs, there is no natural place to call its flush() method.

      Maybe something like finishWrite() to match the existing prepareWrite(WritableByteChannel channel) can work.

      Attachments

        Issue Links

          Activity

            People

              aviemzur Aviem Zur
              aviemzur Aviem Zur
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: