Package org.apache.ignite.compute

Interface BroadcastJobTarget

All Known Implementing Classes:
AllNodesBroadcastJobTarget, TableJobTarget
public interface BroadcastJobTarget
Broadcast job execution target.

Determines the rules for selecting nodes to execute a job.

  • Method Details

    • nodes

      static BroadcastJobTarget nodes(ClusterNode... nodes)
      Creates a job target for all nodes from the provided collection.

      This target determines that a job will be executed on all nodes from a given nodes.

      Parameters:
      nodes - Collection of nodes.
      Returns:
      Job target.

    • nodes

      static BroadcastJobTarget nodes(Collection<ClusterNode> nodes)
      Creates a job target for all nodes from the provided collection.

      This target determines that a job will be executed on all nodes from a given collection.

      Parameters:
      nodes - Collection of nodes.
      Returns:
      Job target.

    • nodes

      static BroadcastJobTarget nodes(Set<ClusterNode> nodes)
      Creates a job target for all nodes from the provided collection.

      This target determines that a job will be executed on all nodes from a given set.

      Parameters:
      nodes - Collection of nodes.
      Returns:
      Job target.

    • table

      static BroadcastJobTarget table(String tableName)
      Creates a job target for partitioned execution. For each partition in the provided table the job will be executed on a node that holds the primary replica.
      Parameters:
      tableName - Name of the table with SQL-parser style quotation, e.g. "tbl0" - the table "TBL0" will be looked up, "\"Tbl0\"" - "Tbl0", etc.
      Returns:
      Job target.

    • table

      static BroadcastJobTarget table(QualifiedName tableName)
      Creates a job target for partitioned execution. For each partition in the provided table the job will be executed on a node that holds the primary replica.
      Parameters:
      tableName - QualifiedName name.
      Returns:
      Job target.