Modifier and Type | Class and Description |
---|---|
class |
ExpressionEvaluationException
This exception is thrown when an error occurs while evaluating a SQL expression.
|
class |
FunctionExecutionException
During processing, an invalid function was detected.
|
class |
FunctionMetadataException
Detected invalid function metadata during validation.
|
class |
InvalidFunctionException
During processing, an invalid function was detected.
|
class |
QueryParserException
Thrown when a query cannot be parsed.
|
class |
QueryPlannerException
This exception is thrown when an error occurs while planning the query.
|
class |
QueryProcessingException
This exception is thrown when an error occurs while retrieving metadata
from a query component metadata facade.
|
class |
QueryResolverException
This exception represents the case where the query submitted could not resolved
when it is checked against the metadata
|
class |
QueryValidatorException
This exception is thrown if an error is discovered while validating the query.
|
Modifier and Type | Class and Description |
---|---|
class |
ProcedureErrorInstructionException
Used to notify the user that the virtual procedure raised an error.
|
Modifier and Type | Method and Description |
---|---|
boolean |
DQP.cancelRequest(long requestID) |
ResultsFuture<?> |
DQP.closeLobChunkStream(int lobRequestId,
long requestId,
String streamId) |
ResultsFuture<?> |
DQP.closeRequest(long requestID) |
ResultsFuture<ResultsMessage> |
DQP.executeRequest(long reqID,
RequestMessage message) |
MetadataResult |
DQP.getMetadata(long requestID) |
MetadataResult |
DQP.getMetadata(long requestID,
String preparedSql,
boolean allowDoubleQuotedVariable) |
ResultsFuture<ResultsMessage> |
DQP.processCursorRequest(long reqID,
int batchFirst,
int fetchSize) |
ResultsFuture<LobChunk> |
DQP.requestNextLobChunk(int lobRequestId,
long requestId,
String streamId) |
void |
RequestMessage.setTxnAutoWrapMode(String txnAutoWrapMode)
Sets the txnAutoWrapMode.
|
Modifier and Type | Class and Description |
---|---|
class |
InvalidSessionException |
class |
LogonException
This exception is thrown when an attempt to log in to obtain a session has failed.
|
class |
TeiidSecurityException |
Modifier and Type | Class and Description |
---|---|
class |
XATransactionException
Exception which occurs if an error occurs within the server that is
XA transaction-related.
|
Modifier and Type | Method and Description |
---|---|
protected List<?> |
TupleBuffer.TupleBufferTupleSource.finalRow() |
protected abstract List<?> |
AbstractTupleSource.finalRow() |
protected abstract TupleBatch |
AbstractTupleSource.getBatch(long row) |
protected List<?> |
AbstractTupleSource.getCurrentTuple() |
boolean |
IndexedTupleSource.hasNext() |
boolean |
AbstractTupleSource.hasNext() |
List<?> |
TupleSource.nextTuple()
Returns the next tuple
|
List<?> |
AbstractTupleSource.nextTuple() |
List<?> |
TupleBrowser.nextTuple() |
Modifier and Type | Class and Description |
---|---|
class |
TransformationException
The exception is thrown when an error occurs during data transformation,
typically a formatting error or an invalid input type.
|
Modifier and Type | Class and Description |
---|---|
class |
VirtualDatabaseException
The base exception from which all Runtime Metadata Exceptions extend.
|
Modifier and Type | Method and Description |
---|---|
TempTable |
CompositeGlobalTableStore.createMatTable(String matTableName,
GroupSymbol group) |
TempMetadataID |
CompositeGlobalTableStore.getGlobalTempTableMetadataId(Object groupID) |
Modifier and Type | Method and Description |
---|---|
boolean |
DQPCore.cancelRequest(long requestID) |
ResultsFuture<?> |
DQPCore.closeLobChunkStream(int lobRequestId,
long requestId,
String streamId) |
ResultsFuture<?> |
DQPCore.closeRequest(long requestId) |
QueryProcessor |
QueryProcessorFactoryImpl.createQueryProcessor(String query,
String recursionGroup,
CommandContext commandContext,
Object... params) |
ResultsFuture<ResultsMessage> |
DQPCore.executeRequest(long reqID,
RequestMessage requestMsg) |
ResultsFuture<ResultsMessage> |
DQPCore.executeRequest(long reqID,
RequestMessage requestMsg,
Long queryTimeout) |
protected void |
Request.generatePlan(boolean prepared)
state side effects:
creates the analysis record
creates the command context
sets the pre-rewrite command on the request
adds a limit clause if the row limit is specified
sets the processor plan
|
protected void |
PreparedStatementRequest.generatePlan(boolean addLimit) |
static int |
DataTierManagerImpl.getLevel(String level) |
MetadataResult |
DQPCore.getMetadata(long requestID) |
MetadataResult |
DQPCore.getMetadata(long requestID,
String preparedSql,
boolean allowDoubleQuotedVariable) |
PreparedPlan |
QueryProcessorFactoryImpl.getPreparedPlan(String query,
String recursionGroup,
CommandContext commandContext,
QueryMetadataInterface metadata) |
TupleSource |
TupleSourceCache.getSharedTupleSource(CommandContext context,
Command command,
String modelName,
RegisterRequestParameter parameterObject,
BufferManager bufferMgr,
ProcessorDataManager pdm) |
Object |
DataTierManagerImpl.lookupCodeValue(CommandContext context,
String codeTableName,
String returnElementName,
String keyElementName,
Object keyValue) |
TupleBatch |
ExplainProcessPlan.nextBatch() |
List<?> |
TupleSourceCache.CopyOnReadTupleSource.nextTuple() |
List<?> |
DataTierTupleSource.nextTuple() |
void |
ExplainProcessPlan.open() |
ResultsFuture<ResultsMessage> |
DQPCore.processCursorRequest(long reqID,
int batchFirst,
int fetchSize) |
protected void |
RequestWorkItem.processNew() |
void |
Request.processRequest() |
void |
PreparedStatementRequest.processRequest() |
TupleSource |
DataTierManagerImpl.registerRequest(CommandContext context,
Command command,
String modelName,
RegisterRequestParameter parameterObject) |
ResultsFuture<LobChunk> |
DQPCore.requestNextLobChunk(int lobRequestId,
long requestId,
String streamId) |
protected boolean |
RequestWorkItem.sendResultsIfNeeded(TupleBatch batch)
Send results if they have been requested.
|
Modifier and Type | Class and Description |
---|---|
class |
SessionServiceException |
Modifier and Type | Method and Description |
---|---|
void |
ConnectionImpl.cancelRequest(String id)
Cancel the request
|
Modifier and Type | Method and Description |
---|---|
Connection |
Client.open() |
Modifier and Type | Method and Description |
---|---|
static Object |
ODataTypeManager.parseLiteral(org.apache.olingo.commons.api.edm.EdmParameter edmParameter,
Class<?> runtimeType,
String value) |
Modifier and Type | Class and Description |
---|---|
class |
TeiidNotImplementedException |
Modifier and Type | Method and Description |
---|---|
static void |
ODataSQLBuilder.checkExpandLevel(int expandLevel) |
OlingoBridge.HandlerInfo |
OlingoBridge.getHandlers(String baseUri,
Client client,
String schemaName) |
Connection |
LocalClient.open() |
Constructor and Description |
---|
ProcedureSQLBuilder(MetadataStore metadata,
org.apache.olingo.commons.api.edm.EdmOperation edmOperation,
org.teiid.olingo.service.TeiidServiceHandler.OperationParameterValueProvider parameterProvider,
ArrayList<SQLParameter> params) |
Modifier and Type | Method and Description |
---|---|
void |
ODataFilter.internalDoFilter(javax.servlet.ServletRequest request,
javax.servlet.ServletResponse response,
javax.servlet.FilterChain chain) |
boolean |
OpenApiHandler.processOpenApiMetadata(javax.servlet.http.HttpServletRequest httpRequest,
VDBKey key,
String uri,
String modelName,
javax.servlet.ServletResponse response,
org.apache.olingo.server.api.ServiceMetadata serviceMetadata,
Map<String,String> parameters) |
Modifier and Type | Method and Description |
---|---|
protected Object |
Evaluator.evaluateProcedure(Function function,
List<?> tuple,
Object[] values) |
protected Object |
Evaluator.evaluatePushdown(Function function,
List<?> tuple,
Object[] values) |
protected ValueIterator |
Evaluator.evaluateSubquery(SubqueryContainer<?> container,
List<?> tuple) |
static JsonType |
Evaluator.jsonArray(CommandContext context,
Function f,
Object[] vals,
JSONFunctionMethods.JSONBuilder builder,
Evaluator eval,
List<?> tuple) |
Modifier and Type | Method and Description |
---|---|
void |
JSONFunctionMethods.JSONBuilder.addValue(Object object) |
void |
JSONFunctionMethods.JSONBuilder.addValue(String key,
Object object) |
JsonType |
JSONFunctionMethods.JSONBuilder.close(CommandContext cc) |
void |
JSONFunctionMethods.JSONBuilder.end(boolean array) |
static JsonType |
JSONFunctionMethods.jsonArray(CommandContext context,
Object... vals) |
void |
JSONFunctionMethods.JSONBuilder.start(boolean array) |
void |
JSONFunctionMethods.JSONBuilder.startValue(String key) |
Modifier and Type | Method and Description |
---|---|
void |
AggregateFunction.addInput(List<?> tuple,
CommandContext commandContext) |
void |
NthValue.addInput(List<?> tuple,
CommandContext commandContext,
long startFrame,
long endFrame,
TupleBuffer frame) |
void |
Count.addInputDirect(List<?> tuple,
CommandContext commandContext) |
void |
UserDefined.addInputDirect(List<?> tuple,
CommandContext commandContext) |
void |
SingleArgumentAggregateFunction.addInputDirect(List<?> tuple,
CommandContext commandContext) |
void |
NthValue.addInputDirect(List<?> tuple,
CommandContext commandContext) |
void |
LeadLagValue.addInputDirect(List<?> tuple,
CommandContext commandContext) |
abstract void |
AggregateFunction.addInputDirect(List<?> tuple,
CommandContext commandContext)
Called for the element value in every row of a group.
|
void |
CountBig.addInputDirect(List<?> tuple,
CommandContext commandContext) |
void |
StringAgg.addInputDirect(List<?> tuple,
CommandContext commandContext) |
void |
Ntile.addInputDirect(Object input,
List<?> tuple,
CommandContext commandContext) |
void |
JSONArrayAgg.addInputDirect(Object input,
List<?> tuple,
CommandContext commandContext) |
void |
XMLAgg.addInputDirect(Object input,
List<?> tuple,
CommandContext commandContext) |
abstract void |
SingleArgumentAggregateFunction.addInputDirect(Object input,
List<?> tuple,
CommandContext commandContext) |
void |
ArrayAgg.addInputDirect(Object input,
List<?> tuple,
CommandContext commandContext) |
void |
TextAgg.addInputDirect(Object input,
List<?> tuple,
CommandContext commandContext) |
void |
FirstLastValue.addInputDirect(Object input,
List<?> tuple,
CommandContext commandContext) |
Object |
JSONArrayAgg.getResult(CommandContext commandContext) |
Object |
XMLAgg.getResult(CommandContext commandContext) |
Object |
UserDefined.getResult(CommandContext commandContext) |
Object |
ArrayAgg.getResult(CommandContext commandContext) |
Object |
NthValue.getResult(CommandContext commandContext) |
Object |
TextAgg.getResult(CommandContext commandContext) |
Object |
LeadLagValue.getResult(CommandContext commandContext) |
abstract Object |
AggregateFunction.getResult(CommandContext commandContext)
Called after all values have been processed to get the result.
|
Object |
StringAgg.getResult(CommandContext commandContext) |
Modifier and Type | Method and Description |
---|---|
void |
XMLSystemFunctions.XmlConcat.addValue(Object object) |
XMLType |
XMLSystemFunctions.XmlConcat.close(CommandContext context) |
static Source |
XMLSystemFunctions.convertToSource(Object value) |
boolean |
XMLHelper.isValidNCName(String prefix) |
static SQLXML |
XMLSystemFunctions.jsonToXml(CommandContext context,
String rootName,
Blob json) |
static SQLXML |
XMLSystemFunctions.jsonToXml(CommandContext context,
String rootName,
Blob json,
boolean stream) |
static SQLXML |
XMLSystemFunctions.jsonToXml(CommandContext context,
String rootName,
Clob json) |
static SQLXML |
XMLSystemFunctions.jsonToXml(CommandContext context,
String rootName,
Clob json,
boolean stream) |
static SQLXMLImpl |
XMLSystemFunctions.saveToBufferManager(BufferManager bufferMgr,
XMLTranslator translator,
CommandContext context)
This method saves the given XML object to the buffer manager's disk process
Documents less than the maxMemorySize will be held directly in memory
|
String[] |
XMLHelper.validateQName(String name) |
void |
XMLHelper.validateXpath(String xpath) |
static XMLType |
XMLSystemFunctions.xmlConcat(CommandContext context,
XMLType xml,
Object... other) |
static XMLType |
XMLSystemFunctions.xmlElement(CommandContext context,
String name,
Evaluator.NameValuePair<String>[] namespaces,
Evaluator.NameValuePair<?>[] attributes,
List<?> contents)
Basic support for xmlelement.
|
static XMLType |
XMLSystemFunctions.xmlForest(CommandContext context,
Evaluator.NameValuePair[] namespaces,
Evaluator.NameValuePair[] values) |
Constructor and Description |
---|
XmlConcat(BufferManager bm) |
Modifier and Type | Method and Description |
---|---|
ScriptEngine |
BasicQueryMetadataWrapper.getScriptEngine(String langauge) |
ScriptEngine |
BasicQueryMetadata.getScriptEngine(String language) |
ScriptEngine |
QueryMetadataInterface.getScriptEngine(String langauge) |
ScriptEngine |
BasicQueryMetadata.getScriptEngineDirect(String language) |
ScriptEngine |
TransformationMetadata.getScriptEngineDirect(String language) |
Modifier and Type | Method and Description |
---|---|
TupleBatch |
SourceTriggerActionPlanner.CompositeProcessorPlan.nextBatch() |
void |
SourceTriggerActionPlanner.CompositeProcessorPlan.open() |
ProcessorPlan |
TriggerActionPlanner.optimize(ProcedureContainer userCommand,
TriggerAction ta,
IDGenerator idGenerator,
QueryMetadataInterface metadata,
CapabilitiesFinder capFinder,
AnalysisRecord analysisRecord,
CommandContext context) |
Modifier and Type | Method and Description |
---|---|
static Command |
RowBasedSecurityHelper.checkUpdateRowBasedFilters(ProcedureContainer container,
Command procedure,
RelationalPlanner planner) |
protected RelationalNode |
PlanToProcessConverter.convertNode(PlanNode node) |
PlanNode |
RelationalPlanner.generatePlan(Command cmd) |
static Criteria |
RowBasedSecurityHelper.getRowBasedFilters(QueryMetadataInterface metadata,
GroupSymbol group,
CommandContext cc,
boolean constraintsOnly,
Policy.Operation operation) |
static List<? extends Expression> |
ColumnMaskingHelper.maskColumns(List<ElementSymbol> cols,
GroupSymbol group,
QueryMetadataInterface metadata,
CommandContext cc) |
Modifier and Type | Method and Description |
---|---|
TupleBuffer |
BatchCollector.collectTuples() |
TupleBuffer |
BatchCollector.collectTuples(boolean singleBatch) |
QueryProcessor |
QueryProcessor.ProcessorFactory.createQueryProcessor(String query,
String recursionGroup,
CommandContext commandContext,
Object... params) |
protected List<?> |
BatchIterator.finalRow() |
protected void |
BatchCollector.flushBatchDirect(TupleBatch batch,
boolean add) |
protected TupleBatch |
BatchIterator.getBatch(long row) |
TupleBuffer |
QueryProcessor.getBuffer(int maxRows) |
TupleBuffer |
ProcessorPlan.getBuffer(int maxRows)
return the final tuple buffer or null if not available
|
TupleBuffer |
BatchCollector.BatchProducer.getBuffer(int maxRows)
return the final tuple buffer or null if not available
|
protected List<?> |
BatchIterator.getCurrentTuple() |
PreparedPlan |
QueryProcessor.ProcessorFactory.getPreparedPlan(String query,
String recursionGroup,
CommandContext commandContext,
QueryMetadataInterface metadata) |
void |
QueryProcessor.init() |
Object |
ProcessorDataManager.lookupCodeValue(CommandContext context,
String codeTableName,
String returnElementName,
String keyElementName,
Object keyValue)
Lookup a value from a cached code table.
|
TupleBatch |
DdlPlan.nextBatch() |
TupleBatch |
QueryProcessor.nextBatch() |
abstract TupleBatch |
ProcessorPlan.nextBatch()
Get a batch of results or possibly an Exception.
|
TupleBatch |
BatchedUpdatePlan.nextBatch() |
TupleBatch |
BatchCollector.BatchProducer.nextBatch()
Get a batch of results or possibly an Exception.
|
List<Object> |
BatchCollector.BatchProducerTupleSource.nextTuple() |
void |
DdlPlan.open() |
abstract void |
ProcessorPlan.open()
Open the plan for processing.
|
void |
BatchedUpdatePlan.open() |
void |
BatchIterator.readAhead(long limit) |
TupleSource |
ProcessorDataManager.registerRequest(CommandContext context,
Command command,
String modelName,
RegisterRequestParameter parameterObject) |
String |
DdlPlan.SetPropertyProcessor.setProperty(VDBMetaData vdb,
AbstractMetadataRecord record,
String key,
String value) |
Modifier and Type | Method and Description |
---|---|
void |
ProcedurePlan.executePlan(ProcessorPlan command,
String rsName,
Map<ElementSymbol,ElementSymbol> procAssignments,
CreateCursorResultSetInstruction.Mode mode,
boolean usesLocalTemp) |
boolean |
ProcedurePlan.iterateCursor(String rsName) |
Object |
ProcedurePlan.lookupCodeValue(CommandContext context,
String codeTableName,
String returnElementName,
String keyElementName,
Object keyValue) |
TupleBatch |
ForEachRowPlan.nextBatch() |
TupleBatch |
ProcedurePlan.nextBatch() |
TupleBatch |
ProcedurePlan.nextBatchDirect() |
void |
ForEachRowPlan.open() |
void |
ProcedurePlan.open() |
abstract void |
ProgramInstruction.process(ProcedurePlan env)
Allow this instruction to do whatever processing it needs, and to
in turn manipulate the running program.
|
void |
AssignmentInstruction.process(ProcedurePlan procEnv)
Updates the current variable context with a value for the Variable
defined using a DeclareInstruction, the variable value is obtained by either processing
a expression or a command(stored as a processplan).
|
void |
BlockInstruction.process(ProcedurePlan procEnv) |
void |
ErrorInstruction.process(ProcedurePlan env) |
void |
IfInstruction.process(ProcedurePlan procEnv)
This instruction will evaluate it's criteria, if it evaluates
to true, it will push the corresponding sub Program on to the top of the
program stack, and break from the loop.
|
void |
ExecDynamicSqlInstruction.process(ProcedurePlan procEnv)
Processing this instruction executes the ProcessorPlan for the command on
the CommandStatement of the update procedure language.
|
void |
CreateCursorResultSetInstruction.process(ProcedurePlan procEnv) |
TupleSource |
ProcedurePlan.registerRequest(CommandContext context,
Command command,
String modelName,
RegisterRequestParameter parameterObject) |
boolean |
RepeatedInstruction.testCondition(ProcedurePlan procEnv) |
boolean |
WhileInstruction.testCondition(ProcedurePlan procEnv) |
boolean |
LoopInstruction.testCondition(ProcedurePlan procEnv) |
Modifier and Type | Method and Description |
---|---|
void |
SortingFilter.addInputDirect(List<?> tuple,
CommandContext commandContext) |
protected void |
GroupingNode.closeGroup(int colDiff,
boolean reset,
CommandContext context) |
protected boolean |
MergeJoinStrategy.compareToPrevious(org.teiid.query.processor.relational.SourceState target) |
void |
EnhancedSortMergeJoinStrategy.createIndex(org.teiid.query.processor.relational.SourceState state,
MergeJoinStrategy.SortOption sortOption)
Create an index of the smaller size
|
protected void |
SortUtility.doMerge(int rowLimit) |
protected Object |
SubqueryAwareEvaluator.evaluateProcedure(Function function,
List<?> tuple,
Object[] values)
Implements procedure function handling.
|
protected Object |
SubqueryAwareEvaluator.evaluatePushdown(Function function,
List<?> tuple,
Object[] values)
Implements must pushdown function handling if supported by the source.
|
protected ValueIterator |
SubqueryAwareEvaluator.evaluateSubquery(SubqueryContainer<?> container,
List<?> tuple) |
TupleBuffer |
RelationalPlan.getBuffer(int maxRows) |
TupleBuffer |
RelationalNode.getBuffer(int maxRows)
return the final tuple buffer or null if not available
|
TupleBuffer |
SortNode.getBufferDirect(int maxRows) |
TupleBuffer |
LimitNode.getBufferDirect(int maxRows) |
TupleBuffer |
ProjectNode.getBufferDirect(int maxRows) |
protected TupleBuffer |
RelationalNode.getBufferDirect(int maxRows)
For subclasses to override if they wish to return a buffer rather than batches.
|
Set<Object> |
DependentValueSource.getCachedSet(Expression valueExpression) |
Object |
SortingFilter.getResult(CommandContext commandContext) |
protected void |
SortUtility.initialSort(boolean onePass,
boolean lowLatency,
int rowLimit)
creates sorted sublists stored in tuplebuffers
|
protected void |
JoinStrategy.loadLeft() |
protected void |
MergeJoinStrategy.loadLeft() |
protected void |
EnhancedSortMergeJoinStrategy.loadLeft() |
protected void |
NestedLoopJoinStrategy.loadRight() |
protected void |
JoinStrategy.loadRight() |
protected void |
MergeJoinStrategy.loadRight() |
protected void |
EnhancedSortMergeJoinStrategy.loadRight() |
protected void |
SortUtility.mergePhase(int rowLimit) |
TupleBatch |
RelationalPlan.nextBatch() |
TupleBatch |
RelationalNode.nextBatch()
Wrapper for nextBatchDirect that does performance timing - callers
should always call this rather than nextBatchDirect().
|
TupleBatch |
AccessNode.nextBatchDirect() |
TupleBatch |
GroupingNode.nextBatchDirect() |
TupleBatch |
DupRemoveNode.nextBatchDirect() |
TupleBatch |
PlanExecutionNode.nextBatchDirect() |
TupleBatch |
UnionAllNode.nextBatchDirect() |
TupleBatch |
SortNode.nextBatchDirect() |
protected TupleBatch |
TextTableNode.nextBatchDirect() |
TupleBatch |
SelectNode.nextBatchDirect() |
protected TupleBatch |
ArrayTableNode.nextBatchDirect() |
TupleBatch |
ProjectIntoNode.nextBatchDirect()
Get batch from child node
Walk through each row of child batch
Bind values to insertCommand
Execute insertCommand
Update insertCount
When no more data is available, output batch with single row containing insertCount
|
TupleBatch |
JoinNode.nextBatchDirect() |
protected TupleBatch |
LimitNode.nextBatchDirect() |
protected TupleBatch |
WindowFunctionProjectNode.nextBatchDirect() |
protected TupleBatch |
ObjectTableNode.nextBatchDirect() |
TupleBatch |
ProjectNode.nextBatchDirect() |
protected abstract TupleBatch |
RelationalNode.nextBatchDirect()
Template method for subclasses to implement.
|
TupleBatch |
BatchedUpdateNode.nextBatchDirect() |
TupleBatch |
UnionAllNode.nextBatchDirectInternal() |
protected TupleBatch |
JoinNode.nextBatchDirectInternal() |
protected Command |
AccessNode.nextCommand() |
protected Command |
DependentAccessNode.nextCommand() |
List<TupleBuffer> |
SortUtility.onePassSort(boolean lowLatency) |
void |
AccessNode.open() |
void |
DependentProcedureAccessNode.open() |
void |
DupRemoveNode.open() |
void |
PlanExecutionNode.open() |
void |
UnionAllNode.open() |
void |
TextTableNode.open() |
void |
SelectNode.open() |
void |
JoinNode.open() |
void |
LimitNode.open() |
void |
DependentProcedureExecutionNode.open() |
void |
RelationalPlan.open() |
void |
ObjectTableNode.open() |
void |
RelationalNode.open() |
void |
BatchedUpdateNode.open() |
void |
UnionAllNode.openInternal() |
void |
JoinNode.openInternal() |
protected void |
JoinStrategy.openLeft() |
protected void |
NestedTableJoinStrategy.openRight() |
protected void |
JoinStrategy.openRight() |
Criteria |
DependentCriteriaProcessor.prepareCriteria() |
protected boolean |
PlanExecutionNode.prepareNextCommand() |
protected boolean |
DependentProcedureExecutionNode.prepareNextCommand() |
protected boolean |
InsertPlanExecutionNode.prepareNextCommand() |
protected boolean |
AccessNode.prepareNextCommand(Command atomicCommand) |
protected boolean |
DependentProcedureAccessNode.prepareNextCommand(Command atomicCommand) |
protected boolean |
DependentAccessNode.prepareNextCommand(Command atomicCommand) |
protected boolean |
DependentProcedureCriteriaProcessor.prepareNextCommand(VariableContext context) |
protected void |
NestedTableJoinStrategy.process() |
protected abstract void |
JoinStrategy.process() |
protected void |
MergeJoinStrategy.process() |
protected void |
EnhancedSortMergeJoinStrategy.process() |
TupleBuffer |
SortUtility.sort() |
TupleBuffer |
SortUtility.sort(int rowLimit) |
static void |
RelationalNode.unwrapException(TeiidRuntimeException e) |
Modifier and Type | Method and Description |
---|---|
void |
XMLTable.compileXqueryExpression() |
Modifier and Type | Method and Description |
---|---|
static <T> String[] |
TextLine.evaluate(List<T> values,
TextLine.ValueExtractor<T> valueExtractor,
TextLine textLine) |
Modifier and Type | Method and Description |
---|---|
Set<Object> |
ValueIteratorSource.getCachedSet(Expression valueExpression) |
Modifier and Type | Method and Description |
---|---|
TempTable |
GlobalTableStoreImpl.createMatTable(String tableName,
GroupSymbol group) |
TempTable |
GlobalTableStore.createMatTable(String tableName,
GroupSymbol group) |
protected abstract TupleSource |
TempTableDataManager.ProxyTupleSource.createTupleSource() |
TupleSource |
TempTable.createTupleSource(List<? extends Expression> projectedCols,
Criteria condition,
OrderBy orderBy) |
TupleSource |
TempTable.delete(Criteria crit) |
TempMetadataID |
GlobalTableStoreImpl.getGlobalTempTableMetadataId(Object viewId) |
TempMetadataID |
GlobalTableStore.getGlobalTempTableMetadataId(Object groupID) |
TupleSource |
TempTable.insert(TupleSource tuples,
List<ElementSymbol> variables,
boolean canUndo,
boolean upsert,
CommandContext context) |
Object |
TempTableDataManager.lookupCodeValue(CommandContext context,
String codeTableName,
String returnElementName,
String keyElementName,
Object keyValue) |
List<?> |
TempTableDataManager.ProxyTupleSource.nextTuple() |
TempTable |
TempTableStore.TableProcessor.process(TempTable tempTable)
Ensure the temp table is ready for use.
|
TempTable |
TempTableStore.RecursiveTableProcessor.process(TempTable tempTable) |
TupleSource |
TempTableDataManager.registerRequest(CommandContext context,
Command command,
String modelName,
RegisterRequestParameter parameterObject) |
void |
TempTableStore.removeTempTableByName(String tempTableName,
CommandContext context) |
TupleSource |
TempTable.update(Criteria crit,
SetClauseList update) |
Modifier and Type | Method and Description |
---|---|
XMLType |
SaxonXQueryExpression.createXMLType(net.sf.saxon.om.SequenceIterator iter,
BufferManager bufferManager,
boolean emptyOnEmpty,
CommandContext context) |
static SaxonXQueryExpression.Result |
XQueryEvaluator.evaluateXQuery(SaxonXQueryExpression xquery,
Object context,
Map<String,Object> parameterValues,
SaxonXQueryExpression.RowProcessor processor,
CommandContext commandContext) |
boolean |
XMLHelperImpl.isValidNCName(String prefix) |
protected TupleBatch |
SaxonXMLTableNode.nextBatchDirect() |
void |
SaxonXMLTableNode.open() |
static String[] |
XMLFunctions.validateQName(String name) |
String[] |
XMLHelperImpl.validateQName(String name) |
static void |
XMLFunctions.validateXpath(String xpath)
Validate whether the XPath is a valid XPath.
|
void |
XMLHelperImpl.validateXpath(String xpath) |
static String |
XMLFunctions.xpathValue(Object doc,
String xpath) |
Copyright © 2020. All rights reserved.