Package com.illumon.iris.pqimport

Class JdbcImportPersistentQuery

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.JdbcImportPersistentQuery

All Implemented Interfaces:

RemoteQuery<PersistentQueryState>, Serializable

public class JdbcImportPersistentQuery
extends BaseImportPersistentQuery

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CATALOG
static final String	CONFIGURATION_TYPE
static final String	DRIVER
static final String	PASSWORD
static final String	QUERY
static final String	URI
static final String	USER

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
JdbcImportPersistentQuery(PersistentQueryConfiguration config, String scriptBody, PersistentQueryDbServerConfig dbServerConfig, ControllerConfigurationType configurationType, ScriptPathLoaderState scriptLoaderState, PublicPrivateKeyEncryption encryption)

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

Methods inherited from class java.lang.Object

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

Field Details

CONFIGURATION_TYPE

public static final String CONFIGURATION_TYPE

See Also:

• Constant Field Values

DRIVER

public static final String DRIVER

See Also:

• Constant Field Values

URI

public static final String URI

See Also:

• Constant Field Values

USER

public static final String USER

See Also:

• Constant Field Values

PASSWORD

public static final String PASSWORD

See Also:

• Constant Field Values

CATALOG

public static final String CATALOG

See Also:

• Constant Field Values

QUERY

public static final String QUERY

See Also:

• Constant Field Values

Constructor Details

JdbcImportPersistentQuery

public JdbcImportPersistentQuery(PersistentQueryConfiguration config,
 String scriptBody,
 PersistentQueryDbServerConfig dbServerConfig,
 ControllerConfigurationType configurationType,
 ScriptPathLoaderState scriptLoaderState,
 PublicPrivateKeyEncryption encryption)

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