[STORM-2712] accept arbitrary number of rows per tuple in storm-cassandra

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 2.0.0, 1.1.1
• Fix Version/s: 2.0.0, 1.2.0, 1.1.2
• Component/s: storm-cassandra
• Labels: pull-request-available
• Assignee: Yohei Kishimoto
• Reporter: Yohei Kishimoto
• Created: 28/Aug/17 14:26
• Updated: 19/Sep/17 22:59
• Resolved: 19/Sep/17 22:59

Description

Current implementation in `TridentResultSetValuesMapper::map` restricts a SELECT query to return one row. In `StateQueryProcessor::finishBatch`, it checks the equality between the result size of `batchRetrieve` and input tuple size. When the number of result rows is less than 1 or greater than 1, it breaks the condition and an exception is thrown.

We should accept arbitrary number of rows by adjusting List dimensions.

Issue Links

• links to: GitHub Pull Request #2295