| Modifier and Type | Method and Description |
|---|---|
com.couchbase.client.java.query.N1qlQueryResult |
CouchbaseConnection.execute(String statement)
Executes the given N1QL statement, which returns a single
N1qlQueryResult
object. |
| Modifier and Type | Method and Description |
|---|---|
void |
ConnectorWork.execute() |
void |
ConnectorWorkItem.execute() |
byte[] |
RuntimeMetadataImpl.getBinaryVDBResource(String resourcePath) |
CacheDirective |
ConnectorWork.getCacheDirective() |
CacheDirective |
ConnectorWorkItem.getCacheDirective() |
SourceCapabilities |
ConnectorManager.getCapabilities() |
String |
RuntimeMetadataImpl.getCharacterVDBResource(String resourcePath) |
Column |
RuntimeMetadataImpl.getColumn(String fullName) |
Column |
RuntimeMetadataImpl.getColumn(String schema,
String table,
String name) |
Object |
ConnectorManager.getConnectionFactory()
Get the ConnectionFactory object required by this manager
|
Procedure |
RuntimeMetadataImpl.getProcedure(String fullName) |
Procedure |
RuntimeMetadataImpl.getProcedure(String schema,
String name) |
Table |
RuntimeMetadataImpl.getTable(String fullName) |
Table |
RuntimeMetadataImpl.getTable(String schema,
String name) |
String[] |
RuntimeMetadataImpl.getVDBResourcePaths() |
protected AtomicResultsMessage |
ConnectorWorkItem.handleBatch() |
AtomicResultsMessage |
ConnectorWork.more() |
AtomicResultsMessage |
ConnectorWorkItem.more() |
ConnectorWork |
ConnectorManager.registerRequest(AtomicRequestMessage message) |
| Modifier and Type | Method and Description |
|---|---|
void |
VirtualFileConnection.add(InputStream in,
String path)
Add a file
|
VirtualFile[] |
VirtualFileConnection.getFiles(String namePattern)
Return a list of files by a given file pattern
|
static VirtualFile[] |
VirtualFileConnection.Util.getFiles(String location,
VirtualFileConnection fc,
boolean exceptionIfFileNotFound)
Gets the file or files, if the path is a directory, at the given path.
|
boolean |
VirtualFileConnection.remove(String path)
Remove a file
|
| Modifier and Type | Method and Description |
|---|---|
<K,V> org.infinispan.commons.api.BasicCache<K,V> |
InfinispanConnection.getCache() |
<K,V> org.infinispan.commons.api.BasicCache<K,V> |
InfinispanConnection.getCache(String cacheName,
boolean createIfNotExists) |
boolean |
DocumentFilter.matches(Map<String,Object> parentProperties,
Map<String,Object> childProperties)
Does the the document with given properties matches filter?
|
void |
InfinispanConnection.registerMarshaller(org.infinispan.protostream.BaseMarshaller<InfinispanDocument> marshller) |
void |
InfinispanConnection.registerProtobufFile(ProtobufResource protobuf) |
void |
InfinispanConnection.unRegisterMarshaller(org.infinispan.protostream.BaseMarshaller<InfinispanDocument> marshller) |
| Modifier and Type | Method and Description |
|---|---|
byte[] |
RuntimeMetadata.getBinaryVDBResource(String resourcePath)
Gets the contents of a VDB resource in binary form.
|
String |
RuntimeMetadata.getCharacterVDBResource(String resourcePath)
Gets the contents of a VDB resource as a String.
|
Column |
RuntimeMetadata.getColumn(String fullName)
Look up an object by identifier
|
Column |
RuntimeMetadata.getColumn(String schema,
String table,
String name)
Look up an object by identifier
|
Procedure |
RuntimeMetadata.getProcedure(String fullName)
Look up an object by identifier
|
Procedure |
RuntimeMetadata.getProcedure(String schema,
String name)
Look up an object by identifier
|
Table |
RuntimeMetadata.getTable(String fullName)
Look up an object by identifier
|
Table |
RuntimeMetadata.getTable(String schema,
String name)
Look up an object by identifier
|
String[] |
RuntimeMetadata.getVDBResourcePaths()
Gets the resource paths of all the resources in the VDB.
|
void |
DefaultMetadataRepository.loadMetadata(MetadataFactory factory,
ExecutionFactory<F,C> executionFactory,
F connectionFactory)
Deprecated.
Calls the specific getter methods of this class to populate metadata on schema being loaded.
|
default void |
MetadataRepository.loadMetadata(MetadataFactory factory,
ExecutionFactory<F,C> executionFactory,
F connectionFactory)
Loads the schema information for the vdb for the given schemaName.
|
default void |
MetadataRepository.loadMetadata(MetadataFactory factory,
ExecutionFactory<F,C> executionFactory,
F connectionFactory,
String text)
Loads the schema information for the vdb for the given schemaName.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IndexMetadataRepository.loadMetadata(MetadataFactory factory,
ExecutionFactory executionFactory,
Object connectionFactory) |
| Modifier and Type | Method and Description |
|---|---|
void |
ChainingMetadataRepository.loadMetadata(MetadataFactory factory,
ExecutionFactory<Object,Object> executionFactory,
Object connectionFactory) |
void |
MaterializationMetadataRepository.loadMetadata(MetadataFactory factory,
ExecutionFactory executionFactory,
Object connectionFactory) |
void |
NativeMetadataRepository.loadMetadata(MetadataFactory factory,
ExecutionFactory executionFactory,
Object connectionFactory) |
void |
DirectQueryMetadataRepository.loadMetadata(MetadataFactory factory,
ExecutionFactory executionFactory,
Object connectionFactory) |
void |
DDLMetadataRepository.loadMetadata(MetadataFactory factory,
ExecutionFactory executionFactory,
Object connectionFactory,
String text) |
void |
UDFMetadataRepository.loadMetadata(MetadataFactory factory,
ExecutionFactory executionFactory,
Object connectionFactory,
String text) |
void |
DDLFileMetadataRepository.loadMetadata(MetadataFactory factory,
ExecutionFactory executionFactory,
Object connectionFactory,
String text) |
| Modifier and Type | Method and Description |
|---|---|
com.datastax.driver.core.KeyspaceMetadata |
CassandraConnectionImpl.keyspaceInfo() |
| Modifier and Type | Method and Description |
|---|---|
com.couchbase.client.java.query.N1qlQueryResult |
CouchbaseConnectionImpl.execute(String statement) |
| Modifier and Type | Method and Description |
|---|---|
void |
FileConnectionImpl.add(InputStream in,
String path) |
VirtualFile[] |
FileConnectionImpl.getFiles(String location) |
boolean |
FileConnectionImpl.remove(String path) |
| Modifier and Type | Method and Description |
|---|---|
void |
FtpFileConnectionImpl.add(InputStream in,
String path) |
| Modifier and Type | Method and Description |
|---|---|
org.infinispan.commons.api.BasicCache |
InfinispanConnectionImpl.getCache() |
<K,V> org.infinispan.commons.api.BasicCache<K,V> |
InfinispanConnectionImpl.getCache(String cacheName,
boolean createIfNotExists) |
void |
InfinispanConnectionImpl.registerMarshaller(org.infinispan.protostream.BaseMarshaller<InfinispanDocument> marshaller) |
void |
InfinispanConnectionImpl.registerProtobufFile(ProtobufResource protobuf) |
void |
InfinispanConnectionImpl.unRegisterMarshaller(org.infinispan.protostream.BaseMarshaller<InfinispanDocument> marshaller) |
| Modifier and Type | Method and Description |
|---|---|
String |
SalesforceConnectionImpl.addBatch(List<com.sforce.async.SObject> payload,
com.sforce.async.JobInfo job) |
SalesforceConnection.BatchResultInfo |
SalesforceConnectionImpl.addBatch(String query,
com.sforce.async.JobInfo job) |
void |
SalesforceConnectionImpl.cancelBulkJob(com.sforce.async.JobInfo job) |
com.sforce.async.JobInfo |
SalesforceConnectionImpl.closeJob(String jobId) |
int |
SalesforceConnectionImpl.create(DataPayload data) |
com.sforce.async.JobInfo |
SalesforceConnectionImpl.createBulkJob(String objectName,
com.sforce.async.OperationEnum operation,
boolean usePkChunking) |
int |
SalesforceConnectionImpl.delete(String[] ids) |
SalesforceConnection.BulkBatchResult |
SalesforceConnectionImpl.getBatchQueryResults(String jobId,
SalesforceConnection.BatchResultInfo info) |
com.sforce.async.BatchResult[] |
SalesforceConnectionImpl.getBulkResults(com.sforce.async.JobInfo job,
List<String> ids) |
Long |
SalesforceConnectionImpl.getCardinality(String sobject) |
DeletedResult |
SalesforceConnectionImpl.getDeleted(String objectName,
Calendar startCalendar,
Calendar endCalendar) |
com.sforce.soap.partner.DescribeSObjectResult[] |
SalesforceConnectionImpl.getObjectMetaData(String... objectName) |
com.sforce.soap.partner.DescribeGlobalResult |
SalesforceConnectionImpl.getObjects() |
UpdatedResult |
SalesforceConnectionImpl.getUpdated(String objectType,
Calendar startDate,
Calendar endDate) |
com.sforce.soap.partner.QueryResult |
SalesforceConnectionImpl.query(String queryString,
int batchSize,
boolean queryAll) |
com.sforce.soap.partner.QueryResult |
SalesforceConnectionImpl.queryMore(String queryLocator,
int batchSize) |
com.sforce.soap.partner.sobject.SObject[] |
SalesforceConnectionImpl.retrieve(String fieldList,
String sObjectType,
List<String> ids) |
int |
SalesforceConnectionImpl.update(List<DataPayload> updateDataList) |
int |
SalesforceConnectionImpl.upsert(DataPayload data) |
| Modifier and Type | Method and Description |
|---|---|
void |
SimpleDBConnectionImpl.createDomain(String domainName) |
void |
SimpleDBConnectionImpl.deleteDomain(String domainName) |
Set<SimpleDBConnection.SimpleDBAttribute> |
SimpleDBConnectionImpl.getAttributeNames(String domainName) |
List<String> |
SimpleDBConnectionImpl.getDomains() |
int |
SimpleDBConnectionImpl.performDelete(String domainName,
String selectExpression)
Removes item with given ItemName from domain
|
int |
SimpleDBConnectionImpl.performInsert(String domainName,
List<Column> columns,
Iterator<? extends List<?>> valueList)
Inserts item into given domain.
|
com.amazonaws.services.simpledb.model.SelectResult |
SimpleDBConnectionImpl.performSelect(String selectExpression,
String nextToken)
Performs select expression.
|
int |
SimpleDBConnectionImpl.performUpdate(String domainName,
Map<String,Object> updateAttributes,
String selectExpression)
Performs update on given domain and items
|
| Modifier and Type | Method and Description |
|---|---|
org.apache.solr.client.solrj.response.LukeResponse |
SolrConnectionImpl.metadata(org.apache.solr.client.solrj.request.LukeRequest request) |
org.apache.solr.client.solrj.response.QueryResponse |
SolrConnectionImpl.query(org.apache.solr.client.solrj.SolrQuery params) |
org.apache.solr.client.solrj.response.UpdateResponse |
SolrConnectionImpl.update(org.apache.solr.client.solrj.request.UpdateRequest request) |
| Modifier and Type | Method and Description |
|---|---|
void |
EmbeddedServer.addTranslator(Class<? extends ExecutionFactory> clazz)
Adds a definition of the
ExecutionFactory using the default name either from the Translator annotation or the class name. |
void |
EmbeddedServer.addTranslator(String name,
String type,
Map<String,String> properties)
Add an override translator
|
void |
EmbeddedServer.deployVDB(InputStream is)
Deploy a vdb.xml file.
|
void |
EmbeddedServer.deployVDB(InputStream is,
boolean ddl)
Deploy a vdb.xml file.
|
void |
EmbeddedServer.deployVDB(String name,
ModelMetaData... models)
Deploy the given set of models as vdb name.1
|
protected void |
EmbeddedServer.deployVDB(VDBMetaData vdb,
VDBResources resources) |
void |
EmbeddedServer.deployVDBZip(URL url)
Deploy a vdb zip file.
|
T |
EmbeddedServer.ConnectionFactoryProvider.getConnectionFactory() |
T |
EmbeddedServer.SimpleConnectionFactoryProvider.getConnectionFactory() |
void |
MultiSourceMetadataRepository.loadMetadata(MetadataFactory factory,
ExecutionFactory<Object,Object> executionFactory,
Object connectionFactory) |
protected void |
AbstractVDBDeployer.loadMetadata(VDBMetaData vdb,
ConnectorManagerRepository cmr,
MetadataStore store,
VDBResources vdbResources) |
protected void |
EmbeddedServer.runMetadataJob(VDBMetaData vdb,
ModelMetaData model,
Runnable job) |
protected abstract void |
AbstractVDBDeployer.runMetadataJob(VDBMetaData vdb,
ModelMetaData model,
Runnable job) |
| Modifier and Type | Method and Description |
|---|---|
static String |
ConvertVDB.convert(File f) |
| Modifier and Type | Class and Description |
|---|---|
class |
TranslatorBatchException
An exception the connector writer can return in case of an
error while executing
BatchedUpdates |
| Modifier and Type | Method and Description |
|---|---|
void |
Execution.cancel()
Cancels the execution abnormally.
|
ProcedureExecution |
BaseDelegatingExecutionFactory.createDirectExecution(List<Argument> arguments,
Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
C connection) |
ProcedureExecution |
ExecutionFactory.createDirectExecution(List<Argument> arguments,
Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
C connection) |
Execution |
ExecutionFactory.createExecution(Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
C connection)
Create an execution object for the specified command
|
ProcedureExecution |
BaseDelegatingExecutionFactory.createProcedureExecution(Call command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
C connection) |
ProcedureExecution |
ExecutionFactory.createProcedureExecution(Call command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
C connection) |
ResultSetExecution |
BaseDelegatingExecutionFactory.createResultSetExecution(QueryExpression command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
C connection) |
ResultSetExecution |
ExecutionFactory.createResultSetExecution(QueryExpression command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
C connection) |
UpdateExecution |
BaseDelegatingExecutionFactory.createUpdateExecution(Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
C connection) |
UpdateExecution |
ExecutionFactory.createUpdateExecution(Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
C connection) |
void |
Execution.execute()
Execute the associated command.
|
CacheDirective |
BaseDelegatingExecutionFactory.getCacheDirective(Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata) |
CacheDirective |
ExecutionFactory.getCacheDirective(Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata)
Get the
CacheDirective to control command caching. |
C |
ExecutionFactory.getConnection(F factory)
Deprecated.
|
C |
BaseDelegatingExecutionFactory.getConnection(F factory,
ExecutionContext executionContext) |
C |
ExecutionFactory.getConnection(F factory,
ExecutionContext executionContext)
Return a connection object from the given connection factory.
|
static <T> T |
ExecutionFactory.getInstance(Class<T> expectedType,
String className,
Collection<?> ctorObjs,
Class<? extends T> defaultClass) |
void |
BaseDelegatingExecutionFactory.getMetadata(MetadataFactory metadataFactory,
C conn) |
void |
ExecutionFactory.getMetadata(MetadataFactory metadataFactory,
C conn)
Implement to provide metadata to the metadata for use by the engine.
|
List<?> |
ProcedureExecution.getOutputParameterValues()
Get the output parameter values.
|
int[] |
UpdateExecution.getUpdateCounts()
Returns the update counts for the execution.
|
void |
BaseDelegatingExecutionFactory.initCapabilities(C connection) |
void |
ExecutionFactory.initCapabilities(C connection)
Will be called by
ExecutionFactory.start() with a null connection if a source connection is not ExecutionFactory.isSourceRequiredForCapabilities() |
List<?> |
ResultSetExecution.next()
Retrieves the next row of the resultset.
|
void |
MetadataProcessor.process(MetadataFactory metadataFactory,
C connection) |
void |
BaseDelegatingExecutionFactory.start() |
void |
ExecutionFactory.start()
Initialize the connector with supplied configuration
|
| Modifier and Type | Field and Description |
|---|---|
protected ArrayList<TranslatorException> |
AccumuloQueryVisitor.exceptions |
| Modifier and Type | Method and Description |
|---|---|
void |
AccumuloQueryExecution.cancel() |
void |
AccumuloUpdateExecution.cancel() |
ResultSetExecution |
AccumuloExecutionFactory.createResultSetExecution(QueryExpression command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
AccumuloConnection connection) |
UpdateExecution |
AccumuloExecutionFactory.createUpdateExecution(Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
AccumuloConnection connection) |
void |
AccumuloQueryExecution.execute() |
void |
AccumuloUpdateExecution.execute() |
int[] |
AccumuloUpdateExecution.getUpdateCounts() |
List<?> |
AccumuloQueryExecution.next() |
void |
AccumuloExecutionFactory.start() |
| Constructor and Description |
|---|
AccumuloQueryExecution(AccumuloExecutionFactory aef,
Select command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
AccumuloConnection connection) |
| Modifier and Type | Method and Description |
|---|---|
void |
S3ProcedureExecution.cancel() |
ProcedureExecution |
S3ExecutionFactory.createProcedureExecution(Call command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
WSConnection conn) |
void |
S3ProcedureExecution.execute() |
void |
S3ExecutionFactory.getMetadata(MetadataFactory metadataFactory,
WSConnection connection) |
List<?> |
S3ProcedureExecution.getOutputParameterValues() |
protected BinaryWSProcedureExecution |
S3ProcedureExecution.invokeHTTP(String method,
String uri,
Object payload,
Map<String,String> headers) |
List<?> |
S3ProcedureExecution.next() |
| Modifier and Type | Method and Description |
|---|---|
void |
CassandraQueryExecution.cancel() |
void |
CassandraUpdateExecution.cancel() |
ProcedureExecution |
CassandraExecutionFactory.createDirectExecution(List<Argument> arguments,
Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
CassandraConnection connection) |
ProcedureExecution |
CassandraExecutionFactory.createProcedureExecution(Call command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
CassandraConnection connection) |
ResultSetExecution |
CassandraExecutionFactory.createResultSetExecution(QueryExpression command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
CassandraConnection connection) |
UpdateExecution |
CassandraExecutionFactory.createUpdateExecution(Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
CassandraConnection connection) |
void |
CassandraDirectQueryExecution.execute() |
void |
CassandraQueryExecution.execute() |
void |
CassandraUpdateExecution.execute() |
List<?> |
CassandraDirectQueryExecution.getOutputParameterValues() |
int[] |
CassandraUpdateExecution.getUpdateCounts() |
void |
CassandraExecutionFactory.initCapabilities(CassandraConnection connection) |
com.datastax.driver.core.KeyspaceMetadata |
CassandraConnection.keyspaceInfo()
Returns metadata about Cassandra keyspace (column families, columns metadata etc.)
|
List<?> |
CassandraQueryExecution.next() |
void |
CassandraMetadataProcessor.process(MetadataFactory factory,
CassandraConnection connection)
Creates metadata from all column families in current keyspace.
|
void |
CassandraExecutionFactory.start() |
| Modifier and Type | Method and Description |
|---|---|
void |
CouchbaseUpdateExecution.cancel() |
void |
CouchbaseQueryExecution.cancel() |
void |
CouchbaseDirectQueryExecution.cancel() |
void |
CouchbaseProcedureExecution.cancel() |
ProcedureExecution |
CouchbaseExecutionFactory.createDirectExecution(List<Argument> arguments,
Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
CouchbaseConnection connection) |
ProcedureExecution |
CouchbaseExecutionFactory.createProcedureExecution(Call command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
CouchbaseConnection connection) |
ResultSetExecution |
CouchbaseExecutionFactory.createResultSetExecution(QueryExpression command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
CouchbaseConnection connection) |
UpdateExecution |
CouchbaseExecutionFactory.createUpdateExecution(Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
CouchbaseConnection connection) |
void |
CouchbaseUpdateExecution.execute() |
void |
CouchbaseQueryExecution.execute() |
void |
CouchbaseDirectQueryExecution.execute() |
void |
CouchbaseProcedureExecution.execute() |
List<?> |
CouchbaseDirectQueryExecution.getOutputParameterValues() |
List<?> |
CouchbaseProcedureExecution.getOutputParameterValues() |
int[] |
CouchbaseUpdateExecution.getUpdateCounts() |
List<?> |
CouchbaseQueryExecution.next() |
List<?> |
CouchbaseDirectQueryExecution.next() |
List<?> |
CouchbaseProcedureExecution.next() |
void |
CouchbaseMetadataProcessor.process(MetadataFactory mf,
CouchbaseConnection conn) |
Object |
CouchbaseExecutionFactory.retrieveValue(Class<?> columnType,
Object value) |
void |
CouchbaseExecutionFactory.start() |
| Modifier and Type | Field and Description |
|---|---|
protected ArrayList<TranslatorException> |
ExcelQueryVisitor.exceptions |
| Modifier and Type | Method and Description |
|---|---|
ArrayList<TranslatorException> |
ExcelQueryVisitor.getExceptions() |
| Modifier and Type | Method and Description |
|---|---|
void |
BaseExcelExecution.cancel() |
ResultSetExecution |
ExcelExecutionFactory.createResultSetExecution(QueryExpression command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
VirtualFileConnection connection) |
ExcelUpdateExecution |
ExcelExecutionFactory.createUpdateExecution(Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
VirtualFileConnection connection) |
void |
BaseExcelExecution.execute() |
void |
ExcelUpdateExecution.execute() |
protected VirtualFile |
BaseExcelExecution.getNextXLSFile() |
protected VirtualFile |
ExcelUpdateExecution.getNextXLSFile() |
int[] |
ExcelUpdateExecution.getUpdateCounts() |
List<?> |
ExcelExecution.next() |
org.apache.poi.ss.usermodel.Row |
BaseExcelExecution.nextRow() |
void |
ExcelMetadataProcessor.process(MetadataFactory mf,
VirtualFileConnection conn) |
void |
BaseExcelExecution.visit(LanguageObject command) |
| Constructor and Description |
|---|
ExcelExecution(Select query,
ExecutionContext executionContext,
RuntimeMetadata metadata,
VirtualFileConnection connection) |
ExcelUpdateExecution(LanguageObject command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
VirtualFileConnection connection) |
| Modifier and Type | Method and Description |
|---|---|
ProcedureExecution |
FileExecutionFactory.createProcedureExecution(Call command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
VirtualFileConnection conn) |
void |
FileExecutionFactory.getMetadata(MetadataFactory metadataFactory,
VirtualFileConnection connection) |
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractSpreadsheetExecution.cancel() |
void |
SpreadsheetUpdateExecution.cancel() |
void |
DirectSpreadsheetQueryExecution.cancel() |
void |
SpreadsheetQueryExecution.cancel() |
ProcedureExecution |
SpreadsheetExecutionFactory.createDirectExecution(List<Argument> arguments,
Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
GoogleSpreadsheetConnection connection) |
ProcedureExecution |
SpreadsheetExecutionFactory.createProcedureExecution(Call command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
GoogleSpreadsheetConnection connection) |
ResultSetExecution |
SpreadsheetExecutionFactory.createResultSetExecution(QueryExpression command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
GoogleSpreadsheetConnection connection) |
UpdateExecution |
SpreadsheetExecutionFactory.createUpdateExecution(Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
GoogleSpreadsheetConnection connection) |
void |
SpreadsheetUpdateExecution.execute() |
void |
DirectSpreadsheetQueryExecution.execute() |
void |
SpreadsheetQueryExecution.execute() |
List<?> |
DirectSpreadsheetQueryExecution.getOutputParameterValues() |
int[] |
AbstractSpreadsheetExecution.getUpdateCounts() |
List<?> |
DirectSpreadsheetQueryExecution.next() |
List<?> |
SpreadsheetQueryExecution.next() |
void |
GoogleMetadataProcessor.process(MetadataFactory mf,
GoogleSpreadsheetConnection conn)
Creates metadata from all spreadsheets in the user account.
|
void |
SpreadsheetExecutionFactory.start() |
| Modifier and Type | Method and Description |
|---|---|
ProcedureExecution |
BaseHiveExecutionFactory.createProcedureExecution(Call command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
Connection conn) |
JDBCUpdateExecution |
BaseHiveExecutionFactory.createUpdateExecution(Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
Connection conn) |
void |
ImpalaExecutionFactory.initCapabilities(Connection connection) |
void |
HiveMetadataProcessor.process(MetadataFactory metadataFactory,
Connection conn) |
void |
ImpalaExecutionFactory.start() |
void |
HiveExecutionFactory.start() |
| Modifier and Type | Field and Description |
|---|---|
protected ArrayList<TranslatorException> |
IckleConversionVisitor.exceptions |
protected ArrayList<TranslatorException> |
InfinispanUpdateVisitor.exceptions |
| Modifier and Type | Method and Description |
|---|---|
void |
InfinispanQueryExecution.cancel() |
void |
InfinispanUpdateExecution.cancel() |
void |
InfinispanDirectQueryExecution.cancel() |
ProcedureExecution |
InfinispanExecutionFactory.createDirectExecution(List<Argument> arguments,
Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
InfinispanConnection connection) |
ResultSetExecution |
InfinispanExecutionFactory.createResultSetExecution(QueryExpression command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
InfinispanConnection connection) |
UpdateExecution |
InfinispanExecutionFactory.createUpdateExecution(Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
InfinispanConnection connection) |
void |
InfinispanQueryExecution.execute() |
void |
InfinispanUpdateExecution.execute() |
void |
InfinispanDirectQueryExecution.execute() |
static String |
MarshallerBuilder.getDocumentAttributeName(Column column,
boolean nested,
RuntimeMetadata metadata) |
static TeiidTableMarsheller |
MarshallerBuilder.getMarshaller(Table table,
RuntimeMetadata metadata) |
static TeiidTableMarsheller |
MarshallerBuilder.getMarshaller(Table table,
RuntimeMetadata metadata,
DocumentFilter filter) |
void |
InfinispanExecutionFactory.getMetadata(MetadataFactory metadataFactory,
InfinispanConnection conn) |
List<?> |
InfinispanDirectQueryExecution.getOutputParameterValues() |
Map<String,Class<?>> |
IckleConversionVisitor.getProjectedDocumentAttributes() |
int[] |
InfinispanUpdateExecution.getUpdateCounts() |
static TreeMap<Integer,TableWireFormat> |
MarshallerBuilder.getWireMap(Table parentTbl,
RuntimeMetadata metadata) |
boolean |
ComplexDocumentFilter.matches(Map<String,Object> parentProperties,
Map<String,Object> childProperties) |
List<?> |
InfinispanQueryExecution.next() |
List<?> |
InfinispanDirectQueryExecution.next() |
ProtobufResource |
SchemaToProtobufProcessor.process(MetadataFactory metadataFactory,
InfinispanConnection connection) |
void |
ProtobufMetadataProcessor.process(MetadataFactory metadataFactory,
InfinispanConnection connection) |
void |
InfinispanExecutionFactory.start() |
| Constructor and Description |
|---|
ComplexDocumentFilter(NamedTable parentTable,
NamedTable childTable,
RuntimeMetadata metadata,
String filter,
DocumentFilter.Action action) |
InfinispanQueryExecution(InfinispanExecutionFactory translator,
QueryExpression command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
InfinispanConnection connection,
boolean useAliasCache) |
InfinispanUpdateExecution(Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
InfinispanConnection connection,
boolean useAliasCache) |
| Modifier and Type | Class and Description |
|---|---|
class |
JDBCExecutionException |
| Modifier and Type | Method and Description |
|---|---|
void |
JDBCBaseExecution.cancel() |
ProcedureExecution |
JDBCExecutionFactory.createDirectExecution(List<Argument> arguments,
Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
Connection conn) |
protected boolean |
JDBCQueryExecution.createFullTempTables(QueryExpression qe,
boolean usingTxn) |
ProcedureExecution |
JDBCExecutionFactory.createProcedureExecution(Call command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
Connection conn) |
ResultSetExecution |
JDBCExecutionFactory.createResultSetExecution(QueryExpression command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
Connection conn) |
protected boolean |
JDBCQueryExecution.createTempTables(Select select) |
JDBCUpdateExecution |
JDBCExecutionFactory.createUpdateExecution(Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
Connection conn) |
void |
JDBCQueryExecution.execute() |
void |
JDBCDirectQueryExecution.execute() |
void |
JDBCProcedureExecution.execute() |
void |
JDBCUpdateExecution.execute() |
int[] |
JDBCUpdateExecution.execute(BatchedUpdates batchedCommand) |
Connection |
JDBCExecutionFactory.getConnection(DataSource ds) |
void |
JDBCExecutionFactory.getMetadata(MetadataFactory metadataFactory,
Connection conn) |
List<?> |
JDBCDirectQueryExecution.getOutputParameterValues() |
List<?> |
JDBCProcedureExecution.getOutputParameterValues() |
int[] |
JDBCUpdateExecution.getUpdateCounts() |
void |
JDBCExecutionFactory.initCapabilities(Connection connection) |
List<?> |
JDBCQueryExecution.next() |
List<?> |
JDBCDirectQueryExecution.next() |
List<?> |
JDBCProcedureExecution.next() |
void |
JDBCMetadataProcessor.process(MetadataFactory metadataFactory,
Connection conn) |
void |
JDBCExecutionFactory.start() |
protected TranslatedCommand |
JDBCBaseExecution.translateCommand(Command command) |
void |
TranslatedCommand.translateCommand(Command command)
The method to cause this object to do it's thing.
|
| Modifier and Type | Method and Description |
|---|---|
void |
AccessExecutionFactory.start() |
| Modifier and Type | Method and Description |
|---|---|
void |
ActianVectorInHadoopExecutionFactory.start() |
| Modifier and Type | Method and Description |
|---|---|
void |
DB2ExecutionFactory.start() |
void |
BaseDB2ExecutionFactory.start() |
| Modifier and Type | Method and Description |
|---|---|
void |
DerbyExecutionFactory.start() |
| Modifier and Type | Method and Description |
|---|---|
void |
ExasolExecutionFactory.start() |
| Modifier and Type | Method and Description |
|---|---|
void |
H2ExecutionFactory.start() |
| Modifier and Type | Method and Description |
|---|---|
void |
HanaExecutionFactory.getMetadata(MetadataFactory metadataFactory,
Connection connection) |
void |
HanaExecutionFactory.start() |
| Modifier and Type | Method and Description |
|---|---|
void |
HsqlExecutionFactory.start() |
| Modifier and Type | Method and Description |
|---|---|
void |
InformixExecutionFactory.start() |
| Modifier and Type | Method and Description |
|---|---|
void |
Ingres93ExecutionFactory.start() |
void |
IngresExecutionFactory.start() |
| Modifier and Type | Method and Description |
|---|---|
void |
InterSystemsCacheExecutionFactory.start() |
| Modifier and Type | Method and Description |
|---|---|
void |
MetaMatrixExecutionFactory.start() |
| Modifier and Type | Method and Description |
|---|---|
void |
ModeShapeExecutionFactory.start() |
| Modifier and Type | Method and Description |
|---|---|
void |
MySQLExecutionFactory.start() |
void |
MySQL5ExecutionFactory.start() |
| Modifier and Type | Method and Description |
|---|---|
void |
NetezzaExecutionFactory.start() |
| Modifier and Type | Method and Description |
|---|---|
void |
OracleExecutionFactory.handleInsertSequences(Insert insert) |
void |
OracleExecutionFactory.initCapabilities(Connection connection) |
void |
OracleExecutionFactory.start() |
| Modifier and Type | Method and Description |
|---|---|
void |
PIExecutionFactory.getMetadata(MetadataFactory metadataFactory,
Connection conn) |
void |
PIExecutionFactory.start() |
| Modifier and Type | Method and Description |
|---|---|
void |
PostgreSQLExecutionFactory.initCapabilities(Connection connection) |
void |
PostgreSQLExecutionFactory.start() |
| Modifier and Type | Method and Description |
|---|---|
void |
RedshiftExecutionFactory.start() |
| Modifier and Type | Method and Description |
|---|---|
void |
SAPIQExecutionFactory.initCapabilities(Connection connection) |
void |
SAPIQExecutionFactory.start() |
| Modifier and Type | Method and Description |
|---|---|
void |
SQLServerExecutionFactory.initCapabilities(Connection connection) |
void |
SQLServerExecutionFactory.start() |
| Modifier and Type | Method and Description |
|---|---|
void |
SybaseExecutionFactory.initCapabilities(Connection connection) |
void |
SybaseExecutionFactory.start() |
| Modifier and Type | Method and Description |
|---|---|
void |
TeradataExecutionFactory.start() |
| Modifier and Type | Method and Description |
|---|---|
void |
UCanAccessExecutionFactory.start() |
| Modifier and Type | Method and Description |
|---|---|
void |
VerticaExecutionFactory.start() |
| Modifier and Type | Field and Description |
|---|---|
protected ArrayList<TranslatorException> |
JPQLSelectVisitor.exceptions |
protected ArrayList<TranslatorException> |
JPQLUpdateQueryVisitor.exceptions |
| Modifier and Type | Method and Description |
|---|---|
void |
JPQLUpdateExecution.cancel() |
void |
JPQLQueryExecution.cancel() |
void |
JPQLDirectQueryExecution.cancel() |
ProcedureExecution |
JPA2ExecutionFactory.createDirectExecution(List<Argument> arguments,
Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
javax.persistence.EntityManager connection) |
ProcedureExecution |
JPA2ExecutionFactory.createProcedureExecution(Call command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
javax.persistence.EntityManager connection) |
ResultSetExecution |
JPA2ExecutionFactory.createResultSetExecution(QueryExpression command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
javax.persistence.EntityManager connection) |
UpdateExecution |
JPA2ExecutionFactory.createUpdateExecution(Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
javax.persistence.EntityManager connection) |
void |
JPQLUpdateExecution.execute() |
void |
JPQLQueryExecution.execute() |
void |
JPQLDirectQueryExecution.execute() |
javax.persistence.EntityManager |
JPA2ExecutionFactory.getConnection(javax.persistence.EntityManagerFactory factory,
ExecutionContext executionContext) |
static String |
JPQLUpdateQueryVisitor.getJPQLString(Command obj) |
static String |
JPQLSelectVisitor.getJPQLString(Select obj,
JPA2ExecutionFactory executionFactory,
RuntimeMetadata metadata) |
List<?> |
JPQLDirectQueryExecution.getOutputParameterValues() |
int[] |
JPQLUpdateExecution.getUpdateCounts() |
List<?> |
JPQLQueryExecution.next() |
List<?> |
JPQLDirectQueryExecution.next() |
void |
JPAMetadataProcessor.process(MetadataFactory mf,
javax.persistence.EntityManager entityManager) |
void |
JPA2ExecutionFactory.start() |
| Modifier and Type | Method and Description |
|---|---|
LDAPSearchDetails |
IQueryToLdapSearchParser.buildRequest(String query) |
void |
LDAPQueryExecution.cancel() |
void |
LDAPSyncQueryExecution.cancel() |
void |
LDAPDirectCreateUpdateDeleteQueryExecution.cancel() |
void |
LDAPUpdateExecution.cancel() |
ProcedureExecution |
LDAPExecutionFactory.createDirectExecution(List<Argument> arguments,
Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
LdapContext context) |
ProcedureExecution |
LDAPExecutionFactory.createProcedureExecution(Call command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
LdapContext connection) |
ResultSetExecution |
LDAPExecutionFactory.createResultSetExecution(QueryExpression command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
LdapContext context) |
protected LdapContext |
LDAPSyncQueryExecution.createSearchContext(String contextName)
Perform a lookup against the initial LDAP context, which
sets the context to something appropriate for the search that is about to occur.
|
UpdateExecution |
LDAPExecutionFactory.createUpdateExecution(Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
LdapContext context) |
void |
LDAPQueryExecution.execute() |
void |
LDAPSyncQueryExecution.execute()
method to execute the supplied query
|
void |
LDAPDirectSearchQueryExecution.execute() |
void |
LDAPDirectCreateUpdateDeleteQueryExecution.execute() |
void |
LDAPUpdateExecution.execute()
execute generic update-class (either an update, delete, or insert)
operation and returns a count of affected rows.
|
List<?> |
LDAPDirectSearchQueryExecution.getOutputParameterValues() |
List<?> |
LDAPDirectCreateUpdateDeleteQueryExecution.getOutputParameterValues() |
int[] |
LDAPUpdateExecution.getUpdateCounts() |
List<?> |
LDAPQueryExecution.next()
Fetch the next batch of data from the LDAP searchEnumerationr result.
|
List<?> |
LDAPSyncQueryExecution.next() |
List<?> |
LDAPDirectSearchQueryExecution.next() |
List<?> |
LDAPDirectCreateUpdateDeleteQueryExecution.next() |
LDAPSearchDetails |
IQueryToLdapSearchParser.translateSQLQueryToLDAPSearch(Select query)
Public entry point to the parser.
|
| Modifier and Type | Method and Description |
|---|---|
ProcedureExecution |
RecordLoggingExecutionFactory.createDirectExecution(List<Argument> arguments,
Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
C connection) |
ProcedureExecution |
RecordLoggingExecutionFactory.createProcedureExecution(Call command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
C connection) |
ResultSetExecution |
RecordLoggingExecutionFactory.createResultSetExecution(QueryExpression command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
C connection) |
UpdateExecution |
RecordLoggingExecutionFactory.createUpdateExecution(Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
C connection) |
| Modifier and Type | Method and Description |
|---|---|
void |
LoopbackExecution.cancel() |
Execution |
LoopbackExecutionFactory.createExecution(Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
Object connection) |
void |
LoopbackExecution.execute() |
Object |
LoopbackExecutionFactory.getConnection(Object factory) |
Object |
LoopbackExecutionFactory.getConnection(Object factory,
ExecutionContext executionContext) |
void |
LoopbackExecutionFactory.getMetadata(MetadataFactory metadataFactory,
Object conn) |
List<?> |
LoopbackExecution.getOutputParameterValues() |
int[] |
LoopbackExecution.getUpdateCounts() |
List<?> |
LoopbackExecution.next() |
void |
LoopbackExecutionFactory.start() |
| Modifier and Type | Field and Description |
|---|---|
protected TranslatorException |
MongoDBUpdateVisitor.pullException |
| Modifier and Type | Field and Description |
|---|---|
protected ArrayList<TranslatorException> |
ExpressionEvaluator.exceptions |
protected ArrayList<TranslatorException> |
MongoDBSelectVisitor.exceptions |
| Modifier and Type | Method and Description |
|---|---|
void |
MergePlanner.addNode(ExistsNode node) |
void |
MergePlanner.addNode(UnwindNode node) |
void |
MongoDBUpdateExecution.cancel() |
void |
MongoDBDirectQueryExecution.cancel() |
void |
MongoDBQueryExecution.cancel() |
Object |
MongoDBExecutionFactory.convertToMongoType(Object value,
com.mongodb.DB mongoDB,
String fqn)
Mongodb only supports certain data types, Teiid need to serialize them in other compatible
formats, and convert them back while reading them.
|
ProcedureExecution |
MongoDBExecutionFactory.createDirectExecution(List<Argument> arguments,
Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
MongoDBConnection connection) |
ProcedureExecution |
MongoDBExecutionFactory.createProcedureExecution(Call command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
MongoDBConnection connection) |
ResultSetExecution |
MongoDBExecutionFactory.createResultSetExecution(QueryExpression command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
MongoDBConnection connection) |
UpdateExecution |
MongoDBExecutionFactory.createUpdateExecution(Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
MongoDBConnection connection) |
void |
MongoDBUpdateExecution.execute() |
void |
MongoDBDirectQueryExecution.execute() |
void |
MongoDBQueryExecution.execute() |
String |
ProcessingNode.getDocumentName() |
Object |
MergeDetails.getId() |
abstract com.mongodb.BasicDBObject |
ProcessingNode.getInstruction() |
com.mongodb.BasicDBObject |
ProjectionNode.getInstruction() |
com.mongodb.BasicDBObject |
ExistsNode.getInstruction() |
com.mongodb.BasicDBObject |
UnwindNode.getInstruction() |
List<?> |
MongoDBDirectQueryExecution.getOutputParameterValues() |
com.mongodb.BasicDBObject |
MongoDBUpdateVisitor.getPullQuery() |
com.mongodb.BasicDBObject |
MongoDBUpdateVisitor.getUpdate(LinkedHashMap<String,com.mongodb.DBObject> embeddedDocuments) |
int[] |
MongoDBUpdateExecution.getUpdateCounts() |
void |
MongoDBExecutionFactory.initCapabilities(MongoDBConnection connection) |
static boolean |
ExpressionEvaluator.matches(MongoDBExecutionFactory executionFactory,
com.mongodb.DB mongoDB,
Condition condition,
com.mongodb.BasicDBObject row,
org.teiid.translator.mongodb.MongoDBUpdateExecution.RowInfo rowInfo) |
List<?> |
MongoDBDirectQueryExecution.next() |
List<?> |
MongoDBQueryExecution.next() |
com.mongodb.DBObject |
MongoDBDirectQueryExecution.nextRow() |
void |
MongoDBMetadataProcessor.process(MetadataFactory metadataFactory,
MongoDBConnection connection) |
Object |
MongoDBExecutionFactory.retrieveValue(Object value,
Class<?> expectedClass,
com.mongodb.DB mongoDB,
String fqn,
String colName) |
void |
MongoDBExecutionFactory.start() |
boolean |
MongoDBUpdateVisitor.updateDelete(com.mongodb.BasicDBList previousRows,
org.teiid.translator.mongodb.MongoDBUpdateExecution.RowInfo parentKey,
com.mongodb.BasicDBList updated) |
boolean |
MongoDBUpdateVisitor.updateMerge(com.mongodb.BasicDBList previousRows,
org.teiid.translator.mongodb.MongoDBUpdateExecution.RowInfo parentKey,
com.mongodb.BasicDBList updated) |
boolean |
MongoDBUpdateVisitor.updateMerge(com.mongodb.BasicDBObject previousRow,
org.teiid.translator.mongodb.MongoDBUpdateExecution.RowInfo parentKey) |
| Constructor and Description |
|---|
MongoDBUpdateExecution(MongoDBExecutionFactory executionFactory,
Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
MongoDBConnection connection) |
| Modifier and Type | Field and Description |
|---|---|
protected ArrayList<TranslatorException> |
ODataUpdateVisitor.exceptions |
protected ArrayList<TranslatorException> |
ODataSQLVisitor.exceptions |
protected ArrayList<TranslatorException> |
ODataProcedureVisitor.exceptions |
| Modifier and Type | Method and Description |
|---|---|
protected TranslatorException |
BaseQueryExecution.buildError(BinaryWSProcedureExecution execution) |
| Modifier and Type | Method and Description |
|---|---|
protected Table |
ODataMetadataProcessor.addEntitySetAsTable(MetadataFactory mf,
org.odata4j.edm.EdmEntitySet entitySet) |
void |
ODataQueryExecution.cancel() |
void |
ODataUpdateExecution.cancel() |
void |
ODataProcedureExecution.cancel() |
ProcedureExecution |
ODataExecutionFactory.createProcedureExecution(Call command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
WSConnection connection) |
ResultSetExecution |
ODataExecutionFactory.createResultSetExecution(QueryExpression command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
WSConnection connection) |
UpdateExecution |
ODataExecutionFactory.createUpdateExecution(Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
WSConnection connection) |
void |
ODataQueryExecution.execute() |
void |
ODataUpdateExecution.execute() |
void |
ODataProcedureExecution.execute() |
protected BinaryWSProcedureExecution |
BaseQueryExecution.executeDirect(String method,
String uri,
String payload,
Map<String,List<String>> headers) |
protected org.teiid.translator.odata.BaseQueryExecution.ODataEntitiesResponse |
BaseQueryExecution.executeWithComplexReturn(String method,
String uri,
String payload,
String complexTypeName,
org.odata4j.edm.EdmDataServices edsMetadata,
String eTag,
javax.ws.rs.core.Response.Status... expectedStatus) |
protected org.teiid.translator.odata.BaseQueryExecution.ODataEntitiesResponse |
BaseQueryExecution.executeWithReturnEntity(String method,
String uri,
String payload,
String entityTable,
org.odata4j.edm.EdmDataServices edsMetadata,
String eTag,
javax.ws.rs.core.Response.Status... expectedStatus) |
void |
ODataMetadataProcessor.getMetadata(MetadataFactory mf,
org.odata4j.edm.EdmDataServices eds) |
void |
ODataExecutionFactory.getMetadata(MetadataFactory metadataFactory,
WSConnection conn) |
List<?> |
ODataProcedureExecution.getOutputParameterValues() |
int[] |
ODataUpdateExecution.getUpdateCounts() |
List<?> |
ODataQueryExecution.next() |
List<?> |
ODataProcedureExecution.next() |
protected org.odata4j.format.Feed |
BaseQueryExecution.parse(Blob blob,
org.odata4j.core.ODataVersion version,
String entityTable,
org.odata4j.edm.EdmDataServices edsMetadata) |
void |
ODataMetadataProcessor.process(MetadataFactory mf,
WSConnection conn) |
void |
ODataExecutionFactory.start() |
| Constructor and Description |
|---|
ODataProcedureExecution(Call command,
ODataExecutionFactory translator,
ExecutionContext executionContext,
RuntimeMetadata metadata,
WSConnection connection) |
ODataQueryExecution(ODataExecutionFactory translator,
QueryExpression command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
WSConnection connection) |
ODataUpdateExecution(Command command,
ODataExecutionFactory translator,
ExecutionContext executionContext,
RuntimeMetadata metadata,
WSConnection connection) |
| Modifier and Type | Method and Description |
|---|---|
protected Table |
SAPMetadataProcessor.addEntitySetAsTable(MetadataFactory mf,
org.odata4j.edm.EdmEntitySet entitySet) |
| Modifier and Type | Field and Description |
|---|---|
protected ArrayList<TranslatorException> |
ODataUpdateVisitor.exceptions |
protected ArrayList<TranslatorException> |
ODataFilterVisitor.exceptions |
protected ArrayList<TranslatorException> |
ODataSQLVisitor.exceptions |
| Modifier and Type | Method and Description |
|---|---|
protected TranslatorException |
BaseQueryExecution.buildError(BinaryWSProcedureExecution execution) |
| Modifier and Type | Method and Description |
|---|---|
Condition |
ODataQuery.addNavigation(Condition obj,
Join.JoinType joinType,
Table right) |
Condition |
ODataQuery.addNavigation(Condition obj,
Join.JoinType joinType,
Table left,
Table right) |
void |
ODataQuery.addRootDocument(Table table) |
void |
ODataFilterVisitor.appendFilter(Condition condition) |
String |
ODataUpdateQuery.buildInsertURL(String serviceRoot) |
String |
ODataUpdateQuery.buildUpdateSelectionURL(String serviceRoot) |
String |
ODataSQLVisitor.buildURL(String serviceRoot) |
org.apache.olingo.client.core.uri.URIBuilderImpl |
ODataSelectQuery.buildURL(String serviceRoot,
List<Column> projectedColumns,
Condition condition) |
void |
ODataQueryExecution.cancel() |
void |
ODataUpdateExecution.cancel() |
void |
ODataProcedureExecution.cancel() |
ProcedureExecution |
ODataExecutionFactory.createProcedureExecution(Call command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
WSConnection connection) |
ResultSetExecution |
ODataExecutionFactory.createResultSetExecution(QueryExpression command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
WSConnection connection) |
UpdateExecution |
ODataExecutionFactory.createUpdateExecution(Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
WSConnection connection) |
void |
ODataQueryExecution.execute() |
void |
ODataUpdateExecution.execute() |
void |
ODataProcedureExecution.execute() |
protected InputStream |
BaseQueryExecution.executeQuery(String method,
String uri,
String payload,
String eTag,
org.apache.olingo.commons.api.http.HttpStatusCode[] expectedStatus) |
protected InputStream |
BaseQueryExecution.executeSkipToken(URI nextURL,
String baseURL,
org.apache.olingo.commons.api.http.HttpStatusCode[] accepeted) |
void |
ODataExecutionFactory.getMetadata(MetadataFactory metadataFactory,
WSConnection conn) |
Map<String,Object> |
ODataResponse.getNext() |
List<?> |
ODataProcedureExecution.getOutputParameterValues() |
String |
ODataUpdateQuery.getPayload(org.apache.olingo.commons.api.data.Entity parentEntity) |
protected org.apache.olingo.client.api.edm.xml.XMLMetadata |
ODataExecutionFactory.getSchema(WSConnection conn) |
protected org.apache.olingo.client.api.edm.xml.XMLMetadata |
ODataMetadataProcessor.getSchema(WSConnection conn) |
int[] |
ODataUpdateExecution.getUpdateCounts() |
protected BinaryWSProcedureExecution |
BaseQueryExecution.invokeHTTP(String method,
String uri,
String payload,
Map<String,List<String>> headers) |
List<?> |
ODataQueryExecution.next() |
List<?> |
ODataProcedureExecution.next() |
abstract InputStream |
ODataResponse.nextBatch(URI uri) |
protected Condition |
ODataQuery.parseKeySegmentFromCondition(Condition obj) |
void |
ODataMetadataProcessor.process(MetadataFactory mf,
WSConnection conn) |
protected String |
ODataQuery.processFilter(Condition condition) |
void |
ODataExecutionFactory.start() |
| Constructor and Description |
|---|
ODataProcedureExecution(Call command,
ODataExecutionFactory translator,
ExecutionContext executionContext,
RuntimeMetadata metadata,
WSConnection connection) |
ODataQueryExecution(ODataExecutionFactory translator,
QueryExpression command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
WSConnection connection) |
ODataResponse(InputStream payload,
ODataMetadataProcessor.ODataType type,
DocumentNode rootNode) |
ODataUpdateExecution(Command command,
ODataExecutionFactory translator,
ExecutionContext executionContext,
RuntimeMetadata metadata,
WSConnection connection) |
| Modifier and Type | Method and Description |
|---|---|
void |
OlapQueryExecution.cancel() |
ProcedureExecution |
OlapExecutionFactory.createDirectExecution(List<Argument> arguments,
Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
Connection connection) |
ProcedureExecution |
OlapExecutionFactory.createProcedureExecution(Call command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
Connection connection) |
void |
OlapQueryExecution.execute() |
Connection |
OlapExecutionFactory.getConnection(DataSource ds) |
List<?> |
OlapQueryExecution.getOutputParameterValues() |
List<?> |
OlapQueryExecution.next() |
| Modifier and Type | Method and Description |
|---|---|
ProcedureExecution |
OpenAPIExecutionFactory.createProcedureExecution(Call command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
WSConnection connection) |
protected io.swagger.v3.parser.core.models.SwaggerParseResult |
OpenAPIMetadataProcessor.getSchema(WSConnection conn) |
void |
OpenAPIMetadataProcessor.process(MetadataFactory mf,
WSConnection connection) |
| Modifier and Type | Method and Description |
|---|---|
JDBCUpdateExecution |
PhoenixExecutionFactory.createUpdateExecution(Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
Connection conn) |
void |
PhoenixExecutionFactory.initCapabilities(Connection connection) |
void |
PhoenixExecutionFactory.start() |
protected TranslatedCommand |
PhoenixUpdateExecution.translateCommand(Command command) |
| Constructor and Description |
|---|
PhoenixUpdateExecution(Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
Connection conn,
PhoenixExecutionFactory executionFactory) |
| Modifier and Type | Method and Description |
|---|---|
ProcedureExecution |
PrestoDBExecutionFactory.createDirectExecution(List<Argument> arguments,
Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
Connection conn) |
ProcedureExecution |
PrestoDBExecutionFactory.createProcedureExecution(Call command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
Connection conn) |
JDBCUpdateExecution |
PrestoDBExecutionFactory.createUpdateExecution(Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
Connection conn) |
void |
PrestoDBExecutionFactory.initCapabilities(Connection connection) |
void |
PrestoDBMetadataProcessor.process(MetadataFactory metadataFactory,
Connection conn) |
void |
PrestoDBExecutionFactory.start() |
| Modifier and Type | Method and Description |
|---|---|
String |
SalesforceConnection.addBatch(List<com.sforce.async.SObject> payload,
com.sforce.async.JobInfo job) |
SalesforceConnection.BatchResultInfo |
SalesforceConnection.addBatch(String query,
com.sforce.async.JobInfo job) |
void |
SalesforceConnection.cancelBulkJob(com.sforce.async.JobInfo job) |
com.sforce.async.JobInfo |
SalesforceConnection.closeJob(String jobId) |
int |
SalesforceConnection.create(DataPayload data) |
com.sforce.async.JobInfo |
SalesforceConnection.createBulkJob(String objectName,
com.sforce.async.OperationEnum operation,
boolean usePkChunking) |
ProcedureExecution |
SalesForceExecutionFactory.createDirectExecution(List<Argument> arguments,
Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
SalesforceConnection connection) |
ProcedureExecution |
SalesForceExecutionFactory.createProcedureExecution(Call command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
SalesforceConnection connection) |
ResultSetExecution |
SalesForceExecutionFactory.createResultSetExecution(QueryExpression command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
SalesforceConnection connection) |
UpdateExecution |
SalesForceExecutionFactory.createUpdateExecution(Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
SalesforceConnection connection) |
int |
SalesforceConnection.delete(String[] ids) |
SalesforceConnection.BulkBatchResult |
SalesforceConnection.getBatchQueryResults(String id,
SalesforceConnection.BatchResultInfo info) |
com.sforce.async.BatchResult[] |
SalesforceConnection.getBulkResults(com.sforce.async.JobInfo job,
List<String> ids) |
Long |
SalesforceConnection.getCardinality(String sobject) |
DeletedResult |
SalesforceConnection.getDeleted(String objectName,
Calendar startCalendar,
Calendar endCalendar) |
void |
SalesForceExecutionFactory.getMetadata(MetadataFactory metadataFactory,
SalesforceConnection connection) |
com.sforce.soap.partner.DescribeSObjectResult[] |
SalesforceConnection.getObjectMetaData(String... objectName) |
com.sforce.soap.partner.DescribeGlobalResult |
SalesforceConnection.getObjects() |
UpdatedResult |
SalesforceConnection.getUpdated(String objectName,
Calendar startCalendar,
Calendar endCalendar) |
void |
SalesForceMetadataProcessor.process(MetadataFactory mf,
SalesforceConnection connection) |
void |
SalesForceMetadataProcessor.processMetadata() |
com.sforce.soap.partner.QueryResult |
SalesforceConnection.query(String queryString,
int maxBatchSize,
boolean queryAll) |
com.sforce.soap.partner.QueryResult |
SalesforceConnection.queryMore(String queryLocator,
int batchSize) |
com.sforce.soap.partner.sobject.SObject[] |
SalesforceConnection.retrieve(String fieldList,
String sObjectType,
List<String> ids) |
void |
SalesForceExecutionFactory.start() |
int |
SalesforceConnection.update(List<DataPayload> updateDataList) |
int |
SalesforceConnection.upsert(DataPayload data) |
| Modifier and Type | Method and Description |
|---|---|
protected List<com.sforce.async.SObject> |
InsertExecutionImpl.buildBulkRowPayload(Insert insert,
Iterator<? extends List<?>> it,
int rowCount) |
void |
QueryExecutionImpl.cancel() |
void |
AbstractUpdateExecution.cancel() |
void |
InsertExecutionImpl.cancel() |
void |
DirectQueryExecution.cancel() |
void |
ProcedureExecutionParentImpl.cancel() |
void |
DeleteExecutionImpl.execute() |
void |
QueryExecutionImpl.execute() |
void |
UpdateExecutionImpl.execute() |
void |
InsertExecutionImpl.execute() |
void |
DirectQueryExecution.execute() |
void |
ProcedureExecutionParentImpl.execute() |
void |
GetDeletedExecutionImpl.execute(ProcedureExecutionParent procedureExecutionParent) |
void |
SalesforceProcedureExecution.execute(ProcedureExecutionParent procedureExecutionParent) |
void |
GetUpdatedExecutionImpl.execute(ProcedureExecutionParent procedureExecutionParent) |
List<?> |
DirectQueryExecution.getOutputParameterValues() |
List<?> |
ProcedureExecutionParentImpl.getOutputParameterValues() |
int[] |
AbstractUpdateExecution.getUpdateCounts() |
int[] |
InsertExecutionImpl.getUpdateCounts() |
List<?> |
QueryExecutionImpl.next() |
List<?> |
DirectQueryExecution.next() |
List<?> |
ProcedureExecutionParentImpl.next() |
protected int |
DeleteExecutionImpl.processIds(String[] ids,
IQueryProvidingVisitor visitor) |
protected int |
UpdateExecutionImpl.processIds(String[] ids,
IQueryProvidingVisitor visitor) |
protected int |
AbstractUpdateExecution.processIds(String[] ids,
IQueryProvidingVisitor visitor)
Process an update against the ids
|
| Constructor and Description |
|---|
GetDeletedExecutionImpl(ProcedureExecutionParent procedureExecutionParent) |
GetUpdatedExecutionImpl(ProcedureExecutionParent procedureExecutionParent) |
InsertExecutionImpl(SalesForceExecutionFactory ef,
Command command,
SalesforceConnection salesforceConnection,
RuntimeMetadata metadata,
ExecutionContext context) |
| Modifier and Type | Field and Description |
|---|---|
protected List<TranslatorException> |
CriteriaVisitor.exceptions |
| Modifier and Type | Method and Description |
|---|---|
String |
UpdateVisitor.getQuery() |
String |
SelectVisitor.getQuery() |
String |
IQueryProvidingVisitor.getQuery() |
String |
DeleteVisitor.getQuery() |
String |
JoinQueryVisitor.getQuery() |
protected void |
CriteriaVisitor.loadColumnMetadata(NamedTable group) |
| Modifier and Type | Method and Description |
|---|---|
protected List<?> |
SimpleDBDirectQueryExecution.buildRow(com.amazonaws.services.simpledb.model.Item item) |
protected List<?> |
SimpleDBQueryExecution.buildRow(com.amazonaws.services.simpledb.model.Item item) |
void |
SimpleDBInsertExecute.cancel() |
void |
SimpleDBUpdateExecute.cancel() |
void |
SimpleDBQueryExecution.cancel() |
void |
SimpleDBDeleteExecute.cancel() |
void |
SimpleDBUpdateVisitor.checkExceptions() |
void |
SimpleDBDeleteVisitor.checkExceptions() |
void |
SimpleDBSQLVisitor.checkExceptions() |
void |
SimpleDBInsertVisitor.checkExceptions() |
ProcedureExecution |
SimpleDBExecutionFactory.createDirectExecution(List<Argument> arguments,
Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
SimpleDBConnection connection) |
ResultSetExecution |
SimpleDBExecutionFactory.createResultSetExecution(QueryExpression command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
SimpleDBConnection connection) |
UpdateExecution |
SimpleDBExecutionFactory.createUpdateExecution(Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
SimpleDBConnection connection) |
void |
SimpleDBInsertExecute.execute() |
void |
SimpleDBDirectQueryExecution.execute() |
void |
SimpleDBUpdateExecute.execute() |
void |
SimpleDBQueryExecution.execute() |
void |
SimpleDBDeleteExecute.execute() |
protected void |
SimpleDBQueryExecution.executeDirect(String sql,
String next) |
List<?> |
SimpleDBDirectQueryExecution.getOutputParameterValues() |
int[] |
SimpleDBInsertExecute.getUpdateCounts() |
int[] |
SimpleDBUpdateExecute.getUpdateCounts() |
int[] |
SimpleDBDeleteExecute.getUpdateCounts() |
List<?> |
SimpleDBQueryExecution.next() |
void |
SimpleDBMetadataProcessor.process(MetadataFactory metadataFactory,
SimpleDBConnection connection)
As SimpleDB does not provide any way to obtain all attribute names for
given domain (one can query only attribute names for single item) and
querrying all items in domain to get complete set of attribute names
would be very slow and resource consuming, this approach has been
selected: For each domain only first item is queried for attribute names
and metadata are created using this information.
|
void |
SimpleDBExecutionFactory.start() |
| Constructor and Description |
|---|
SimpleDBDeleteExecute(Command command,
SimpleDBConnection connection) |
SimpleDBDirectQueryExecution(List<Argument> arguments,
Command command,
RuntimeMetadata metadata,
SimpleDBConnection connection,
ExecutionContext context) |
SimpleDBInsertExecute(Command command,
SimpleDBConnection connection) |
SimpleDBQueryExecution(Select command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
SimpleDBConnection connection) |
SimpleDBUpdateExecute(Command command,
SimpleDBConnection connection) |
| Modifier and Type | Method and Description |
|---|---|
static Object |
SimpleDBDataTypeManager.convertFromSimpleDBType(List<String> origialValue,
Class<?> expectedType) |
static Object |
SimpleDBDataTypeManager.convertToSimpleDBType(Object value,
Class<?> type) |
void |
SimpleDBConnection.createDomain(String domainName)
Create a domain
|
void |
SimpleDBConnection.deleteDomain(String domainName)
Delete a Domain
|
Set<SimpleDBConnection.SimpleDBAttribute> |
SimpleDBConnection.getAttributeNames(String domainName)
Get the attributes for given domain name
|
List<String> |
SimpleDBConnection.getDomains()
Lists all domains of database
|
int |
SimpleDBConnection.performDelete(String domainName,
String selectExpression)
Removes item with given ItemName from domain
|
int |
SimpleDBConnection.performInsert(String domainName,
List<Column> columns,
Iterator<? extends List<?>> values)
Inserts item into given domain.
|
com.amazonaws.services.simpledb.model.SelectResult |
SimpleDBConnection.performSelect(String selectExpression,
String nextToken)
Performs select expression.
|
int |
SimpleDBConnection.performUpdate(String domainName,
Map<String,Object> updateAttributes,
String selectExpression)
Performs update on given domain and items
|
| Modifier and Type | Method and Description |
|---|---|
void |
SolrQueryExecution.cancel() |
void |
SolrUpdateExecution.cancel() |
ResultSetExecution |
SolrExecutionFactory.createResultSetExecution(QueryExpression command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
SolrConnection connection) |
UpdateExecution |
SolrExecutionFactory.createUpdateExecution(Command command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
SolrConnection connection) |
void |
SolrQueryExecution.execute() |
void |
SolrUpdateExecution.execute() |
void |
SolrMetadataProcessor.getConnectorMetadata(SolrConnection conn,
MetadataFactory metadataFactory) |
int[] |
SolrUpdateExecution.getUpdateCounts() |
org.apache.solr.client.solrj.response.LukeResponse |
SolrConnection.metadata(org.apache.solr.client.solrj.request.LukeRequest request) |
List<?> |
SolrQueryExecution.next() |
void |
SolrQueryExecution.nextBatch() |
void |
SolrMetadataProcessor.process(MetadataFactory metadataFactory,
SolrConnection connection) |
org.apache.solr.client.solrj.response.QueryResponse |
SolrConnection.query(org.apache.solr.client.solrj.SolrQuery query) |
void |
SolrExecutionFactory.start() |
org.apache.solr.client.solrj.response.UpdateResponse |
SolrConnection.update(org.apache.solr.client.solrj.request.UpdateRequest request) |
void |
SolrQueryExecution.walkDocuments(org.teiid.translator.solr.SolrQueryExecution.SolrDocumentCallback callback) |
| Modifier and Type | Method and Description |
|---|---|
BinaryWSProcedureExecution |
BaseQueryExecution.buildInvokeHTTP(String method,
String uri,
Object payload,
Map<String,List<String>> headers) |
void |
SwaggerProcedureExecution.cancel() |
static Object |
SwaggerTypeManager.convertTeiidRuntimeType(Object value,
Class<?> expectedType) |
ProcedureExecution |
SwaggerExecutionFactory.createProcedureExecution(Call command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
WSConnection connection) |
List<Document> |
SwaggerSerializer.deserialize(InputStream stream) |
List<Document> |
JsonSerializer.deserialize(InputStream stream) |
void |
SwaggerProcedureExecution.execute() |
Map<String,Object> |
SwaggerResponse.getNext() |
List<?> |
SwaggerProcedureExecution.getOutputParameterValues() |
protected io.swagger.models.Swagger |
SwaggerMetadataProcessor.getSchema(WSConnection conn) |
List<?> |
SwaggerProcedureExecution.next() |
void |
SwaggerMetadataProcessor.process(MetadataFactory mf,
WSConnection connection) |
InputStream |
SwaggerSerializer.serialize(Document doc) |
InputStream |
JsonSerializer.serialize(Document doc) |
| Constructor and Description |
|---|
SwaggerProcedureExecution(Call command,
ExecutionFactory translator,
ExecutionContext executionContext,
RuntimeMetadata metadata,
WSConnection connection) |
SwaggerResponse(InputStream payload,
Map<String,Object> headers,
SwaggerSerializer serializer,
boolean mapResponse) |
| Modifier and Type | Method and Description |
|---|---|
void |
BinaryWSProcedureExecution.cancel() |
void |
WSWSDLProcedureExecution.cancel() |
void |
WSProcedureExecution.cancel() |
ProcedureExecution |
WSExecutionFactory.createProcedureExecution(Call command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
WSConnection connection) |
void |
BinaryWSProcedureExecution.execute() |
void |
WSWSDLProcedureExecution.execute() |
void |
WSProcedureExecution.execute() |
void |
WSExecutionFactory.getMetadata(MetadataFactory metadataFactory,
WSConnection conn) |
List<?> |
BinaryWSProcedureExecution.getOutputParameterValues() |
List<?> |
WSWSDLProcedureExecution.getOutputParameterValues() |
List<?> |
WSProcedureExecution.getOutputParameterValues() |
List<?> |
BinaryWSProcedureExecution.next() |
List<?> |
WSWSDLProcedureExecution.next() |
List<?> |
WSProcedureExecution.next() |
void |
WSDLMetadataProcessor.process(MetadataFactory mf,
WSConnection connection) |
| Modifier and Type | Method and Description |
|---|---|
TranslatorException |
TickerCollectorVisitor.getException() |
| Modifier and Type | Method and Description |
|---|---|
void |
YahooExecution.cancel() |
ResultSetExecution |
YahooExecutionFactory.createResultSetExecution(QueryExpression command,
ExecutionContext executionContext,
RuntimeMetadata metadata,
Object connectionFactory) |
void |
YahooExecution.execute() |
protected List<List<?>> |
YahooExecution.executeUrl(String yahooUrl) |
void |
YahooExecutionFactory.getMetadata(MetadataFactory metadataFactory,
Object connection) |
static Set<String> |
TickerCollectorVisitor.getTickers(Condition crit) |
List<?> |
YahooExecution.next() |
void |
YahooExecutionFactory.start() |
Copyright © 2019. All rights reserved.