Package com.denodo.scheduler.client.commons.utils

Class JobHelper

java.lang.Object

com.denodo.scheduler.client.commons.utils.JobHelper

public final class JobHelper
extends Object

Helper class to get parameters from Configuration objects representing jobs.

Since:

5.0

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ADVANCED_QUERY_FILTER_PARAMETER
static final String	CACHE_ATOMIC_OPERATION_PARAMETER
static final String	CACHE_CONTEXT_OPTS_PARAMETER
static final String	CACHE_INCREMENTAL_FIELD_NAME_PARAMETER
static final String	CACHE_INCREMENTAL_LOAD_BLOCK_SIZE_PARAMETER
static final String	CACHE_INCREMENTAL_LOAD_CONFIG_PARAMETER
static final String	CACHE_INCREMENTAL_LOAD_ENABLED_PARAMETER
static final String	CACHE_INCREMENTAL_LOAD_FIELD_NAME_PARAMETER
static final String	CACHE_INVALIDATE_MODE_PARAMETER
static final String	CACHE_LOAD_ON_ERROR_PARAMETER
static final String	CONCURRENCY_LEVEL_PARAMETER
static final String	DATALOAD_CUSTOM_QUERY_PARAMETER
static final String	DATALOAD_ENABLE_UPDATE_ON_KEYS_PARAMETER
static final String	DATALOAD_INCREMENTAL_FIELD_NAME_PARAMETER
static final String	DATALOAD_INCREMENTAL_LOAD_CONFIG_PARAMETER
static final String	DATALOAD_QUERY_CONDITIONS_PARAMETER
static final String	DATALOAD_QUERY_OPTIONS_PARAMETER
static final String	DATALOAD_UPDATE_ON_KEYS_PARAMETER
static final String	DATASOURCE_PARAMETER
static final String	ENABLE_INCREMENTAL_INDEXING_PARAMETER
static final String	ESCAPED_VIEW_NAME_PARAMETER
static final String	EXPORT_AS_TRANSACTION
static final String	FIELD_NAME_PARAMETER
static final String	FIELD_PARAMETER
static final String	FIELDS_PARAMETER
static final String	HANDLE_ONLY_LAST_RETRY_PARAMETER
static final String	HANDLER_PARAMETER
static final String	INCLUDE_ONLY_LAST_RETRY_PARAMETER
static final String	INCLUDE_SERVER_INFO_PARAMETER
static final String	INCREMENTAL_INDEXING_EXPRESSION_PARAMETER
static final String	INCREMENTAL_INDEXING_FIELD_NAME_PARAMETER
static final String	INCREMENTAL_INDEXING_START_DATE_PARAMETER
static final String	INDEX_ONLY_TEXT_AND_PK_FIELDS
static final String	JOB_CONCURRENCY_LEVEL_PARAMETER
static final String	JOB_MAX_ITERATIONS_PARAMETER
static final String	LOAD_PROCESS_NAME_PARAMETER
static final String	LOAD_PROCESS_PARAMETER
static final String	LOG_ERROR_OUTPUT_PARAMETER
static final String	MAX_INDIVIDUAL_REPORTS_PARAMETER
static final String	MAX_ITERATIONS_PARAMETER
static final String	MAX_NUM_RESULTS_PER_VIEW_PARAMETER
static final String	ONLY_ERRORS_PARAMETER
static final String	ORDER_BY_EXPRESSION_PARAMETER
static final String	OUTPUT_FIELDS_PARAMETER
static final String	PARAMETERIZED_QUERY_PARAMETER
static final String	QUERY_ERROR_LOG_PARAMETER
static final String	REPORT_CONFIG_PARAMETER
static final String	SOURCE_FIELD_PARAMETER
static final String	SOURCE_PARAMETER
static final String	SOURCES_NOT_CHANGE_PARAMETER
static final String	VIEW_INDEXING_PROCESS_CONFIGS_PARAMETER
static final String	VIEW_INDEXING_PROCESS_NAME_PARAMETER
static final String	VIEW_NAME_PARAMETER
static final String	WRAPPER_PARAMETER

Method Summary

Modifier and Type	Method	Description
static String	getAdvancedQueryFilter(ParameterStructure parameters)
static String	getCacheContextOpts(ParameterStructure parameters)
static String	getCacheIncrementalFieldName(ParameterStructure parameters)
static int	getCacheIncrementalLoadBlockSize(ParameterStructure parameters)
static String	getCacheIncrementalLoadFieldName(ParameterStructure parameters)
static CacheInvalidationMode	getCacheInvalidationMode(ParameterStructure parameters)
static int	getConcurrencyLevel(ParameterStructure parameters)
static String	getDataLoadCustomQuery(ParameterStructure parameters)
static String	getDataLoadIncrementalFieldName(ParameterStructure parameters)
static String	getDataLoadQueryConditions(ParameterStructure parameters)
static String	getDataLoadQueryOptions(ParameterStructure parameters)
static List<String>	getDataLoadUpdateOnKeys(ParameterStructure parameters)
static int	getDataSourceID(ParameterStructure parameters)
static String	getEscapedViewName(ParameterStructure parameters)
static Collection<ParameterStructure>	getHandlersConfig(ParameterStructure parameters)
static String	getIncrementalIndexingExpression(ParameterStructure parameters)
static String	getIncrementalIndexingFieldName(ParameterStructure parameters)
static String	getIncrementalIndexingStartDate(ParameterStructure parameters)
static String	getITPQuery(ParameterStructure parameters)
static int	getJobConcurrencyLevel(ParameterStructure parameters)
static int	getJobMaxIterations(ParameterStructure parameters)
static Collection<ParameterStructure>	getLoadProcessesConfig(ParameterStructure parameters)
static String	getLoadProcessName(ParameterStructure parameters)
static Collection<String>	getLogErrorOutput(ParameterStructure parameters)
static int	getMaxIndividualReports(ParameterStructure parameters)
static int	getMaxIterations(ParameterStructure parameters)
static long	getMaxNumResultsPerView(ParameterStructure parameters)
static String	getOrderByExpresion(ParameterStructure parameters)
static String	getParameterizedQuery(ParameterStructure parameters)
static ParameterStructure	getQueryErrorLogConfig(ParameterStructure parameters)
static Collection<ParameterStructure>	getViewIndexingProcessConfigs(ParameterStructure parameters)
static String	getViewIndexingProcessName(ParameterStructure parameters)
static String	getViewName(ParameterStructure parameters)
static Collection<String>	getWrapperOutputFields(ParameterStructure parameters)
static boolean	includeOnlyOnLastRetry(ParameterStructure parameters)
static boolean	isCacheAtomicOperation(ParameterStructure parameters)
static boolean	isCacheIncrementalLoad(ParameterStructure parameters)
static boolean	isCacheLoadOnError(ParameterStructure parameters)
static boolean	isDataLoadEnableUpdateOnKeys(ParameterStructure parameters)
static boolean	isEnableIncrementalIndexing(ParameterStructure parameters)
static boolean	isExportAsTransaction(ParameterStructure parameters)
static boolean	isHandleOnlyOnLastRetry(ParameterStructure parameters)
static boolean	isIndexOnlyTextAndPKFields(ParameterStructure parameters)
static boolean	isIndexOnlyTextAndPKFieldsViewProcess(ParameterStructure parameters)
static boolean	isReportIncludeServerInfo(ParameterStructure parameters)
static boolean	isReportOnlyErrors(ParameterStructure parameters)
static boolean	isSourcesNotChange(ParameterStructure parameters)
static boolean	isVDPIndexerJob(ParameterStructure parameters)

Methods inherited from class java.lang.Object

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

Field Details

DATASOURCE_PARAMETER

public static final String DATASOURCE_PARAMETER

See Also:

• Constant Field Values

PARAMETERIZED_QUERY_PARAMETER

public static final String PARAMETERIZED_QUERY_PARAMETER

See Also:

• Constant Field Values

LOAD_PROCESS_NAME_PARAMETER

public static final String LOAD_PROCESS_NAME_PARAMETER

See Also:

• Constant Field Values

SOURCES_NOT_CHANGE_PARAMETER

public static final String SOURCES_NOT_CHANGE_PARAMETER

See Also:

• Constant Field Values

CACHE_INVALIDATE_MODE_PARAMETER

public static final String CACHE_INVALIDATE_MODE_PARAMETER

See Also:

• Constant Field Values

CACHE_ATOMIC_OPERATION_PARAMETER

public static final String CACHE_ATOMIC_OPERATION_PARAMETER

See Also:

• Constant Field Values

CACHE_LOAD_ON_ERROR_PARAMETER

public static final String CACHE_LOAD_ON_ERROR_PARAMETER

See Also:

• Constant Field Values

CACHE_INCREMENTAL_LOAD_CONFIG_PARAMETER

public static final String CACHE_INCREMENTAL_LOAD_CONFIG_PARAMETER

See Also:

• Constant Field Values

CACHE_INCREMENTAL_LOAD_ENABLED_PARAMETER

public static final String CACHE_INCREMENTAL_LOAD_ENABLED_PARAMETER

See Also:

• Constant Field Values

CACHE_INCREMENTAL_LOAD_BLOCK_SIZE_PARAMETER

public static final String CACHE_INCREMENTAL_LOAD_BLOCK_SIZE_PARAMETER

See Also:

• Constant Field Values

CACHE_INCREMENTAL_LOAD_FIELD_NAME_PARAMETER

public static final String CACHE_INCREMENTAL_LOAD_FIELD_NAME_PARAMETER

See Also:

• Constant Field Values

CACHE_INCREMENTAL_FIELD_NAME_PARAMETER

public static final String CACHE_INCREMENTAL_FIELD_NAME_PARAMETER

See Also:

• Constant Field Values

CACHE_CONTEXT_OPTS_PARAMETER

public static final String CACHE_CONTEXT_OPTS_PARAMETER

See Also:

• Constant Field Values

MAX_ITERATIONS_PARAMETER

public static final String MAX_ITERATIONS_PARAMETER

See Also:

• Constant Field Values

JOB_MAX_ITERATIONS_PARAMETER

public static final String JOB_MAX_ITERATIONS_PARAMETER

See Also:

• Constant Field Values

CONCURRENCY_LEVEL_PARAMETER

public static final String CONCURRENCY_LEVEL_PARAMETER

See Also:

• Constant Field Values

JOB_CONCURRENCY_LEVEL_PARAMETER

public static final String JOB_CONCURRENCY_LEVEL_PARAMETER

See Also:

• Constant Field Values

REPORT_CONFIG_PARAMETER

public static final String REPORT_CONFIG_PARAMETER

See Also:

• Constant Field Values

INCLUDE_SERVER_INFO_PARAMETER

public static final String INCLUDE_SERVER_INFO_PARAMETER

See Also:

• Constant Field Values

ONLY_ERRORS_PARAMETER

public static final String ONLY_ERRORS_PARAMETER

See Also:

• Constant Field Values

MAX_INDIVIDUAL_REPORTS_PARAMETER

public static final String MAX_INDIVIDUAL_REPORTS_PARAMETER

See Also:

• Constant Field Values

FIELDS_PARAMETER

public static final String FIELDS_PARAMETER

See Also:

• Constant Field Values

FIELD_PARAMETER

public static final String FIELD_PARAMETER

See Also:

• Constant Field Values

FIELD_NAME_PARAMETER

public static final String FIELD_NAME_PARAMETER

See Also:

• Constant Field Values

SOURCE_FIELD_PARAMETER

public static final String SOURCE_FIELD_PARAMETER

See Also:

• Constant Field Values

WRAPPER_PARAMETER

public static final String WRAPPER_PARAMETER

See Also:

• Constant Field Values

OUTPUT_FIELDS_PARAMETER

public static final String OUTPUT_FIELDS_PARAMETER

See Also:

• Constant Field Values

LOAD_PROCESS_PARAMETER

public static final String LOAD_PROCESS_PARAMETER

See Also:

• Constant Field Values

SOURCE_PARAMETER

public static final String SOURCE_PARAMETER

See Also:

• Constant Field Values

HANDLER_PARAMETER

public static final String HANDLER_PARAMETER

See Also:

• Constant Field Values

HANDLE_ONLY_LAST_RETRY_PARAMETER

public static final String HANDLE_ONLY_LAST_RETRY_PARAMETER

See Also:

• Constant Field Values

QUERY_ERROR_LOG_PARAMETER

public static final String QUERY_ERROR_LOG_PARAMETER

See Also:

• Constant Field Values

INCLUDE_ONLY_LAST_RETRY_PARAMETER

public static final String INCLUDE_ONLY_LAST_RETRY_PARAMETER

See Also:

• Constant Field Values

LOG_ERROR_OUTPUT_PARAMETER

public static final String LOG_ERROR_OUTPUT_PARAMETER

See Also:

• Constant Field Values

INCREMENTAL_INDEXING_START_DATE_PARAMETER

public static final String INCREMENTAL_INDEXING_START_DATE_PARAMETER

See Also:

• Constant Field Values

MAX_NUM_RESULTS_PER_VIEW_PARAMETER

public static final String MAX_NUM_RESULTS_PER_VIEW_PARAMETER

See Also:

• Constant Field Values

VIEW_INDEXING_PROCESS_CONFIGS_PARAMETER

public static final String VIEW_INDEXING_PROCESS_CONFIGS_PARAMETER

See Also:

• Constant Field Values

VIEW_NAME_PARAMETER

public static final String VIEW_NAME_PARAMETER

See Also:

• Constant Field Values

ESCAPED_VIEW_NAME_PARAMETER

public static final String ESCAPED_VIEW_NAME_PARAMETER

See Also:

• Constant Field Values

VIEW_INDEXING_PROCESS_NAME_PARAMETER

public static final String VIEW_INDEXING_PROCESS_NAME_PARAMETER

See Also:

• Constant Field Values

ORDER_BY_EXPRESSION_PARAMETER

public static final String ORDER_BY_EXPRESSION_PARAMETER

See Also:

• Constant Field Values

ADVANCED_QUERY_FILTER_PARAMETER

public static final String ADVANCED_QUERY_FILTER_PARAMETER

See Also:

• Constant Field Values

ENABLE_INCREMENTAL_INDEXING_PARAMETER

public static final String ENABLE_INCREMENTAL_INDEXING_PARAMETER

See Also:

• Constant Field Values

INCREMENTAL_INDEXING_EXPRESSION_PARAMETER

public static final String INCREMENTAL_INDEXING_EXPRESSION_PARAMETER

See Also:

• Constant Field Values

INCREMENTAL_INDEXING_FIELD_NAME_PARAMETER

public static final String INCREMENTAL_INDEXING_FIELD_NAME_PARAMETER

See Also:

• Constant Field Values

INDEX_ONLY_TEXT_AND_PK_FIELDS

public static final String INDEX_ONLY_TEXT_AND_PK_FIELDS

See Also:

• Constant Field Values

EXPORT_AS_TRANSACTION

public static final String EXPORT_AS_TRANSACTION

See Also:

• Constant Field Values

DATALOAD_INCREMENTAL_LOAD_CONFIG_PARAMETER

public static final String DATALOAD_INCREMENTAL_LOAD_CONFIG_PARAMETER

See Also:

• Constant Field Values

DATALOAD_INCREMENTAL_FIELD_NAME_PARAMETER

public static final String DATALOAD_INCREMENTAL_FIELD_NAME_PARAMETER

See Also:

• Constant Field Values

DATALOAD_QUERY_OPTIONS_PARAMETER

public static final String DATALOAD_QUERY_OPTIONS_PARAMETER

See Also:

• Constant Field Values

DATALOAD_QUERY_CONDITIONS_PARAMETER

public static final String DATALOAD_QUERY_CONDITIONS_PARAMETER

See Also:

• Constant Field Values

DATALOAD_CUSTOM_QUERY_PARAMETER

public static final String DATALOAD_CUSTOM_QUERY_PARAMETER

See Also:

• Constant Field Values

DATALOAD_ENABLE_UPDATE_ON_KEYS_PARAMETER

public static final String DATALOAD_ENABLE_UPDATE_ON_KEYS_PARAMETER

See Also:

• Constant Field Values

DATALOAD_UPDATE_ON_KEYS_PARAMETER

public static final String DATALOAD_UPDATE_ON_KEYS_PARAMETER

See Also:

• Constant Field Values

Method Details

getDataSourceID

public static int getDataSourceID(ParameterStructure parameters)
                           throws ConfigurationException

Throws:

ConfigurationException

getMaxIterations

public static int getMaxIterations(ParameterStructure parameters)
                            throws ConfigurationException

Throws:

ConfigurationException

getJobMaxIterations

public static int getJobMaxIterations(ParameterStructure parameters)
                               throws ConfigurationException

Throws:

ConfigurationException

getConcurrencyLevel

public static int getConcurrencyLevel(ParameterStructure parameters)
                               throws ConfigurationException

Throws:

ConfigurationException

getJobConcurrencyLevel

public static int getJobConcurrencyLevel(ParameterStructure parameters)
                                  throws ConfigurationException

Throws:

ConfigurationException

getParameterizedQuery

public static String getParameterizedQuery(ParameterStructure parameters)
                                    throws ConfigurationException

Throws:

ConfigurationException

getLoadProcessName

public static String getLoadProcessName(ParameterStructure parameters)
                                 throws ConfigurationException

Throws:

ConfigurationException

getITPQuery

public static String getITPQuery(ParameterStructure parameters)
                          throws ConfigurationException

Throws:

ConfigurationException

getWrapperOutputFields

public static Collection<String> getWrapperOutputFields(ParameterStructure parameters)

getCacheInvalidationMode

public static CacheInvalidationMode getCacheInvalidationMode(ParameterStructure parameters)

isCacheAtomicOperation

public static boolean isCacheAtomicOperation(ParameterStructure parameters)
                                      throws ConfigurationException

Throws:

ConfigurationException

isCacheLoadOnError

public static boolean isCacheLoadOnError(ParameterStructure parameters)
                                  throws ConfigurationException

Throws:

ConfigurationException

getCacheContextOpts

public static String getCacheContextOpts(ParameterStructure parameters)
                                  throws ConfigurationException

Throws:

ConfigurationException

isCacheIncrementalLoad

public static boolean isCacheIncrementalLoad(ParameterStructure parameters)
                                      throws ConfigurationException

Throws:

ConfigurationException

getCacheIncrementalLoadBlockSize

public static int getCacheIncrementalLoadBlockSize(ParameterStructure parameters)
                                            throws ConfigurationException

Throws:

ConfigurationException

getCacheIncrementalLoadFieldName

public static String getCacheIncrementalLoadFieldName(ParameterStructure parameters)
                                               throws ConfigurationException

Throws:

ConfigurationException

getCacheIncrementalFieldName

public static String getCacheIncrementalFieldName(ParameterStructure parameters)
                                           throws ConfigurationException

Throws:

ConfigurationException

getDataLoadQueryOptions

public static String getDataLoadQueryOptions(ParameterStructure parameters)
                                      throws ConfigurationException

Throws:

ConfigurationException

getDataLoadIncrementalFieldName

public static String getDataLoadIncrementalFieldName(ParameterStructure parameters)
                                              throws ConfigurationException

Throws:

ConfigurationException

getDataLoadQueryConditions

public static String getDataLoadQueryConditions(ParameterStructure parameters)
                                         throws ConfigurationException

Throws:

ConfigurationException

getDataLoadCustomQuery

public static String getDataLoadCustomQuery(ParameterStructure parameters)
                                     throws ConfigurationException

Throws:

ConfigurationException

isDataLoadEnableUpdateOnKeys

public static boolean isDataLoadEnableUpdateOnKeys(ParameterStructure parameters)
                                            throws ConfigurationException

Throws:

ConfigurationException

getDataLoadUpdateOnKeys

public static List<String> getDataLoadUpdateOnKeys(ParameterStructure parameters)

isSourcesNotChange

public static boolean isSourcesNotChange(ParameterStructure parameters)
                                  throws ConfigurationException

Throws:

ConfigurationException

getHandlersConfig

public static Collection<ParameterStructure> getHandlersConfig(ParameterStructure parameters)

isHandleOnlyOnLastRetry

public static boolean isHandleOnlyOnLastRetry(ParameterStructure parameters)
                                       throws ConfigurationException

Throws:

ConfigurationException

isReportOnlyErrors

public static boolean isReportOnlyErrors(ParameterStructure parameters)
                                  throws ConfigurationException

Throws:

ConfigurationException

isReportIncludeServerInfo

public static boolean isReportIncludeServerInfo(ParameterStructure parameters)
                                         throws ConfigurationException

Throws:

ConfigurationException

getMaxIndividualReports

public static int getMaxIndividualReports(ParameterStructure parameters)
                                   throws ConfigurationException

Throws:

ConfigurationException

getLoadProcessesConfig

public static Collection<ParameterStructure> getLoadProcessesConfig(ParameterStructure parameters)
                                                             throws ConfigurationException

Throws:

ConfigurationException

getQueryErrorLogConfig

public static ParameterStructure getQueryErrorLogConfig(ParameterStructure parameters)

includeOnlyOnLastRetry

public static boolean includeOnlyOnLastRetry(ParameterStructure parameters)
                                      throws ConfigurationException

Throws:

ConfigurationException

getLogErrorOutput

public static Collection<String> getLogErrorOutput(ParameterStructure parameters)
                                            throws ConfigurationException

Throws:

ConfigurationException

getIncrementalIndexingStartDate

public static String getIncrementalIndexingStartDate(ParameterStructure parameters)
                                              throws ConfigurationException

Throws:

ConfigurationException

getMaxNumResultsPerView

public static long getMaxNumResultsPerView(ParameterStructure parameters)
                                    throws ConfigurationException

Throws:

ConfigurationException

getViewIndexingProcessConfigs

public static Collection<ParameterStructure> getViewIndexingProcessConfigs(ParameterStructure parameters)
                                                                    throws ConfigurationException

Throws:

ConfigurationException

getViewName

public static String getViewName(ParameterStructure parameters)
                          throws ConfigurationException

Throws:

ConfigurationException

getEscapedViewName

public static String getEscapedViewName(ParameterStructure parameters)
                                 throws ConfigurationException

Throws:

ConfigurationException

getViewIndexingProcessName

public static String getViewIndexingProcessName(ParameterStructure parameters)
                                         throws ConfigurationException

Throws:

ConfigurationException

getOrderByExpresion

public static String getOrderByExpresion(ParameterStructure parameters)
                                  throws ConfigurationException

Throws:

ConfigurationException

getAdvancedQueryFilter

public static String getAdvancedQueryFilter(ParameterStructure parameters)
                                     throws ConfigurationException

Throws:

ConfigurationException

isEnableIncrementalIndexing

public static boolean isEnableIncrementalIndexing(ParameterStructure parameters)
                                           throws ConfigurationException

Throws:

ConfigurationException

getIncrementalIndexingExpression

public static String getIncrementalIndexingExpression(ParameterStructure parameters)
                                               throws ConfigurationException

Throws:

ConfigurationException

getIncrementalIndexingFieldName

public static String getIncrementalIndexingFieldName(ParameterStructure parameters)
                                              throws ConfigurationException

Throws:

ConfigurationException

isIndexOnlyTextAndPKFields

public static boolean isIndexOnlyTextAndPKFields(ParameterStructure parameters)
                                          throws ConfigurationException

Throws:

ConfigurationException

isIndexOnlyTextAndPKFieldsViewProcess

public static boolean isIndexOnlyTextAndPKFieldsViewProcess(ParameterStructure parameters)
                                                     throws ConfigurationException

Throws:

ConfigurationException

isVDPIndexerJob

public static boolean isVDPIndexerJob(ParameterStructure parameters)
                               throws ConfigurationException

Throws:

ConfigurationException

isExportAsTransaction

public static boolean isExportAsTransaction(ParameterStructure parameters)
                                     throws ConfigurationException

Throws:

ConfigurationException