roboto.domain.topics.parquet#

Submodules#

Package Contents#

class roboto.domain.topics.parquet.ParquetTopicReader(roboto_client)#

Bases: roboto.domain.topics.topic_reader.TopicReader

Private interface for retrieving topic data stored in Parquet files.

Note

This is not intended as a public API. To access topic data, prefer the get_data or get_data_as_df methods on Topic, MessagePath, or Event.

Parameters:: roboto_client (roboto.http.RobotoClient)

static accepts(message_paths_to_representations)#

Parameters:: message_paths_to_representations (collections.abc.Iterable[roboto.domain.topics.operations.MessagePathRepresentationMapping])
Return type:: bool

get_data(message_paths_to_representations, log_time_attr_name, log_time_unit=TimeUnit.Nanoseconds, start_time=None, end_time=None, timestamp_message_path_representation_mapping=None)#

Parameters:

message_paths_to_representations (collections.abc.Iterable[roboto.domain.topics.operations.MessagePathRepresentationMapping])
log_time_attr_name (str)
log_time_unit (roboto.time.TimeUnit)
start_time (Optional[int])
end_time (Optional[int])
timestamp_message_path_representation_mapping (Optional[roboto.domain.topics.operations.MessagePathRepresentationMapping])

Return type:

collections.abc.Generator[dict[str, Any], None, None]

get_data_as_df(message_paths_to_representations, log_time_attr_name, log_time_unit=TimeUnit.Nanoseconds, start_time=None, end_time=None, timestamp_message_path_representation_mapping=None)#

Parameters:

message_paths_to_representations (collections.abc.Iterable[roboto.domain.topics.operations.MessagePathRepresentationMapping])
log_time_attr_name (str)
log_time_unit (roboto.time.TimeUnit)
start_time (Optional[int])
end_time (Optional[int])
timestamp_message_path_representation_mapping (Optional[roboto.domain.topics.operations.MessagePathRepresentationMapping])

Return type:

pandas.DataFrame