Batch Scalability Functions (4.3)
Â
This chapter describes the functions that support scalable batch workflows: batch workflows that start with a Scalable Inter workflow Collector.
setPartition
This function copies the partition associated with an existing UDR to another UDR.
void setPartition ( drudr to, drudr from )
In scalable workflows, all UDRs must be assigned a partition using the partition profile configured on the collector. UDRs originating at the collector are automatically assigned a partition. Aggregation sessions are also automatically assigned a partition. However, if a workflow creates additional UDRs, the author of the workflow is responsible for ensuring that these UDRs are assigned a partition. This function allows the author to copy the partition of an existing UDR to a newly created UDR.
Parameter | Description |
---|---|
| The UDR to which the partition is copied. |
| The existing UDR from which the partition will be copied. This UDR must have already been assigned a partition either automatically or by other calls to |
Example - using setPartition
A simple APL example of setPartition
:
consume {
  OutputUDR outputUDR = udrCreate(OutputUDR);
setPartition(outputUDR, input);
  udrRoute(outputUDR);
}
Â