com.pervasive.datarush.operators.source

Class Sequences

java.lang.Object

com.pervasive.datarush.operators.source.Sequences

public final class Sequences
extends Object

Contains sequence functions. NOTE: These functions should not be used within DeriveFields when running distributed.

Method Summary

Modifier and Type	Method and Description
static ScalarValuedFunction	sequence(BigDecimal startValue, BigDecimal stepSize) Creates a sequence function that increments/decrements its value by the specified step size with each invocation.
static ScalarValuedFunction	sequence(double startValue, double stepSize) Creates a sequence function that increments/decrements its value by the specified step size with each invocation.
static ScalarValuedFunction	sequence(float startValue, float stepSize) Creates a sequence function that increments/decrements its value by the specified step size with each invocation.
static ScalarValuedFunction	sequence(int startValue, int stepSize) Creates a sequence function that increments/decrements its value by the specified step size with each invocation.
static ScalarValuedFunction	sequence(long startValue, long stepSize) Creates a sequence function that increments/decrements its value by the specified step size with each invocation.
static ScalarValuedFunction	sequence(ScalarTokenType resultType) Creates a sequence function that increments the value with each invocation.
static ScalarValuedFunction	sequence(ScalarTokenType resultType, BigDecimal startValue, BigDecimal stepSize) Creates a sequence function that increments the value with each invocation.

Methods inherited from class java.lang.Object

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

Method Detail

sequence

public static ScalarValuedFunction sequence(ScalarTokenType resultType)

Creates a sequence function that increments the value with each invocation. The sequence starts at one and is incremented by one each time.

NOTE: this function should not be used within DeriveFields when running distributed. You must disable distribution of DeriveFields; otherwise each partition will see the same sequence.

Parameters:

resultType - the type of the value to produce

Returns:

a sequence function that increments the value with each invocation

sequence

public static ScalarValuedFunction sequence(ScalarTokenType resultType,
                                            BigDecimal startValue,
                                            BigDecimal stepSize)

Creates a sequence function that increments the value with each invocation. The sequence starts at one and is incremented by one each time.

NOTE: this function should not be used within DeriveFields when running distributed. You must disable distribution of DeriveFields; otherwise each partition will see the same sequence.

Parameters:

resultType - the type of the value to produce

startValue - the initial value to return

stepSize - the step size

Returns:

a sequence function that increments the value with each invocation

sequence

public static ScalarValuedFunction sequence(int startValue,
                                            int stepSize)

Creates a sequence function that increments/decrements its value by the specified step size with each invocation.

NOTE: this function should not be used within DeriveFields when running distributed. You must disable distribution of DeriveFields; otherwise each partition will see the same sequence.

Parameters:

startValue - the initial value to return

stepSize - the step size

Returns:

a sequence function that increments/decrements its value by the specified step size with each invocation

sequence

public static ScalarValuedFunction sequence(long startValue,
                                            long stepSize)

Creates a sequence function that increments/decrements its value by the specified step size with each invocation.

NOTE: this function should not be used within DeriveFields when running distributed. You must disable distribution of DeriveFields; otherwise each partition will see the same sequence.

Parameters:

startValue - the initial value to return

stepSize - the step size

Returns:

a sequence function that increments/decrements its value by the specified step size with each invocation

sequence

public static ScalarValuedFunction sequence(float startValue,
                                            float stepSize)

Creates a sequence function that increments/decrements its value by the specified step size with each invocation.

NOTE: this function should not be used within DeriveFields when running distributed. You must disable distribution of DeriveFields; otherwise each partition will see the same sequence.

Parameters:

startValue - the initial value to return

stepSize - the step size

Returns:

a sequence function that increments/decrements its value by the specified step size with each invocation

sequence

public static ScalarValuedFunction sequence(double startValue,
                                            double stepSize)

Creates a sequence function that increments/decrements its value by the specified step size with each invocation.

NOTE: this function should not be used within DeriveFields when running distributed. You must disable distribution of DeriveFields; otherwise each partition will see the same sequence.

Parameters:

startValue - the initial value to return

stepSize - the step size

Returns:

a sequence function that increments/decrements its value by the specified step size with each invocation

sequence

public static ScalarValuedFunction sequence(BigDecimal startValue,
                                            BigDecimal stepSize)

Creates a sequence function that increments/decrements its value by the specified step size with each invocation.

NOTE: this function should not be used within DeriveFields when running distributed. You must disable distribution of DeriveFields; otherwise each partition will see the same sequence.

Parameters:

startValue - the initial value to return

stepSize - the step size

Returns:

a sequence function that increments/decrements its value by the specified step size with each invocation