Package | Description |
---|---|
com.pervasive.datarush.operators.io |
Provides base file I/O components including encoders and decoders.
|
com.pervasive.datarush.ports.record |
Provides implementations of port objects related to the flow of record sets
between operators.
|
Constructor and Description |
---|
FileMetadata(RecordMetadata metadata)
Create a FileMetadata inheriting the setting from a RecordPort's metadata with the specified parallelism.
|
Modifier and Type | Method and Description |
---|---|
RecordMetadata |
RecordMetadata.distributed(DataDistribution dataDistribution)
Returns a new RecordMetadata, equivalent to this, but
with dataDistribution set to the specified value.
|
RecordMetadata |
RecordPort.getCombinedMetadata(MetadataContext ctx)
Returns the actual metadata that the operator will see given its current
requirements and parallelism setting.
|
RecordMetadata |
RecordPort.getRequiredMetadata(MetadataContext ctx)
Returns the required metadata associated with this port
|
RecordMetadata |
RecordPort.getSourceMetadata(MetadataContext ctx)
Returns the metadata associated with this port
|
RecordMetadata |
RecordMetadata.mutating(List<String> modifiedFields)
Computes the resulting metadata assuming that the specified fields
may be mutated.
|
RecordMetadata |
RecordMetadata.ordered(DataOrdering dataOrdering)
Returns a new RecordMetadata, equivalent to this, but
with ordering set to the specified value.
|
RecordMetadata |
RecordMetadata.remap(FieldRemapping mapping)
Computes the resulting metadata after applying the specified schema
remapping.
|
RecordMetadata |
RecordMetadata.stagingOptions(DatasetOptions stagingOptions)
Returns a new RecordMetadata, equivalent to this, but
with stagingOptions set to the specified value.
|
Modifier and Type | Method and Description |
---|---|
Class<RecordMetadata> |
RecordPort.getMetadataType() |
Copyright © 2019 Actian Corporation. All rights reserved.