Package com.illumon.iris.pqimport

Class CsvImportPersistentQuery

java.lang.Object

com.illumon.iris.db.tables.remotequery.ContextAwareRemoteQuery<PersistentQueryState>

com.illumon.iris.pqimport.MergeImportPersistentQuery

com.illumon.iris.pqimport.ImportPersistentQuery

com.illumon.iris.pqimport.BaseImportPersistentQuery

com.illumon.iris.pqimport.CsvImportPersistentQuery

All Implemented Interfaces:

RemoteQuery<PersistentQueryState>, Serializable

public class CsvImportPersistentQuery
extends BaseImportPersistentQuery

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CONFIGURATION_TYPE
static final String	CONSTANT
static final String	DELIMITER
static final String	FILEFORMAT
static final String	NO_HEADER
static final String	SKIP_FOOTER_LINES
static final String	SKIPLINES
static final String	SOURCE_DIRECTORY
static final String	SOURCE_FILE
static final String	SOURCE_GLOB
static final String	TRIM

Fields inherited from class com.illumon.iris.pqimport.BaseImportPersistentQuery

dbServerConfig

Fields inherited from class com.illumon.iris.pqimport.ImportPersistentQuery

APPEND, IMPORT_SOURCE, INTRADAY_PARTITION_COLUMN, OUTPUT_MODE_APPEND, OUTPUT_MODE_REPLACE, OUTPUT_MODE_SAFE, STRICT, TYPE_SPECIFIC_FIELDS_OUTPUT_MODE

Fields inherited from class com.illumon.iris.pqimport.MergeImportPersistentQuery

PARTITION_SUBSTITUTION, SUBSTITUTION_DATE_FORMAT

Constructor Summary

Constructors

Constructor	Description
CsvImportPersistentQuery(PersistentQueryConfiguration config, String scriptBody, PersistentQueryDbServerConfig dbServerConfig, ControllerConfigurationType configurationType, ScriptPathLoaderState scriptLoaderState)

Method Summary

Modifier and Type	Method	Description
protected void	doImport(PersistentQueryConfiguration config, org.jdom2.Element importSource, ImportOutputMode outputMode, ImportTableWriterFactory importTableWriterFactory, String intradayPartitionColumn, Boolean strict, RemoteCommandProgress progress, String columnPartitionValue, Database database, TableDefinitionSchema schema)
protected String	getConfigurationType()
protected String	getImportSourceType()

Methods inherited from class com.illumon.iris.pqimport.BaseImportPersistentQuery

execute

Methods inherited from class com.illumon.iris.db.tables.remotequery.ContextAwareRemoteQuery

getClient, getLog, getRemoteQueryProcessor, getUserContext, initializeContext, initializeContext, toString

Methods inherited from class java.lang.Object

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

Field Details

CONFIGURATION_TYPE

public static final String CONFIGURATION_TYPE

See Also:

• Constant Field Values

SOURCE_FILE

public static final String SOURCE_FILE

See Also:

• Constant Field Values

SOURCE_GLOB

public static final String SOURCE_GLOB

See Also:

• Constant Field Values

SOURCE_DIRECTORY

public static final String SOURCE_DIRECTORY

See Also:

• Constant Field Values

TRIM

public static final String TRIM

See Also:

• Constant Field Values

NO_HEADER

public static final String NO_HEADER

See Also:

• Constant Field Values

SKIPLINES

public static final String SKIPLINES

See Also:

• Constant Field Values

SKIP_FOOTER_LINES

public static final String SKIP_FOOTER_LINES

See Also:

• Constant Field Values

DELIMITER

public static final String DELIMITER

See Also:

• Constant Field Values

FILEFORMAT

public static final String FILEFORMAT

See Also:

• Constant Field Values

CONSTANT

public static final String CONSTANT

See Also:

• Constant Field Values

Constructor Details

CsvImportPersistentQuery

public CsvImportPersistentQuery(PersistentQueryConfiguration config,
 String scriptBody,
 PersistentQueryDbServerConfig dbServerConfig,
 ControllerConfigurationType configurationType,
 ScriptPathLoaderState scriptLoaderState)

Method Details

doImport

protected void doImport(PersistentQueryConfiguration config,
 org.jdom2.Element importSource,
 ImportOutputMode outputMode,
 ImportTableWriterFactory importTableWriterFactory,
 String intradayPartitionColumn,
 Boolean strict,
 RemoteCommandProgress progress,
 String columnPartitionValue,
 Database database,
 TableDefinitionSchema schema)

Specified by:

doImport in class BaseImportPersistentQuery

getConfigurationType

@NotNull
protected String getConfigurationType()

Specified by:

getConfigurationType in class BaseImportPersistentQuery

getImportSourceType

@NotNull
protected String getImportSourceType()

Specified by:

getImportSourceType in class BaseImportPersistentQuery