All Superinterfaces:
AutoCloseable, Closeable, Operator, OperatorPipelineV3, Serializable
All Known Subinterfaces:
SupportsFileLocalization, SupportsTableLocalization

@DeveloperApi public interface Executor extends Operator
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. Executor objects are created first by invoking Executor operator factory (implements ExecutorSupport) when pipeline task requests it and will be lazily initialized when it is ready to run. When completed, the close method will be invoked to release resources. SeqsLab supports multiple data processing features to manage and optimize workloads. An executor can inform SeqsLab its supporting features by implementing the specific mix-in interfaces. An Executor must implement either SupportsFileLocalization or SupportsTableLocalization.
See Also:
  • Method Summary

    Modifier and Type
    Method
    Description
    Initializes this executor operator.

    Methods inherited from interface java.io.Closeable

    close

    Methods inherited from interface com.atgenomix.seqslab.piper.plugin.api.Operator

    getName, getOperatorContext
  • Method Details

    • init

      Executor init()
      Initializes this executor operator.
      Returns:
      The object itself