Package com.illumon.iris.importers.csv.parsers

Class CsvParserFactory

java.lang.Object

com.illumon.iris.importers.csv.parsers.CsvParserFactory

public class CsvParserFactory
extends Object

A class that holds the methods to build and associate the appropriate parser for ColumnSinks that are in source file.

Constructor Summary

Constructors

Constructor	Description
CsvParserFactory()

Method Summary

Modifier and Type	Method	Description
static void	updateParsers(PartitionUpdatesObserver partitionUpdatesObserver, BaseAppendableColumnSink<?,?>[] columnSinks, io.deephaven.csv.CsvSpecs.Builder builder, Map<String,ImporterColumnDefinition> icdMap, CsvParserContext parserContext, ForkJoinPool forkJoinPool)	Updates the choice of parsers for each column based on column data type, and other attributes of its ImporterColumnDefinition.

Methods inherited from class java.lang.Object

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

Constructor Details

CsvParserFactory

public CsvParserFactory()

Method Details

updateParsers

public static void updateParsers(@NotNull
 PartitionUpdatesObserver partitionUpdatesObserver,
 @NotNull
 BaseAppendableColumnSink<?,?>[] columnSinks,
 @NotNull
 io.deephaven.csv.CsvSpecs.Builder builder,
 @NotNull
 Map<String,ImporterColumnDefinition> icdMap,
 @NotNull
 CsvParserContext parserContext,
 @NotNull
 ForkJoinPool forkJoinPool)

Updates the choice of parsers for each column based on column data type, and other attributes of its ImporterColumnDefinition.

Parameters:

partitionUpdatesObserver - The observer that would listen to partition updates, currently that would be AppendableTableWrapper

columnSinks - The column wrappers

builder - The CsvSpecs.Builder to update with specific parser by column

icdMap - The column name to ImporterColumnDefinition map

parserContext - The context object that holds common attributes passed down and needed by all Custom Parsers

forkJoinPool - The thread pool being used in the import process