tsdb.loader.ki.type

Class AbstractLoader

java.lang.Object

tsdb.loader.ki.type.AbstractLoader

public abstract class AbstractLoader
extends java.lang.Object

Base class for data loaders

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.String[]	inputSchema
protected StationProperties	properties
protected java.lang.String[]	resultSchema
protected java.lang.String	sourceInfo
protected int[]	sourcePos

Constructor Summary

Constructors

Constructor and Description
AbstractLoader(java.lang.String[] inputSchema, StationProperties properties, java.lang.String sourceInfo)

Method Summary

Modifier and Type	Method and Description
protected abstract void	createProcessingTypes()
protected abstract void	createResultSchema()
protected boolean	createSourcePos(java.lang.String[] targetSchema)
java.lang.String[]	getResultSchema()
java.util.List<DataRow>	load(Station station, java.lang.String[] targetSchema, TimestampSeries timestampSeries)
protected abstract java.util.List<DataRow>	toDataRows(TimestampSeries timestampSeries)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

inputSchema

protected final java.lang.String[] inputSchema

properties

protected final StationProperties properties

sourceInfo

protected final java.lang.String sourceInfo

resultSchema

protected java.lang.String[] resultSchema

sourcePos

protected int[] sourcePos

Constructor Detail

AbstractLoader

public AbstractLoader(java.lang.String[] inputSchema,
                      StationProperties properties,
                      java.lang.String sourceInfo)

Method Detail

createProcessingTypes

protected abstract void createProcessingTypes()

createResultSchema

protected abstract void createResultSchema()

toDataRows

protected abstract java.util.List<DataRow> toDataRows(TimestampSeries timestampSeries)

createSourcePos

protected boolean createSourcePos(java.lang.String[] targetSchema)

load

public java.util.List<DataRow> load(Station station,
                                    java.lang.String[] targetSchema,
                                    TimestampSeries timestampSeries)

getResultSchema

public java.lang.String[] getResultSchema()