Package com.illumon.iris.pqimport

Class DownsampleImportPersistentQuery

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

All Implemented Interfaces:

RemoteQuery<PersistentQueryState>, Serializable

public class DownsampleImportPersistentQuery
extends ImportPersistentQuery

Persistent query that takes a source table, downsamples it and saves into a target table (intraday). We do not base this on BaseImportPersistentQuery for now because we are using the new import "builder" construct, which provides much of the same functionality (creates the table writer factory for example).

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static String	AGGREGATE_COLUMNS
static String	AGGREGATE_TYPES
static String	ALL_BINS
static String	CALENDAR
static String	CONFIGURATION_TYPE
protected PersistentQueryDbServerConfig	dbServerConfig
static String	KEY_COLUMNS
static String	MAINTAIN_STATE_COLUMNS
static String	NUM_THREADS
static String	PERIOD
static String	SOURCE_NAMESPACE
static String	SOURCE_TABLE
static String	TIME_BIN_MODE
static String	TIMESTAMP_COLUMN

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

Method Summary

Modifier and Type	Method	Description
PersistentQueryState	execute(Database database)	Execute a query on a remote host.
protected String	getConfigurationType()

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

PERIOD

public static final String PERIOD

See Also:

Constant Field Values

KEY_COLUMNS

public static final String KEY_COLUMNS

See Also:

Constant Field Values

TIMESTAMP_COLUMN

public static final String TIMESTAMP_COLUMN

See Also:

Constant Field Values

SOURCE_NAMESPACE

public static final String SOURCE_NAMESPACE

See Also:

Constant Field Values

SOURCE_TABLE

public static final String SOURCE_TABLE

See Also:

Constant Field Values

AGGREGATE_COLUMNS

public static final String AGGREGATE_COLUMNS

See Also:

Constant Field Values

AGGREGATE_TYPES

public static final String AGGREGATE_TYPES

See Also:

Constant Field Values

MAINTAIN_STATE_COLUMNS

public static final String MAINTAIN_STATE_COLUMNS

See Also:

Constant Field Values

CALENDAR

public static final String CALENDAR

See Also:

Constant Field Values

ALL_BINS

public static final String ALL_BINS

See Also:

Constant Field Values

TIME_BIN_MODE

public static final String TIME_BIN_MODE

See Also:

Constant Field Values

NUM_THREADS

public static final String NUM_THREADS

See Also:

Constant Field Values

dbServerConfig

protected final PersistentQueryDbServerConfig dbServerConfig

Constructor Details

DownsampleImportPersistentQuery

public DownsampleImportPersistentQuery(PersistentQueryConfiguration config, String scriptBody, PersistentQueryDbServerConfig dbServerConfig, ControllerConfigurationType configurationType, ScriptPathLoaderState scriptLoaderState)

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.

getConfigurationType

@NotNull protected String getConfigurationType()