def iter(self, bucket):
<EOL>table = self.__get_table(bucket)<EOL>schema = tableschema.Schema(self.describe(bucket))<EOL>with self.__connection.begin():<EOL><INDENT>select = table.select().execution_options(stream_results=True)<EOL>result = select.execute()<EOL>for row in result:<EOL><INDENT>row = self.__mapper.restore_row(row, schema=schema)<EOL>yield row<EOL><DEDENT><DEDENT>
https://github.com/frictionlessdata/tableschema-sql-py#storage