Class PartitionDataLoader
- java.lang.Object
-
- com.inductiveautomation.gateway.tags.history.processing.PartitionDataLoader
-
- All Implemented Interfaces:
DataProvider
public class PartitionDataLoader extends java.lang.Object implements DataProvider
-
-
Constructor Summary
Constructors Constructor Description PartitionDataLoader(ConnectionProvider<?> connProvider, java.util.List<Partition> partitions, DBTranslator translator)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
protected org.apache.log4j.Logger
getLogger()
protected RawTagValue
getValueFromRS(java.sql.ResultSet rs)
Result set columns should be {TagId, Int, Float, String, Date, Time, Quality, DType}protected void
moveForward()
long
nextTime()
RawTagValue
nextValue()
Returns the next value, or NULL if there are no more values.protected void
runQuery()
void
setIncludeOrderClause(boolean value)
void
setStartTime(long time)
Sets the time to read from.
-
-
-
Constructor Detail
-
PartitionDataLoader
public PartitionDataLoader(ConnectionProvider<?> connProvider, java.util.List<Partition> partitions, DBTranslator translator)
-
-
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 interfaceDataProvider
- 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
-
close
public void close()
- Specified by:
close
in interfaceDataProvider
-
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
-
-