def sql()

in datafusion_ray/core.py [0:0]

• 9 lines of code
• 1 McCabe index (conditional complexity)

    def sql(self, query: str) -> DFRayDataFrame:

        df = self.ctx.sql(query)

        return DFRayDataFrame(
            df,
            self.supervisor,
            self.batch_size,
            self.partitions_per_processor,
            self.prefetch_buffer_size,
        )