Merge pull request 'v2.4' (#2) from v2.4 into main

Reviewed-on: #2
main
Steve L. Nyemba 2 months ago
commit 3267f93331

@ -0,0 +1,2 @@
cd /D "%~dp0"
python transport %1 %2 %3 %4 %5 %6

@ -33,12 +33,12 @@ class Reader (File):
def read(self,**args): def read(self,**args):
_path = self.path if 'path' not in args else args['path'] _path = self.path if 'path' not in args else args['path']
_delimiter = self.delimiter if 'delimiter' not in args else args['delimiter'] _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) _df = pd.read_csv(_path,sep=self.delimiter) if not self._chunksize else self._stream(_path)
if 'query' in args : if 'query' in args :
_query = args['query'] _query = args['query']
_df = _df.query(_query) _df = _df.query(_query)
return _df return _df
def stream(self,**args): def stream(self,**args):
raise Exception ("streaming needs to be implemented") raise Exception ("streaming needs to be implemented")
class Writer (File): class Writer (File):

Loading…
Cancel
Save