Package | Description |
---|---|
com.pervasive.datarush.operators.assertion |
Provides operators for making assertions on flows and files.
|
com.pervasive.datarush.operators.io |
Provides base file I/O components including encoders and decoders.
|
com.pervasive.datarush.operators.partition |
Provides operators for partitioning and unpartitioning flows of data.
|
com.pervasive.datarush.ports.record |
Provides implementations of port objects related to the flow of record sets
between operators.
|
Modifier and Type | Method and Description |
---|---|
DataOrdering |
AssertMetadata.getDataOrdering()
Get the DataOrdering metadata to assert.
|
Modifier and Type | Method and Description |
---|---|
void |
AssertMetadata.setDataOrdering(DataOrdering dataOrdering)
Set the DataOrdering metadata to assert.
|
Modifier and Type | Method and Description |
---|---|
DataOrdering |
FileMetadata.getDataOrdering()
Returns the data ordering of the file.
|
Constructor and Description |
---|
FileMetadata(RecordTokenType type,
DataOrdering dataOrdering,
DataDistribution dataDistribution)
Create a FileMetadata of the given type, ordering, distribution, and parallelism.
|
Modifier and Type | Method and Description |
---|---|
DataOrdering |
PartitionHint.getDataOrdering()
Gets the data ordering of the output.
|
DataOrdering |
GatherHint.getDataOrdering()
Gets the data ordering of the output.
|
Modifier and Type | Method and Description |
---|---|
void |
PartitionHint.setDataOrdering(DataOrdering dataOrdering)
Sets the data ordering of the output.
|
void |
GatherHint.setDataOrdering(DataOrdering dataOrdering)
Sets the data ordering of the output.
|
Modifier and Type | Field and Description |
---|---|
static DataOrdering |
DataOrdering.UNSPECIFIED
The default data ordering if not specified.
|
Modifier and Type | Method and Description |
---|---|
DataOrdering |
RecordPort.getCombinedDataOrdering(MetadataContext ctx)
Gets the required data ordering of this port
|
DataOrdering |
RecordMetadata.getDataOrdering()
Returns the data ordering of the record port.
|
DataOrdering |
RecordPort.getRequiredDataOrdering(MetadataContext ctx)
Gets the required data ordering of this port
|
DataOrdering |
RecordPort.getSourceDataOrdering(MetadataContext ctx)
Returns source data ordering associated with this input port.
|
static DataOrdering |
MetadataUtil.negotiate(DataOrdering ordering,
String... keys)
Negotiates the required sort ordering with the specified ordering using
the given key fields.
|
static DataOrdering |
MetadataUtil.negotiateOrdering(MetadataCalculationContext ctx,
RecordPort port,
String... keys)
Negotiates the required data ordering on the specified port using
the given key fields.
|
DataOrdering |
DataOrdering.remap(FieldRemapping mapping)
Applies the given field remapping to this ordering, changing names as required.
|
Modifier and Type | Method and Description |
---|---|
static DataOrdering |
MetadataUtil.negotiate(DataOrdering ordering,
String... keys)
Negotiates the required sort ordering with the specified ordering using
the given key fields.
|
RecordMetadata |
RecordMetadata.ordered(DataOrdering dataOrdering)
Returns a new RecordMetadata, equivalent to this, but
with ordering set to the specified value.
|
void |
RecordPort.setOutputDataOrdering(MetadataCalculationContext ctx,
DataOrdering ordering)
Sets the data ordering associated with this output port.
|
void |
RecordPort.setRequiredDataOrdering(MetadataCalculationContext ctx,
DataOrdering ordering)
Sets the required data ordering of the given input.
|
Constructor and Description |
---|
RecordMetadata(RecordTokenType type,
DataOrdering dataOrdering,
DataDistribution dataDistribution)
Create a RecordMetadata of the given type, ordering, and distribution.
|
Copyright © 2019 Actian Corporation. All rights reserved.