Uses of Interface
com.pervasive.datarush.operators.RecordSourceOperator
Packages that use RecordSourceOperator
Package
Description
Provides classes and interfaces for developing dataflow operators.
Provides base file I/O components including encoders and decoders.
Provides operators for reading and writing files in Avro format.
Provides operators for reading and writing DataRush staging datasets.
Provides operators for reading and writing text data.
Provides operators for manipulating record structure.
Provides operators for generating data tokens in various ways.
Provides implementations of port objects related to the flow of record sets
between operators.
-
Uses of RecordSourceOperator in com.actian.dataflow.operators.io.orc
Classes in com.actian.dataflow.operators.io.orc that implement RecordSourceOperator -
Uses of RecordSourceOperator in com.actian.dataflow.operators.io.parquet
Classes in com.actian.dataflow.operators.io.parquet that implement RecordSourceOperatorModifier and TypeClassDescriptionclassReads data previously written using Apache Parquet format by Apache Hive. -
Uses of RecordSourceOperator in com.pervasive.datarush.operators
Classes in com.pervasive.datarush.operators that implement RecordSourceOperatorModifier and TypeClassDescriptionfinal classA record source that can be externally composed. -
Uses of RecordSourceOperator in com.pervasive.datarush.operators.io
Classes in com.pervasive.datarush.operators.io that implement RecordSourceOperatorModifier and TypeClassDescriptionclassA generic reader of byte data representing a stream of records.final classReads a data source as a stream of records. -
Uses of RecordSourceOperator in com.pervasive.datarush.operators.io.avro
Classes in com.pervasive.datarush.operators.io.avro that implement RecordSourceOperator -
Uses of RecordSourceOperator in com.pervasive.datarush.operators.io.mdf
Classes in com.pervasive.datarush.operators.io.mdf that implement RecordSourceOperator -
Uses of RecordSourceOperator in com.pervasive.datarush.operators.io.staging
Classes in com.pervasive.datarush.operators.io.staging that implement RecordSourceOperatorModifier and TypeClassDescriptionclassReads a sequence of records previously staged to disk. -
Uses of RecordSourceOperator in com.pervasive.datarush.operators.io.textfile
Classes in com.pervasive.datarush.operators.io.textfile that implement RecordSourceOperatorModifier and TypeClassDescriptionclassA generic reader of text data representing a stream of records.classRead files in the Attribute-Relation File Format (ARFF).final classReads a text file of delimited records as record tokens.classReads a text file of fixed-width records as record tokens.classThe ReadJSON operator reads a JSON file of key-value pairs or array of objects as record tokens.classReads a log file as record tokens. -
Uses of RecordSourceOperator in com.pervasive.datarush.operators.record
Classes in com.pervasive.datarush.operators.record that implement RecordSourceOperatorModifier and TypeClassDescriptionclassMerges two streams of data with an equivalent number of rows into one. -
Uses of RecordSourceOperator in com.pervasive.datarush.operators.source
Classes in com.pervasive.datarush.operators.source that implement RecordSourceOperatorModifier and TypeClassDescriptionfinal classEmits an in-memory token list as output.final classGenerates a sequence of numerical values, with a constant difference between consecutive values.final classGenerates copies of a constant value.final classGenerates rows of random data.final classGenerates a cycle of repeating values. -
Uses of RecordSourceOperator in com.pervasive.datarush.operators.testutils
Classes in com.pervasive.datarush.operators.testutils that implement RecordSourceOperatorModifier and TypeClassDescriptionfinal classA record source that throws an error either at composition time or execution time.final classFor tests that wish to simulate a partitioned read. -
Uses of RecordSourceOperator in com.pervasive.datarush.ports.record
Classes in com.pervasive.datarush.ports.record that implement RecordSourceOperatorModifier and TypeClassDescriptionfinal classDefines an external source of record data.