Module datarush.library

Package com.pervasive.datarush.operators.testutils

Class ErrorSink

java.lang.Object

com.pervasive.datarush.operators.AbstractLogicalOperator

com.pervasive.datarush.operators.StreamingOperator

com.pervasive.datarush.operators.DeferredCompositeOperator

com.pervasive.datarush.operators.testutils.ErrorSink

All Implemented Interfaces:

LogicalOperator, RecordSinkOperator, SinkOperator<RecordPort>

public final class ErrorSink
extends DeferredCompositeOperator
implements RecordSinkOperator

A record source sink 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
ErrorSink(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	getInput()	Gets the record port providing the input data to the sink.

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

ErrorSink

public ErrorSink(ErrorConfiguration errorConfig)

Parameters:

errorConfig - controls whether error thrown at composition time or runtime

Method Detail

getErrorConfig

public ErrorConfiguration getErrorConfig()

getInput

public RecordPort getInput()

Description copied from interface: RecordSinkOperator

Gets the record port providing the input data to the sink.

Specified by:

getInput in interface RecordSinkOperator

Specified by:

getInput in interface SinkOperator<RecordPort>

Returns:

the input port for the sink

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