Package com.illumon.iris.importers

Class ImportFieldWriter

java.lang.Object

com.illumon.iris.importers.ImportFieldWriter

Direct Known Subclasses:

BaseCsvFieldWriter, CsvColumnDataTransformer, JdbcFieldWriter

public abstract 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 com.fishlib.io.logger.Logger	log

Method Summary

Modifier and Type	Method	Description
static double	accountingDouble(String value)
static int	accountingInt(String value)
static long	accountingLong(String value)
static LongFunction<DBDateTime>	dbDateTimeFromLong(ImporterColumnDefinition col, boolean strict)
static DBDateTime	dbDateTimeFromTimestamp(Timestamp sourceDateTime)
static DBDateTime	dbDateTimeFromTimestamp(Timestamp sourceDateTime, String sourceColumnName, boolean strict)
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)
String	getConstantColumnValue(String columnName)	Returns the value for the requested constant value column or null
protected DBDateTime[]	getDBDateTimeArray(String value, boolean strict)
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)
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)
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 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(org.jdom2.Element sourceElement, String constantValue, 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 com.fishlib.io.logger.Logger log

constantColumnValue

protected String constantColumnValue

Method Details

processField

public void processField()
                  throws IOException

Throws:

IOException

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)

dbDateTimeFromTimestamp

@DynamicUse
public static DBDateTime dbDateTimeFromTimestamp(Timestamp sourceDateTime)

dbDateTimeFromTimestamp

@DynamicUse
public static DBDateTime dbDateTimeFromTimestamp(Timestamp sourceDateTime,
 String sourceColumnName,
 boolean strict)

dbDateTimeFromLong

@DynamicUse
public static LongFunction<DBDateTime> dbDateTimeFromLong(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)

getDBDateTimeArray

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

toISONanos

public static long toISONanos(String value)

updateWithConstantColumnValue

public static Map<String,String> updateWithConstantColumnValue(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. 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 String getConstantColumnValue(@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