com.illumon.modelfarm.fitterfarm.futures

Class FuturesFitDataManager<T extends FuturesFitData>

java.lang.Object

com.illumon.modelfarm.fitterfarm.futures.FuturesFitDataManager<T>

All Implemented Interfaces:

RowDataManager<T>

public class FuturesFitDataManager<T extends FuturesFitData>
extends Object
implements RowDataManager<T>

Utility for accessing and querying futures fit data contained in a dynamic table.

Field Summary

Fields

Modifier and Type	Field and Description
protected ColumnSource	csFutureAsks
protected ColumnSource	csFutureBids
protected ColumnSource	csFutureExpirations
protected ColumnSource	csFutureIds
protected ColumnSource	csFutureSyms
protected ColumnSource	csOptionExerciseTypes
protected ColumnSource	csOptionExpirations
protected ColumnSource	csOptionIds
protected ColumnSource	csOptionPayoffTypes
protected ColumnSource	csOptionSettlementTypes
protected ColumnSource	csOptionStrikes
protected ColumnSource	csOptionSyms
protected ColumnSource	csTimestamp
protected ColumnSource	csUnderlyingFutureIds
protected ColumnSource	csUnderlyingId
protected ColumnSource	csUnderlyingSym
protected ColumnSource	csYieldCurveDates
protected ColumnSource	csYieldCurveRates

Constructor Summary

Constructors

Constructor and Description
FuturesFitDataManager(Supplier<T> newFitData, BiConsumer<T,Long> loadFitDataExtraColumns, DynamicTable data) Create a multithreaded resource to fit a derivative model's parameters for futures.

Method Summary

Modifier and Type	Method and Description
void	loadData(T fitData, long index) Populates a data object with data from a table row.
T	newData() Creates a new data instance.
DynamicTable	table() Gets the source table.
long	uniqueIdCurrent(long index) Gets the current unique identifier value for a row.
long	uniqueIdPrev(long index) Gets the previous unique identifier value for a row.

Methods inherited from class java.lang.Object

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

Field Detail

csTimestamp

protected final ColumnSource csTimestamp

csUnderlyingId

protected final ColumnSource csUnderlyingId

csUnderlyingSym

protected final ColumnSource csUnderlyingSym

csFutureIds

protected final ColumnSource csFutureIds

csFutureSyms

protected final ColumnSource csFutureSyms

csFutureExpirations

protected final ColumnSource csFutureExpirations

csFutureBids

protected final ColumnSource csFutureBids

csFutureAsks

protected final ColumnSource csFutureAsks

csUnderlyingFutureIds

protected final ColumnSource csUnderlyingFutureIds

csOptionIds

protected final ColumnSource csOptionIds

csOptionSyms

protected final ColumnSource csOptionSyms

csOptionPayoffTypes

protected final ColumnSource csOptionPayoffTypes

csOptionExerciseTypes

protected final ColumnSource csOptionExerciseTypes

csOptionSettlementTypes

protected final ColumnSource csOptionSettlementTypes

csOptionExpirations

protected final ColumnSource csOptionExpirations

csOptionStrikes

protected final ColumnSource csOptionStrikes

csYieldCurveDates

protected final ColumnSource csYieldCurveDates

csYieldCurveRates

protected final ColumnSource csYieldCurveRates

Constructor Detail

FuturesFitDataManager

public FuturesFitDataManager(Supplier<T> newFitData,
                             BiConsumer<T,Long> loadFitDataExtraColumns,
                             DynamicTable data)

Create a multithreaded resource to fit a derivative model's parameters for futures.

The input table must have the following columns: - Timestamp: DBDateTime - UnderlyingId: long - UnderlyingSym: String - FutureId: DbLongArray - FutureSym: DbArray - FutureExpiration: DbArray - FutureBid: DbDoubleArray - FutureAsk: DbDoubleArray - UnderlyingFutureId: DbLongArray - OptionId: DbLongArray - OptionSym: DbArray - OptionPayoffType: DbArray - OptionExerciseType: DbArray - OptionExpiration: DbArray - OptionStrike: DbDoubleArray - YieldCurveDate: DbArray - YieldCurveRate: DbArray

Parameters:

newFitData - function to create a new FitData of the proper type.

loadFitDataExtraColumns - function to parse the data at a specific table index and load it into the FitData.

data - data for fitting the option model.

Method Detail

table

public DynamicTable table()

Description copied from interface: RowDataManager

Gets the source table.

Specified by:

table in interface RowDataManager<T extends FuturesFitData>

Returns:

source table.

newData

public T newData()

Description copied from interface: RowDataManager

Creates a new data instance.

Specified by:

newData in interface RowDataManager<T extends FuturesFitData>

Returns:

new data instance.

uniqueIdCurrent

public long uniqueIdCurrent(long index)

Description copied from interface: RowDataManager

Gets the current unique identifier value for a row.

This function should only be called during an update loop or while holding the LTM lock.

Specified by:

uniqueIdCurrent in interface RowDataManager<T extends FuturesFitData>

Parameters:

index - table row index.

Returns:

current unique identifier for a row.

uniqueIdPrev

public long uniqueIdPrev(long index)

Description copied from interface: RowDataManager

Gets the previous unique identifier value for a row. One column of each table is designated as a unique identifier for data rows.

This function should only be called during an update loop or while holding the LTM lock.

Specified by:

uniqueIdPrev in interface RowDataManager<T extends FuturesFitData>

Parameters:

index - table row index.

Returns:

previous underlying id.

loadData

public void loadData(T fitData,
                     long index)

Description copied from interface: RowDataManager

Populates a data object with data from a table row.

This method should be called while the LTM lock is held. This can occur either during the update loop or the LTM lock can be acquired outside the update loop. If the LTM lock is not held, the loaded data can be inconsistent or corrupt.

Specified by:

loadData in interface RowDataManager<T extends FuturesFitData>

Parameters:

fitData - data structure to populate

index - table index of the row to load data from