public class SelectFields extends FilterFields
RetainFields
, there are two
significant behavioral differences:
RemapFields
input, output
Constructor and Description |
---|
SelectFields()
Keeps no fields from the input.
|
SelectFields(List<String> fields)
Keeps the specified fields from the input.
|
SelectFields(RecordTextSchema<?> schema)
Keeps the specified fields from the input schema.
|
SelectFields(String... fields)
Keeps the specified fields from the input.
|
Modifier and Type | Method and 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.
|
void |
setSelectionSchema(RecordTextSchema<?> schema)
Sets the schema with the names of the fields
that will be kept.
|
computeMetadata, execute, getFieldNames, setFieldNames, setFieldNames
cloneForExecution, getNumInputCopies, getPortSettings, handleInactiveOutput
disableParallelism, getInputPorts, getOutputPorts, newInput, newInput, newOutput, newRecordInput, newRecordInput, newRecordOutput, notifyError
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
disableParallelism, getInputPorts, getOutputPorts
public SelectFields()
FilterFields.setFieldNames(String...)
.
If no fields are specified when the containing graph is executed,
an error will be raised.public SelectFields(List<String> fields)
fields
- the names of fields to keep.public SelectFields(String... fields)
fields
- the names of fields to keep.public SelectFields(RecordTextSchema<?> schema)
schema
- the schema with the fields to keep.public void setSelectionSchema(RecordTextSchema<?> schema)
schema
- the schema that defines the field selectionpublic RecordPort getInput()
AbstractExecutableRecordPipeline
getInput
in interface PipelineOperator<RecordPort>
getInput
in class AbstractExecutableRecordPipeline
public RecordPort getOutput()
AbstractExecutableRecordPipeline
getOutput
in interface PipelineOperator<RecordPort>
getOutput
in class AbstractExecutableRecordPipeline
Copyright © 2016 Actian Corporation. All rights reserved.