Package io.deephaven.importers.csv

Class CsvFieldWriter

java.lang.Object

io.deephaven.importers.ImportFieldWriter

io.deephaven.importers.BaseImportFieldWriter

io.deephaven.importers.csv.BaseCsvFieldWriter

io.deephaven.importers.csv.CsvFieldWriter

public abstract class CsvFieldWriter
extends BaseCsvFieldWriter

Abstract class providing methods used when reading data from CSV files to be written to Deephaven columns.

Nested Class Summary

Nested classes/interfaces inherited from class io.deephaven.importers.csv.BaseCsvFieldWriter

BaseCsvFieldWriter.CustomSetterFactory

Field Summary

Fields inherited from class io.deephaven.importers.csv.BaseCsvFieldWriter

ZERO_VALUE_ARRAY

Fields inherited from class io.deephaven.importers.ImportFieldWriter

constantColumnValue, log

Constructor Summary

Constructors

Constructor	Description
CsvFieldWriter(Logger log, String dbColumnName, String delimiter)

Method Summary

Modifier and Type	Method	Description
abstract List<CustomSetterValue<?>>	processValues(@NotNull Map<String,Object[]> columnNameToValueMap, int size, long destEnd)	The method is invoked by the CustomSetter Column Parser by incorporating the values from all dependent columns If dependent columns are not provided then the map would contain values from all the columns Note no change for Constant Column values they need to be retrieved using ImportFieldWriter.getConstantColumnValue(String)

Methods inherited from class io.deephaven.importers.csv.BaseCsvFieldWriter

getConstantColumnValue, getSetterCopy, getSetterValue, initialize, processField, setConstantColumnValue

Methods inherited from class io.deephaven.importers.BaseImportFieldWriter

getBigDecimal, getBoolean, getByte, getChar, getDouble, getFloat, getInt, getISONanos, getLocalDate, getLocalTime, getLong, getShort, getTrimmedStringNull

Methods inherited from class io.deephaven.importers.ImportFieldWriter

accountingDouble, accountingInt, accountingLong, createFormula, createTransform, createTransformDeclaration, getBigDecimalArray, getBigDecimalArray, getBigDecimalArray, getBigIntegerArray, getBigIntegerArray, getBigIntegerArray, getBooleanArray, getBooleanArray, getBooleanArray, getByteArray, getByteArray, getByteArray, getCharArray, getCharArray, getCharArray, getConstantColumnValue, getDbColumnName, getDoubleArray, getDoubleArray, getDoubleArray, getEnumFormatter, getFloatArray, getFloatArray, getFloatArray, getImports, getInstantArray, getIntArray, getIntArray, getIntArray, getLocalDateArray, getLocalDateArray, getLocalDateArray, getLocalTimeArray, getLocalTimeArray, getLocalTimeArray, getLongArray, getLongArray, getLongArray, getSetter, getShortArray, getShortArray, getShortArray, getStringArray, getStringArray, instantFromLong, instantFromTimestamp, instantFromTimestamp, localDateFromString, parseBoolean, processField, setImportProperties, stripFirstCharacter, toISONanos, updateWithConstantColumnValue

Methods inherited from class java.lang.Object

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

Constructor Details

CsvFieldWriter

public CsvFieldWriter(Logger log,
 String dbColumnName,
 String delimiter)

Parameters:

log - the Logger to use for logging

dbColumnName - the column name

delimiter - the delimiter

Method Details

processValues

public abstract List<CustomSetterValue<?>> processValues(@NotNull
 @NotNull Map<String,Object[]> columnNameToValueMap,
 int size,
 long destEnd)
                                                  throws RowProcessingException

The method is invoked by the CustomSetter Column Parser by incorporating the values from all dependent columns If dependent columns are not provided then the map would contain values from all the columns Note no change for Constant Column values they need to be retrieved using ImportFieldWriter.getConstantColumnValue(String)

Overrides:

processValues in class BaseCsvFieldWriter

Parameters:

columnNameToValueMap - The column name to corresponding CustomValue array map

size - The size of the chunk, which is the same as the size of CustomSetterValue array in the map

destEnd - The exclusive end index of the destination range.

Returns:

The processed custom setter column values for each row

Throws:

RowProcessingException - Thrown if processing errors occur when parsing to create Csv records