InputPartitioner

A dev interface for expressing how incoming data is partitioned. By default, data will be partitioned by a hash of the stream name and namespace.

Inheritors