Uses of Interface
com.pervasive.datarush.operators.SourceOperator

Packages that use SourceOperator

Package	Description
com.actian.dataflow.operators.io.orc
com.actian.dataflow.operators.io.parquet
com.pervasive.datarush.analytics.pmml	Provides shared and base classes for PMML model representation of Analytics algorithms.
com.pervasive.datarush.operators	Provides classes and interfaces for developing dataflow operators.
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.mdf
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.model	Provides operators for handling models.
com.pervasive.datarush.operators.record	Provides operators for manipulating record structure.
com.pervasive.datarush.operators.source	Provides operators for generating data tokens in various ways.
com.pervasive.datarush.operators.testutils
com.pervasive.datarush.ports.record	Provides implementations of port objects related to the flow of record sets between operators.

Uses of SourceOperator in com.actian.dataflow.operators.io.orc

Classes in com.actian.dataflow.operators.io.orc that implement SourceOperator

Modifier and Type	Class	Description
class	ReadORC

Uses of SourceOperator in com.actian.dataflow.operators.io.parquet

Classes in com.actian.dataflow.operators.io.parquet that implement SourceOperator

Modifier and Type	Class	Description
class	ReadParquet	Reads data previously written using Apache Parquet format by Apache Hive.

Uses of SourceOperator in com.pervasive.datarush.analytics.pmml

Classes in com.pervasive.datarush.analytics.pmml that implement SourceOperator

Modifier and Type	Class	Description
final class	PutPMML	Specialization of PutModel for PMMLPort's.

Uses of SourceOperator in com.pervasive.datarush.operators

Subinterfaces of SourceOperator in com.pervasive.datarush.operators

Modifier and Type	Interface	Description
interface	RecordSourceOperator	Refinement of SourceOperator, specific to RecortPort's.

Classes in com.pervasive.datarush.operators that implement SourceOperator

Modifier and Type	Class	Description
final class	OpenModelSource<T>	A model source that can be externally composed.
final class	OpenRecordSource	A record source that can be externally composed.

Uses of SourceOperator in com.pervasive.datarush.operators.io

Classes in com.pervasive.datarush.operators.io that implement SourceOperator

Modifier and Type	Class	Description
class	AbstractReader	A generic reader of byte data representing a stream of records.
final class	ReadSource	Reads a data source as a stream of records.

Uses of SourceOperator in com.pervasive.datarush.operators.io.avro

Classes in com.pervasive.datarush.operators.io.avro that implement SourceOperator

Modifier and Type	Class	Description
class	ReadAvro	Reads data previously written using Apache Avro format.

Uses of SourceOperator in com.pervasive.datarush.operators.io.mdf

Classes in com.pervasive.datarush.operators.io.mdf that implement SourceOperator

Modifier and Type	Class	Description
class	ReadMDF	Reads data previously written using MDF format.

Uses of SourceOperator in com.pervasive.datarush.operators.io.staging

Classes in com.pervasive.datarush.operators.io.staging that implement SourceOperator

Modifier and Type	Class	Description
class	ReadStagingDataset	Reads a sequence of records previously staged to disk.

Uses of SourceOperator in com.pervasive.datarush.operators.io.textfile

Classes in com.pervasive.datarush.operators.io.textfile that implement SourceOperator

Modifier and Type	Class	Description
class	AbstractTextReader	A generic reader of text data representing a stream of records.
class	ReadARFF	Read files in the Attribute-Relation File Format (ARFF).
final class	ReadDelimitedText	Reads a text file of delimited records as record tokens.
class	ReadFixedText	Reads a text file of fixed-width records as record tokens.
class	ReadJSON	The ReadJSON operator reads a JSON file of key-value pairs or array of objects as record tokens.
class	ReadLog	Reads a log file as record tokens.

Uses of SourceOperator in com.pervasive.datarush.operators.join

Classes in com.pervasive.datarush.operators.join that implement SourceOperator

Modifier and Type	Class	Description
class	UnionAll	Provides a union of two data sources.

Uses of SourceOperator in com.pervasive.datarush.operators.model

Classes in com.pervasive.datarush.operators.model that implement SourceOperator

Modifier and Type	Class	Description
class	PutModel<T>	Provides a way to inject an in-memory reference to a model object into a graph.

Uses of SourceOperator in com.pervasive.datarush.operators.record

Classes in com.pervasive.datarush.operators.record that implement SourceOperator

Modifier and Type	Class	Description
class	MergeFields	Merges two streams of data with an equivalent number of rows into one.

Uses of SourceOperator in com.pervasive.datarush.operators.source

Classes in com.pervasive.datarush.operators.source that implement SourceOperator

Modifier and Type	Class	Description
final class	EmitRecords	Emits an in-memory token list as output.
final class	GenerateArithmeticSequence	Generates a sequence of numerical values, with a constant difference between consecutive values.
final class	GenerateConstant	Generates copies of a constant value.
final class	GenerateRandom	Generates rows of random data.
final class	GenerateRepeatingCycle	Generates a cycle of repeating values.

Uses of SourceOperator in com.pervasive.datarush.operators.testutils

Classes in com.pervasive.datarush.operators.testutils that implement SourceOperator

Modifier and Type	Class	Description
final class	ErrorSource	A record source that throws an error either at composition time or execution time.
final class	SimulatePartitions	For tests that wish to simulate a partitioned read.

Uses of SourceOperator in com.pervasive.datarush.ports.record

Classes in com.pervasive.datarush.ports.record that implement SourceOperator

Modifier and Type	Class	Description
final class	ExternalRecordSource	Defines an external source of record data.