connectordb/logger.py
def addStream_force(self, streamname, schema=None):
        """This function adds the given stream to the logger, but does not check with a ConnectorDB database
        to make sure that the stream exists. Use at your own risk."""

        c = self.database.cursor()
        c.execute("INSERT OR REPLACE INTO streams VALUES (?,?);",
                  (streamname, json.dumps(schema)))

        self.streams[streamname] = schema
def addStream_force(self, streamname, schema=None):
        c = self.database.cursor()
        c.execute("INSERT OR REPLACE INTO streams VALUES (?,?);",
                  (streamname, json.dumps(schema)))

        self.streams[streamname] = schema
def addStream_force ( self , streamname , schema = None ) : c = self . database . cursor ( ) c . execute ( "INSERT OR REPLACE INTO streams VALUES (?,?);" , ( streamname , json . dumps ( schema ) ) ) self . streams [ streamname ] = schema
This function adds the given stream to the logger, but does not check with a ConnectorDB database
        to make sure that the stream exists. Use at your own risk.
This function adds the given stream to the logger but does not check with a ConnectorDB database to make sure that the stream exists . Use at your own risk .