[
https://issues.apache.org/jira/browse/DRILL-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14261373#comment-14261373
]
Deneche A. Hakim commented on DRILL-1908:
-----------------------------------------
first step in the implementation: I got my own operator to save all incoming
batches into a list of RecordBatchData, once no more batches are available the
operator sends the saved batches downstream one at a time.
The code is available in my repo:
https://github.com/adeneche/incubator-drill/tree/DRILL-1908
One thing I noticed is that once I start sending the saved batches downstream,
I always need to return OK_NEW_SCHEMA or I get exceptions downstream.
> new window function implementation
> ----------------------------------
>
> Key: DRILL-1908
> URL: https://issues.apache.org/jira/browse/DRILL-1908
> Project: Apache Drill
> Issue Type: Improvement
> Components: Execution - Operators
> Reporter: Deneche A. Hakim
> Assignee: Deneche A. Hakim
> Priority: Critical
>
> In order to fix DRILL-1487 a complete rewrite of the
> StreamingWindowFrameRecordBatch may be needed. The purpose of this issue is
> to report my progress and share my thoughts with the community in order to
> get a proper implementation
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
