Stream Time Series Data

Stream a time series directly:

Get a time series (using timeSeriesFor().get(), and call stream()).

<T> CloseableIterator<StreamResult<T>> stream(IRawDocumentQuery<T> query);

Stream results of time series queries:

This syntax is the same as the syntax for streaming query results in general, found here.

<T> CloseableIterator<StreamResult<T>> stream(IDocumentQuery<T> query, Reference<StreamQueryStatistics> streamQueryStats);

<T> CloseableIterator<StreamResult<T>> stream(IRawDocumentQuery<T> query);

<T> CloseableIterator<StreamResult<T>> stream(IRawDocumentQuery<T> query, Reference<StreamQueryStatistics> streamQueryStats);

Example

Using a rawQuery:

IRawDocumentQuery<Employee> query = session.advanced()
    .rawQuery(Employee.class,
        "from Users\n" +
        "select timeseries (\n" +
        "    from HeartRate\n"+
        ")"
    );

CloseableIterator<StreamResult<Employee>> results = session.advanced().stream(query);