[jira] [Created] (IMPALA-8779) Add RowBatchQueue interface with an implementation backed by a std::queue

["Sahil Takiar (JIRA)" <ji...@apache.org>]

Sahil Takiar created IMPALA-8779:
------------------------------------

             Summary: Add RowBatchQueue interface with an implementation backed by a std::queue
                 Key: IMPALA-8779
                 URL: https://issues.apache.org/jira/browse/IMPALA-8779
             Project: IMPALA
          Issue Type: Sub-task
          Components: Backend
            Reporter: Sahil Takiar
            Assignee: Sahil Takiar


Add a {{RowBatchQueue}} interface with an implementation backed by a {{std::queue}}. Introducing a generic queue that can buffer {{RowBatch}}es will help with the implementation of {{BufferedTupleSink}}. Rather than tie the {{BufferedTupleSink}} to a specific method of queuing row batches, we can use an interface. In future patches, a {{RowBatchQueue}} backed by a {{BufferedTupleStream}} can easily be switched out in {{BufferedTupleSink}}.

We should consider re-factoring the existing {{RowBatchQueue}} to use the new interface as well.



--
This message was sent by Atlassian JIRA
(v7.6.14#76016)