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 String`	`CONFIGURATION_TYPE`
`static String`	`CONSTANT`
`static String`	`DELIMITER`
`static String`	`FILEFORMAT`
`static String`	`NO_HEADER`
`static String`	`SKIP_FOOTER_LINES`
`static String`	`SKIPLINES`
`static String`	`SOURCE_DIRECTORY`
`static String`	`SOURCE_FILE`
`static String`	`SOURCE_GLOB`
`static 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

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

Class CsvImportPersistentQuery