Package | Description |
---|---|
com.actian.dataflow.hive.shims | |
com.actian.dataflow.operators.io.orc | |
com.actian.dataflow.operators.io.parquet | |
com.pervasive.datarush.analytics.arm |
Provides common classes for Association Rule Mining (ARM).
|
com.pervasive.datarush.analytics.cluster |
Provides base PMML for clustering models.
|
com.pervasive.datarush.analytics.decisiontree.predictor |
Provides the decision tree predictor operator and associated classes.
|
com.pervasive.datarush.analytics.naivebayes.predictor |
Provides an implementation of a Naive Bayes predictor.
|
com.pervasive.datarush.analytics.pmml |
Provides shared and base classes for PMML model representation of Analytics algorithms.
|
com.pervasive.datarush.analytics.r | |
com.pervasive.datarush.analytics.regression |
Provides utility, PMML and other classes for shared use by regression related entities.
|
com.pervasive.datarush.analytics.svm.predictor |
Provides an implementation of an SVM predictor.
|
com.pervasive.datarush.analytics.util |
Provides some (internal) utility classes for Analytics.
|
com.pervasive.datarush.encoding.binary |
Implementations of encoders of tokens
into binary formats.
|
com.pervasive.datarush.functions |
Provides classes and interfaces related to defining functions on records.
|
com.pervasive.datarush.hbase | |
com.pervasive.datarush.operators.assertion |
Provides operators for making assertions on flows and files.
|
com.pervasive.datarush.operators.group |
Provides data aggregation components.
|
com.pervasive.datarush.operators.io |
Provides base file I/O components including encoders and decoders.
|
com.pervasive.datarush.operators.io.avro |
Provides operators for reading and writing files in Avro format.
|
com.pervasive.datarush.operators.io.jdbc |
Provides operators for reading from JDBC sources and writing to JDBC targets.
|
com.pervasive.datarush.operators.io.paraccel | |
com.pervasive.datarush.operators.io.staging |
Provides operators for reading and writing DataRush staging datasets.
|
com.pervasive.datarush.operators.io.textfile |
Provides operators for reading and writing text data.
|
com.pervasive.datarush.operators.join |
Provides operators for joining together two data sets into a single one.
|
com.pervasive.datarush.operators.record |
Provides operators for manipulating record structure.
|
com.pervasive.datarush.operators.scripting |
Provides the
RunScript
operator for running user-defined scripts on the rows of an input record flow. |
com.pervasive.datarush.operators.source |
Provides operators for generating data tokens in various ways.
|
com.pervasive.datarush.ports.physical |
Provides classes and interfaces for accessing and producing the data flowing
between operators in a dataflow graph.
|
com.pervasive.datarush.ports.record |
Provides implementations of port objects related to the flow of record sets
between operators.
|
com.pervasive.datarush.schema |
Provides an object model for capturing schema information used primarily by the
textfile package. |
com.pervasive.datarush.sequences |
Provides classes and interfaces related to sequences of tokens.
|
com.pervasive.datarush.sequences.record |
Provides implementations of sequences of record valued tokens.
|
com.pervasive.datarush.tokens |
Provides classes and utilities for working with data tokens.
|
com.pervasive.datarush.tokens.record |
Provides implementations of and utilities for record valued
tokens.
|
com.pervasive.datarush.types |
Provides classes and interfaces for the description of token data types.
|
com.pervasive.datarush.util |
Provides common utilities
|
Modifier and Type | Method and Description |
---|---|
RecordTokenType |
ParquetFileShimImpl.getType() |
RecordTokenType |
ParquetFileShim.getType()
Get the record type of the Parquet file.
|
RecordTokenType |
ORCFileShim.getType()
Get the record type of the ORC file.
|
Modifier and Type | Method and Description |
---|---|
RecordTokenType |
ORCMetadata.getType() |
RecordTokenType |
ORCFormat.getType() |
Constructor and Description |
---|
ORCMetadata(RecordTokenType type) |
Modifier and Type | Method and Description |
---|---|
RecordTokenType |
ParquetMetadata.getType() |
RecordTokenType |
ParquetFormat.getType() |
Constructor and Description |
---|
ParquetMetadata(RecordTokenType type) |
Modifier and Type | Method and Description |
---|---|
static PMMLModelSpec |
MetadataHelper.createPMMLSpec(RecordTokenType inputType,
String txnFieldName,
String itemFieldName)
Build the PMML model specification for an ARM model given the transaction field and item field names.
|
Modifier and Type | Method and Description |
---|---|
protected RecordTokenType |
ClusterPredictor.predictedType(PMMLModelSpec modelSpec) |
Modifier and Type | Method and Description |
---|---|
protected RecordTokenType |
DecisionTreePredictor.predictedType(PMMLModelSpec modelSpec) |
Modifier and Type | Method and Description |
---|---|
protected RecordTokenType |
NaiveBayesPredictor.predictedType(PMMLModelSpec spec) |
Modifier and Type | Method and Description |
---|---|
RecordTokenType |
PMMLModelSpec.getInputType()
Returns the input type for which we are constructing a model
|
RecordTokenType |
PMMLModelSpec.getTargetType()
Returns the target type.
|
Modifier and Type | Method and Description |
---|---|
static PMMLModelSpec |
PMMLModelSpec.forAll(RecordTokenType inputType,
String... targetColumns)
Convenience method to create a model spec where the learning columns
are all input columns minus the target columns
|
static PMMLModelSpec |
PMMLModelSpec.forSelected(RecordTokenType inputType,
List<String> selectedColumns,
String... targetColumns)
Convenience method to create a model spec where the learning columns
are the specified selected columns minus the set of target columns.
|
Constructor and Description |
---|
PMMLModelSpec(RecordTokenType inputType,
List<String> learningCols,
List<String> targetCols)
Creates a PMMLModelSpec for the given input
|
Modifier and Type | Method and Description |
---|---|
RecordTokenType |
RunRScript.getOutputType()
Get the configured output type.
|
Modifier and Type | Method and Description |
---|---|
void |
RunRScript.setOutputType(RecordTokenType outputType)
Configure the output token type.
|
Modifier and Type | Method and Description |
---|---|
protected RecordTokenType |
RegressionPredictor.predictedType(PMMLModelSpec modelSpec) |
protected RecordTokenType |
LogisticRegressionPredictor.predictedType(PMMLModelSpec modelSpec) |
Modifier and Type | Method and Description |
---|---|
protected RecordTokenType |
SVMPredictor.predictedType(PMMLModelSpec modelSpec) |
Modifier and Type | Method and Description |
---|---|
RecordTokenType |
MixedTypeMetadataHelper.getAllLearningColumns() |
RecordTokenType |
MixedTypeMetadataHelper.getContinuousLearningColumns() |
RecordTokenType |
MixedTypeMetadataHelper.getDiscreteLearningColumns() |
RecordTokenType |
MixedTypeMetadataHelper.getUnfilteredType() |
protected abstract RecordTokenType |
AbstractPredictor.predictedType(PMMLModelSpec modelSpec)
Given the model spec, returns the predicted type.
|
Modifier and Type | Method and Description |
---|---|
static boolean |
MixedTypeMetadataHelper.hasDomain(RecordTokenType unfilteredType,
List<String> includedColumns,
String targetColumn) |
Constructor and Description |
---|
MixedTypeMetadataHelper(RecordTokenType unfilteredType,
List<String> includedColumns,
String targetColumn,
int maxDistinctNominalValues) |
Modifier and Type | Method and Description |
---|---|
TokenDecoder |
TokenEncodings.allocateRecordDecoder(RecordTokenType type,
ComparableTokenDecoder[] comparableDecoders,
TokenDecoder[] fieldDecoders)
Creates a record decoder from a list of field decoders for the fields in the
record.
|
TokenEncoder |
TokenEncodings.allocateRecordEncoder(RecordTokenType type,
ComparableTokenEncoder[] comparableEncoders,
TokenEncoder[] fieldEncoders)
Creates a record encoder from a list of field encoders for the fields in the
record.
|
Modifier and Type | Method and Description |
---|---|
ScalarTokenType |
ScalarValuedFunction.validateInputType(RecordTokenType inputType)
Calculates the actual output type of the function given the specified input type.
|
ScalarTokenType |
FieldReference.validateInputType(RecordTokenType inputType) |
ScalarTokenType |
ConstantReference.validateInputType(RecordTokenType inputType) |
Modifier and Type | Method and Description |
---|---|
void |
HBasePartitioningFunction.validateForType(RecordTokenType type) |
Modifier and Type | Method and Description |
---|---|
void |
AssertEqualTypes.setExpectedType(RecordTokenType expectedType)
Set the expected type of the actual value input port.
|
Constructor and Description |
---|
AssertEqualTypes(RecordTokenType expectedType)
Construct with an expected type for the actual data input port.
|
Modifier and Type | Method and Description |
---|---|
void |
Aggregation.validateInputType(RecordTokenType inputType)
Validate the input types to this aggregation.
|
Modifier and Type | Method and Description |
---|---|
RecordTokenType |
FileMetadata.getType()
Returns the record data type of the file.
|
RecordTokenType |
DataFormat.getType()
Gets the record type associated with the format.
|
Constructor and Description |
---|
FileMetadata(RecordTokenType type)
Create a FileMetadata of the given type and unspecified ordering and partitioning.
|
FileMetadata(RecordTokenType type,
DataOrdering dataOrdering,
DataDistribution dataDistribution)
Create a FileMetadata of the given type, ordering, distribution, and parallelism.
|
Modifier and Type | Method and Description |
---|---|
static RecordTokenType |
AvroSchemaUtils.determineType(org.apache.avro.Schema schema)
Maps an Avro schema to a DataRush record type.
|
RecordTokenType |
AvroFormat.getType() |
Modifier and Type | Method and Description |
---|---|
static org.apache.avro.Schema |
AvroSchemaUtils.generateSchema(RecordTokenType type)
Creates an Avro schema from the given DataRush record type.
|
Modifier and Type | Method and Description |
---|---|
RecordTokenType |
ReadFromJDBC.discoverType()
Discovers the output type based on this operator's configuration.
|
RecordTokenType |
ReadFromJDBC.getOutputType()
Get the configured output type.
|
RecordTokenType |
AbstractWriteToJDBC.AbstractWriteToJDBCWorker.getOutputType(RecordTokenType inputType) |
Modifier and Type | Method and Description |
---|---|
RecordTokenType |
AbstractWriteToJDBC.AbstractWriteToJDBCWorker.getOutputType(RecordTokenType inputType) |
void |
ReadFromJDBC.setOutputType(RecordTokenType outputType)
Set the record type of the output port of this operator.
|
Constructor and Description |
---|
ReadFromJDBC(String dataQuery,
RecordTokenType outputType)
Creates a new instance of
CopyOfReadFromJDBC , specifying
the minimal set of required parameters. |
Modifier and Type | Method and Description |
---|---|
RecordTokenType |
MatrixSinkInitializeWorker.getInputType() |
Modifier and Type | Method and Description |
---|---|
protected MatrixOperatorBase.Workers<Void> |
MatrixSink.createWorkers(CompositionContext ctx,
RecordTokenType inputType,
com.pervasive.datarush.operators.io.paraccel.TableInfo tableInfo,
List<String> columns,
Map<String,String> columnMap,
int startPortRange,
int endPortRange,
int dataWorkerParallelism) |
protected abstract MatrixOperatorBase.Workers<ExecState> |
MatrixOperatorBase.createWorkers(CompositionContext ctx,
RecordTokenType inputType,
com.pervasive.datarush.operators.io.paraccel.TableInfo tableInfo,
List<String> columns,
Map<String,String> columnMap,
int startPortRange,
int endPortRange,
int dataWorkerParallelism) |
protected MatrixOperatorBase.Workers<com.pervasive.datarush.operators.io.paraccel.ODIInvoker> |
LoadMatrix.createWorkers(CompositionContext ctx,
RecordTokenType inputType,
com.pervasive.datarush.operators.io.paraccel.TableInfo tableInfo,
List<String> columns,
Map<String,String> columnMap,
int startPortRange,
int endPortRange,
int dataWorkerParallelism) |
void |
MatrixSinkInitializeWorker.setInputType(RecordTokenType inputType) |
Constructor and Description |
---|
MatrixSinkInitializeWorker(String coordHost,
int coordPort,
RecordTokenType inputType,
com.pervasive.datarush.operators.io.paraccel.TableInfo tableInfo) |
Modifier and Type | Method and Description |
---|---|
RecordTokenType |
DatasetIterator.getType() |
Constructor and Description |
---|
DatasetBuilder(FileClient client,
Path dataset,
int bufferSize,
TokenEncodings baseEncodings,
RecordTokenType type,
WriteMode mode,
int blockSize)
Creates and opens the builder.
|
DatasetBuilder(FileClient client,
String dataset,
int bufferSize,
TokenEncodings baseEncodings,
WriteMode mode,
RecordTokenType type)
Creates and opens the builder.
|
Modifier and Type | Method and Description |
---|---|
RecordTokenType |
SyslogLogFormat.getType() |
RecordTokenType |
LogFormat.getType()
Gets the record type associated with the format.
|
RecordTokenType |
LogDataFormat.getType() |
RecordTokenType |
Log4jLogFormat.getType() |
RecordTokenType |
GlassfishLogFormat.getType() |
RecordTokenType |
GenericLogFormat.getType() |
RecordTokenType |
FixedTextFormat.getType() |
RecordTokenType |
ELFLogFormat.getType() |
RecordTokenType |
DelimitedTextFormat.getType() |
RecordTokenType |
CombinedLogFormat.getType() |
RecordTokenType |
CLFLogFormat.getType() |
RecordTokenType |
ARFFDataFormat.getType() |
Modifier and Type | Method and Description |
---|---|
static RecordTokenType |
UnionAll.generateSchema(RecordTokenType leftType,
RecordTokenType rightType,
UnionAll.UnionMode mode,
boolean keepExtraFields)
Generate a schema for the union of two records.
|
Modifier and Type | Method and Description |
---|---|
static RecordTokenType |
UnionAll.generateSchema(RecordTokenType leftType,
RecordTokenType rightType,
UnionAll.UnionMode mode,
boolean keepExtraFields)
Generate a schema for the union of two records.
|
Modifier and Type | Method and Description |
---|---|
RecordTokenType |
DiscoverDomain.getResult()
Returns the discovered result
|
Modifier and Type | Method and Description |
---|---|
abstract void |
FieldDerivation.collectMapping(RecordTokenType inputType,
Map<String,ScalarValuedFunction> mappings)
Verifies derivation can be applied in the given input context and
records the field mapping.
|
Modifier and Type | Method and Description |
---|---|
RecordTokenType |
RunScript.getOutputType()
Get the defined output type.
|
RecordTokenType |
RunJavaScript.getOutputType() |
Modifier and Type | Method and Description |
---|---|
void |
RunScript.setOutputType(RecordTokenType outputType)
Set the output type.
|
void |
RunJavaScript.setOutputType(RecordTokenType outputType) |
Constructor and Description |
---|
RunScript(String engineName,
String onEveryRecordScript,
RecordTokenType outputType)
Construct a run script operator with the minimum parameters required for execution.
|
Modifier and Type | Method and Description |
---|---|
RecordTokenType |
GenerateRandom.getOutputType()
Returns the data type of the generated values
|
RecordTokenType |
GenerateArithmeticSequence.getOutputType()
Returns the output type.
|
Modifier and Type | Method and Description |
---|---|
void |
GenerateRandom.setOutputType(RecordTokenType outputType)
Sets the data type of the generated values
|
void |
GenerateArithmeticSequence.setOutputType(RecordTokenType outputType)
Sets the output type.
|
Constructor and Description |
---|
GenerateArithmeticSequence(long rowCount,
RecordTokenType outputType)
Generate an arithmetic sequence of the given number of rows and type.
|
GenerateRandom(RecordTokenType type,
long rowCount)
Creates a new instance of
GenerateRandom , specifying
the minimal set of required parameters. |
Modifier and Type | Method and Description |
---|---|
RecordTokenType |
RecordOutput.getType() |
RecordTokenType |
RecordInput.getType() |
Modifier and Type | Method and Description |
---|---|
RecordTokenType |
RangePartitioningFunction.getBoundaryType()
Returns the boundary type determined by the widest type of all boundaries
|
RecordTokenType |
ExternalRecordSource.getOutputType()
Returns the output record type of this sink
|
RecordTokenType |
RecordMetadata.getType()
Returns the type of the record.
|
RecordTokenType |
RecordPort.getType(MetadataContext ctx)
Returns the record type of this port.
|
Modifier and Type | Method and Description |
---|---|
void |
ExternalRecordSource.setOutputType(RecordTokenType outputType)
Sets the output record type of this sink
|
void |
RecordPort.setType(MetadataCalculationContext ctx,
RecordTokenType type)
Sets the type associated with this port.
|
void |
RangePartitioningFunction.validateForType(RecordTokenType type) |
void |
PartitioningFunction.validateForType(RecordTokenType type)
Performs validation of the specified input type
|
void |
HashPartitioningFunction.validateForType(RecordTokenType type) |
Constructor and Description |
---|
ExternalRecordSource(RecordTokenType outputType)
Creates a new record source of the given type.
|
RecordMetadata(RecordTokenType type)
Create a RecordMetadata of the given type and unspecified ordering and partitioning.
|
RecordMetadata(RecordTokenType type,
DataOrdering dataOrdering,
DataDistribution dataDistribution)
Create a RecordMetadata of the given type, ordering, and distribution.
|
Modifier and Type | Method and Description |
---|---|
RecordTokenType |
RecordTextSchema.getTokenType()
Gets the type of the token representation of the
text record.
|
Modifier and Type | Method and Description |
---|---|
static TextRecord |
TextRecord.convert(RecordTokenType type)
Generates a text file schema from a token type.
|
static TextRecord |
TextRecord.convert(RecordTokenType type,
TextConversionDefaults defaults)
Generates a text file schema from a token type, using the
specified schema-wide default behavior.
|
static TextRecord |
TextRecord.convert(RecordTokenType type,
TextTypes.StringConversion behavior)
Generates a text file schema from a token type, using the
specified string conversion default behavior.
|
TextRecord |
TextRecordDiscoverer.generateForWrite(RecordTokenType recordTokenType,
TextConversionDefaults defaults)
Constructs a schema for writing based on the given record type.
|
TextRecord |
PatternBasedDiscovery.generateForWrite(RecordTokenType type,
TextConversionDefaults defaults) |
Modifier and Type | Method and Description |
---|---|
static MutableRecordTokenSequence |
TokenSequences.recordList(RecordTokenType type,
int capacity,
DataRepresentation representation)
Creates a
MutableRecordTokenSequence with the specified capacity, optionally
optimized for sparse data. |
Modifier and Type | Method and Description |
---|---|
RecordTokenType |
SparseRecordTokenList.getType() |
RecordTokenType |
SeekableRecordValuedIterator.getType() |
Constructor and Description |
---|
CompositeTokenSequence(RecordTokenType type,
ScalarTokenSequence[] columns)
Create a new sequence backed with the specified scalar token
sequences containing the field values for each record element.
|
RecordTokenList(RecordTokenType type,
int capacity)
Create an empty array with the specified type.
|
RecordTokenList(RecordTokenType type,
MutableScalarTokenSequence[] columns)
Create a new array backed with the specified scalar token
arrays containing the field values for each record element.
|
SparseRecordTokenList(RecordTokenType type,
int capacity)
Create an empty array with the specified type.
|
Modifier and Type | Method and Description |
---|---|
static TokenConverter[] |
TokenConverters.getConverters(RecordTokenType type)
Creates an array of converters for each scalar type in the given record type.
|
Modifier and Type | Method and Description |
---|---|
RecordTokenType |
RecordToIDMap.getKeyType()
Returns the type of keys contained within this map.
|
RecordTokenType |
RecordMap.getKeyType()
Returns the token type of the keys of the map.
|
RecordTokenType |
SparseRecordRegister.getType() |
RecordTokenType |
RecordValuedFilter.getType() |
RecordTokenType |
RecordValued.getType() |
RecordTokenType |
RecordSettableFilter.getType() |
RecordTokenType |
RecordSettable.getType() |
RecordTokenType |
RecordRegisterStorage.RecordInfo.getType() |
RecordTokenType |
RecordMap.getType()
Get the token type of the cached data.
|
RecordTokenType |
RecordMap.RecordMapIterator.getType() |
RecordTokenType |
MutableComposite.getType() |
RecordTokenType |
AbstractRecordValued.getType() |
Modifier and Type | Method and Description |
---|---|
static RecordToken |
RecordToken.NULL(RecordTokenType recordType)
Create a new null valued record token of the specified type.
|
static RecordToken |
RecordToken.ZERO(RecordTokenType recordType)
Create a new zero valued record token of the specified type.
|
Constructor and Description |
---|
AbstractRecordValued(RecordTokenType type,
F[] fieldValues,
boolean validateType,
ModificationCountProvider modificationCountProvider)
Constructs a value using the given elements as the
field elements, using the specified type.
|
AbstractRecordValued(RecordTokenType type,
F[] fieldValues,
ModificationCountProvider modificationCountProvider)
Constructs a value using the given elements as the
field elements, using the specified type.
|
CompositeValue(RecordTokenType type,
ScalarValued[] fields)
Construct a composite with the described schema using
the supplied
ScalarValued objects. |
CompositeValue(RecordTokenType type,
ScalarValued[] fields,
ModificationCountProvider modCountProvider)
Construct a composite with the described schema using
the supplied
ScalarValued objects. |
FieldIteratorHelper(RecordTokenType recordType,
FieldIteratorProperties properties)
Create a new FieldIteratorHelper.
|
MutableComposite(RecordTokenType type,
ScalarSettable[] fields)
Construct a composite with the described schema using
the supplied
ScalarSettable objects. |
RecordMap.Builder(RecordTokenType inputType,
String[] keyFieldNames,
int initialCapacity)
Create a new record map builder.
|
RecordRegister(RecordTokenType type)
Constructs a new null-valued register with the given record type.
|
RecordRegisterStorage.RecordInfo(RecordTokenType type) |
RecordRegisterSupport(RecordTokenType type,
RecordRegisterSupport.Access access) |
RecordRegisterSupport(RecordTokenType type,
RecordRegisterSupport.Access access,
RecordRegisterStorage storage,
boolean storageFixed) |
RecordSettableFilter(RecordTokenType type,
RecordSettable target)
Defines a
RecordSettable declaring the specified
type, backed by the underlying target. |
RecordToIDMap(RecordTokenType keyType,
int initialCapacity)
Create a new RecordToIDMap
|
RecordToken(RecordTokenType type,
ScalarValued... fieldValues)
Constructs a new token with the specified field types, using the
field values in the given containers.
|
RecordValuedFilter(RecordTokenType targetType,
Map<String,String> targetToSourceNameMapping,
RecordValued source)
Defines a
RecordValued object, declaring the specified
type, backed by the underlying source. |
RecordValuedFilter(RecordTokenType targetType,
Map<String,String> targetToSourceNameMapping,
RecordValued source,
ModificationCountProvider modificationCountProvider)
Defines a
RecordValued object, declaring the specified
type, backed by the underlying source. |
RecordValuedFilter(RecordTokenType targetType,
RecordValued source)
Defines a
RecordValued object, declaring the specified
type, backed by the underlying source. |
RecordValuedFilter(RecordTokenType targetType,
RecordValued source,
ModificationCountProvider modificationCountProvider)
Defines a
RecordValued object, declaring the specified
type, backed by the underlying source. |
SparseRecordRegister(RecordTokenType type)
Constructs a new register with the given record type.
|
Modifier and Type | Field and Description |
---|---|
static RecordTokenType |
TokenTypeConstant.RECORD
An abstract type representing any record type.
|
Modifier and Type | Method and Description |
---|---|
static RecordTokenType |
TypeUtil.addSourceInfoFields(RecordTokenType type)
Constructs the output type used when tagging with source information fields.
|
static RecordTokenType |
TypeUtil.annotate(RecordTokenType type,
String propertyName,
String propertyValue)
Returns a new RecordTokenType with the given annotation applied to all
of its fields.
|
RecordTokenType |
FieldRemapping.apply(RecordTokenType srcType,
Map<String,String> mapping)
Computes the result of applying the transformation to a record type.
|
static RecordTokenType |
TypeUtil.deriveSchema(ScalarTyped... columns)
Builds a default record schema using the types of the specified
columnar objects.
|
static <T extends ScalarTyped & Named> |
TypeUtil.getRecordType(T... fields)
Computes the record type which a composite of the specified fields would have.
|
RecordTokenType |
RecordTyped.getType() |
static RecordTokenType |
TypeUtil.homogeneousRecord(int size,
ScalarTokenType fieldType,
String fieldBase)
Constructs a record type descriptor in which all fields have the same
type.
|
static RecordTokenType |
TypeUtil.matchFieldNames(RecordTokenType source,
RecordTokenType match)
Utility for renaming the fields of a given record type to match that of
another.
|
static RecordTokenType |
TypeUtil.merge(RecordTokenType... types)
Merges the specified record types into a new one, handling name collisions
by renaming.
|
static RecordTokenType |
TypeUtil.mergeTypes(TokenType... types)
Merges the specified types into a single record type, handling name collisions
by renaming.
|
static RecordTokenType |
TypeUtil.mutating(RecordTokenType type,
Collection<String> modifiedFields)
Computes the resulting type assuming that the specified fields
may be mutated.
|
static RecordTokenType |
TypeUtil.nonUnique(RecordTokenType type)
Returns a RecordTokenType, equivalent to the original, but with all
primaryKey
flags set to false |
static RecordTokenType |
TypeUtil.overlay(RecordTokenType... types)
Merges the specified record types into a new record type, handling name collisions
with a last-one-wins mechanism.
|
static RecordTokenType |
TokenTypeConstant.record(Field... fields)
Constructs a record type descriptor with the given fields.
|
static RecordTokenType |
TypeUtil.remove(RecordTokenType source,
List<String> removed)
Creates a new record type containing all fields from the source type except
those matching one of the specified field names.
|
static RecordTokenType |
TypeUtil.remove(RecordTokenType source,
String... removed)
Creates a new record type containing all fields from the source type except
those matching one of the specified field names.
|
static RecordTokenType |
TypeUtil.rename(RecordTokenType source,
Map<String,String> sourceToTargetNameMap)
Utility for renaming fields in the source type using the given source
and target field names.
|
static RecordTokenType |
TypeUtil.rename(RecordTokenType source,
String[] sourceNames,
String[] targetNames)
Utility for renaming fields in the source type using the given source
and target field names.
|
static RecordTokenType |
TypeUtil.reorderAndRename(RecordTokenType source,
String[] sourceNames,
String[] targetNames)
Utility for the renaming/reordering of a given record type.
|
static RecordTokenType |
TypeUtil.retain(RecordTokenType source,
List<String> retained)
Creates a new record type containing only fields from the source type which
match one of the specified field names.
|
static RecordTokenType |
TypeUtil.retain(RecordTokenType source,
String... retained)
Creates a new record type containing only fields from the source type which
match one of the specified field names.
|
static RecordTokenType |
TypeUtil.select(RecordTokenType source,
List<String> selected)
Creates a new record type containing only fields from the source type which
match one of the specified field names.
|
static RecordTokenType |
TypeUtil.select(RecordTokenType source,
String... selected)
Creates a new record type containing only fields from the source type which
match one of the specified field names.
|
static RecordTokenType |
TokenTypeConstant.sparseRecord(Field... fields)
Constructs a record type descriptor with the given fields.
|
static RecordTokenType |
TypeUtil.strictOverlay(boolean dropUnique,
RecordTokenType... types)
Merges the specified record types into a new record type, allowing name collisions
only if
isAssignableFrom() is true for the types. |
RecordTokenType |
RecordTokenType.toRepresentation(DataRepresentation representation)
Returns a RecordTokenType, equivalent to this, but whose representation
is that specified.
|
RecordTokenType |
RecordTokenTypeBuilder.toType()
Gets the record schema currently defined by this collection.
|
static RecordTokenType |
TypeUtil.toType(DataRepresentation representation,
Namespace<ScalarTokenType> namespace)
Converts from a list of fields to a record token type.
|
static RecordTokenType |
TypeUtil.validateFieldSelection(String propertyName,
RecordTokenType source,
String... selected)
Validates a set of field names against the source type, computing the
resulting type.
|
static RecordTokenType |
TypeUtil.widestNamedType(RecordTokenType... types)
Calculates the record type for which
isAssignableFrom()
is true for all of the specified types matched by name. |
static RecordTokenType |
TypeUtil.widestType(RecordTokenType... types)
Calculates the record type for which
isAssignableFrom()
is true for all of the specified types. |
static RecordTokenType |
TypeUtil.withDomainValues(RecordTokenType type,
String fieldName,
Set<String> discovered)
Returns a new RecordTokenType with domain values set to the discovered values.
|
static RecordTokenType |
TypeUtil.wrap(List<? extends ScalarTokenType> types)
Creates a new record type with the specified field types.
|
static RecordTokenType |
TypeUtil.wrap(String prefix,
List<? extends ScalarTokenType> types)
Creates a new record schema with the specified field types.
|
static RecordTokenType |
TypeUtil.wrap(String name,
ScalarTokenType type)
Creates a new record type with a single named field of the given type.
|
Modifier and Type | Method and Description |
---|---|
static RecordTokenType |
TypeUtil.addSourceInfoFields(RecordTokenType type)
Constructs the output type used when tagging with source information fields.
|
static RecordTokenType |
TypeUtil.annotate(RecordTokenType type,
String propertyName,
String propertyValue)
Returns a new RecordTokenType with the given annotation applied to all
of its fields.
|
RecordTokenType |
FieldRemapping.apply(RecordTokenType srcType,
Map<String,String> mapping)
Computes the result of applying the transformation to a record type.
|
void |
TypeDispatchedConstructor.dispatchRecordType(RecordTokenType recordType) |
void |
TokenValueExtractor.dispatchRecordType(RecordTokenType recordType) |
void |
TokenTypeDispatcher.dispatchRecordType(RecordTokenType recordType)
Handle processing for record typed tokens.
|
static ScalarTokenType[] |
TypeUtil.getTypes(RecordTokenType type)
Returns the types of the fields of this record type.
|
static boolean |
TypeUtil.hasDomainValues(RecordTokenType type)
Returns whether all of the fields in the given type have domain values.
|
static boolean |
TypeUtil.hasDomainValues(RecordTokenType type,
String field)
Returns whether the given field has domain values defined.
|
static RecordTokenType |
TypeUtil.matchFieldNames(RecordTokenType source,
RecordTokenType match)
Utility for renaming the fields of a given record type to match that of
another.
|
static RecordTokenType |
TypeUtil.merge(RecordTokenType... types)
Merges the specified record types into a new one, handling name collisions
by renaming.
|
static RecordTokenType |
TypeUtil.mutating(RecordTokenType type,
Collection<String> modifiedFields)
Computes the resulting type assuming that the specified fields
may be mutated.
|
static RecordTokenType |
TypeUtil.nonUnique(RecordTokenType type)
Returns a RecordTokenType, equivalent to the original, but with all
primaryKey
flags set to false |
static RecordTokenType |
TypeUtil.overlay(RecordTokenType... types)
Merges the specified record types into a new record type, handling name collisions
with a last-one-wins mechanism.
|
static RecordTokenType |
TypeUtil.remove(RecordTokenType source,
List<String> removed)
Creates a new record type containing all fields from the source type except
those matching one of the specified field names.
|
static RecordTokenType |
TypeUtil.remove(RecordTokenType source,
String... removed)
Creates a new record type containing all fields from the source type except
those matching one of the specified field names.
|
static RecordTokenType |
TypeUtil.rename(RecordTokenType source,
Map<String,String> sourceToTargetNameMap)
Utility for renaming fields in the source type using the given source
and target field names.
|
static RecordTokenType |
TypeUtil.rename(RecordTokenType source,
String[] sourceNames,
String[] targetNames)
Utility for renaming fields in the source type using the given source
and target field names.
|
static RecordTokenType |
TypeUtil.reorderAndRename(RecordTokenType source,
String[] sourceNames,
String[] targetNames)
Utility for the renaming/reordering of a given record type.
|
static RecordTokenType |
TypeUtil.retain(RecordTokenType source,
List<String> retained)
Creates a new record type containing only fields from the source type which
match one of the specified field names.
|
static RecordTokenType |
TypeUtil.retain(RecordTokenType source,
String... retained)
Creates a new record type containing only fields from the source type which
match one of the specified field names.
|
static RecordTokenType |
TypeUtil.select(RecordTokenType source,
List<String> selected)
Creates a new record type containing only fields from the source type which
match one of the specified field names.
|
static RecordTokenType |
TypeUtil.select(RecordTokenType source,
String... selected)
Creates a new record type containing only fields from the source type which
match one of the specified field names.
|
static RecordTokenType |
TypeUtil.strictOverlay(boolean dropUnique,
RecordTokenType... types)
Merges the specified record types into a new record type, allowing name collisions
only if
isAssignableFrom() is true for the types. |
static RecordTokenType |
TypeUtil.validateFieldSelection(String propertyName,
RecordTokenType source,
String... selected)
Validates a set of field names against the source type, computing the
resulting type.
|
static void |
TypeUtil.validateRequiredFields(String propertyName,
RecordTokenType source,
RecordTokenType required)
Validates a set of Fields against the source type ensuring the required field names are present and of the same type.
|
static RecordTokenType |
TypeUtil.widestNamedType(RecordTokenType... types)
Calculates the record type for which
isAssignableFrom()
is true for all of the specified types matched by name. |
static RecordTokenType |
TypeUtil.widestType(RecordTokenType... types)
Calculates the record type for which
isAssignableFrom()
is true for all of the specified types. |
static RecordTokenType |
TypeUtil.withDomainValues(RecordTokenType type,
String fieldName,
Set<String> discovered)
Returns a new RecordTokenType with domain values set to the discovered values.
|
Constructor and Description |
---|
TypeNotSupportedException(RecordTokenType type,
String reason,
FieldTypeNotSupportedException cause)
Constructs a
TypeNotSupportException indicating the
specified record type and field causing the failure. |
TypesNotComparableException(RecordTokenType leftType,
RecordTokenType rightType,
FieldTypesNotComparableException cause)
Constructs a
TypesNotComparableException indicating the
specified record types are not comparable due to underlying fields
not being comparable. |
Modifier and Type | Method and Description |
---|---|
RecordTokenType |
ColumnSelector.filter(RecordTokenType type)
Returns a type consisting of a subset of the given type that matches
this column selector's criteria.
|
Modifier and Type | Method and Description |
---|---|
static void |
PropertyUtil.checkFieldExists(RecordTokenType type,
String propertyName,
List<String> fieldNames)
Checks that the given field name(s) are valid field names in the given record type.
|
static void |
PropertyUtil.checkFieldExists(RecordTokenType type,
String propertyName,
String... fieldNames)
Checks that the given field name(s) are valid field names in the given record type.
|
RecordTokenType |
ColumnSelector.filter(RecordTokenType type)
Returns a type consisting of a subset of the given type that matches
this column selector's criteria.
|
String[] |
ColumnSelector.filterNames(RecordTokenType type)
Returns the names of the fields of given type that match
this column selector's criteria.
|
Copyright © 2016 Actian Corporation. All Rights Reserved.