Module datarush.library

Package com.pervasive.datarush.operators.record

Class RemoveFields

java.lang.Object

com.pervasive.datarush.operators.AbstractLogicalOperator

com.pervasive.datarush.operators.StreamingOperator

com.pervasive.datarush.operators.ExecutableOperator

com.pervasive.datarush.operators.AbstractExecutableRecordPipeline

com.pervasive.datarush.operators.record.FilterFields

com.pervasive.datarush.operators.record.RemoveFields

All Implemented Interfaces:

LogicalOperator, PipelineOperator<RecordPort>, RecordPipelineOperator

public class RemoveFields
extends FilterFields

Removes a subset of fields from the input records. Only those fields not named in the filter are copied to the output; if a field specified in the filter does not exist in the input, it is ignored. The relative order of fields within the records is unchanged.

See Also:

• RemapFields

Field Summary

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

input, output

Constructor Summary

Constructors

Constructor	Description
RemoveFields()	Removes no fields from the input.
RemoveFields(List<String> fields)	Removes the specified fields from the input.

Method Summary

Modifier and Type	Method	Description
RecordPort	getInput()	Gets the record port providing the input data to the operation.
RecordPort	getOutput()	Gets the record port providing the output from the operation.

Methods inherited from class com.pervasive.datarush.operators.record.FilterFields

computeMetadata, execute, getFieldNames, setFieldNames, setFieldNames

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

cloneForExecution, getNumInputCopies, getPortSettings, handleInactiveOutput

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

RemoveFields

public RemoveFields()

Removes no fields from the input. To specify fields to remove, use FilterFields.setFieldNames(String...)

RemoveFields

public RemoveFields(List<String> fields)

Removes the specified fields from the input. If the filter specifies all fields when the containing graph is executed, an error will be raised.

Parameters:

fields - the names of fields to remove.

Method Details

getInput

public RecordPort getInput()

Description copied from class: AbstractExecutableRecordPipeline

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

Specified by:

getInput in interface PipelineOperator<RecordPort>

Overrides:

getInput in class AbstractExecutableRecordPipeline

Returns:

the input port for the operation

getOutput

public RecordPort getOutput()

Description copied from class: AbstractExecutableRecordPipeline

Gets the record port providing the output from the operation.

Specified by:

getOutput in interface PipelineOperator<RecordPort>

Overrides:

getOutput in class AbstractExecutableRecordPipeline

Returns:

the output port for the operation