Package dev.vortex.spark

Interface VortexSessionProvider

public interface VortexSessionProvider
User hook for supplying a custom Session to Vortex Spark readers and writers.

Implementations must have a public no-argument constructor. They are instantiated exactly once per JVM (driver or executor) the first time a scan or write references the provider's class name through the vortex.session.provider option. The returned Session is then shared across every Vortex task on that JVM.

Typical use: install custom encodings, scalar functions, or layouts on a Session before returning it.

  • Method Summary

    Modifier and Type
    Method
    Description
    dev.vortex.api.Session
    get()
    Construct (or return a cached) Session.

  • Method Details

    • get

      dev.vortex.api.Session get()
      Construct (or return a cached) Session. Called at most once per JVM per provider class. The returned session is retained for the JVM's lifetime.