Removes inputRef / bookmark params from appendRecord

src/nupic/data/file_record_stream.py

@@ -387,7 +387,7 @@ def getNextRecord(self, useCache=True):
     return record
 
 
-  def appendRecord(self, record, inputBookmark=None):
+  def appendRecord(self, record):
     """
     Saves the record in the underlying csv file.
 
@@ -418,22 +418,17 @@ def appendRecord(self, record, inputBookmark=None):
     self._recordCount += 1
 
 
-  def appendRecords(self, records, inputRef=None, progressCB=None):
+  def appendRecords(self, records, progressCB=None):
     """
     Saves multiple records in the underlying storage.
 
     :param records: array of records as in
                     :meth:`~.FileRecordStream.appendRecord`
-    :param inputRef: reference to the corresponding input (not applicable
-                     in case of a file storage)
     :param progressCB: (function) callback to report progress
     """
 
-    # input ref is not applicable in case of a file storage
-    inputRef = inputRef
-
     for record in records:
-      self.appendRecord(record, None)
+      self.appendRecord(record)
       if progressCB is not None:
         progressCB()
 

src/nupic/data/record_stream.py

@@ -284,10 +284,11 @@ def getAggregationMonthsAndSeconds(self):
     If there is no aggregation associated with the stream, returns None.
 
     Typically, a raw file or hbase stream will NOT have any aggregation info,
-    but subclasses of RecordStreamIface, like :class:`~nupic.data.StreamReader`,
-    will and will return the aggregation period from this call. This call is
-    used by the :meth:`getNextRecordDict` method to assign a record number to a
-    record given its timestamp and the aggregation interval
+    but subclasses of :class:`~nupic.data.record_stream.RecordStreamIface`, like
+    :class:`~nupic.data.stream_reader.StreamReader`, will and will return the
+    aggregation period from this call. This call is used by
+    :meth:`getNextRecordDict` to assign a record number to a record given its
+    timestamp and the aggregation interval.
 
     :returns: ``None``
     """
@@ -303,7 +304,7 @@ def getNextRecordIdx(self):
 
 
   @abstractmethod
-  def appendRecord(self, record, inputRef=None):
+  def appendRecord(self, record):
     """
     Saves the record in the underlying storage. Should be implemented in
     subclasses.
@@ -313,7 +314,7 @@ def appendRecord(self, record, inputRef=None):
 
 
   @abstractmethod
-  def appendRecords(self, records, inputRef=None, progressCB=None):
+  def appendRecords(self, records, progressCB=None):
     """
     Saves multiple records in the underlying storage. Should be implemented in
     subclasses.

src/nupic/data/stream_reader.py

@@ -423,11 +423,11 @@ def getAggregationMonthsAndSeconds(self):
     return self._aggMonthsAndSeconds
 
 
-  def appendRecord(self, record, inputRef=None):
+  def appendRecord(self, record):
     raise RuntimeError("Not implemented in StreamReader")
 
 
-  def appendRecords(self, records, inputRef=None, progressCB=None):
+  def appendRecords(self, records, progressCB=None):
     raise RuntimeError("Not implemented in StreamReader")