@Translator(name="cassandra", description="A translator for Cassandra NoSql database") public class CassandraExecutionFactory extends ExecutionFactory<javax.resource.cci.ConnectionFactory,CassandraConnection>
Modifier and Type | Class and Description |
---|---|
static class |
CassandraExecutionFactory.Event |
ExecutionFactory.Format, ExecutionFactory.NullOrder, ExecutionFactory.SupportedJoinCriteria, ExecutionFactory.TransactionSupport
Modifier and Type | Field and Description |
---|---|
static org.teiid.core.BundleUtil |
UTIL |
DEFAULT_MAX_FROM_GROUPS, DEFAULT_MAX_IN_CRITERIA_SIZE
Constructor and Description |
---|
CassandraExecutionFactory() |
Modifier and Type | Method and Description |
---|---|
ProcedureExecution |
createDirectExecution(List<Argument> arguments,
Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
CassandraConnection connection) |
ProcedureExecution |
createProcedureExecution(Call command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
CassandraConnection connection) |
ResultSetExecution |
createResultSetExecution(QueryExpression command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
CassandraConnection connection) |
UpdateExecution |
createUpdateExecution(Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
CassandraConnection connection) |
MetadataProcessor<CassandraConnection> |
getMetadataProcessor()
Get a MetadataProcessor for the translator to read the metadata.
|
void |
initCapabilities(CassandraConnection 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 the only a single value is returned for the update count.
|
void |
start()
Initialize the connector with supplied configuration
|
boolean |
supportsAggregatesCountStar()
Support indicates connector can accept the COUNT(*) aggregate function
|
boolean |
supportsBatchedUpdates()
Whether the source supports
BatchedUpdates |
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 |
supportsInCriteria()
Support indicates connector accepts criteria of form (element IN set)
|
boolean |
supportsOrderBy()
Support indicates connector accepts ORDER BY clause, including multiple elements
and ascending and descending sorts.
|
boolean |
supportsRowLimit()
Gets whether the connector can limit the number of rows returned by a query.
|
addPushDownFunction, areLobsUsableAfterClose, closeConnection, createExecution, getCacheDirective, getCollationLocale, getConnection, getConnection, getDefaultNullOrder, getDirectQueryProcedureName, getExcludedCommonTableExpressionName, getInstance, getLanguageFactory, getMaxDependentInPredicates, getMaxFromGroups, getMaxInCriteriaSize, getMetadata, 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, supportsAdvancedOlapOperations, supportsAggregatesAvg, supportsAggregatesCount, supportsAggregatesDistinct, supportsAggregatesEnhancedNumeric, supportsAggregatesMax, supportsAggregatesMin, supportsAggregatesSum, supportsAliasedTable, supportsArrayAgg, supportsArrayType, supportsCommonTableExpressions, supportsCompareCriteriaOrderedExclusive, supportsConvert, supportsCorrelatedSubqueries, supportsCorrelatedSubqueryLimit, supportsDependentJoins, supportsDirectQueryProcedure, supportsElementaryOlapOperations, supportsExcept, supportsExistsCriteria, supportsFormatLiteral, supportsFullDependentJoins, supportsFullOuterJoins, supportsFunctionsInGroupBy, supportsGroupBy, supportsGroupByMultipleDistinctAggregates, supportsGroupByRollup, supportsHaving, supportsInCriteriaSubquery, supportsInlineViews, supportsInnerJoins, supportsInsertWithQueryExpression, supportsIntersect, supportsIsNullCriteria, supportsLateralJoin, supportsLateralJoinCondition, supportsLikeCriteria, supportsLikeCriteriaEscapeCharacter, supportsLikeRegex, supportsNativeQueries, supportsNotCriteria, supportsOnlyCorrelatedSubqueries, supportsOnlyFormatLiterals, supportsOnlyLiteralComparison, supportsOnlySingleTableGroupBy, supportsOrCriteria, supportsOrderByNullOrdering, supportsOrderByUnrelated, supportsOrderByWithExtendedGrouping, supportsOuterJoins, supportsPartialFiltering, supportsProcedureTable, supportsQuantifiedCompareCriteriaAll, supportsQuantifiedCompareCriteriaSome, supportsRecursiveCommonTableExpressions, supportsRowOffset, supportsScalarSubqueries, supportsScalarSubqueryProjection, supportsSearchedCaseExpressions, supportsSelectDistinct, supportsSelectExpression, supportsSelectWithoutFrom, supportsSelfJoins, supportsSetQueryOrderBy, supportsSimilarTo, supportsStringAgg, supportsSubqueryCommonTableExpressions, supportsSubqueryInOn, supportsUnions, supportsUpsert, supportsWindowDistinctAggregates, supportsWindowOrderByWithAggregates, useAnsiJoin, useBindingsForDependentJoin
public void start() throws TranslatorException
ExecutionFactory
start
in class ExecutionFactory<javax.resource.cci.ConnectionFactory,CassandraConnection>
TranslatorException
public ResultSetExecution createResultSetExecution(QueryExpression command, ExecutionContext executionContext, RuntimeMetadata metadata, CassandraConnection connection) throws TranslatorException
createResultSetExecution
in class ExecutionFactory<javax.resource.cci.ConnectionFactory,CassandraConnection>
TranslatorException
public UpdateExecution createUpdateExecution(Command command, ExecutionContext executionContext, RuntimeMetadata metadata, CassandraConnection connection) throws TranslatorException
createUpdateExecution
in class ExecutionFactory<javax.resource.cci.ConnectionFactory,CassandraConnection>
TranslatorException
public ProcedureExecution createProcedureExecution(Call command, ExecutionContext executionContext, RuntimeMetadata metadata, CassandraConnection connection) throws TranslatorException
createProcedureExecution
in class ExecutionFactory<javax.resource.cci.ConnectionFactory,CassandraConnection>
TranslatorException
public ProcedureExecution createDirectExecution(List<Argument> arguments, Command command, ExecutionContext executionContext, RuntimeMetadata metadata, CassandraConnection connection) throws TranslatorException
createDirectExecution
in class ExecutionFactory<javax.resource.cci.ConnectionFactory,CassandraConnection>
TranslatorException
public MetadataProcessor<CassandraConnection> getMetadataProcessor()
ExecutionFactory
getMetadataProcessor
in class ExecutionFactory<javax.resource.cci.ConnectionFactory,CassandraConnection>
public boolean supportsOrderBy()
ExecutionFactory
supportsOrderBy
in class ExecutionFactory<javax.resource.cci.ConnectionFactory,CassandraConnection>
public boolean supportsAggregatesCountStar()
ExecutionFactory
supportsAggregatesCountStar
in class ExecutionFactory<javax.resource.cci.ConnectionFactory,CassandraConnection>
public boolean supportsCompareCriteriaEquals()
ExecutionFactory
supportsCompareCriteriaEquals
in class ExecutionFactory<javax.resource.cci.ConnectionFactory,CassandraConnection>
public boolean supportsCompareCriteriaOrdered()
ExecutionFactory
supportsCompareCriteriaOrdered
in class ExecutionFactory<javax.resource.cci.ConnectionFactory,CassandraConnection>
public boolean supportsInCriteria()
ExecutionFactory
supportsInCriteria
in class ExecutionFactory<javax.resource.cci.ConnectionFactory,CassandraConnection>
public boolean supportsRowLimit()
ExecutionFactory
supportsRowLimit
in class ExecutionFactory<javax.resource.cci.ConnectionFactory,CassandraConnection>
public boolean supportsBulkUpdate()
ExecutionFactory
supportsBulkUpdate
in class ExecutionFactory<javax.resource.cci.ConnectionFactory,CassandraConnection>
public boolean supportsBatchedUpdates()
ExecutionFactory
BatchedUpdates
supportsBatchedUpdates
in class ExecutionFactory<javax.resource.cci.ConnectionFactory,CassandraConnection>
public boolean returnsSingleUpdateCount()
ExecutionFactory
returnsSingleUpdateCount
in class ExecutionFactory<javax.resource.cci.ConnectionFactory,CassandraConnection>
public void initCapabilities(CassandraConnection connection) throws TranslatorException
ExecutionFactory
ExecutionFactory.start()
with a null connection if a source connection is not ExecutionFactory.isSourceRequiredForCapabilities()
initCapabilities
in class ExecutionFactory<javax.resource.cci.ConnectionFactory,CassandraConnection>
TranslatorException
public boolean isSourceRequiredForCapabilities()
ExecutionFactory
ExecutionFactory.initCapabilities(Object)
method will be consulted prior
to determining the capabilitiesisSourceRequiredForCapabilities
in class ExecutionFactory<javax.resource.cci.ConnectionFactory,CassandraConnection>
Copyright © 2016 JBoss by Red Hat. All rights reserved.