@Translator(name="infinispan-hotrod", description="The Infinispan Translator Using Protobuf & Hotrod") public class InfinispanExecutionFactory extends ExecutionFactory<ConnectionFactory,InfinispanConnection>
ExecutionFactory.Format, ExecutionFactory.NullOrder, ExecutionFactory.SupportedJoinCriteria, ExecutionFactory.TransactionSupport
Modifier and Type | Field and Description |
---|---|
static int |
MAX_SET_SIZE |
static String |
TEIID_ALIAS_NAMING_CACHE |
DEFAULT_MAX_FROM_GROUPS, DEFAULT_MAX_IN_CRITERIA_SIZE, DEFAULT_MAX_PROJECTED_COLUMNS
Constructor and Description |
---|
InfinispanExecutionFactory() |
Modifier and Type | Method and 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) |
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.
|
boolean |
isSourceRequiredForCapabilities()
If true, the
ExecutionFactory.initCapabilities(Object) method will be consulted prior
to determining the capabilities |
boolean |
setSupportsBulkUpdate(boolean supports) |
boolean |
setSupportsCompareCriteriaOrdered(boolean supports) |
boolean |
setSupportsUpsert(boolean supports) |
void |
start()
Initialize the connector with supplied configuration
|
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.
|
addPushDownFunction, areLobsUsableAfterClose, closeConnection, createExecution, createProcedureExecution, getCacheDirective, getCollationLocale, getConnection, getConnection, getDefaultNullOrder, getDirectQueryProcedureName, getExcludedCommonTableExpressionName, getInstance, getLanguageFactory, getMaxDependentInPredicates, getMaxFromGroups, getMaxInCriteriaSize, getMaxProjectedColumns, getNativeQueryProcedureName, getPushDownFunctions, getRequiredLikeEscape, getSupportedFunctions, getSupportedJoinCriteria, getTransactionSupport, getTypeFacility, initCapabilities, isCopyLobs, isForkable, isImmutable, isSourceRequired, isSourceRequiredForMetadata, isThreadBound, requiresCriteria, returnsSingleUpdateCount, setCollationLocale, setCopyLobs, setDirectQueryProcedureName, setExcludedCommonTableExpressionName, setImmutable, setMaxDependentInPredicates, setMaxInCriteriaSize, setNativeQueryProcedureName, setRequiresCriteria, setSourceRequired, setSourceRequiredForMetadata, setSupportedJoinCriteria, setSupportsDirectQueryProcedure, setSupportsFullOuterJoins, setSupportsInnerJoins, setSupportsNativeQueries, setSupportsOrderBy, setSupportsOuterJoins, setSupportsSelectDistinct, setThreadBound, setTransactionSupport, 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, supportsOnlySingleTableGroupBy, supportsOnlyTimestampAddLiteral, supportsOrderBy, supportsOrderByNullOrdering, supportsOrderByUnrelated, supportsOrderByWithExtendedGrouping, supportsOuterJoins, supportsPartialFiltering, 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
public static final int MAX_SET_SIZE
public static final String TEIID_ALIAS_NAMING_CACHE
public void start() throws TranslatorException
ExecutionFactory
start
in class ExecutionFactory<ConnectionFactory,InfinispanConnection>
TranslatorException
public ResultSetExecution createResultSetExecution(QueryExpression command, ExecutionContext executionContext, RuntimeMetadata metadata, InfinispanConnection connection) throws TranslatorException
createResultSetExecution
in class ExecutionFactory<ConnectionFactory,InfinispanConnection>
TranslatorException
public UpdateExecution createUpdateExecution(Command command, ExecutionContext executionContext, RuntimeMetadata metadata, InfinispanConnection connection) throws TranslatorException
createUpdateExecution
in class ExecutionFactory<ConnectionFactory,InfinispanConnection>
TranslatorException
public ProcedureExecution createDirectExecution(List<Argument> arguments, Command command, ExecutionContext executionContext, RuntimeMetadata metadata, InfinispanConnection connection) throws TranslatorException
createDirectExecution
in class ExecutionFactory<ConnectionFactory,InfinispanConnection>
TranslatorException
public void getMetadata(MetadataFactory metadataFactory, InfinispanConnection conn) throws TranslatorException
ExecutionFactory
getMetadata
in class ExecutionFactory<ConnectionFactory,InfinispanConnection>
conn
- may be null if the source is not requiredTranslatorException
- to indicate a recoverable error, otherwise a RuntimeExceptionExecutionFactory.isSourceRequiredForMetadata()
public MetadataProcessor<InfinispanConnection> getMetadataProcessor()
ExecutionFactory
getMetadataProcessor
in class ExecutionFactory<ConnectionFactory,InfinispanConnection>
public boolean isSourceRequiredForCapabilities()
ExecutionFactory
ExecutionFactory.initCapabilities(Object)
method will be consulted prior
to determining the capabilitiesisSourceRequiredForCapabilities
in class ExecutionFactory<ConnectionFactory,InfinispanConnection>
public boolean supportsAliasedTable()
ExecutionFactory
supportsAliasedTable
in class ExecutionFactory<ConnectionFactory,InfinispanConnection>
public boolean supportsInCriteria()
ExecutionFactory
supportsInCriteria
in class ExecutionFactory<ConnectionFactory,InfinispanConnection>
public boolean supportsIsNullCriteria()
ExecutionFactory
supportsIsNullCriteria
in class ExecutionFactory<ConnectionFactory,InfinispanConnection>
public boolean supportsOrCriteria()
ExecutionFactory
supportsOrCriteria
in class ExecutionFactory<ConnectionFactory,InfinispanConnection>
public boolean supportsCompareCriteriaEquals()
ExecutionFactory
supportsCompareCriteriaEquals
in class ExecutionFactory<ConnectionFactory,InfinispanConnection>
@TranslatorProperty(display="CompareCriteriaOrdered", description="If true, translator can support comparison criteria with the operator \'=>\' or \'<=\' ", advanced=true) public boolean supportsCompareCriteriaOrdered()
ExecutionFactory
supportsCompareCriteriaOrdered
in class ExecutionFactory<ConnectionFactory,InfinispanConnection>
public boolean setSupportsCompareCriteriaOrdered(boolean supports)
@TranslatorProperty(display="Upsert", description="If true, translator can support Upsert command", advanced=true) public boolean supportsUpsert()
supportsUpsert
in class ExecutionFactory<ConnectionFactory,InfinispanConnection>
public boolean setSupportsUpsert(boolean supports)
public boolean supportsLikeCriteria()
ExecutionFactory
supportsLikeCriteria
in class ExecutionFactory<ConnectionFactory,InfinispanConnection>
public boolean supportsLikeCriteriaEscapeCharacter()
ExecutionFactory
supportsLikeCriteriaEscapeCharacter
in class ExecutionFactory<ConnectionFactory,InfinispanConnection>
public boolean supportsNotCriteria()
ExecutionFactory
supportsNotCriteria
in class ExecutionFactory<ConnectionFactory,InfinispanConnection>
public boolean supportsGroupBy()
ExecutionFactory
supportsGroupBy
in class ExecutionFactory<ConnectionFactory,InfinispanConnection>
public boolean supportsRowLimit()
ExecutionFactory
supportsRowLimit
in class ExecutionFactory<ConnectionFactory,InfinispanConnection>
public boolean supportsRowOffset()
ExecutionFactory
supportsRowOffset
in class ExecutionFactory<ConnectionFactory,InfinispanConnection>
public boolean useAnsiJoin()
ExecutionFactory
useAnsiJoin
in class ExecutionFactory<ConnectionFactory,InfinispanConnection>
public boolean supportsOnlyLiteralComparison()
supportsOnlyLiteralComparison
in class ExecutionFactory<ConnectionFactory,InfinispanConnection>
public boolean supportsAggregatesSum()
ExecutionFactory
supportsAggregatesSum
in class ExecutionFactory<ConnectionFactory,InfinispanConnection>
public boolean supportsAggregatesAvg()
ExecutionFactory
supportsAggregatesAvg
in class ExecutionFactory<ConnectionFactory,InfinispanConnection>
public boolean supportsAggregatesMin()
ExecutionFactory
supportsAggregatesMin
in class ExecutionFactory<ConnectionFactory,InfinispanConnection>
public boolean supportsAggregatesMax()
ExecutionFactory
supportsAggregatesMax
in class ExecutionFactory<ConnectionFactory,InfinispanConnection>
public boolean supportsAggregatesCount()
ExecutionFactory
supportsAggregatesCount
in class ExecutionFactory<ConnectionFactory,InfinispanConnection>
public boolean supportsHaving()
ExecutionFactory
supportsHaving
in class ExecutionFactory<ConnectionFactory,InfinispanConnection>
@TranslatorProperty(display="Supports Bulk Update", description="If true, translator can support Bulk Updates", advanced=true) public boolean supportsBulkUpdate()
ExecutionFactory
supportsBulkUpdate
in class ExecutionFactory<ConnectionFactory,InfinispanConnection>
public boolean setSupportsBulkUpdate(boolean supports)
Copyright © 2019. All rights reserved.