Java SDK Documentation
12.0.3
|
Public Member Functions | |
ExecutorPlanContext (ExecutorParamWriter writer, ArrayList< String > clusterNodes, ArrayList< String > targetNodes, boolean canApportionSource, int maxAllowedThreads) | |
ExecutorPlanContext (ExecutorParamWriter writer, ArrayList< String > clusterNodes, ArrayList< String > targetNodes, boolean canApportionSource, int maxAllowedThreads, int actualThreads) | |
boolean | canApportionSource () |
ArrayList< String > | getClusterNodes () |
int | getLoadConcurrency () |
int | getMaxAllowedThreads () |
ParamReader | getReader () |
SourceIterator | getSources () |
ArrayList< String > | getTargetNodes () |
ExecutorParamWriter | getWriter () |
void | setSources (SourceIterator sources) |
void | setTargetNodes (ArrayList< String > nodes) throws UdfException |
A PlanContext object whose scope is limited to a single executor node: it and its parameters will never be serialized. In addition to providing information about nodes involved in a query, it indicates how many threads are available and allocated for a load. This class is used for UDLs.
|
inherited |
|
inherited |
|
inherited |
|
inherited |
Change the set of nodes that the query is intended to run on.
nodes | new target nodes |
UdfException | if any of the specified node names is not actually the name of any node in the cluster. |