roboto.domain.topics.parquet.parquet_topic_reader
Module Contents
OUTFILE_NAME_PATTERN
roboto.
Filename template for locally cached Parquet files.
ParquetTopicReader
class roboto.
Bases: roboto.domain.topics.topic_reader.TopicReader
Private interface for retrieving topic data stored in Parquet files.
Parameters
roboto_client roboto.cache_dir Optional[pathlib.ParquetTopicReader.accepts()
Parameters
message_paths_to_representations collections.Return type
bool
ParquetTopicReader.get_data()
get_data(message_paths_to_representations, start_time=None, end_time=None, timestamp_message_path_representation_mapping=None)#View Source
Parameters
message_paths_to_representations collections.start_time Optional[int]end_time Optional[int]timestamp_message_path_representation_mapping Optional[roboto.Return type
collections.
ParquetTopicReader.get_data_as_df()
get_data_as_df(message_paths_to_representations, start_time=None, end_time=None, timestamp_message_path_representation_mapping=None)#View Source
Parameters
message_paths_to_representations collections.start_time Optional[int]end_time Optional[int]timestamp_message_path_representation_mapping Optional[roboto.Return type
tuple[pandas.