Package org.teiid.translator.infinispan.hotrod

Class InfinispanExecutionFactory

java.lang.Object

org.teiid.translator.ExecutionFactory<ConnectionFactory,InfinispanConnection>

org.teiid.translator.infinispan.hotrod.InfinispanExecutionFactory

@Translator(name="infinispan-hotrod",
            description="The Infinispan Translator Using Protobuf & Hotrod")
public class InfinispanExecutionFactory
extends ExecutionFactory<ConnectionFactory,InfinispanConnection>

Nested Class Summary

Nested classes/interfaces inherited from class org.teiid.translator.ExecutionFactory

ExecutionFactory.Format, ExecutionFactory.NullOrder, ExecutionFactory.SupportedJoinCriteria, ExecutionFactory.TransactionSupport

Field Summary

Fields

Modifier and Type	Field	Description
static int	MAX_SET_SIZE

Fields inherited from class org.teiid.translator.ExecutionFactory

DEFAULT_MAX_FROM_GROUPS, DEFAULT_MAX_IN_CRITERIA_SIZE, DEFAULT_MAX_PROJECTED_COLUMNS

Constructor Summary

Constructors

Constructor	Description
InfinispanExecutionFactory()

Method Summary

Modifier and Type	Method	Description
ProcedureExecution	createDirectExecution(List<Argument> arguments, Command command, ExecutionContext executionContext, RuntimeMetadata metadata, InfinispanConnection connection)
ResultSetExecution	createResultSetExecution(QueryExpression command, ExecutionContext executionContext, RuntimeMetadata metadata, InfinispanConnection connection)
UpdateExecution	createUpdateExecution(Command command, ExecutionContext executionContext, RuntimeMetadata metadata, InfinispanConnection connection)
int	getMaxFromGroups()	The number of groups supported in the from clause.
void	getMetadata(MetadataFactory metadataFactory, InfinispanConnection conn)	Implement to provide metadata to the metadata for use by the engine.
MetadataProcessor<InfinispanConnection>	getMetadataProcessor()	Get a MetadataProcessor for the translator to read the metadata.
void	initCapabilities(InfinispanConnection connection)	Will be called by ExecutionFactory.start() with a null connection if a source connection is not ExecutionFactory.isSourceRequiredForCapabilities()
boolean	isSourceRequiredForCapabilities()	If true, the ExecutionFactory.initCapabilities(Object) method will be consulted prior to determining the capabilities
boolean	returnsSingleUpdateCount()	True if only a single value is returned for the update count.
boolean	setSupportsBulkUpdate(boolean supports)
boolean	setSupportsCompareCriteriaOrdered(boolean supports)
boolean	setSupportsUpsert(boolean supports)
boolean	supportsAggregatesAvg()	Support indicates connector can accept the AVG aggregate function
boolean	supportsAggregatesCount()	Support indicates connector can accept the COUNT aggregate function
boolean	supportsAggregatesMax()	Support indicates connector can accept the MAX aggregate function
boolean	supportsAggregatesMin()	Support indicates connector can accept the MIN aggregate function
boolean	supportsAggregatesSum()	Support indicates connector can accept the SUM aggregate function
boolean	supportsAliasedTable()	Support indicates connector can accept groups with aliases
boolean	supportsBulkUpdate()	Whether the source supports updates with multiple value sets
boolean	supportsCompareCriteriaEquals()	Support indicates connector accepts criteria of form (element = constant)
boolean	supportsCompareCriteriaOrdered()	Support indicates connector accepts criteria of form (element <=|>= constant) The query engine will may pushdown queries containing < or > if NOT is also supported.
boolean	supportsGroupBy()	Whether the source supports an explicit GROUP BY clause
boolean	supportsHaving()	Whether the source supports the HAVING clause
boolean	supportsInCriteria()	Support indicates connector accepts criteria of form (element IN set)
boolean	supportsIsNullCriteria()	Support indicates connector accepts criteria of form (element IS NULL)
boolean	supportsLikeCriteria()	Support indicates connector accepts criteria of form (element LIKE constant)
boolean	supportsLikeCriteriaEscapeCharacter()	Support indicates connector accepts criteria of form (element LIKE constant ESCAPE char)
boolean	supportsNotCriteria()	Support indicates connector accepts logical criteria NOT
boolean	supportsOnlyLiteralComparison()
boolean	supportsOrCriteria()	Support indicates connector accepts logical criteria connected by OR
boolean	supportsRowLimit()	Gets whether the connector can limit the number of rows returned by a query.
boolean	supportsRowOffset()	Gets whether the connector supports a SQL clause (similar to the LIMIT with an offset) that can return result sets that start in the middle of the resulting rows returned by a query
boolean	supportsUpsert()
boolean	useAnsiJoin()	Whether the source prefers to use ANSI style joins.

Methods inherited from class org.teiid.translator.ExecutionFactory

addPushDownFunction, areLobsUsableAfterClose, closeConnection, createExecution, createProcedureExecution, getCacheDirective, getCollationLocale, getConnection, getConnection, getDefaultNullOrder, getDirectQueryProcedureName, getExcludedCommonTableExpressionName, getInstance, getLanguageFactory, getMaxDependentInPredicates, getMaxInCriteriaSize, getMaxProjectedColumns, getNativeQueryProcedureName, getPushDownFunctions, getRequiredLikeEscape, getSupportedFunctions, getSupportedJoinCriteria, getTransactionSupport, getTypeFacility, isCopyLobs, isForkable, isImmutable, isSourceRequired, isSourceRequiredForMetadata, isThreadBound, requiresCriteria, setCollationLocale, setCopyLobs, setDirectQueryProcedureName, setExcludedCommonTableExpressionName, setImmutable, setMaxDependentInPredicates, setMaxInCriteriaSize, setNativeQueryProcedureName, setRequiresCriteria, setSourceRequired, setSourceRequiredForMetadata, setSupportedJoinCriteria, setSupportsDirectQueryProcedure, setSupportsFullOuterJoins, setSupportsInnerJoins, setSupportsNativeQueries, setSupportsOrderBy, setSupportsOuterJoins, setSupportsSelectDistinct, setThreadBound, setTransactionSupport, start, supportsAdvancedOlapOperations, supportsAggregatesCountBig, supportsAggregatesCountStar, supportsAggregatesDistinct, supportsAggregatesEnhancedNumeric, supportsArrayAgg, supportsArrayType, supportsBatchedUpdates, supportsCommonTableExpressions, supportsCompareCriteriaOrderedExclusive, supportsConvert, supportsCorrelatedSubqueries, supportsCorrelatedSubqueryLimit, supportsDependentJoins, supportsDirectQueryProcedure, supportsElementaryOlapOperations, supportsExcept, supportsExistsCriteria, supportsFormatLiteral, supportsFullDependentJoins, supportsFullOuterJoins, supportsFunctionsInGroupBy, supportsGeographyType, supportsGroupByMultipleDistinctAggregates, supportsGroupByRollup, supportsInCriteriaSubquery, supportsInlineViews, supportsInnerJoins, supportsInsertWithQueryExpression, supportsIntersect, supportsIsDistinctCriteria, supportsLateralJoin, supportsLateralJoinCondition, supportsLikeRegex, supportsListAgg, supportsMultipleOpenExecutions, supportsNativeQueries, supportsOnlyCorrelatedSubqueries, supportsOnlyFormatLiterals, supportsOnlyLateralJoinProcedure, supportsOnlyRelationshipStyleJoins, supportsOnlySingleTableGroupBy, supportsOnlyTimestampAddLiteral, supportsOrderBy, supportsOrderByNullOrdering, supportsOrderByUnrelated, supportsOrderByWithExtendedGrouping, supportsOuterJoins, supportsPartialFiltering, supportsProcedureParameterExpression, supportsProcedureTable, supportsQuantifiedCompareCriteriaAll, supportsQuantifiedCompareCriteriaSome, supportsRecursiveCommonTableExpressions, supportsScalarSubqueries, supportsScalarSubqueryProjection, supportsSearchedCaseExpressions, supportsSelectDistinct, supportsSelectExpression, supportsSelectExpressionArrayType, supportsSelectWithoutFrom, supportsSelfJoins, supportsSetQueryLimitOffset, supportsSetQueryOrderBy, supportsSimilarTo, supportsStringAgg, supportsSubqueryCommonTableExpressions, supportsSubqueryInOn, supportsUnions, supportsWindowDistinctAggregates, supportsWindowFrameClause, supportsWindowFunctionCumeDist, supportsWindowFunctionNthValue, supportsWindowFunctionNtile, supportsWindowFunctionPercentRank, supportsWindowOrderByWithAggregates, useBindingsForDependentJoin

Methods inherited from class java.lang.Object

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

Field Detail

MAX_SET_SIZE

public static final int MAX_SET_SIZE

See Also:

Constant Field Values

Constructor Detail

InfinispanExecutionFactory

public InfinispanExecutionFactory()

Method Detail

initCapabilities

public void initCapabilities(InfinispanConnection connection)
                      throws TranslatorException

Description copied from class: ExecutionFactory

Will be called by ExecutionFactory.start() with a null connection if a source connection is not ExecutionFactory.isSourceRequiredForCapabilities()

Overrides:

initCapabilities in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

Throws:

TranslatorException

createResultSetExecution

public ResultSetExecution createResultSetExecution(QueryExpression command,
                                                   ExecutionContext executionContext,
                                                   RuntimeMetadata metadata,
                                                   InfinispanConnection connection)
                                            throws TranslatorException

Overrides:

createResultSetExecution in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

Throws:

TranslatorException

createUpdateExecution

public UpdateExecution createUpdateExecution(Command command,
                                             ExecutionContext executionContext,
                                             RuntimeMetadata metadata,
                                             InfinispanConnection connection)
                                      throws TranslatorException

Overrides:

createUpdateExecution in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

Throws:

TranslatorException

createDirectExecution

public ProcedureExecution createDirectExecution(List<Argument> arguments,
                                                Command command,
                                                ExecutionContext executionContext,
                                                RuntimeMetadata metadata,
                                                InfinispanConnection connection)
                                         throws TranslatorException

Overrides:

createDirectExecution in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

Throws:

TranslatorException

getMetadata

public void getMetadata(MetadataFactory metadataFactory,
                        InfinispanConnection conn)
                 throws TranslatorException

Description copied from class: ExecutionFactory

Implement to provide metadata to the metadata for use by the engine. This is the primary method of creating metadata for dynamic VDBs.

Overrides:

getMetadata in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

conn - may be null if the source is not required

Throws:

TranslatorException - to indicate a recoverable error, otherwise a RuntimeException

See Also:

ExecutionFactory.isSourceRequiredForMetadata()

getMetadataProcessor

public MetadataProcessor<InfinispanConnection> getMetadataProcessor()

Description copied from class: ExecutionFactory

Get a MetadataProcessor for the translator to read the metadata. Typically this will return a new instance.

Overrides:

getMetadataProcessor in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

Returns:

isSourceRequiredForCapabilities

public boolean isSourceRequiredForCapabilities()

Description copied from class: ExecutionFactory

If true, the ExecutionFactory.initCapabilities(Object) method will be consulted prior to determining the capabilities

Overrides:

isSourceRequiredForCapabilities in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

Returns:

supportsAliasedTable

public boolean supportsAliasedTable()

Description copied from class: ExecutionFactory

Support indicates connector can accept groups with aliases

Overrides:

supportsAliasedTable in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

supportsInCriteria

public boolean supportsInCriteria()

Description copied from class: ExecutionFactory

Support indicates connector accepts criteria of form (element IN set)

Overrides:

supportsInCriteria in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

supportsIsNullCriteria

public boolean supportsIsNullCriteria()

Description copied from class: ExecutionFactory

Support indicates connector accepts criteria of form (element IS NULL)

Overrides:

supportsIsNullCriteria in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

supportsOrCriteria

public boolean supportsOrCriteria()

Description copied from class: ExecutionFactory

Support indicates connector accepts logical criteria connected by OR

Overrides:

supportsOrCriteria in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

supportsCompareCriteriaEquals

public boolean supportsCompareCriteriaEquals()

Description copied from class: ExecutionFactory

Support indicates connector accepts criteria of form (element = constant)

Overrides:

supportsCompareCriteriaEquals in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

supportsCompareCriteriaOrdered

@TranslatorProperty(display="CompareCriteriaOrdered",
                    description="If true, translator can support comparison criteria with the operator \'=>\' or \'<=\' ",
                    advanced=true)
public boolean supportsCompareCriteriaOrdered()

Description copied from class: ExecutionFactory

Support indicates connector accepts criteria of form (element <=|>= constant)
The query engine will may pushdown queries containing < or > if NOT is also supported.

Overrides:

supportsCompareCriteriaOrdered in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

setSupportsCompareCriteriaOrdered

public boolean setSupportsCompareCriteriaOrdered(boolean supports)

supportsUpsert

@TranslatorProperty(display="Upsert",
                    description="If true, translator can support Upsert command",
                    advanced=true)
public boolean supportsUpsert()

Overrides:

supportsUpsert in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

Returns:

true if the source supports upsert

setSupportsUpsert

public boolean setSupportsUpsert(boolean supports)

supportsLikeCriteria

public boolean supportsLikeCriteria()

Description copied from class: ExecutionFactory

Support indicates connector accepts criteria of form (element LIKE constant)

Overrides:

supportsLikeCriteria in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

supportsLikeCriteriaEscapeCharacter

public boolean supportsLikeCriteriaEscapeCharacter()

Description copied from class: ExecutionFactory

Support indicates connector accepts criteria of form (element LIKE constant ESCAPE char)

Overrides:

supportsLikeCriteriaEscapeCharacter in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

supportsNotCriteria

public boolean supportsNotCriteria()

Description copied from class: ExecutionFactory

Support indicates connector accepts logical criteria NOT

Overrides:

supportsNotCriteria in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

supportsGroupBy

public boolean supportsGroupBy()

Description copied from class: ExecutionFactory

Whether the source supports an explicit GROUP BY clause

Overrides:

supportsGroupBy in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

supportsRowLimit

public boolean supportsRowLimit()

Description copied from class: ExecutionFactory

Gets whether the connector can limit the number of rows returned by a query.

Overrides:

supportsRowLimit in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

supportsRowOffset

public boolean supportsRowOffset()

Description copied from class: ExecutionFactory

Gets whether the connector supports a SQL clause (similar to the LIMIT with an offset) that can return result sets that start in the middle of the resulting rows returned by a query

Overrides:

supportsRowOffset in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

useAnsiJoin

public boolean useAnsiJoin()

Description copied from class: ExecutionFactory

Whether the source prefers to use ANSI style joins.

Overrides:

useAnsiJoin in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

supportsOnlyLiteralComparison

public boolean supportsOnlyLiteralComparison()

Overrides:

supportsOnlyLiteralComparison in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

Returns:

true if only Literal comparisons (equality, ordered, like, etc.) are supported for non-join conditions.

supportsAggregatesSum

public boolean supportsAggregatesSum()

Description copied from class: ExecutionFactory

Support indicates connector can accept the SUM aggregate function

Overrides:

supportsAggregatesSum in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

supportsAggregatesAvg

public boolean supportsAggregatesAvg()

Description copied from class: ExecutionFactory

Support indicates connector can accept the AVG aggregate function

Overrides:

supportsAggregatesAvg in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

supportsAggregatesMin

public boolean supportsAggregatesMin()

Description copied from class: ExecutionFactory

Support indicates connector can accept the MIN aggregate function

Overrides:

supportsAggregatesMin in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

supportsAggregatesMax

public boolean supportsAggregatesMax()

Description copied from class: ExecutionFactory

Support indicates connector can accept the MAX aggregate function

Overrides:

supportsAggregatesMax in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

supportsAggregatesCount

public boolean supportsAggregatesCount()

Description copied from class: ExecutionFactory

Support indicates connector can accept the COUNT aggregate function

Overrides:

supportsAggregatesCount in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

supportsHaving

public boolean supportsHaving()

Description copied from class: ExecutionFactory

Whether the source supports the HAVING clause

Overrides:

supportsHaving in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

supportsBulkUpdate

@TranslatorProperty(display="Supports Bulk Update",
                    description="If true, translator can support Bulk Updates",
                    advanced=true)
public boolean supportsBulkUpdate()

Description copied from class: ExecutionFactory

Whether the source supports updates with multiple value sets

Overrides:

supportsBulkUpdate in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

setSupportsBulkUpdate

public boolean setSupportsBulkUpdate(boolean supports)

getMaxFromGroups

public int getMaxFromGroups()

Description copied from class: ExecutionFactory

The number of groups supported in the from clause. Added for a Sybase limitation.

Overrides:

getMaxFromGroups in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

Returns:

the number of groups supported in the from clause, or -1 if there is no limit

returnsSingleUpdateCount

public boolean returnsSingleUpdateCount()

Description copied from class: ExecutionFactory

True if only a single value is returned for the update count. This overrides the default expectation of an update count array for bulk/batch commands. It is expected that every command is successful.

Overrides:

returnsSingleUpdateCount in class ExecutionFactory<ConnectionFactory,InfinispanConnection>

Returns: