Details

PartitionConsumer has support for concurrency, as well as a limit and filter on read.

Rank:

1|hzz1gf:

Description

Multiple partition consumers:
CDAP should support concurrency for multiple partition consumers operating on the same Dataset. Each Consumer would be able to mark the partitions the workflow operates on as 'in progress' and have the ability to roll back to 'unprocessed' should the workflow fail or timeout.