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 String`	`CATALOG`
`static String`	`CONFIGURATION_TYPE`
`static String`	`DRIVER`
`static String`	`PASSWORD`
`static String`	`QUERY`
`static String`	`URI`
`static 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

Class JdbcImportPersistentQuery