@ -35,10 +35,10 @@ class Reader (File):
_delimiter = self.delimiter if 'delimiter' not in args else args['delimiter']
_df = pd.read_csv(_path,sep=self.delimiter) if not self._chunksize else self._stream(_path)
if 'query' in args :
_query = args['query']
_df = _df.query(_query)
return _df
def stream(self,**args):
raise Exception ("streaming needs to be implemented")
class Writer (File):