All Classes and Interfaces
Class
Description
The operator responsible for retrieving command outputs from local file system and returning a DataFrame.
Factory object responsible for creating
Collector
operators.The main interface responsible for representing an accessible data source in SeqsLab.
An API intended for developers.
Indicates the computing resource requirements, types of workload and
pipeline structures that an operator supports.
Indicates the computing resource requirements, types of workload and
pipeline structures that an operator supports.
The operator responsible for preprocessing (localizing) input dataframe as a managed table for
Spark SQL command or saving to local files for shell script execution.
Factory object responsible for creating
Executor
operators.An annotation indicates pipeline operator features that will be checked and invoked
after calling operator function.
An annotation indicates pipeline operator features that will be checked and invoked
prior to calling operator function.
An operator responsible for formatting input datasets, such as converting schema, adding or deleting columns,
and encoding domain specific object.
Factory object responsible for creating
Formatter
operators.The operator responsible for loading (reading) a dataset into in-memory DataFrame or copying to local host
file system from a specific data source, e.g.
Factory object responsible for creating
Loader
operators.An operator that processes Spark DataFrame and produces a new DataFrame.
An object used in pipeline operations to represent a persistent set of properties, inputs,
and outputs.
The base contract interface for SeqsLab operator pipeline v3.
An interface represents a complete configuration of workflow task
including input parameters, dataset connection, as well as localization, computation,
and delocalization workload processes.
An interface represents the localization, computation, and delocalization workload processes
in a pipeline task of a given variable identified by FQN (Fully Qualified Name).
An object used in all operations of a workflow task execution.
A plugin that can be dynamically loaded into a SeqsLab piper application.
An interface represents value of primitive types, e.g.
Concrete types of all supported workflow parameters
An object returned when initializing this SeqsLab piper.
A mix-in interface for
Collector
.A mix-in interface for
Loader
.A mix-in interface for
Executor
.A mix-in interface for
Transformer
.A mix-in interface for
Loader
.A mix-in interface for
Transformer
.A mix-in interface for
Loader
.A mix-in interface for
Collector
.The mix-in interface for
Writer
.The mix-in interface for
Writer
.The mix-in interface for
Writer
.A mix-in interface for
Loader
.A mix-in interface for
Executor
.A mix-in interface for
Formatter
.A mix-in interface for
Formatter
.A mix-in interface for
Formatter
.A mix-in interface for
Formatter
.A mix-in interface for
Formatter
.The operator responsible for repartitioning, and additionally sorting, DataFrames loaded by
Loader
to optimize downstream data processing.Factory object responsible for creating
Transformer
operators.The operator responsible for delocalizing/saving command output DataFrame to storage or
repositories, e.g.
Factory object responsible for creating
Writer
operators.