org.teiid.translator.hive

Class ImpalaExecutionFactory

java.lang.Object

org.teiid.translator.ExecutionFactory<DataSource,Connection>

org.teiid.translator.jdbc.JDBCExecutionFactory

org.teiid.translator.hive.BaseHiveExecutionFactory

org.teiid.translator.hive.ImpalaExecutionFactory

@Translator(name="impala",
            description="A translator for Coludera\'s Impala based database on HDFS")
public class ImpalaExecutionFactory
extends BaseHiveExecutionFactory

Nested Class Summary

Nested classes/interfaces inherited from class org.teiid.translator.jdbc.JDBCExecutionFactory

JDBCExecutionFactory.StructRetrieval

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 and Description
static String	IMPALA
static Version	ONE_2_1
static Version	ONE_3_1
static Version	TWO_0
static Version	TWO_2

Fields inherited from class org.teiid.translator.hive.BaseHiveExecutionFactory

convert, useDatabaseMetaData

Fields inherited from class org.teiid.translator.jdbc.JDBCExecutionFactory

DEFAULT_MAX_DEPENDENT_PREDICATES, DEFAULT_MAX_IN_CRITERIA, DEFAULT_TIME_ZONE, dialect

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 and Description
ImpalaExecutionFactory()

Method Summary

Modifier and Type	Method and Description
ExecutionFactory.NullOrder	getDefaultNullOrder() Returns the default null ordering
List<String>	getSupportedFunctions() Get list of all supported function names.
ExecutionFactory.SupportedJoinCriteria	getSupportedJoinCriteria() Get the supported join criteria.
void	initCapabilities(Connection connection) Will be called by ExecutionFactory.start() with a null connection if a source connection is not ExecutionFactory.isSourceRequiredForCapabilities()
boolean	requiresLeftLinearJoin()
boolean	rewriteBooleanFunctions()
void	start() Initialize the connector with supplied configuration
boolean	supportsCommonTableExpressions()
boolean	supportsElementaryOlapOperations()
boolean	supportsGroupByMultipleDistinctAggregates() Whether the source supports grouping with multiple distinct aggregates
boolean	supportsHaving() Whether the source supports the HAVING clause
boolean	supportsIsDistinctCriteria() Support indicates connector accepts criteria of form (exp1 IS DISTINCT exp2)
boolean	supportsLikeRegex()
boolean	supportsOrderByNullOrdering() Returns whether the database supports explicit null ordering.
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	supportsStringAgg()
List<?>	translate(LanguageObject obj, ExecutionContext context) Return a List of translated parts (LanguageObjects and Objects), or null if to rely on the default translation.
List<?>	translateCommand(Command command, ExecutionContext context) Return a List of translated parts (LanguageObjects and Objects), or null if to rely on the default translation.
List<?>	translateLimit(Limit limit, ExecutionContext context) Return a List of translated parts (LanguageObjects and Objects), or null if to rely on the default translation.
String	translateLiteralDate(Date dateValue) Subclasses should override this method to provide a different sql translation of the literal date value.
protected boolean	usesDatabaseVersion()

Methods inherited from class org.teiid.translator.hive.BaseHiveExecutionFactory

addAggregatePushDownFunction, addSourceComment, bindValue, createMetadataProcessor, createProcedureExecution, createUpdateExecution, getLikeRegexString, getMetadataProcessor, getSQLConversionVisitor, hasTimeType, isUseDatabaseMetaData, retrieveValue, retrieveValue, setUseDatabaseMetaData, supportsBatchedUpdates, supportsBulkUpdate, supportsConvert, supportsCorrelatedSubqueries, supportsExcept, supportsExistsCriteria, supportsInCriteriaSubquery, supportsInlineViews, supportsInsertWithQueryExpression, supportsIntersect, supportsLikeCriteriaEscapeCharacter, supportsOrderByUnrelated, supportsQuantifiedCompareCriteriaAll, supportsQuantifiedCompareCriteriaSome, supportsScalarSubqueries, supportsUnions, supportsWindowFunctionNthValue, translateLiteralBoolean, translateLiteralTime, translateLiteralTimestamp, useAnsiJoin, useAsInGroupAlias

Methods inherited from class org.teiid.translator.jdbc.JDBCExecutionFactory

afterInitialConnectionObtained, closeConnection, convertObject, createDirectExecution, createResultSetExecution, createTempTable, executeStoredProcedure, formatDateValue, formatDateValue, getCommentFormat, getConnection, getCreateTemporaryTablePostfix, getCreateTemporaryTableString, getCreateTempTableSQL, getDatabaseCalendar, getDatabaseTimeZone, getDatabaseVersion, getDefaultSupportedFunctions, getDialect, getFunctionModifiers, getHibernateDialectClassName, getLateralKeyword, getMaxPreparedInsertBatchSize, getMetadata, getRemovePushdownCharacters, getSetOperationString, getSourceComment, getStructRetrieval, getTemporaryTableName, getTimestampNanoPrecision, getVersion, intializeConnectionAfterCancel, isEnableDependentJoins, isExtendedAscii, isNonAscii, isNonAscii, isNonAsciiFunction, isSourceRequired, isSourceRequiredForCapabilities, isTrimStrings, loadedTemporaryTable, obtainedConnection, parseName, registerFunctionModifier, registerSpecificTypeOfOutParameter, replaceElementName, retrieveGeographyValue, retrieveGeographyValue, retrieveGeometryValue, retrieveGeometryValue, setCommentFormat, setDatabaseTimeZone, setDatabaseVersion, setDatabaseVersion, setEnableDependentJoins, setFetchSize, setMaxPreparedInsertBatchSize, setRemovePushdownCharacters, setStructRetrieval, setTrimStrings, setUseBindingsForDependentJoin, setUseBindVariables, setUseCommentsInSourceQuery, supportsAggregatesAvg, supportsAggregatesCount, supportsAggregatesCountStar, supportsAggregatesDistinct, supportsAggregatesMax, supportsAggregatesMin, supportsAggregatesSum, supportsAliasedTable, supportsBooleanExpressions, supportsCompareCriteriaEquals, supportsCompareCriteriaOrdered, supportsDependentJoins, supportsFullDependentJoins, supportsGeneratedKeys, supportsGeneratedKeys, supportsGroupBy, supportsInCriteria, supportsIsNullCriteria, supportsLikeCriteria, supportsNotCriteria, supportsOrCriteria, supportsSearchedCaseExpressions, supportsSelectExpression, supportsSelfJoins, supportsSetQueryOrderBy, tempTableRequiresTransaction, translateGeographyLiteral, translateGeographyParameter, translateGeographySelect, translateGeometryLiteral, translateGeometryParameter, translateGeometrySelect, translateLiteralBinaryType, useBindingsForDependentJoin, useBindVariables, useColumnNamesForGeneratedKeys, useCommentsInSourceQuery, useParensForJoins, useParensForSetQueries, usePreparedStatements, useScientificNotation, useSelectLimit, useStreamsForLobs, useUnicodePrefix, useWithRollup

Methods inherited from class org.teiid.translator.ExecutionFactory

addPushDownFunction, areLobsUsableAfterClose, createExecution, getCacheDirective, getCollationLocale, getConnection, getDirectQueryProcedureName, getExcludedCommonTableExpressionName, getInstance, getLanguageFactory, getMaxDependentInPredicates, getMaxFromGroups, getMaxInCriteriaSize, getMaxProjectedColumns, getNativeQueryProcedureName, getPushDownFunctions, getRequiredLikeEscape, getTransactionSupport, getTypeFacility, isCopyLobs, isForkable, isImmutable, 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, supportsAggregatesEnhancedNumeric, supportsArrayAgg, supportsArrayType, supportsCompareCriteriaOrderedExclusive, supportsCorrelatedSubqueryLimit, supportsDirectQueryProcedure, supportsFormatLiteral, supportsFullOuterJoins, supportsFunctionsInGroupBy, supportsGeographyType, supportsGroupByRollup, supportsInnerJoins, supportsLateralJoin, supportsLateralJoinCondition, supportsListAgg, supportsMultipleOpenExecutions, supportsNativeQueries, supportsOnlyCorrelatedSubqueries, supportsOnlyFormatLiterals, supportsOnlyLateralJoinProcedure, supportsOnlyLiteralComparison, supportsOnlySingleTableGroupBy, supportsOnlyTimestampAddLiteral, supportsOrderBy, supportsOrderByWithExtendedGrouping, supportsOuterJoins, supportsPartialFiltering, supportsProcedureTable, supportsRecursiveCommonTableExpressions, supportsScalarSubqueryProjection, supportsSelectDistinct, supportsSelectExpressionArrayType, supportsSelectWithoutFrom, supportsSetQueryLimitOffset, supportsSimilarTo, supportsSubqueryCommonTableExpressions, supportsSubqueryInOn, supportsUpsert, supportsWindowDistinctAggregates, supportsWindowFrameClause, supportsWindowFunctionCumeDist, supportsWindowFunctionNtile, supportsWindowFunctionPercentRank, supportsWindowOrderByWithAggregates

Methods inherited from class java.lang.Object

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

Field Detail

IMPALA

public static String IMPALA

TWO_2

public static final Version TWO_2

TWO_0

public static final Version TWO_0

ONE_2_1

public static final Version ONE_2_1

ONE_3_1

public static final Version ONE_3_1

Constructor Detail

ImpalaExecutionFactory

public ImpalaExecutionFactory()

Method Detail

start

public void start()
           throws TranslatorException

Description copied from class: ExecutionFactory

Initialize the connector with supplied configuration

Overrides:

start in class JDBCExecutionFactory

Throws:

TranslatorException

initCapabilities

public void initCapabilities(Connection 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 JDBCExecutionFactory

Throws:

TranslatorException

getSupportedFunctions

public List<String> getSupportedFunctions()

Description copied from class: ExecutionFactory

Get list of all supported function names. Arithmetic functions have names like "+".

Overrides:

getSupportedFunctions in class JDBCExecutionFactory

See Also:

for a listing of system pushdown functions. Note that not all system functions are listed as some functions will use a common name such as CONCAT vs. the || operator, and other functions will be rewritten and not pushed down, such as SPACE.
Note: User defined functions should be specified fully qualified.

supportsCommonTableExpressions

public boolean supportsCommonTableExpressions()

Overrides:

supportsCommonTableExpressions in class BaseHiveExecutionFactory

Returns:

true if the WITH clause is supported

supportsElementaryOlapOperations

public boolean supportsElementaryOlapOperations()

Overrides:

supportsElementaryOlapOperations in class ExecutionFactory<DataSource,Connection>

Returns:

true if Elementary OLAP operations are supported including window functions and inline window specifications that include simple expressions in partitioning and ordering

supportsHaving

public boolean supportsHaving()

Description copied from class: ExecutionFactory

Whether the source supports the HAVING clause

Overrides:

supportsHaving in class BaseHiveExecutionFactory

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 BaseHiveExecutionFactory

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<DataSource,Connection>

getDefaultNullOrder

public ExecutionFactory.NullOrder getDefaultNullOrder()

Description copied from class: ExecutionFactory

Returns the default null ordering

Overrides:

getDefaultNullOrder in class JDBCExecutionFactory

Returns:

the ExecutionFactory.NullOrder

supportsOrderByNullOrdering

public boolean supportsOrderByNullOrdering()

Description copied from class: ExecutionFactory

Returns whether the database supports explicit null ordering.

Overrides:

supportsOrderByNullOrdering in class ExecutionFactory<DataSource,Connection>

Returns:

true if nulls first/last can be specified

getSupportedJoinCriteria

public ExecutionFactory.SupportedJoinCriteria getSupportedJoinCriteria()

Description copied from class: ExecutionFactory

Get the supported join criteria. A null return value will be treated as ExecutionFactory.SupportedJoinCriteria.ANY

Overrides:

getSupportedJoinCriteria in class ExecutionFactory<DataSource,Connection>

requiresLeftLinearJoin

public boolean requiresLeftLinearJoin()

Overrides:

requiresLeftLinearJoin in class BaseHiveExecutionFactory

supportsLikeRegex

public boolean supportsLikeRegex()

Overrides:

supportsLikeRegex in class BaseHiveExecutionFactory

Returns:

true if the LIKE_REGEX predicate is supported

translateCommand

public List<?> translateCommand(Command command,
                                ExecutionContext context)

Description copied from class: JDBCExecutionFactory

Return a List of translated parts (LanguageObjects and Objects), or null if to rely on the default translation.

Overrides:

translateCommand in class BaseHiveExecutionFactory

Returns:

a list of translated parts

translate

public List<?> translate(LanguageObject obj,
                         ExecutionContext context)

Description copied from class: JDBCExecutionFactory

Return a List of translated parts (LanguageObjects and Objects), or null if to rely on the default translation. Override with care.

Overrides:

translate in class JDBCExecutionFactory

Returns:

list of translated parts

usesDatabaseVersion

protected boolean usesDatabaseVersion()

Overrides:

usesDatabaseVersion in class JDBCExecutionFactory

translateLimit

public List<?> translateLimit(Limit limit,
                              ExecutionContext context)

Description copied from class: JDBCExecutionFactory

Return a List of translated parts (LanguageObjects and Objects), or null if to rely on the default translation.

Overrides:

translateLimit in class BaseHiveExecutionFactory

Returns:

a list of translated parts

translateLiteralDate

public String translateLiteralDate(Date dateValue)

Description copied from class: JDBCExecutionFactory

Subclasses should override this method to provide a different sql translation of the literal date value. By default, a date literal is represented as: {d '2002-12-31'}

Overrides:

translateLiteralDate in class JDBCExecutionFactory

Parameters:

dateValue - Date value, never null

Returns:

Translated string

supportsGroupByMultipleDistinctAggregates

public boolean supportsGroupByMultipleDistinctAggregates()

Description copied from class: ExecutionFactory

Whether the source supports grouping with multiple distinct aggregates

Overrides:

supportsGroupByMultipleDistinctAggregates in class ExecutionFactory<DataSource,Connection>

Returns:

supportsStringAgg

public boolean supportsStringAgg()

Overrides:

supportsStringAgg in class ExecutionFactory<DataSource,Connection>

Returns:

true if string_agg is supported

supportsIsDistinctCriteria

public boolean supportsIsDistinctCriteria()

Description copied from class: ExecutionFactory

Support indicates connector accepts criteria of form (exp1 IS DISTINCT exp2)

Overrides:

supportsIsDistinctCriteria in class ExecutionFactory<DataSource,Connection>

rewriteBooleanFunctions

public boolean rewriteBooleanFunctions()

Overrides:

rewriteBooleanFunctions in class BaseHiveExecutionFactory