Class PartitionDataLoader

  • All Implemented Interfaces:
    DataProvider

    public class PartitionDataLoader
    extends java.lang.Object
    implements DataProvider
    • Method Detail

      • setStartTime

        public void setStartTime​(long time)
        Sets the time to read from.
      • getLogger

        protected org.apache.log4j.Logger getLogger()
      • setIncludeOrderClause

        public void setIncludeOrderClause​(boolean value)
      • nextTime

        public long nextTime()
      • nextValue

        public RawTagValue nextValue()
                              throws java.lang.Exception
        Description copied from interface: DataProvider
        Returns the next value, or NULL if there are no more values.
        Specified by:
        nextValue in interface DataProvider
        Throws:
        java.lang.Exception
      • moveForward

        protected void moveForward()
                            throws java.lang.Exception
        Throws:
        java.lang.Exception
      • runQuery

        protected void runQuery()
                         throws java.lang.Exception
        Throws:
        java.lang.Exception
      • getValueFromRS

        protected RawTagValue getValueFromRS​(java.sql.ResultSet rs)
                                      throws java.lang.Exception
        Result set columns should be {TagId, Int, Float, String, Date, Time, Quality, DType}
        Throws:
        java.lang.Exception