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

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

dbServerConfig

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 @NotNull String	getConfigurationType()
protected @NotNull 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

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 @NotNull String getConfigurationType()

Specified by:

getConfigurationType in class BaseImportPersistentQuery

getImportSourceType

@NotNull
protected @NotNull String getImportSourceType()

Specified by:

getImportSourceType in class BaseImportPersistentQuery