MCPcopy Create free account
hub / github.com/crate/crate / execute

Method execute

server/src/main/java/io/crate/planner/Plan.java:68–68  ·  view source on GitHub ↗

Execute the plan, transferring the result to the RowConsumer Implementations must override #executeOrFail(DependencyCarrier, PlannerContext, RowConsumer, Row, SubQueryResults) instead.

(Plan plan,
                        DependencyCarrier dependencies,
                        PlannerContext plannerContext,
                        RowConsumer consumer,
                        Row params,
                        SubQueryResults subQueryResults)

Source from the content-addressed store, hash-verified

66 * Implementations must override {@link #executeOrFail(DependencyCarrier, PlannerContext, RowConsumer, Row, SubQueryResults)} instead.
67 */
68 static void execute(Plan plan,
69 DependencyCarrier dependencies,
70 PlannerContext plannerContext,
71 RowConsumer consumer,

Callers 15

executeMethod · 0.95
executeMethod · 0.95
executeMethod · 0.95
executePlanMethod · 0.95
executePlanMethod · 0.95
executeOrFailMethod · 0.95
executeOrFailMethod · 0.95
executeOrFailMethod · 0.95
quickExecMethod · 0.95
retryQueryMethod · 0.95
singleExecMethod · 0.95

Implementers 15

InsertFromValuesserver/src/main/java/io/crate/planner/
MultiPhasePlanserver/src/main/java/io/crate/planner/
DropForeignTablePlanserver/src/main/java/io/crate/planner/
DropUserMappingPlanserver/src/main/java/io/crate/planner/
DropServerPlanserver/src/main/java/io/crate/planner/
GCDanglingArtifactsPlanserver/src/main/java/io/crate/planner/
DropSchemaPlanserver/src/main/java/io/crate/planner/
NoopPlanserver/src/main/java/io/crate/planner/
SwapTablePlanserver/src/main/java/io/crate/planner/
DropViewPlanserver/src/main/java/io/crate/planner/
AlterServerPlanserver/src/main/java/io/crate/planner/
CreateServerPlanserver/src/main/java/io/crate/planner/

Calls

no outgoing calls

Tested by 15

executeMethod · 0.76
executeMethod · 0.76
executeMethod · 0.76
executePlanMethod · 0.76
executePlanMethod · 0.76
test_mbean_shardsMethod · 0.52
_execute_sqlFunction · 0.52
wait_for_schema_updateFunction · 0.52