connectordb / connectordb-python

        self.query["dataset"] = {}

    def addStream(self, stream, interpolator="closest", t1=None, t2=None, dt=None, limit=None, i1=None, i2=None, transform=None,colname=None):

        """Adds the given stream to the query construction. Additionally, you can choose the interpolator to use for this stream, as well as a special name

        for the column in the returned dataset. If no column name is given, the full stream path will be used.

        addStream also supports Merge queries. You can insert a merge query instead of a stream, but be sure to name the column::

            d = Dataset(cdb, t1=time.time()-1000,t2=time.time(),dt=10.)

            d.addStream("temperature","average")

            d.addStream("steps","sum")

            m = Merge(cdb)

            m.addStream("mystream")

            m.addStream("mystream2")

            d.addStream(m,colname="mycolumn")

            result = d.run()

        """

        streamquery = query_maker(t1, t2, limit, i1, i2, transform)

        param_stream(self.cdb, streamquery, stream)

        streamquery["interpolator"] = interpolator

        if colname is None:

            # What do we call this column?

            if isinstance(stream, six.string_types):

                colname = stream

            elif isinstance(stream, Stream):

                colname = stream.path

            else:

                raise Exception(

                    "Could not find a name for the column! use the 'colname' parameter.")

        if colname in self.query["dataset"] or colname is "x":

            raise Exception(

                "The column name either exists, or is labeled 'x'. Use the colname parameter to change the column name.")

        self.query["dataset"][colname] = streamquery

    def run(self):

        """Runs the dataset query, and returns the result"""

    """

    def __init__(self, cdb, x=None, t1=None, t2=None, dt=None, limit=None, i1=None, i2=None, transform=None, posttransform=None):

        """In order to begin dataset generation, you need to specify the reference time range or stream.

        To generate a T-dataset::

            d = Dataset(cdb, t1=start, t2=end, dt=tchange)

        To generate an X-dataset::

            d = Dataset(cdb,"mystream", i1=start, i2=end)

        Note that everywhere you insert a stream name, you are also free to insert Stream objects

        or even Merge queries. The Dataset query in ConnectorDB supports merges natively for each field.

        The only "special" field in this query is the "posttransform". This is a special transform to run on the

        entire row of data after the all of the interpolations complete.

        """

        self.cdb = cdb

        self.query = query_maker(t1, t2, limit, i1, i2, transform)

        if x is not None:

            if dt is not None:

                raise Exception(

                    "Can't do both T-dataset and X-dataset at the same time")

            # Add the stream to the query as the X-dataset

            param_stream(self.cdb, self.query, x)

        elif dt is not None:

            self.query["dt"] = dt

        else:

            raise Exception("Dataset must have either x or dt parameter")

        if posttransform is not None:

            self.query["posttransform"] = posttransform

        self.query["dataset"] = {}

    def addStream(self, stream, interpolator="closest", t1=None, t2=None, dt=None, limit=None, i1=None, i2=None, transform=None,colname=None):

        """Adds the given stream to the query construction. Additionally, you can choose the interpolator to use for this stream, as well as a special name