Class DatabaseSplit

java.lang.Object
com.pervasive.datarush.operators.io.jdbc.DatabaseSplit
All Implemented Interfaces:
Serializable

public class DatabaseSplit extends Object implements Serializable
Defines the parameters for one instance of a parameterized query that is run in parallel.

This class is meant for internal use only.

See Also:
  • Constructor Details

    • DatabaseSplit

      public DatabaseSplit()
      Creates a split with no-parameters that is meant to run on all nodes. Generally used in non-parallel mode.
    • DatabaseSplit

      public DatabaseSplit(String nodeAssignment, Object... parameters)
      Creates a split with the given node assignment and set of parameter values.
      Parameters:
      nodeAssignment - node intended to execute this split
      parameters - set of parameter values to apply
    • DatabaseSplit

      public DatabaseSplit(String nodeAssignment, int[] parameterTypes, Object... parameters)
      Creates a split with the given node assignment and set of parameter values.
      Parameters:
      nodeAssignment - node intended to execute this split
      parameters - set of parameter values to apply
  • Method Details

    • getParameterTypes

      public int[] getParameterTypes()
    • getParameters

      public Object[] getParameters()
      Get the parameter values.
      Returns:
      parameter values
    • getNodeAssignment

      public String getNodeAssignment()
      Get the node assignment for this split.
      Returns:
      node assignment
    • isAllNodes

      public boolean isAllNodes()
      Get the setting of the "all nodes" property.
      Returns:
      run on all nodes or not