Class JoinNode

java.lang.Object

com.google.adk.workflow.BaseNode

com.google.adk.workflow.JoinNode

All Implemented Interfaces:

Node

@Experimental
public final class JoinNode
extends BaseNode

A node that waits for every predecessor to complete, then outputs their outputs keyed by predecessor name. Route each predecessor into the join every time it completes: one that routes elsewhere still counts as complete, and if it completes last, the join never runs.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	JoinNode.Builder	Builder for JoinNode.

Method Summary

Modifier and Type	Method	Description
static JoinNode.Builder	builder()
boolean	requiresAllPredecessors()	Returns true if the node runs only once every predecessor has completed, receiving all their outputs keyed by node name, as a fan-in node does.
io.reactivex.rxjava3.core.Flowable<?>	runNode(Context context, @Nullable Object nodeInput)	Outputs its input unchanged, or nothing when the input is null.

Methods inherited from class BaseNode

config, description, inputSchema, name, outputSchema, rerunOnResume, stateSchema, waitForOutput

Modifier and Type	Method	Description
NodeConfig	config()	Returns the node's retry policy and execution timeout.
String	description()	Returns what the node does, for humans and for a model that may call it.
Optional<com.google.genai.types.Schema>	inputSchema()	Returns the schema the node's input must match.
final String	name()	Returns the name that identifies the node within its graph.
Optional<com.google.genai.types.Schema>	outputSchema()	Returns the schema that the node's output value must match.
boolean	rerunOnResume()	Returns true if a resumed node runs again from scratch, rather than completing with the resuming answer as its output.
Optional<com.google.genai.types.Schema>	stateSchema()	Returns the schema declaring the state keys the node uses.
boolean	waitForOutput()	Returns true if the node stays re-triggerable until it produces an output or a route, instead of completing when its run completes.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

builder

public static JoinNode.Builder builder()

requiresAllPredecessors

public boolean requiresAllPredecessors()

Description copied from interface: Node

Returns true if the node runs only once every predecessor has completed, receiving all their outputs keyed by node name, as a fan-in node does.

runNode

public io.reactivex.rxjava3.core.Flowable<?> runNode(Context context,
 @Nullable Object nodeInput)

Outputs its input unchanged, or nothing when the input is null.