<s> class DataStore : <EOL> """<STR_LIT>""" <EOL> def __init__ ( self , schema ) : <EOL> self . schema = schema <EOL> def storage_target ( self ) : <EOL> raise NotImplementedError ( ) <EOL> def load ( self ) : <EOL> result = self . _load ( ) <EOL> self . schema . conform_df ( result ) <EOL> return result <EOL> def load_chunks ( self ) : <EOL> for chunk in self . _load_chunks ( ) : <EOL> self . schema . conform_df ( chunk ) <EOL> yield chunk <EOL> del chunk <EOL> def store ( self , df ) : <EOL> df = df . copy ( ) <EOL> self . schema . conform_df ( df , storage_target = self . storage_target ( ) ) <EOL> self . _store ( df ) <EOL> del df <EOL> def store_chunks ( self , chunks ) : <EOL> def conform_each ( chunks ) : <EOL> for chunk in chunks : <EOL> chunk = chunk . copy ( ) <EOL> self . schema . conform_df ( chunk , storage_target = self . storage_target ( ) ) <EOL> yield chunk <EOL> del chunk <EOL> self . _store_chunks ( conform_each ( chunks ) ) <EOL> def update ( self , df ) : <EOL> df = df . copy ( ) <EOL> self . schema . conform_df ( df , storage_target = self . storage_target ( ) ) <EOL> self . _update ( df ) <EOL> del df <EOL> def delete ( self ) : <EOL> raise NotImplementedError ( ) <EOL> def exists ( self ) : <EOL> raise NotImplementedError ( ) <EOL> def _load ( self ) : <EOL> raise NotImplementedError ( ) <EOL> def _load_chunks ( self ) : <EOL> raise NotImplementedError ( ) <EOL> yield <EOL> def _store ( self , df ) : <EOL> raise NotImplementedError ( ) <EOL> def _store_chunks ( self , chunk ) : <EOL> raise NotImplementedError ( ) <EOL> def _update ( self , df ) : <EOL> raise NotImplementedError ( ) </s>
