in pyspark_huggingface/huggingface_source.py [0:0]
def schema(self): return from_arrow_schema(self.streaming_dataset.features.arrow_schema)