Module datarush.library

Package com.pervasive.datarush.operators.testutils

Class ErrorSource

java.lang.Object

com.pervasive.datarush.operators.AbstractLogicalOperator

com.pervasive.datarush.operators.StreamingOperator

com.pervasive.datarush.operators.DeferredCompositeOperator

com.pervasive.datarush.operators.testutils.ErrorSource

All Implemented Interfaces:

LogicalOperator, RecordSourceOperator, SourceOperator<RecordPort>

public final class ErrorSource
extends DeferredCompositeOperator
implements RecordSourceOperator

A record source that throws an error either at composition time or execution time.

Field Summary

Fields

Modifier and Type	Field	Description
static String	ERROR_MESSAGE

Constructor Summary

Constructors

Constructor	Description
ErrorSource(RecordTokenType outputType, ErrorConfiguration errorConfig)

Method Summary

Modifier and Type	Method	Description
protected void	compose(DeferredCompositionContext ctx)	Compose the body of this operator.
protected void	computeMetadata(StreamingMetadataContext ctx)	Implementations must adhere to all of the contracts specified by StreamingOperator.computeMetadata(com.pervasive.datarush.operators.StreamingMetadataContext).
ErrorConfiguration	getErrorConfig()
RecordPort	getOutput()	Gets the record port providing the output data from the source.
RecordTokenType	getOutputType()

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

computeOutputTypes

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

Field Detail

ERROR_MESSAGE

public static final String ERROR_MESSAGE

See Also:

Constant Field Values

Constructor Detail

ErrorSource

public ErrorSource(RecordTokenType outputType,
                   ErrorConfiguration errorConfig)

Parameters:

outputType - the type of the record output.

errorConfig - controls whether error thrown at composition time or runtime

Method Detail

getOutputType

public RecordTokenType getOutputType()

getErrorConfig

public ErrorConfiguration getErrorConfig()

getOutput

public RecordPort getOutput()

Description copied from interface: RecordSourceOperator

Gets the record port providing the output data from the source.

Specified by:

getOutput in interface RecordSourceOperator

Specified by:

getOutput in interface SourceOperator<RecordPort>

Returns:

the output port for the source

computeMetadata

protected void computeMetadata(StreamingMetadataContext ctx)

Description copied from class: DeferredCompositeOperator

Implementations must adhere to all of the contracts specified by StreamingOperator.computeMetadata(com.pervasive.datarush.operators.StreamingMetadataContext). In addition, DeferredCompositeOperators must declare required metadata so as to satisfy requirements of the operators that are added during DeferredCompositeOperator.compose(com.pervasive.datarush.operators.DeferredCompositionContext).

Specified by:

computeMetadata in class DeferredCompositeOperator

Parameters:

ctx - the context

compose

protected void compose(DeferredCompositionContext ctx)

Description copied from class: DeferredCompositeOperator

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

1. Instantiate and configure sub-operators, adding them to the provided context via the method OperatorComposable.add(O)
2. 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 DeferredCompositeOperator

Parameters:

ctx - the context