Package com.activequant.archive

Examples of com.activequant.archive.TimeSeriesIterator

43
44
45
46
47
48
49
50
51
52
53
54
55
        IArchiveReader iar = archiveFactory.getReader(inTimeFrame);

        for (String value : fields) {
            TSContainer container = iar.getTimeSeries(mdiId, value, startTS, stopTS);
            TimeSeriesIterator iterator = iar.getTimeSeriesStream(mdiId, value, startTS, stopTS);
            while (iterator.hasNext()) {
                Tuple<TimeStamp, Double> val = iterator.next();
                System.out.println(val.getA().getNanoseconds() + "," + val.getB());
            }
        }
        //
    }
View Full Code Here
108
109
110
111
112
113
114
115
116
117
118
    }

    public TimeSeriesIterator getTimeSeriesStream(String instrumentId, final String key, TimeStamp startTimeStamp, TimeStamp stopTimeStamp) throws Exception {
        final ResultScanner scanner = getScanner(instrumentId, startTimeStamp, stopTimeStamp);

        return new TimeSeriesIterator() {
            Iterator<Result> resultIterator = scanner.iterator();
            final Result rr = null;

            @Override
            public boolean hasNext() {
View Full Code Here
TOP

Related Classes of com.activequant.archive.TimeSeriesIterator

  • com.activequant.archive.hbase.HBaseArchiveReader
  • com.activequant.utils.ExportMarketDataCSV
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.