Updated Loader/Parser API naming

frictionless/loader.py

@@ -249,7 +249,7 @@ def write_byte_stream(self, path):
             any: result of writing e.g. resulting path
         """
         byte_stream = self.write_byte_stream_create(path)
-        result = self.write_byte_stream_record(byte_stream)
+        result = self.write_byte_stream_save(byte_stream)
         return result
 
     def write_byte_stream_create(self, path):
@@ -265,7 +265,7 @@ def write_byte_stream_create(self, path):
         file = open(path, "rb")
         return file
 
-    def write_byte_stream_record(self, byte_stream):
+    def write_byte_stream_save(self, byte_stream):
         """Store byte stream"""
         raise NotImplementedError()
 

frictionless/parser.py

@@ -143,13 +143,13 @@ def write_row_stream(self, read_row_stream):
             read_row_stream (gen<Row[]>): row stream factory
         """
         read_row_stream = self.write_row_stream_create(read_row_stream)
-        result = self.write_row_stream_record(read_row_stream)
+        result = self.write_row_stream_save(read_row_stream)
         return result
 
     def write_row_stream_create(self, read_row_stream):
         return read_row_stream
 
-    def write_row_stream_record(self, read_row_stream):
+    def write_row_stream_save(self, read_row_stream):
         raise NotImplementedError()
 
 

frictionless/plugins/aws.py

@@ -109,7 +109,7 @@ def read_byte_stream_create(self):
 
     # Write
 
-    def write_byte_stream_record(self, byte_stream):
+    def write_byte_stream_save(self, byte_stream):
         error = errors.Error(note="Writing to S3 is not supported")
         raise FrictionlessException(error)
 

frictionless/plugins/bigquery.py

@@ -155,7 +155,7 @@ def read_data_stream_create(self):
 
     # Write
 
-    def write_row_stream_record(self, read_row_stream):
+    def write_row_stream_save(self, read_row_stream):
         dialect = self.resource.dialect
         schema = self.resource.schema
         storage = BigqueryStorage(

frictionless/plugins/ckan.py

@@ -141,7 +141,7 @@ def read_data_stream_create(self):
 
     # Write
 
-    def write_row_stream_record(self, read_row_stream):
+    def write_row_stream_save(self, read_row_stream):
         dialect = self.resource.dialect
         schema = self.resource.schema
         storage = CkanStorage(

frictionless/plugins/csv.py

@@ -260,7 +260,7 @@ def read_data_stream_infer_dialect(self):
 
     # Write
 
-    def write_row_stream_record(self, read_row_stream):
+    def write_row_stream_save(self, read_row_stream):
         options = {}
         for name in vars(self.resource.dialect.to_python()):
             value = getattr(self.resource.dialect, name, None)

frictionless/plugins/excel.py

@@ -263,7 +263,7 @@ def read_data_stream_create(self):
 
     # Write
 
-    def write_row_stream_record(self, read_row_stream):
+    def write_row_stream_save(self, read_row_stream):
         openpyxl = helpers.import_from_plugin("openpyxl", plugin="excel")
         dialect = self.resource.dialect
         helpers.ensure_dir(self.resource.source)
@@ -375,7 +375,7 @@ def type_value(ctype, value):
 
     # Write
 
-    def write_row_stream_record(self, read_row_stream):
+    def write_row_stream_save(self, read_row_stream):
         xlwt = helpers.import_from_plugin("xlwt", plugin="excel")
         dialect = self.resource.dialect
         helpers.ensure_dir(self.resource.source)

frictionless/plugins/filelike.py

@@ -70,5 +70,5 @@ def read_byte_stream_create(self):
 
     # Write
 
-    def write_byte_stream_record(self, byte_stream):
+    def write_byte_stream_save(self, byte_stream):
         return byte_stream

frictionless/plugins/gsheet.py

@@ -83,6 +83,6 @@ def read_data_stream_create(self):
 
     # Write
 
-    def write_row_stream_record(self, read_row_stream):
+    def write_row_stream_save(self, read_row_stream):
         error = errors.Error(note="Writing to Google Sheets is not supported")
         raise FrictionlessException(error)

frictionless/plugins/html.py

@@ -145,7 +145,7 @@ def read_data_stream_create(self):
 
     # NOTE: rebase on proper pyquery
     # NOTE: take dialect into account
-    def write_row_stream_record(self, read_row_stream):
+    def write_row_stream_save(self, read_row_stream):
         html = "<html><body><table>\n"
         for row in read_row_stream():
             if row.row_number == 1:

frictionless/plugins/inline.py

@@ -178,7 +178,7 @@ def read_data_stream_create(self):
 
     # Write
 
-    def write_row_stream_record(self, read_row_stream):
+    def write_row_stream_save(self, read_row_stream):
         data = []
         dialect = self.resource.dialect
         for row in read_row_stream():

frictionless/plugins/json.py

@@ -172,7 +172,7 @@ def read_data_stream_create(self, dialect=None):
 
     # Write
 
-    def write_row_stream_record(self, read_row_stream):
+    def write_row_stream_save(self, read_row_stream):
         data = []
         dialect = self.resource.dialect
         for row in read_row_stream():
@@ -225,7 +225,7 @@ def read_data_stream_create(self, dialect=None):
 
     # Write
 
-    def write_row_stream_record(self, read_row_stream):
+    def write_row_stream_save(self, read_row_stream):
         jsonlines = helpers.import_from_plugin("jsonlines", plugin="json")
         dialect = self.resource.dialect
         with tempfile.NamedTemporaryFile(delete=False) as file:

frictionless/plugins/multipart.py

@@ -73,7 +73,7 @@ def read_byte_stream_create(self):
     # Write
 
     # TODO: review
-    def write_byte_stream_record(self, byte_stream):
+    def write_byte_stream_save(self, byte_stream):
         error = errors.Error(note="Writing to Multipart Target is not supported")
         raise FrictionlessException(error)
 

frictionless/plugins/ods.py

@@ -170,7 +170,7 @@ def type_value(cell):
 
     # Write
 
-    def write_row_stream_record(self, read_row_stream):
+    def write_row_stream_save(self, read_row_stream):
         ezodf = helpers.import_from_plugin("ezodf", plugin="ods")
         dialect = self.resource.dialect
         helpers.ensure_dir(self.resource.source)

frictionless/plugins/pandas.py

@@ -96,7 +96,7 @@ def read_data_stream_create(self):
 
     # Write
 
-    def write_row_stream_record(self, read_row_stream):
+    def write_row_stream_save(self, read_row_stream):
         schema = self.resource.schema
         storage = PandasStorage()
         resource = Resource(name=self.resource.name, data=read_row_stream, schema=schema)

frictionless/plugins/remote.py

@@ -147,7 +147,7 @@ def read_byte_stream_create(self):
 
     # Write
 
-    def write_byte_stream_record(self, byte_stream):
+    def write_byte_stream_save(self, byte_stream):
         error = errors.Error(note="Writing to Remote is not supported")
         raise FrictionlessException(error)
 

frictionless/plugins/spss.py

@@ -87,7 +87,7 @@ def read_data_stream_create(self):
 
     # Write
 
-    def write_row_stream_record(self, read_row_stream):
+    def write_row_stream_save(self, read_row_stream):
         name = os.path.basename(self.resource.path)
         basepath = os.path.dirname(self.resource.path)
         schema = self.resource.schema

frictionless/plugins/sql.py

@@ -142,7 +142,7 @@ def read_data_stream_create(self):
 
     # Write
 
-    def write_row_stream_record(self, read_row_stream):
+    def write_row_stream_save(self, read_row_stream):
         sa = helpers.import_from_plugin("sqlalchemy", plugin="sql")
         engine = sa.create_engine(self.resource.source)
         dialect = self.resource.dialect

frictionless/plugins/text.py

@@ -75,7 +75,7 @@ def read_byte_stream_create(self):
 
     # Write
 
-    def write_byte_stream_record(self, byte_stream):
+    def write_byte_stream_save(self, byte_stream):
         # TODO: review
         error = errors.Error(note="Writing to Text is not supported")
         raise FrictionlessException(error)