[ https://issues.apache.org/jira/browse/HIVE-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14310098#comment-14310098 ]
Prasanth Jayachandran commented on HIVE-9603: --------------------------------------------- Adding some relevant links for easy reference https://github.com/ReactiveX/RxJava/wiki/How-To-Use-RxJava https://github.com/ReactiveX/RxJava/wiki/Backpressure https://github.com/ReactiveX/RxJava/wiki/Error-Handling > LLAP: (IO) consider using reactive framework to string together parts of code > ----------------------------------------------------------------------------- > > Key: HIVE-9603 > URL: https://issues.apache.org/jira/browse/HIVE-9603 > Project: Hive > Issue Type: Sub-task > Reporter: Sergey Shelukhin > > Hand-rolled async consumers-producers are somewhat confusing. [~prasanth_j] > proposed using RxJava; Observable seems to be a natural fit for data producer > and provides built-in error handling and backpressure. -- This message was sent by Atlassian JIRA (v6.3.4#6332)