Package com.illumon.iris.importers
Class CsvFieldWriter.EndOfRecordWriter
java.lang.Object
com.illumon.iris.importers.ImportFieldWriter
com.illumon.iris.importers.BaseCsvFieldWriter
com.illumon.iris.importers.CsvFieldWriter
com.illumon.iris.importers.CsvFieldWriter.EndOfRecordWriter
- All Implemented Interfaces:
EndOfRecordFieldWriter
- Enclosing class:
- CsvFieldWriter
public static class CsvFieldWriter.EndOfRecordWriter
extends CsvFieldWriter
implements EndOfRecordFieldWriter
-
Nested Class Summary
Nested classes/interfaces inherited from class com.illumon.iris.importers.CsvFieldWriter
CsvFieldWriter.EndOfRecordWriter, CsvFieldWriter.Factory, CsvFieldWriter.ParseException, CsvFieldWriter.RowFlagsWriterNested classes/interfaces inherited from class com.illumon.iris.importers.BaseCsvFieldWriter
BaseCsvFieldWriter.CustomSetterFactory -
Field Summary
Fields inherited from class com.illumon.iris.importers.BaseCsvFieldWriter
ZERO_VALUE_ARRAYFields inherited from class com.illumon.iris.importers.ImportFieldWriter
constantColumnValue, log -
Constructor Summary
ConstructorsConstructorDescriptionEndOfRecordWriter(com.fishlib.io.logger.Logger log, TableWriter writer, String dbColumnName) -
Method Summary
Modifier and TypeMethodDescriptionstatic BigDecimalgetBigDecimal(String value, String columnName, com.fishlib.io.logger.Logger log, boolean strict, boolean failDefault, BigDecimal onEmpty) Reads a BigDecimal value from a CSVRecordstatic BooleangetBoolean(String value, String columnName, com.fishlib.io.logger.Logger log, boolean strict, boolean failDefault, Boolean onEmpty) Reads a Boolean value from a CSVRecord.static bytegetByte(String value, String columnName, com.fishlib.io.logger.Logger log, boolean strict, boolean failDefault, byte onEmpty) Reads a byte value from a CSVRecordstatic chargetChar(String value, String columnName, com.fishlib.io.logger.Logger log, boolean strict, boolean failDefault, char onEmpty) Reads a char value from a CSVRecordstatic doublegetDouble(String value, String columnName, com.fishlib.io.logger.Logger log, boolean strict, boolean failDefault, double onEmpty) Reads a double value from a CSVRecordstatic floatgetFloat(String value, String columnName, com.fishlib.io.logger.Logger log, boolean strict, boolean failDefault, float onEmpty) Reads a float value from a CSVRecordstatic intgetInt(String value, String columnName, com.fishlib.io.logger.Logger log, boolean strict, boolean failDefault, int onEmpty) Reads an int value from a CSVRecordstatic longgetISONanos(String value, String columnName, com.fishlib.io.logger.Logger log, boolean strict, boolean failDefault, long onEmpty) Reads a ISO formatted date value from a CSVRecord and converts it to nanoseconds since the epoch.static LocalDategetLocalDate(String value, String columnName, com.fishlib.io.logger.Logger log, boolean strict, boolean failDefault, LocalDate onEmpty) Read a LocalDate value from a CSVRecord.static LocalTimegetLocalTime(String value, String columnName, com.fishlib.io.logger.Logger log, boolean strict, boolean failDefault, LocalTime onEmpty) Read a LocalTime value from a CSVRecord.static longgetLong(String value, String columnName, com.fishlib.io.logger.Logger log, boolean strict, boolean failDefault, long onEmpty) Reads a long value from a CSVRecordlongstatic shortgetShort(String value, String columnName, com.fishlib.io.logger.Logger log, boolean strict, boolean failDefault, short onEmpty) Reads a short value from a CSVRecordstatic StringgetTrimmedStringNull(String value, String columnName) Reads a String value from a CSVRecord.voidprocessField(org.apache.commons.csv.CSVRecord record) Methods inherited from class com.illumon.iris.importers.CsvFieldWriter
asString, getSourceValue, processValuesMethods inherited from class com.illumon.iris.importers.BaseCsvFieldWriter
getConstantColumnValue, getSetterCopy, getSetterValue, getSinglePartitionValue, initialize, processField, setConstantColumnValue, setSinglePartitionValueMethods inherited from class com.illumon.iris.importers.ImportFieldWriter
accountingDouble, accountingInt, accountingLong, dbDateTimeFromLong, dbDateTimeFromTimestamp, dbDateTimeFromTimestamp, getBigDecimalArray, getBigDecimalArray, getBigDecimalArray, getBigIntegerArray, getBigIntegerArray, getBigIntegerArray, getBooleanArray, getBooleanArray, getBooleanArray, getByteArray, getByteArray, getByteArray, getCharArray, getCharArray, getCharArray, getConstantColumnValue, getDBDateTimeArray, getDoubleArray, getDoubleArray, getDoubleArray, getEnumFormatter, getFloatArray, getFloatArray, getFloatArray, getIntArray, getIntArray, getIntArray, getLocalDateArray, getLocalDateArray, getLocalDateArray, getLocalTimeArray, getLocalTimeArray, getLocalTimeArray, getLongArray, getLongArray, getLongArray, getShortArray, getShortArray, getShortArray, getStringArray, getStringArray, localDateFromString, parseBoolean, processField, setImportProperties, stripFirstCharacter, toISONanos, updateWithConstantColumnValue
-
Constructor Details
-
EndOfRecordWriter
-
-
Method Details
-
getRowCount
public long getRowCount()- Specified by:
getRowCountin interfaceEndOfRecordFieldWriter
-
processField
- Overrides:
processFieldin classCsvFieldWriter- Throws:
IOException
-
getShort
@DynamicUse public static short getShort(@NotNull String value, @Nullable String columnName, @NotNull com.fishlib.io.logger.Logger log, boolean strict, boolean failDefault, short onEmpty) Reads a short value from a CSVRecord- Parameters:
value- The value of the named column in the current row in the import filecolumnName- The column name from which the value should be readlog- The passed-down loggerstrict- Whether strict (true) or permissive (false) import rules are being usedfailDefault- Whether (true) to use the default value (onEmpty) if parsing/conversion of the source value failsonEmpty- A default value that may be used if the source is empty or parsing fails- Returns:
- the converted value, or the onEmpty value, depending on strict, failDefault, and the source value itself
-
getInt
@DynamicUse public static int getInt(@NotNull String value, @Nullable String columnName, @NotNull com.fishlib.io.logger.Logger log, boolean strict, boolean failDefault, int onEmpty) Reads an int value from a CSVRecord- Parameters:
value- The value of the named column in the current row in the import filecolumnName- The column name from which the value should be readlog- The passed-down loggerstrict- Whether strict (true) or permissive (false) import rules are being usedfailDefault- Whether (true) to use the default value (onEmpty) if parsing/conversion of the source value failsonEmpty- A default value that may be used if the source is empty or parsing fails- Returns:
- the converted value, or the onEmpty value, depending on strict, failDefault, and the source value itself
-
getLong
@DynamicUse public static long getLong(@NotNull String value, @Nullable String columnName, @NotNull com.fishlib.io.logger.Logger log, boolean strict, boolean failDefault, long onEmpty) Reads a long value from a CSVRecord- Parameters:
value- The value of the named column in the current row in the import filecolumnName- The column name from which the value should be readlog- The passed-down loggerstrict- Whether strict (true) or permissive (false) import rules are being usedfailDefault- Whether (true) to use the default value (onEmpty) if parsing/conversion of the source value failsonEmpty- A default value that may be used if the source is empty or parsing fails- Returns:
- the converted value, or the onEmpty value, depending on strict, failDefault, and the source value itself
-
getISONanos
@DynamicUse public static long getISONanos(@Nullable String value, @Nullable String columnName, @NotNull com.fishlib.io.logger.Logger log, boolean strict, boolean failDefault, long onEmpty) Reads a ISO formatted date value from a CSVRecord and converts it to nanoseconds since the epoch. This parser is a little less strict than ISO, in that it will accept time zone offsets without colons.- Parameters:
value- The value of the named column in the current row in the import filecolumnName- The column name from which the value should be readlog- The passed-down loggerstrict- Whether strict (true) or permissive (false) import rules are being usedfailDefault- Whether (true) to use the default value (onEmpty) if parsing/conversion of the source value failsonEmpty- A default value that may be used if the source is empty or parsing fails- Returns:
- the converted value, or the onEmpty value, depending on strict, failDefault, and the source value itself
-
getDouble
@DynamicUse public static double getDouble(@NotNull String value, @Nullable String columnName, @NotNull com.fishlib.io.logger.Logger log, boolean strict, boolean failDefault, double onEmpty) Reads a double value from a CSVRecord- Parameters:
value- The value of the named column in the current row in the import filecolumnName- The column name from which the value should be readlog- The passed-down loggerstrict- Whether strict (true) or permissive (false) import rules are being usedfailDefault- Whether (true) to use the default value (onEmpty) if parsing/conversion of the source value failsonEmpty- A default value that may be used if the source is empty or parsing fails- Returns:
- the converted value, or the onEmpty value, depending on strict, failDefault, and the source value itself
-
getBigDecimal
@DynamicUse public static BigDecimal getBigDecimal(@NotNull String value, @Nullable String columnName, @NotNull com.fishlib.io.logger.Logger log, boolean strict, boolean failDefault, @Nullable BigDecimal onEmpty) Reads a BigDecimal value from a CSVRecord- Parameters:
value- The value of the named column in the current row in the import filecolumnName- The column name from which the value should be readlog- The passed-down loggerstrict- Whether strict (true) or permissive (false) import rules are being usedfailDefault- Whether (true) to use the default value (onEmpty) if parsing/conversion of the source value failsonEmpty- A default value that may be used if the source is empty or parsing fails- Returns:
- the converted value, or the onEmpty value, depending on strict, failDefault, and the source value itself
-
getLocalDate
@DynamicUse public static LocalDate getLocalDate(@NotNull String value, @Nullable String columnName, @NotNull com.fishlib.io.logger.Logger log, boolean strict, boolean failDefault, @Nullable LocalDate onEmpty) Read a LocalDate value from a CSVRecord.- Parameters:
value- The value of the named column in the current row in the import filecolumnName- The column name from which the value should be readlog- The passed-down loggerstrict- Whether strict (true) or permissive (false) import rules are being usedfailDefault- Whether (true) to use the default value (onEmpty) if parsing/conversion of the source value failsonEmpty- A default value that may be used if the source is empty or parsing fails- Returns:
- the converted value, or the onEmpty value, depending on strict, failDefault, and the source value itself
-
getLocalTime
@DynamicUse public static LocalTime getLocalTime(@NotNull String value, @Nullable String columnName, @NotNull com.fishlib.io.logger.Logger log, boolean strict, boolean failDefault, @Nullable LocalTime onEmpty) Read a LocalTime value from a CSVRecord.- Parameters:
value- The value of the named column in the current row in the import filecolumnName- The column name from which the value should be readlog- The passed-down loggerstrict- Whether strict (true) or permissive (false) import rules are being usedfailDefault- Whether (true) to use the default value (onEmpty) if parsing/conversion of the source value failsonEmpty- A default value that may be used if the source is empty or parsing fails- Returns:
- the converted value, or the onEmpty value, depending on strict, failDefault, and the source value itself
-
getFloat
@DynamicUse public static float getFloat(@NotNull String value, @Nullable String columnName, @NotNull com.fishlib.io.logger.Logger log, boolean strict, boolean failDefault, float onEmpty) Reads a float value from a CSVRecord- Parameters:
value- The value of the named column in the current row in the import filecolumnName- The column name from which the value should be readlog- The passed-down loggerstrict- Whether strict (true) or permissive (false) import rules are being usedfailDefault- Whether (true) to use the default value (onEmpty) if parsing/conversion of the source value failsonEmpty- A default value that may be used if the source is empty or parsing fails- Returns:
- the converted value, or the onEmpty value, depending on strict, failDefault, and the source value itself
-
getChar
@DynamicUse public static char getChar(@Nullable String value, @Nullable String columnName, @NotNull com.fishlib.io.logger.Logger log, boolean strict, boolean failDefault, char onEmpty) Reads a char value from a CSVRecord- Parameters:
value- The value of the named column in the current row in the import filecolumnName- The column name from which the value should be readlog- The passed-down loggerstrict- Whether strict (true) or permissive (false) import rules are being usedfailDefault- Whether (true) to use the default value (onEmpty) if parsing/conversion of the source value failsonEmpty- A default value that may be used if the source is empty or parsing fails- Returns:
- the converted value, or the onEmpty value, depending on strict, failDefault, and the source value itself
-
getByte
@DynamicUse public static byte getByte(@Nullable String value, @Nullable String columnName, @NotNull com.fishlib.io.logger.Logger log, boolean strict, boolean failDefault, byte onEmpty) Reads a byte value from a CSVRecord- Parameters:
value- The value of the named column in the current row in the import filecolumnName- The column name from which the value should be readlog- The passed-down loggerstrict- Whether strict (true) or permissive (false) import rules are being usedfailDefault- Whether (true) to use the default value (onEmpty) if parsing/conversion of the source value failsonEmpty- A default value that may be used if the source is empty or parsing fails- Returns:
- the converted value, or the onEmpty value, depending on strict, failDefault, and the source value itself
-
getTrimmedStringNull
@DynamicUse public static String getTrimmedStringNull(@Nullable String value, @Nullable String columnName) Reads a String value from a CSVRecord. Trims white space, and handles the special case of the word null being returned as a null String.- Returns:
- the read value, or a null String if the field contains the keyword "null"
-
getBoolean
@DynamicUse public static Boolean getBoolean(@NotNull String value, @Nullable String columnName, @NotNull com.fishlib.io.logger.Logger log, boolean strict, boolean failDefault, Boolean onEmpty) Reads a Boolean value from a CSVRecord. parseBoolean handles interpretation of various text boolean expressions (true, false, 1, 0, T, F, etc).- Parameters:
value- The value of the named column in the current row in the import filecolumnName- The column name from which the value should be readlog- The passed-down loggerstrict- Whether strict (true) or permissive (false) import rules are being usedfailDefault- Whether (true) to use the default value (onEmpty) if parsing/conversion of the source value failsonEmpty- A default value that may be used if the source is empty or parsing fails- Returns:
- the converted value, or the onEmpty value, depending on strict, failDefault, and the source value itself
-