public class PartitionDataLoader extends java.lang.Object implements DataProvider
Constructor and Description |
---|
PartitionDataLoader(ConnectionProvider<?> connProvider,
java.util.List<Partition> partitions,
DBTranslator translator) |
Modifier and Type | Method and 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.
|
public PartitionDataLoader(ConnectionProvider<?> connProvider, java.util.List<Partition> partitions, DBTranslator translator)
public void setStartTime(long time)
time
- protected org.apache.log4j.Logger getLogger()
public void setIncludeOrderClause(boolean value)
public long nextTime()
public RawTagValue nextValue() throws java.lang.Exception
DataProvider
nextValue
in interface DataProvider
java.lang.Exception
protected void moveForward() throws java.lang.Exception
java.lang.Exception
protected void runQuery() throws java.lang.Exception
java.lang.Exception
public void close()
close
in interface DataProvider
protected RawTagValue getValueFromRS(java.sql.ResultSet rs) throws java.lang.Exception
rs
- java.lang.Exception