Package org.teiid.translator.amazon.s3
Class S3ExecutionFactory
- java.lang.Object
-
- org.teiid.translator.ExecutionFactory<ConnectionFactory,WSConnection>
-
- org.teiid.translator.amazon.s3.S3ExecutionFactory
-
@Translator(name="amazon-s3", description="Amazon S3 Translator, reads contents of files or writes to them") public class S3ExecutionFactory extends ExecutionFactory<ConnectionFactory,WSConnection>
-
-
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 String
DELETEFILE
static String
GETFILE
static String
GETTEXTFILE
static String
LISTBUCKET
static String
LISTBUCKETV1
static String
SAVEFILE
static String
US_EAST_1
static BundleUtil
UTIL
-
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 S3ExecutionFactory()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
areLobsUsableAfterClose()
Indicates if LOBs are usable after the execution is closed.ProcedureExecution
createProcedureExecution(Call command, ExecutionContext executionContext, RuntimeMetadata metadata, WSConnection conn)
String
getAccesskey()
String
getBucket()
String
getEncoding()
String
getEncryption()
String
getEncryptionkey()
void
getMetadata(MetadataFactory metadataFactory, WSConnection connection)
Implement to provide metadata to the metadata for use by the engine.String
getRegion()
String
getSecretkey()
void
setAccesskey(String value)
void
setBucket(String value)
void
setEncoding(String encoding)
void
setEncryption(String value)
void
setEncryptionkey(String value)
void
setRegion(String value)
void
setSecretkey(String value)
-
Methods inherited from class org.teiid.translator.ExecutionFactory
addPushDownFunction, closeConnection, createDirectExecution, createExecution, createResultSetExecution, createUpdateExecution, getCacheDirective, getCollationLocale, getConnection, getConnection, getDefaultNullOrder, getDirectQueryProcedureName, getExcludedCommonTableExpressionName, getInstance, getLanguageFactory, getMaxDependentInPredicates, getMaxFromGroups, getMaxInCriteriaSize, getMaxProjectedColumns, getMetadataProcessor, getNativeQueryProcedureName, getPushDownFunctions, getRequiredLikeEscape, getSupportedFunctions, getSupportedJoinCriteria, getTransactionSupport, getTypeFacility, initCapabilities, isCopyLobs, isForkable, isImmutable, isSourceRequired, isSourceRequiredForCapabilities, 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, start, supportsAdvancedOlapOperations, supportsAggregatesAvg, supportsAggregatesCount, supportsAggregatesCountBig, supportsAggregatesCountStar, supportsAggregatesDistinct, supportsAggregatesEnhancedNumeric, supportsAggregatesMax, supportsAggregatesMin, supportsAggregatesSum, supportsAliasedTable, supportsArrayAgg, supportsArrayType, supportsBatchedUpdates, supportsBulkUpdate, supportsCommonTableExpressions, supportsCompareCriteriaEquals, supportsCompareCriteriaOrdered, supportsCompareCriteriaOrderedExclusive, supportsConvert, supportsCorrelatedSubqueries, supportsCorrelatedSubqueryLimit, supportsDependentJoins, supportsDirectQueryProcedure, supportsElementaryOlapOperations, supportsExcept, supportsExistsCriteria, supportsFormatLiteral, supportsFullDependentJoins, supportsFullOuterJoins, supportsFunctionsInGroupBy, supportsGeographyType, supportsGroupBy, supportsGroupByMultipleDistinctAggregates, supportsGroupByRollup, supportsHaving, supportsInCriteria, supportsInCriteriaSubquery, supportsInlineViews, supportsInnerJoins, supportsInsertWithQueryExpression, supportsIntersect, supportsIsDistinctCriteria, supportsIsNullCriteria, supportsLateralJoin, supportsLateralJoinCondition, supportsLikeCriteria, supportsLikeCriteriaEscapeCharacter, supportsLikeRegex, supportsListAgg, supportsMultipleOpenExecutions, supportsNativeQueries, supportsNotCriteria, supportsOnlyCorrelatedSubqueries, supportsOnlyFormatLiterals, supportsOnlyLateralJoinProcedure, supportsOnlyLiteralComparison, supportsOnlyRelationshipStyleJoins, supportsOnlySingleTableGroupBy, supportsOnlyTimestampAddLiteral, supportsOrCriteria, supportsOrderBy, supportsOrderByNullOrdering, supportsOrderByUnrelated, supportsOrderByWithExtendedGrouping, supportsOuterJoins, supportsPartialFiltering, supportsProcedureParameterExpression, supportsProcedureTable, supportsQuantifiedCompareCriteriaAll, supportsQuantifiedCompareCriteriaSome, supportsRecursiveCommonTableExpressions, supportsRowLimit, supportsRowOffset, supportsScalarSubqueries, supportsScalarSubqueryProjection, supportsSearchedCaseExpressions, supportsSelectDistinct, supportsSelectExpression, supportsSelectExpressionArrayType, supportsSelectWithoutFrom, supportsSelfJoins, supportsSetQueryLimitOffset, supportsSetQueryOrderBy, supportsSimilarTo, supportsStringAgg, supportsSubqueryCommonTableExpressions, supportsSubqueryInOn, supportsUnions, supportsUpsert, supportsWindowDistinctAggregates, supportsWindowFrameClause, supportsWindowFunctionCumeDist, supportsWindowFunctionNthValue, supportsWindowFunctionNtile, supportsWindowFunctionPercentRank, supportsWindowOrderByWithAggregates, useAnsiJoin, useBindingsForDependentJoin
-
-
-
-
Field Detail
-
US_EAST_1
public static final String US_EAST_1
- See Also:
- Constant Field Values
-
UTIL
public static BundleUtil UTIL
-
GETTEXTFILE
public static final String GETTEXTFILE
- See Also:
- Constant Field Values
-
GETFILE
public static final String GETFILE
- See Also:
- Constant Field Values
-
SAVEFILE
public static final String SAVEFILE
- See Also:
- Constant Field Values
-
DELETEFILE
public static final String DELETEFILE
- See Also:
- Constant Field Values
-
LISTBUCKET
public static final String LISTBUCKET
- See Also:
- Constant Field Values
-
LISTBUCKETV1
public static final String LISTBUCKETV1
- See Also:
- Constant Field Values
-
-
Method Detail
-
getEncoding
@TranslatorProperty(display="File Encoding", advanced=true) public String getEncoding()
-
setEncoding
public void setEncoding(String encoding)
-
getAccesskey
@TranslatorProperty(display="Amazon Access Key", advanced=true) public String getAccesskey()
-
setAccesskey
public void setAccesskey(String value)
-
getSecretkey
@TranslatorProperty(display="Amazon Secret Key", advanced=true) public String getSecretkey()
-
setSecretkey
public void setSecretkey(String value)
-
getRegion
@TranslatorProperty(display="Amazon Region", advanced=true) public String getRegion()
-
setRegion
public void setRegion(String value)
-
getBucket
@TranslatorProperty(display="Amazon Bucket", advanced=true) public String getBucket()
-
setBucket
public void setBucket(String value)
-
getEncryption
@TranslatorProperty(display="Server Side Customer Encryption Algorithm Used", advanced=true) public String getEncryption()
-
setEncryption
public void setEncryption(String value)
-
getEncryptionkey
@TranslatorProperty(display="Server Side Customer Encryption Key to be used to decrypt the object", advanced=true) public String getEncryptionkey()
-
setEncryptionkey
public void setEncryptionkey(String value)
-
createProcedureExecution
public ProcedureExecution createProcedureExecution(Call command, ExecutionContext executionContext, RuntimeMetadata metadata, WSConnection conn) throws TranslatorException
- Overrides:
createProcedureExecution
in classExecutionFactory<ConnectionFactory,WSConnection>
- Throws:
TranslatorException
-
getMetadata
public void getMetadata(MetadataFactory metadataFactory, WSConnection connection) 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 classExecutionFactory<ConnectionFactory,WSConnection>
connection
- may be null if the source is not required- Throws:
TranslatorException
- to indicate a recoverable error, otherwise a RuntimeException- See Also:
ExecutionFactory.isSourceRequiredForMetadata()
-
areLobsUsableAfterClose
public boolean areLobsUsableAfterClose()
Description copied from class:ExecutionFactory
Indicates if LOBs are usable after the execution is closed. This check is not performed for values that are alreadyClobType
orBlobType
- Overrides:
areLobsUsableAfterClose
in classExecutionFactory<ConnectionFactory,WSConnection>
- Returns:
- true if LOBs can be used after close
-
-