Package com.illumon.iris.pqimport

Class BaseImportPersistentQuery

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

All Implemented Interfaces:

RemoteQuery<PersistentQueryState>, Serializable

Direct Known Subclasses:

BinaryImportPersistentQuery, CsvImportPersistentQuery, JdbcImportPersistentQuery, XmlImportPersistentQuery

public abstract class BaseImportPersistentQuery
extends ImportPersistentQuery

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected PersistentQueryDbServerConfig	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

Method Summary

Modifier and Type	Method	Description
protected abstract void	doImport(PersistentQueryConfiguration config, org.jdom2.Element importSource, ImportOutputMode outputMode, ImportTableWriterFactory importTableWriterFactory, String intradayPartitionColumn, Boolean strict, RemoteCommandProgress progress, String partitionValue, Database database, TableDefinitionSchema schema)
PersistentQueryState	execute(Database database)	Execute a query on a remote host.
protected abstract String	getConfigurationType()
protected abstract String	getImportSourceType()

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

dbServerConfig

protected final PersistentQueryDbServerConfig dbServerConfig

Method Details

execute

public PersistentQueryState execute(Database database)

Description copied from interface: RemoteQuery

Execute a query on a remote host.

Parameters:

database - database to use for execution.

Returns:

result of the query.

getImportSourceType

@NotNull protected abstract String getImportSourceType()

doImport

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

getConfigurationType

@NotNull protected abstract String getConfigurationType()