Module datarush.library

Package com.pervasive.datarush.operators.partition

Class Randomize

java.lang.Object

com.pervasive.datarush.operators.AbstractLogicalOperator

com.pervasive.datarush.operators.CompositeOperator

com.pervasive.datarush.operators.AbstractRecordCompositeOperator

com.pervasive.datarush.operators.partition.Randomize

All Implemented Interfaces:

LogicalOperator, PipelineOperator<RecordPort>, RecordPipelineOperator

public class Randomize
extends AbstractRecordCompositeOperator

Operator that re-orders its input in a random fashion. The output is identical to the input, but ordered randomly and with each record on a random partition.

Field Summary

Fields inherited from class com.pervasive.datarush.operators.AbstractRecordCompositeOperator

input, output

Constructor Summary

Constructors

Constructor	Description
Randomize()	Default Constructor.

Method Summary

Modifier and Type	Method	Description
protected void	compose(CompositionContext ctx)	Compose the body of this operator.
long	getSeed()	Get the random seed used.
void	setSeed(long seed)	Set the random seed used.

Methods inherited from class com.pervasive.datarush.operators.AbstractRecordCompositeOperator

getInput, getOutput

Methods inherited from class com.pervasive.datarush.operators.AbstractLogicalOperator

disableParallelism, getInputPorts, getOutputPorts, newInput, newInput, newOutput, newRecordInput, newRecordInput, newRecordOutput, notifyError

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.pervasive.datarush.operators.LogicalOperator

disableParallelism, getInputPorts, getOutputPorts

Constructor Details

Randomize

public Randomize()

Default Constructor.

Method Details

compose

protected void compose(CompositionContext ctx)

Description copied from class: CompositeOperator

Compose the body of this operator. Implementations should do the following:

1. Perform any validation of configuration, input types, etc
2. Instantiate and configure sub-operators, adding them to the provided context via the method OperatorComposable.add(O)
3. Create necessary connections via the method OperatorComposable.connect(P, P). This includes connections from the composite's input ports to sub-operators, connections between sub-operators, and connections from sub-operators output ports to the composite's output ports

Specified by:

compose in class CompositeOperator

Parameters:

ctx - the context

setSeed

public void setSeed(long seed)

Set the random seed used.

Parameters:

seed - the random seed to set.

getSeed

public long getSeed()

Get the random seed used.

Returns:

the random seed.