Versions in this module Expand all Collapse all v0 v0.1.5 Jun 29, 2021 Changes in this version + const AclPermissionManage + const AclPermissionRead + const AclPermissionWrite + const AwsAvailabilityOnDemand + const AwsAvailabilitySpot + const AwsAvailabilitySpotWithFallback + const ClusterCloudProviderNodeStatusNotAvailableInRegion + const ClusterCloudProviderNodeStatusNotEnabledOnSubscription + const ClusterEventTypeAutoscalingStatsReport + const ClusterEventTypeCreating + const ClusterEventTypeDbfsDown + const ClusterEventTypeDidNotExpandDisk + const ClusterEventTypeDriverHealthy + const ClusterEventTypeDriverNotResponding + const ClusterEventTypeDriverUnavailable + const ClusterEventTypeEdited + const ClusterEventTypeExpandedDisk + const ClusterEventTypeFailedToExpandDisk + const ClusterEventTypeInitScriptFinished + const ClusterEventTypeInitScriptStarting + const ClusterEventTypeMetastoreDown + const ClusterEventTypeNodesLost + const ClusterEventTypeResizing + const ClusterEventTypeRestarting + const ClusterEventTypeRunning + const ClusterEventTypeSparkException + const ClusterEventTypeStarting + const ClusterEventTypeTerminating + const ClusterEventTypeUpsizeCompleted + const ClusterSourceAPI + const ClusterSourceJob + const ClusterSourceUI + const ClusterStateError + const ClusterStatePending + const ClusterStateResizing + const ClusterStateRestarting + const ClusterStateRunning + const ClusterStateTerminating + const ClusterStateUnknown + const EbsVolumeTypeGeneralPurposeSsd + const EbsVolumeTypeThroughputOptimizedHdd + const ExportFormatDbc + const ExportFormatHtml + const ExportFormatJupyter + const ExportFormatSource + const InstancePoolStateActive + const InstancePoolStateDeleted + const LanguagePython + const LanguageR + const LanguageSQL + const LanguageScala + const LibraryInstallStatusFailed + const LibraryInstallStatusInstalled + const LibraryInstallStatusInstalling + const LibraryInstallStatusPending + const LibraryInstallStatusResolving + const LibraryInstallStatusUninstallOnRestart + const ListOrderAsc + const ListOrderDesc + const ObjectTypeDirectory + const ObjectTypeLibrary + const ObjectTypeNotebook + const ResizeCauseAutorecovery + const ResizeCauseAutoscale + const ResizeCauseUserRequest + const RunLifeCycleStateInternalError + const RunLifeCycleStatePending + const RunLifeCycleStateRunning + const RunLifeCycleStateSkipped + const RunLifeCycleStateTerminated + const RunLifeCycleStateTerminating + const RunResultStateCanceled + const RunResultStateFailed + const RunResultStateSuccess + const RunResultStateTimedout + const ScopeBackendTypeDatabricks + const TerminationCodeCloudProviderLaunchFailure + const TerminationCodeCloudProviderShutdown + const TerminationCodeCommunicationLost + const TerminationCodeInactivity + const TerminationCodeInitScriptFailure + const TerminationCodeInstanceUnreachable + const TerminationCodeInternalError + const TerminationCodeInvalidArgument + const TerminationCodeJobFinished + const TerminationCodeRequestRejected + const TerminationCodeSparkStartupFailure + const TerminationCodeTrialExpired + const TerminationCodeUnexpectedLaunchFailure + const TerminationCodeUserRequest + const TerminationParameterAwsAPIErrorCode + const TerminationParameterAwsErrorMessage + const TerminationParameterAwsImpairedStatusDetails + const TerminationParameterAwsInstanceStateReason + const TerminationParameterAwsInstanceStatusEvent + const TerminationParameterAwsSpotRequestFaultCode + const TerminationParameterAwsSpotRequestStatus + const TerminationParameterDatabricksErrorMessage + const TerminationParameterInactivityDurationMin + const TerminationParameterInstanceID + const TerminationParameterUsername + const TriggerTypeOneTime + const TriggerTypePeriodic + const TriggerTypeRetry + const ViewTypeDashboard + const ViewTypeNotebook + const ViewsToExportAll + const ViewsToExportCode + const ViewsToExportDashboards + type AclItem struct + Permission *AclPermission + Principal string + func (in *AclItem) DeepCopy() *AclItem + func (in *AclItem) DeepCopyInto(out *AclItem) + type AclPermission string + type AutoScale struct + MaxWorkers int32 + MinWorkers int32 + func (in *AutoScale) DeepCopy() *AutoScale + func (in *AutoScale) DeepCopyInto(out *AutoScale) + type AwsAttributes struct + Availability *AwsAvailability + EbsVolumeCount int32 + EbsVolumeSize int32 + EbsVolumeType *EbsVolumeType + FirstOnDemand int32 + InstanceProfileArn string + SpotBidPricePercent int32 + ZoneID string + func (in *AwsAttributes) DeepCopy() *AwsAttributes + func (in *AwsAttributes) DeepCopyInto(out *AwsAttributes) + type AwsAvailability string + type BasicAuth struct + Password string + Username string + type ClusterAttributes struct + AutoterminationMinutes int32 + AwsAttributes *AwsAttributes + ClusterLogConf *ClusterLogConf + ClusterName string + ClusterSource *AwsAvailability + CustomTags []ClusterTag + DriverNodeTypeID string + EnableElasticDisk bool + InitScripts []InitScriptInfo + NodeTypeID string + SSHPublicKeys []string + SparkConf *SparkConfPair + SparkEnvVars map[string]string + SparkVersion string + func (in *ClusterAttributes) DeepCopy() *ClusterAttributes + func (in *ClusterAttributes) DeepCopyInto(out *ClusterAttributes) + type ClusterCloudProviderNodeInfo struct + AvailableCoreQuota int32 + Status *ClusterCloudProviderNodeStatus + TotalCoreQuota int32 + func (in *ClusterCloudProviderNodeInfo) DeepCopy() *ClusterCloudProviderNodeInfo + func (in *ClusterCloudProviderNodeInfo) DeepCopyInto(out *ClusterCloudProviderNodeInfo) + type ClusterCloudProviderNodeStatus string + type ClusterEvent struct + ClusterID string + Details *AwsAttributes + Timestamp int64 + Type *ClusterEventType + func (in *ClusterEvent) DeepCopy() *ClusterEvent + func (in *ClusterEvent) DeepCopyInto(out *ClusterEvent) + type ClusterEventType string + type ClusterInfo struct + AutoScale *AutoScale + AutoterminationMinutes int32 + AwsAttributes *AwsAttributes + ClusterCores float32 + ClusterID string + ClusterLogConf *ClusterLogConf + ClusterLogStatus *LogSyncStatus + ClusterMemoryMb int64 + ClusterName string + ClusterSource *AwsAvailability + CreatorUserName string + CustomTags []ClusterTag + DefaultTags []ClusterTag + DockerImage *DockerImage + Driver *SparkNode + DriverNodeTypeID string + EnableElasticDisk bool + Executors []SparkNode + InitScripts []InitScriptInfo + JdbcPort int32 + LastActivityTime int64 + LastStateLossTime int64 + NodeTypeID string + NumWorkers int32 + SSHPublicKeys []string + SparkConf *SparkConfPair + SparkContextID int64 + SparkEnvVars map[string]string + SparkVersion string + StartTime int64 + State *ClusterState + StateMessage string + TerminateTime int64 + TerminationReason *S3StorageInfo + func (in *ClusterInfo) DeepCopy() *ClusterInfo + func (in *ClusterInfo) DeepCopyInto(out *ClusterInfo) + type ClusterInstance struct + ClusterID string + SparkContextID string + func (in *ClusterInstance) DeepCopy() *ClusterInstance + func (in *ClusterInstance) DeepCopyInto(out *ClusterInstance) + type ClusterLibraryStatuses struct + ClusterID string + LibraryStatuses []LibraryFullStatus + func (in *ClusterLibraryStatuses) DeepCopy() *ClusterLibraryStatuses + func (in *ClusterLibraryStatuses) DeepCopyInto(out *ClusterLibraryStatuses) + type ClusterLogConf struct + Dbfs *DbfsStorageInfo + S3 *S3StorageInfo + func (in *ClusterLogConf) DeepCopy() *ClusterLogConf + func (in *ClusterLogConf) DeepCopyInto(out *ClusterLogConf) + type ClusterSize struct + Autoscale *AutoScale + NumWorkers int32 + func (in *ClusterSize) DeepCopy() *ClusterSize + func (in *ClusterSize) DeepCopyInto(out *ClusterSize) + type ClusterSource string + type ClusterSpec struct + ExistingClusterID string + Libraries []Library + NewCluster *NewCluster + func (in *ClusterSpec) DeepCopy() *ClusterSpec + func (in *ClusterSpec) DeepCopyInto(out *ClusterSpec) + type ClusterState string + type ClusterTag struct + Key string + Value string + func (in *ClusterTag) DeepCopy() *ClusterTag + func (in *ClusterTag) DeepCopyInto(out *ClusterTag) + type CronSchedule struct + QuartzCronExpression string + TimezoneID string + func (in *CronSchedule) DeepCopy() *CronSchedule + func (in *CronSchedule) DeepCopyInto(out *CronSchedule) + type DbfsStorageInfo struct + Destination string + func (in *DbfsStorageInfo) DeepCopy() *DbfsStorageInfo + func (in *DbfsStorageInfo) DeepCopyInto(out *DbfsStorageInfo) + type DiskSpec struct + DiskCount int32 + DiskSize int32 + DiskType *DiskType + func (in *DiskSpec) DeepCopy() *DiskSpec + func (in *DiskSpec) DeepCopyInto(out *DiskSpec) + type DiskType struct + EbsVolumeType EbsVolumeType + func (in *DiskType) DeepCopy() *DiskType + func (in *DiskType) DeepCopyInto(out *DiskType) + type DockerImage struct + BasicAuth *BasicAuth + URL string + type EbsVolumeType string + type EventDetails struct + Attributes *ClusterAttributes + ClusterSize *ClusterSize + CurrentNumWorkers int32 + PreviousAttributes *ClusterAttributes + PreviousClusterSize *ClusterSize + TargetNumWorkers int32 + func (in *EventDetails) DeepCopy() *EventDetails + func (in *EventDetails) DeepCopyInto(out *EventDetails) + type ExportFormat string + type FileInfo struct + FileSize int64 + IsDir bool + Path string + func (in *FileInfo) DeepCopy() *FileInfo + func (in *FileInfo) DeepCopyInto(out *FileInfo) + type InitScriptInfo struct + Dbfs *DbfsStorageInfo + S3 *S3StorageInfo + func (in *InitScriptInfo) DeepCopy() *InitScriptInfo + func (in *InitScriptInfo) DeepCopyInto(out *InitScriptInfo) + type InstancePoolAndStats struct + AwsAttributes InstancePoolAwsAttributes + CustomTags []ClusterTag + DefaultTags []ClusterTag + DiskSpec DiskSpec + EnableElasticDisk bool + IdleInstanceAutoterminationMinutes int32 + InstancePoolID string + InstancePoolName string + MaxCapacity int32 + MinIdleInstances int32 + NodetypeID string + PreloadedSparkVersions []string + State InstancePoolState + Stats InstancePoolStats + func (in *InstancePoolAndStats) DeepCopy() *InstancePoolAndStats + func (in *InstancePoolAndStats) DeepCopyInto(out *InstancePoolAndStats) + type InstancePoolAwsAttributes struct + Availability AwsAvailability + SpotBidPricePercent int32 + ZoneID string + func (in *InstancePoolAwsAttributes) DeepCopy() *InstancePoolAwsAttributes + func (in *InstancePoolAwsAttributes) DeepCopyInto(out *InstancePoolAwsAttributes) + type InstancePoolState string + type InstancePoolStats struct + IdleCount int32 + PendingIdleCount int32 + PendingUsedCount int32 + UsedCount int32 + func (in *InstancePoolStats) DeepCopy() *InstancePoolStats + func (in *InstancePoolStats) DeepCopyInto(out *InstancePoolStats) + type InstanceProfile struct + InstanceProfileArn string + func (in *InstanceProfile) DeepCopy() *InstanceProfile + func (in *InstanceProfile) DeepCopyInto(out *InstanceProfile) + type Job struct + CreatedTime int64 + CreatorUserName string + JobID int64 + Settings *JobSettings + func (in *Job) DeepCopy() *Job + func (in *Job) DeepCopyInto(out *Job) + type JobEmailNotifications struct + NoAlertForSkippedRuns bool + OnFailure []string + OnStart []string + OnSuccess []string + func (in *JobEmailNotifications) DeepCopy() *JobEmailNotifications + func (in *JobEmailNotifications) DeepCopyInto(out *JobEmailNotifications) + type JobSettings struct + EmailNotifications *JobEmailNotifications + ExistingClusterID string + Libraries []Library + MaxConcurrentRuns int32 + MaxRetries int32 + MinRetryIntervalMillis int32 + Name string + NewCluster *NewCluster + NotebookTask *NotebookTask + RetryOnTimeout bool + Schedule *CronSchedule + SparkJarTask *SparkJarTask + SparkPythonTask *SparkPythonTask + SparkSubmitTask *SparkSubmitTask + TimeoutSeconds int32 + func (in *JobSettings) DeepCopy() *JobSettings + func (in *JobSettings) DeepCopyInto(out *JobSettings) + type JobTask struct + NotebookTask *NotebookTask + SparkJarTask *SparkJarTask + SparkPythonTask *SparkPythonTask + SparkSubmitTask *SparkSubmitTask + func (in *JobTask) DeepCopy() *JobTask + func (in *JobTask) DeepCopyInto(out *JobTask) + type Language string + type Library struct + Cran *RCranLibrary + Egg string + Jar string + Maven *MavenLibrary + Pypi *PythonPyPiLibrary + Whl string + func (in *Library) DeepCopy() *Library + func (in *Library) DeepCopyInto(out *Library) + type LibraryFullStatus struct + IsLibraryForAllClusters bool + Library *Library + Messages []string + Status *LibraryInstallStatus + func (in *LibraryFullStatus) DeepCopy() *LibraryFullStatus + func (in *LibraryFullStatus) DeepCopyInto(out *LibraryFullStatus) + type LibraryInstallStatus string + type ListOrder string + type LogSyncStatus struct + LastAttempted int64 + LastException string + func (in *LogSyncStatus) DeepCopy() *LogSyncStatus + func (in *LogSyncStatus) DeepCopyInto(out *LogSyncStatus) + type MavenLibrary struct + Coordinates string + Exclusions []string + Repo string + func (in *MavenLibrary) DeepCopy() *MavenLibrary + func (in *MavenLibrary) DeepCopyInto(out *MavenLibrary) + type NewCluster struct + Autoscale *AutoScale + AwsAttributes *AwsAttributes + ClusterLogConf *ClusterLogConf + ClusterName string + CustomTags []ClusterTag + DockerImage *DockerImage + DriverNodeTypeID string + EnableElasticDisk bool + InitScripts []InitScriptInfo + NodeTypeID string + NumWorkers int32 + SSHPublicKeys []string + SparkConf *SparkConfPair + SparkEnvVars map[string]string + SparkVersion string + func (in *NewCluster) DeepCopy() *NewCluster + func (in *NewCluster) DeepCopyInto(out *NewCluster) + type NodeType struct + Description string + InstanceTypeID string + IsDeprecated bool + MemoryMb int32 + NodeInfo *ClusterCloudProviderNodeInfo + NodeTypeID string + NumCores float32 + func (in *NodeType) DeepCopy() *NodeType + func (in *NodeType) DeepCopyInto(out *NodeType) + type NotebookOutput struct + Result string + Truncated bool + func (in *NotebookOutput) DeepCopy() *NotebookOutput + func (in *NotebookOutput) DeepCopyInto(out *NotebookOutput) + type NotebookTask struct + BaseParameters map[string]string + NotebookPath string + func (in *NotebookTask) DeepCopy() *NotebookTask + func (in *NotebookTask) DeepCopyInto(out *NotebookTask) + type ObjectInfo struct + Language *Language + ObjectType *ObjectType + Path string + func (in *ObjectInfo) DeepCopy() *ObjectInfo + func (in *ObjectInfo) DeepCopyInto(out *ObjectInfo) + type ObjectType string + type ParamPair struct + Key string + Value string + func (in *ParamPair) DeepCopy() *ParamPair + func (in *ParamPair) DeepCopyInto(out *ParamPair) + type ParameterPair struct + Key string + Value string + func (in *ParameterPair) DeepCopy() *ParameterPair + func (in *ParameterPair) DeepCopyInto(out *ParameterPair) + type PrincipalName struct + GroupName string + UserName string + func (in *PrincipalName) DeepCopy() *PrincipalName + func (in *PrincipalName) DeepCopyInto(out *PrincipalName) + type PublicTokenInfo struct + Comment string + CreationTime int64 + ExpiryTime int64 + TokenID string + func (in *PublicTokenInfo) DeepCopy() *PublicTokenInfo + func (in *PublicTokenInfo) DeepCopyInto(out *PublicTokenInfo) + type PythonPyPiLibrary struct + Package string + Repo string + func (in *PythonPyPiLibrary) DeepCopy() *PythonPyPiLibrary + func (in *PythonPyPiLibrary) DeepCopyInto(out *PythonPyPiLibrary) + type RCranLibrary struct + Package string + Repo string + func (in *RCranLibrary) DeepCopy() *RCranLibrary + func (in *RCranLibrary) DeepCopyInto(out *RCranLibrary) + type ResizeCause string + type Run struct + CleanupDuration int64 + ClusterInstance *ClusterInstance + ClusterSpec *ClusterSpec + CreatorUserName string + ExecutionDuration int64 + JobID int64 + NumberInJob int64 + OriginalAttemptRunID int64 + OverridingParameters *RunParameters + RunID int64 + Schedule *CronSchedule + SetupDuration int64 + StartTime int64 + State *RunState + Task *JobTask + Trigger *TriggerType + func (in *Run) DeepCopy() *Run + func (in *Run) DeepCopyInto(out *Run) + type RunLifeCycleState string + type RunParameters struct + JarParams []string + NotebookParams map[string]string + PythonParams []string + SparkSubmitParams []string + func (in *RunParameters) DeepCopy() *RunParameters + func (in *RunParameters) DeepCopyInto(out *RunParameters) + type RunResultState string + type RunState struct + LifeCycleState *RunLifeCycleState + ResultState *RunResultState + StateMessage string + func (in *RunState) DeepCopy() *RunState + func (in *RunState) DeepCopyInto(out *RunState) + type S3StorageInfo struct + CannedACL string + Destination string + EnableEncryption bool + EncryptionType string + Endpoint string + KmsKey string + Region string + func (in *S3StorageInfo) DeepCopy() *S3StorageInfo + func (in *S3StorageInfo) DeepCopyInto(out *S3StorageInfo) + type ScopeBackendType string + type SecretMetadata struct + Key string + LastUpdatedTimestamp int64 + func (in *SecretMetadata) DeepCopy() *SecretMetadata + func (in *SecretMetadata) DeepCopyInto(out *SecretMetadata) + type SecretScope struct + BackendType *ScopeBackendType + Name string + func (in *SecretScope) DeepCopy() *SecretScope + func (in *SecretScope) DeepCopyInto(out *SecretScope) + type SparkConfPair struct + Key string + Value string + func (in *SparkConfPair) DeepCopy() *SparkConfPair + func (in *SparkConfPair) DeepCopyInto(out *SparkConfPair) + type SparkEnvPair struct + Key string + Value string + func (in *SparkEnvPair) DeepCopy() *SparkEnvPair + func (in *SparkEnvPair) DeepCopyInto(out *SparkEnvPair) + type SparkJarTask struct + JarURI string + MainClassName string + Parameters []string + func (in *SparkJarTask) DeepCopy() *SparkJarTask + func (in *SparkJarTask) DeepCopyInto(out *SparkJarTask) + type SparkNode struct + HostPrivateIP string + InstanceID string + NodeAwsAttributes *SparkNodeAwsAttributes + NodeID string + PrivateIP string + PublicDNS string + StartTimestamp int64 + func (in *SparkNode) DeepCopy() *SparkNode + func (in *SparkNode) DeepCopyInto(out *SparkNode) + type SparkNodeAwsAttributes struct + IsSpot bool + func (in *SparkNodeAwsAttributes) DeepCopy() *SparkNodeAwsAttributes + func (in *SparkNodeAwsAttributes) DeepCopyInto(out *SparkNodeAwsAttributes) + type SparkPythonTask struct + Parameters []string + PythonFile string + func (in *SparkPythonTask) DeepCopy() *SparkPythonTask + func (in *SparkPythonTask) DeepCopyInto(out *SparkPythonTask) + type SparkSubmitTask struct + Parameters []string + func (in *SparkSubmitTask) DeepCopy() *SparkSubmitTask + func (in *SparkSubmitTask) DeepCopyInto(out *SparkSubmitTask) + type SparkVersion struct + Key string + Name string + func (in *SparkVersion) DeepCopy() *SparkVersion + func (in *SparkVersion) DeepCopyInto(out *SparkVersion) + type TerminationCode string + type TerminationParameter string + type TerminationReason struct + Code *TerminationCode + Parameters []ParameterPair + func (in *TerminationReason) DeepCopy() *TerminationReason + func (in *TerminationReason) DeepCopyInto(out *TerminationReason) + type TriggerType string + type ViewItem struct + Content string + Name string + Type *ViewType + func (in *ViewItem) DeepCopy() *ViewItem + func (in *ViewItem) DeepCopyInto(out *ViewItem) + type ViewType string + type ViewsToExport string
Go to main page