aggregation_modules/aggregator.py
def read_stream_metadata(self):
        """
        reads <stream>.json file and parse
        stream related details
        """
        self.stream_metadata = StreamMetadata()
        stream_buffer = self.cloud_storage_object.read_stream_metadata()
        self.stream_metadata.populate_fields(
            stream_buffer, self.all_fields_map)

        reads <stream>.json file and parse
        stream related details
        
reads .json file and parse
stream related details
reads . json file and parse stream related details
def read_stream_metadata(self):
        self.stream_metadata = StreamMetadata()
        stream_buffer = self.cloud_storage_object.read_stream_metadata()
        self.stream_metadata.populate_fields(
            stream_buffer, self.all_fields_map)
def read_stream_metadata ( self ) : self . stream_metadata = StreamMetadata ( ) stream_buffer = self . cloud_storage_object . read_stream_metadata ( ) self . stream_metadata . populate_fields ( stream_buffer , self . all_fields_map )
reads <stream>.json file and parse
stream related details
reads <stream > . json file and parse stream related details
"""
        reads <stream>.json file and parse
        stream related details
        """
self