Skip to content

RouteQuery

RouteQuery is an abstraction of query routers.

Contract

routeQuery

PartitionFetchResult routeQuery(
  KsqlNode node,
  KsqlPartitionLocation location,
  ConfiguredStatement<Query> statement,
  ServiceContext serviceContext,
  RoutingOptions routingOptions,
  Optional<PullQueryExecutorMetrics> pullQueryMetrics,
  PullPhysicalPlan pullPhysicalPlan,
  LogicalSchema outputSchema,
  QueryId queryId,
  PullQueryQueue pullQueryQueue,
  CompletableFuture<Void> shouldCancelRequests,
  Optional<ConsistencyOffsetVector> consistencyOffsetVector)

Used when:

Implementations