hi,
i want to pass the ${VALUE} from the partition transformer to the java class it is running, how can i do that?
i want to pass the ${VALUE} from the partition transformer to the java class it is running, how can i do that?
-
Graph parameters can be accessed by calling getGraph().getGraphProperties() method.
So in case of Partition a very small example that sends data to output port given by graph parameter "partitionSetting" would be like this:
public class MyPartition extends DataPartitionFunction {
@Override
public int getOutputPort(DataRecord arg0) throws TransformException {
return Integer.parseInt(getGraph().getGraphProperties().getProperty("partitionSetting"));
}
@Override
public boolean supportsDirectRecord() {
return false;
}
}
Please sign in to leave a comment.
Comments 5