Package io.deephaven.importers

Class ImportFieldWriter

java.lang.Object

io.deephaven.importers.ImportFieldWriter

Direct Known Subclasses:

BaseImportFieldWriter, JdbcFieldWriter

public class ImportFieldWriter
extends Object

This class encapsulates common transformations that can be used in ImportSource elements. This class includes methods for code generation, and all internal protected methods are intended for use with dynamic code generation/

Field Summary

Fields

Modifier and Type	Field	Description
protected String	constantColumnValue
protected final Logger	log

Constructor Summary

Constructors

Constructor	Description
ImportFieldWriter(Logger log, String dbColumnName, String arrayDelimiter)

Method Summary

Modifier and Type	Method	Description
static double	accountingDouble(String value)
static int	accountingInt(String value)
static long	accountingLong(String value)
static String	createFormula(String formulaName, ImporterColumnDefinition col, Class setterType)
static String	createTransform(ImporterColumnDefinition col, Class setterType)
static String	createTransformDeclaration(ImporterColumnDefinition col, Class setterType)
protected BigDecimal[]	getBigDecimalArray(String value, boolean strict)
protected BigDecimal[]	getBigDecimalArray(String value, boolean strict, String arrayDelimiter)
protected BigDecimal[]	getBigDecimalArray(String value, String arrayDelimiter)
protected BigInteger[]	getBigIntegerArray(String value, boolean strict)
protected BigInteger[]	getBigIntegerArray(String value, boolean strict, String arrayDelimiter)
protected BigInteger[]	getBigIntegerArray(String value, String arrayDelimiter)
protected Boolean[]	getBooleanArray(String value, boolean strict)
protected Boolean[]	getBooleanArray(String value, boolean strict, String arrayDelimiter)
protected Boolean[]	getBooleanArray(String value, String arrayDelimiter)
protected byte[]	getByteArray(String value, boolean strict)
protected byte[]	getByteArray(String value, boolean strict, String arrayDelimiter)
protected byte[]	getByteArray(String value, String arrayDelimiter)
protected char[]	getCharArray(String value, boolean strict)
protected char[]	getCharArray(String value, boolean strict, String arrayDelimiter)
protected char[]	getCharArray(String value, String arrayDelimiter)
@Nullable String	getConstantColumnValue(@NotNull String columnName)	Returns the value for the requested constant value column or null
String	getDbColumnName()
protected double[]	getDoubleArray(String value, boolean strict)
protected double[]	getDoubleArray(String value, boolean strict, String arrayDelimiter)
double[]	getDoubleArray(String value, String arrayDelimiter)
static IntFunction<String>	getEnumFormatter(ImporterColumnDefinition col, boolean strict)
protected float[]	getFloatArray(String value, boolean strict)
protected float[]	getFloatArray(String value, boolean strict, String arrayDelimiter)
protected float[]	getFloatArray(String value, String arrayDelimiter)
static String	getImports(ImporterColumnDefinition col)
protected Instant[]	getInstantArray(String value, boolean strict)
protected int[]	getIntArray(String value, boolean strict)
protected int[]	getIntArray(String value, boolean strict, String arrayDelimiter)
protected int[]	getIntArray(String value, String arrayDelimiter)
protected LocalDate[]	getLocalDateArray(String value, boolean strict)
protected LocalDate[]	getLocalDateArray(String value, boolean strict, String arrayDelimiter)
protected LocalDate[]	getLocalDateArray(String value, String arrayDelimiter)
protected LocalTime[]	getLocalTimeArray(String value, boolean strict)
protected LocalTime[]	getLocalTimeArray(String value, boolean strict, String arrayDelimiter)
protected LocalTime[]	getLocalTimeArray(String value, String arrayDelimiter)
protected long[]	getLongArray(String value, boolean strict)
protected long[]	getLongArray(String value, boolean strict, String arrayDelimiter)
long[]	getLongArray(String value, String arrayDelimiter)
static String	getSetter(Class type)
protected short[]	getShortArray(String value, boolean strict)
protected short[]	getShortArray(String value, boolean strict, String arrayDelimiter)
protected short[]	getShortArray(String value, String arrayDelimiter)
protected String[]	getStringArray(String value, boolean strict)
protected String[]	getStringArray(String value, boolean strict, String arrayDelimiter)
static LongFunction<Instant>	instantFromLong(ImporterColumnDefinition col, boolean strict)
static Instant	instantFromTimestamp(Timestamp sourceDateTime)
static Instant	instantFromTimestamp(Timestamp sourceDateTime, String sourceColumnName, boolean strict)
static LocalDate	localDateFromString(String str)
static Boolean	parseBoolean(String value)
void	processField()
void	setImportProperties(Map<String,String> importProperties)	The setter to update the importProperties field in the FieldWriter.
static String	stripFirstCharacter(String value)
static long	toISONanos(String value)
static Map<String,String>	updateWithConstantColumnValue(io.deephaven.shadow.enterprise.org.jdom2.Element sourceElement, String constantValue, @NotNull Map<String,String> importProperties)	Utility method that verifies if the given Element includes an Import Column attribute for a constant column.

Methods inherited from class java.lang.Object

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

Field Details

log

protected final Logger log

constantColumnValue

protected String constantColumnValue

Constructor Details

ImportFieldWriter

public ImportFieldWriter(Logger log,
 String dbColumnName,
 String arrayDelimiter)

Method Details

processField

public void processField()
                  throws IOException

Throws:

IOException

getDbColumnName

public String getDbColumnName()

getSetter

public static String getSetter(Class type)

parseBoolean

@DynamicUse
public static Boolean parseBoolean(String value)

getLongArray

@DynamicUse
public long[] getLongArray(String value,
 String arrayDelimiter)

getLongArray

@DynamicUse
protected long[] getLongArray(String value,
 boolean strict)

getLongArray

@DynamicUse
protected long[] getLongArray(String value,
 boolean strict,
 String arrayDelimiter)

getDoubleArray

@DynamicUse
public double[] getDoubleArray(String value,
 String arrayDelimiter)

getDoubleArray

@DynamicUse
protected double[] getDoubleArray(String value,
 boolean strict)

getDoubleArray

@DynamicUse
protected double[] getDoubleArray(String value,
 boolean strict,
 String arrayDelimiter)

getBooleanArray

@DynamicUse
protected Boolean[] getBooleanArray(String value,
 String arrayDelimiter)

getBooleanArray

@DynamicUse
protected Boolean[] getBooleanArray(String value,
 boolean strict)

getBooleanArray

@DynamicUse
protected Boolean[] getBooleanArray(String value,
 boolean strict,
 String arrayDelimiter)

getByteArray

@DynamicUse
protected byte[] getByteArray(String value,
 String arrayDelimiter)

getByteArray

@DynamicUse
protected byte[] getByteArray(String value,
 boolean strict)

getByteArray

@DynamicUse
protected byte[] getByteArray(String value,
 boolean strict,
 String arrayDelimiter)

getCharArray

@DynamicUse
protected char[] getCharArray(String value,
 String arrayDelimiter)

getCharArray

@DynamicUse
protected char[] getCharArray(String value,
 boolean strict)

getCharArray

@DynamicUse
protected char[] getCharArray(String value,
 boolean strict,
 String arrayDelimiter)

getFloatArray

@DynamicUse
protected float[] getFloatArray(String value,
 String arrayDelimiter)

getFloatArray

@DynamicUse
protected float[] getFloatArray(String value,
 boolean strict)

getFloatArray

@DynamicUse
protected float[] getFloatArray(String value,
 boolean strict,
 String arrayDelimiter)

getIntArray

@DynamicUse
protected int[] getIntArray(String value,
 String arrayDelimiter)

getIntArray

@DynamicUse
protected int[] getIntArray(String value,
 boolean strict)

getIntArray

@DynamicUse
protected int[] getIntArray(String value,
 boolean strict,
 String arrayDelimiter)

getShortArray

@DynamicUse
protected short[] getShortArray(String value,
 String arrayDelimiter)

getShortArray

@DynamicUse
protected short[] getShortArray(String value,
 boolean strict)

getShortArray

@DynamicUse
protected short[] getShortArray(String value,
 boolean strict,
 String arrayDelimiter)

getBigDecimalArray

@DynamicUse
protected BigDecimal[] getBigDecimalArray(String value,
 String arrayDelimiter)

getBigDecimalArray

@DynamicUse
protected BigDecimal[] getBigDecimalArray(String value,
 boolean strict)

getBigDecimalArray

@DynamicUse
protected BigDecimal[] getBigDecimalArray(String value,
 boolean strict,
 String arrayDelimiter)

getBigIntegerArray

@DynamicUse
protected BigInteger[] getBigIntegerArray(String value,
 String arrayDelimiter)

getBigIntegerArray

@DynamicUse
protected BigInteger[] getBigIntegerArray(String value,
 boolean strict)

getBigIntegerArray

@DynamicUse
protected BigInteger[] getBigIntegerArray(String value,
 boolean strict,
 String arrayDelimiter)

getLocalTimeArray

@DynamicUse
protected LocalTime[] getLocalTimeArray(String value,
 String arrayDelimiter)

getLocalTimeArray

@DynamicUse
protected LocalTime[] getLocalTimeArray(String value,
 boolean strict)

getLocalTimeArray

@DynamicUse
protected LocalTime[] getLocalTimeArray(String value,
 boolean strict,
 String arrayDelimiter)

getLocalDateArray

@DynamicUse
protected LocalDate[] getLocalDateArray(String value,
 String arrayDelimiter)

getLocalDateArray

@DynamicUse
protected LocalDate[] getLocalDateArray(String value,
 boolean strict)

getLocalDateArray

@DynamicUse
protected LocalDate[] getLocalDateArray(String value,
 boolean strict,
 String arrayDelimiter)

getStringArray

@DynamicUse
protected String[] getStringArray(String value,
 boolean strict)

getStringArray

@DynamicUse
protected String[] getStringArray(String value,
 boolean strict,
 String arrayDelimiter)

instantFromTimestamp

@DynamicUse
public static Instant instantFromTimestamp(Timestamp sourceDateTime)

instantFromTimestamp

@DynamicUse
public static Instant instantFromTimestamp(Timestamp sourceDateTime,
 String sourceColumnName,
 boolean strict)

instantFromLong

@DynamicUse
public static LongFunction<Instant> instantFromLong(ImporterColumnDefinition col,
 boolean strict)

localDateFromString

@DynamicUse
public static LocalDate localDateFromString(String str)

getEnumFormatter

@DynamicUse
public static IntFunction<String> getEnumFormatter(ImporterColumnDefinition col,
 boolean strict)

accountingInt

@DynamicUse
public static int accountingInt(String value)

accountingLong

@DynamicUse
public static long accountingLong(String value)

stripFirstCharacter

@DynamicUse
public static String stripFirstCharacter(String value)

accountingDouble

@DynamicUse
public static double accountingDouble(String value)

getInstantArray

@DynamicUse
protected Instant[] getInstantArray(String value,
 boolean strict)

toISONanos

public static long toISONanos(String value)

getImports

public static String getImports(ImporterColumnDefinition col)

createFormula

public static String createFormula(String formulaName,
 ImporterColumnDefinition col,
 Class setterType)

createTransformDeclaration

public static String createTransformDeclaration(ImporterColumnDefinition col,
 Class setterType)

createTransform

public static String createTransform(ImporterColumnDefinition col,
 Class setterType)

updateWithConstantColumnValue

public static Map<String,String> updateWithConstantColumnValue(io.deephaven.shadow.enterprise.org.jdom2.Element sourceElement,
 String constantValue,
 @NotNull
 @NotNull Map<String,String> importProperties)

Utility method that verifies if the given Element includes an Import Column attribute for a constant column. If found identifies the appropriate value associated for the column and returns a new unmodifiable Map that includes the (const column) to (constant column value) mapping.

Parameters:

sourceElement - The source in which to look for constant column attributes

constantValue - The global constant value for the csv import

importProperties - The custom import properties map

Returns:

Returns an unmodifiable map that may include a constant column to constant column value mapping

setImportProperties

public void setImportProperties(Map<String,String> importProperties)

The setter to update the importProperties field in the FieldWriter. This is used while instantiating a custom CsvFieldWriter, for a column using a custom setter Having access to the importProperties allows a Custom setter to access custom import properties along with access to constant column value using the method getConstantColumnValue(String)

Parameters:

importProperties - The custom properties map passed in csv import method

getConstantColumnValue

@Nullable
public @Nullable String getConstantColumnValue(@NotNull
 @NotNull String columnName)

Returns the value for the requested constant value column or null

Parameters:

columnName - The constant value column name

Returns:

the value of the constant column if found in importer properties or null