roboto.domain.topics.parquet.timestamp#
Module Contents#
- class roboto.domain.topics.parquet.timestamp.Timestamp#
Timestamp signal in topic data stored as Parquet. Serves as both a descriptor of that signal and as a utility for projecting it to other time units.
Note
This is not intended as a public API.
- field: pyarrow.Field#
- message_path: roboto.domain.topics.record.MessagePathRecord#
- to_epoch_nanoseconds(timestamp)#
- Parameters:
timestamp (roboto.time.Time)
- Return type:
int
- unit()#
- Return type:
- class roboto.domain.topics.parquet.timestamp.TimestampInfo#
- end_time: int | float | datetime.datetime | None#
- end_time_ns()#
- Return type:
Optional[int]
- field: pyarrow.Field#
- start_time: int | float | datetime.datetime | None#
- start_time_ns()#
- Return type:
Optional[int]
- unit: roboto.time.TimeUnit#
- roboto.domain.topics.parquet.timestamp.is_timestamp_like(arrow_type)#
- Parameters:
arrow_type (pyarrow.DataType)
- Return type:
bool
- roboto.domain.topics.parquet.timestamp.is_timezone_aware(arrow_type)#
- Parameters:
arrow_type (pyarrow.DataType)
- Return type:
bool
- roboto.domain.topics.parquet.timestamp.time_unit_from_timestamp_type(timestamp_type)#
- Parameters:
timestamp_type (pyarrow.TimestampType)
- Return type: