spark

Documentation

Index

• Constants
• func UserAgent() string
• func Version() string
• type BaseClient
  • func New(endpoint string, sparkPoolName string) BaseClient
  • func NewWithoutDefaults(endpoint string, sparkPoolName string, livyAPIVersion string) BaseClient
• type BatchClient
  • func NewBatchClient(endpoint string, sparkPoolName string) BatchClient
• type BatchJob
• type BatchJobCollection
• type BatchJobOptions
• type BatchJobResultType
  • func PossibleBatchJobResultTypeValues() []BatchJobResultType
• type BatchJobState
• type ErrorSource
  • func PossibleErrorSourceValues() []ErrorSource
• type JobType
  • func PossibleJobTypeValues() []JobType
• type PluginCurrentState
  • func PossiblePluginCurrentStateValues() []PluginCurrentState
• type Request
• type Scheduler
• type SchedulerCurrentState
  • func PossibleSchedulerCurrentStateValues() []SchedulerCurrentState
• type ServiceError
• type ServicePlugin
• type Session
• type SessionClient
  • func NewSessionClient(endpoint string, sparkPoolName string) SessionClient
• type SessionCollection
• type SessionOptions
• type SessionResultType
  • func PossibleSessionResultTypeValues() []SessionResultType
• type SessionState
• type Statement
• type StatementCancellationResult
• type StatementCollection
• type StatementLanguageType
  • func PossibleStatementLanguageTypeValues() []StatementLanguageType
• type StatementOptions
• type StatementOutput

Constants

const (
	DefaultLivyAPIVersion = original.DefaultLivyAPIVersion
)

Functions

func UserAgent

func UserAgent() string

func Version

func Version() string

Types

type BaseClient

type BaseClient = original.BaseClient

func New

func New(endpoint string, sparkPoolName string) BaseClient

func NewWithoutDefaults

func NewWithoutDefaults(endpoint string, sparkPoolName string, livyAPIVersion string) BaseClient

type BatchClient

type BatchClient = original.BatchClient

func NewBatchClient

func NewBatchClient(endpoint string, sparkPoolName string) BatchClient

type BatchJob

type BatchJob = original.BatchJob

type BatchJobCollection

type BatchJobCollection = original.BatchJobCollection

type BatchJobOptions

type BatchJobOptions = original.BatchJobOptions

type BatchJobResultType

type BatchJobResultType = original.BatchJobResultType

const (
	Cancelled BatchJobResultType = original.Cancelled
	Failed    BatchJobResultType = original.Failed
	Succeeded BatchJobResultType = original.Succeeded
	Uncertain BatchJobResultType = original.Uncertain
)

func PossibleBatchJobResultTypeValues

func PossibleBatchJobResultTypeValues() []BatchJobResultType

type BatchJobState

type BatchJobState = original.BatchJobState

type ErrorSource

type ErrorSource = original.ErrorSource

const (
	Dependency ErrorSource = original.Dependency
	System     ErrorSource = original.System
	Unknown    ErrorSource = original.Unknown
	User       ErrorSource = original.User
)

func PossibleErrorSourceValues

func PossibleErrorSourceValues() []ErrorSource

type JobType

type JobType = original.JobType

const (
	SparkBatch   JobType = original.SparkBatch
	SparkSession JobType = original.SparkSession
)

func PossibleJobTypeValues

func PossibleJobTypeValues() []JobType

type PluginCurrentState

type PluginCurrentState = original.PluginCurrentState

const (
	Cleanup             PluginCurrentState = original.Cleanup
	Ended               PluginCurrentState = original.Ended
	Monitoring          PluginCurrentState = original.Monitoring
	Preparation         PluginCurrentState = original.Preparation
	Queued              PluginCurrentState = original.Queued
	ResourceAcquisition PluginCurrentState = original.ResourceAcquisition
	Submission          PluginCurrentState = original.Submission
)

func PossiblePluginCurrentStateValues

func PossiblePluginCurrentStateValues() []PluginCurrentState

type Request

type Request = original.Request

type Scheduler

type Scheduler = original.Scheduler

type SchedulerCurrentState

type SchedulerCurrentState = original.SchedulerCurrentState

const (
	SchedulerCurrentStateEnded     SchedulerCurrentState = original.SchedulerCurrentStateEnded
	SchedulerCurrentStateQueued    SchedulerCurrentState = original.SchedulerCurrentStateQueued
	SchedulerCurrentStateScheduled SchedulerCurrentState = original.SchedulerCurrentStateScheduled
)

func PossibleSchedulerCurrentStateValues

func PossibleSchedulerCurrentStateValues() []SchedulerCurrentState

type ServiceError

type ServiceError = original.ServiceError

type ServicePlugin

type ServicePlugin = original.ServicePlugin

type Session

type Session = original.Session

type SessionClient

type SessionClient = original.SessionClient

func NewSessionClient

func NewSessionClient(endpoint string, sparkPoolName string) SessionClient

type SessionCollection

type SessionCollection = original.SessionCollection

type SessionOptions

type SessionOptions = original.SessionOptions

type SessionResultType

type SessionResultType = original.SessionResultType

const (
	SessionResultTypeCancelled SessionResultType = original.SessionResultTypeCancelled
	SessionResultTypeFailed    SessionResultType = original.SessionResultTypeFailed
	SessionResultTypeSucceeded SessionResultType = original.SessionResultTypeSucceeded
	SessionResultTypeUncertain SessionResultType = original.SessionResultTypeUncertain
)

func PossibleSessionResultTypeValues

func PossibleSessionResultTypeValues() []SessionResultType

type SessionState

type SessionState = original.SessionState

type Statement

type Statement = original.Statement

type StatementCancellationResult

type StatementCancellationResult = original.StatementCancellationResult

type StatementCollection

type StatementCollection = original.StatementCollection

type StatementLanguageType

type StatementLanguageType = original.StatementLanguageType

const (
	Dotnetspark StatementLanguageType = original.Dotnetspark
	Pyspark     StatementLanguageType = original.Pyspark
	Spark       StatementLanguageType = original.Spark
	SQL         StatementLanguageType = original.SQL
)

func PossibleStatementLanguageTypeValues

func PossibleStatementLanguageTypeValues() []StatementLanguageType

type StatementOptions

type StatementOptions = original.StatementOptions

type StatementOutput

type StatementOutput = original.StatementOutput