Package io.deephaven.importers.csv.parsers

Class CsvParserFactory

java.lang.Object

io.deephaven.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(@NotNull PartitionUpdatesObserver partitionUpdatesObserver, @NotNull BaseAppendableColumnSink<?,?>[] columnSinks, 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.

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
 @NotNull PartitionUpdatesObserver partitionUpdatesObserver,
 @NotNull
 @NotNull BaseAppendableColumnSink<?,?>[] columnSinks,
 @NotNull
 CsvSpecs.Builder builder,
 @NotNull
 @NotNull Map<String,ImporterColumnDefinition> icdMap,
 @NotNull
 @NotNull CsvParserContext parserContext,
 @NotNull
 @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