roboto.experimental.topics.decode.timestamp_unit

Module Contents

roboto.experimental.topics.decode.timestamp_unit.plan_timestamp_unit(partition)

Return the unit the plan gives the partition’s timestamp field, or None when it gives none.

Raises:

RobotoReadPlanExecutionException – With kind unsupported-timestamp, for a unit other than s, ms, us or ns, which only a plan built without validation can hold.

Parameters:

partition (roboto.experimental.topics.read_plan.ReadPlanPartition)

Return type:

Optional[roboto.time.TimeUnit]