Versions in this module Expand all Collapse all v0 v0.0.1 Nov 7, 2022 Changes in this version + const DefaultAdlaJobDNSSuffix + func UserAgent() string + func Version() string + type BaseClient struct + AdlaJobDNSSuffix string + func New() BaseClient + func NewWithoutDefaults(adlaJobDNSSuffix string) BaseClient + type BaseJobParameters struct + Properties BasicCreateJobProperties + Type TypeEnum + func (bjp *BaseJobParameters) UnmarshalJSON(body []byte) error + type BasicCreateJobProperties interface + AsCreateJobProperties func() (*CreateJobProperties, bool) + AsCreateUSQLJobProperties func() (*CreateUSQLJobProperties, bool) + type BasicProperties interface + AsHiveJobProperties func() (*HiveJobProperties, bool) + AsProperties func() (*Properties, bool) + AsUSQLJobProperties func() (*USQLJobProperties, bool) + type BuildJobParameters struct + Name *string + Properties BasicCreateJobProperties + Type TypeEnum + func (bjp *BuildJobParameters) UnmarshalJSON(body []byte) error + type Client struct + func NewClient() Client + func (client Client) Build(ctx context.Context, accountName string, parameters BuildJobParameters) (result Information, err error) + func (client Client) BuildPreparer(ctx context.Context, accountName string, parameters BuildJobParameters) (*http.Request, error) + func (client Client) BuildResponder(resp *http.Response) (result Information, err error) + func (client Client) BuildSender(req *http.Request) (*http.Response, error) + func (client Client) Cancel(ctx context.Context, accountName string, jobIdentity uuid.UUID) (result autorest.Response, err error) + func (client Client) CancelPreparer(ctx context.Context, accountName string, jobIdentity uuid.UUID) (*http.Request, error) + func (client Client) CancelResponder(resp *http.Response) (result autorest.Response, err error) + func (client Client) CancelSender(req *http.Request) (*http.Response, error) + func (client Client) Create(ctx context.Context, accountName string, jobIdentity uuid.UUID, ...) (result Information, err error) + func (client Client) CreatePreparer(ctx context.Context, accountName string, jobIdentity uuid.UUID, ...) (*http.Request, error) + func (client Client) CreateResponder(resp *http.Response) (result Information, err error) + func (client Client) CreateSender(req *http.Request) (*http.Response, error) + func (client Client) Get(ctx context.Context, accountName string, jobIdentity uuid.UUID) (result Information, err error) + func (client Client) GetDebugDataPath(ctx context.Context, accountName string, jobIdentity uuid.UUID) (result DataPath, err error) + func (client Client) GetDebugDataPathPreparer(ctx context.Context, accountName string, jobIdentity uuid.UUID) (*http.Request, error) + func (client Client) GetDebugDataPathResponder(resp *http.Response) (result DataPath, err error) + func (client Client) GetDebugDataPathSender(req *http.Request) (*http.Response, error) + func (client Client) GetPreparer(ctx context.Context, accountName string, jobIdentity uuid.UUID) (*http.Request, error) + func (client Client) GetResponder(resp *http.Response) (result Information, err error) + func (client Client) GetSender(req *http.Request) (*http.Response, error) + func (client Client) GetStatistics(ctx context.Context, accountName string, jobIdentity uuid.UUID) (result Statistics, err error) + func (client Client) GetStatisticsPreparer(ctx context.Context, accountName string, jobIdentity uuid.UUID) (*http.Request, error) + func (client Client) GetStatisticsResponder(resp *http.Response) (result Statistics, err error) + func (client Client) GetStatisticsSender(req *http.Request) (*http.Response, error) + func (client Client) List(ctx context.Context, accountName string, filter string, top *int32, ...) (result InfoListResultPage, err error) + func (client Client) ListComplete(ctx context.Context, accountName string, filter string, top *int32, ...) (result InfoListResultIterator, err error) + func (client Client) ListPreparer(ctx context.Context, accountName string, filter string, top *int32, ...) (*http.Request, error) + func (client Client) ListResponder(resp *http.Response) (result InfoListResult, err error) + func (client Client) ListSender(req *http.Request) (*http.Response, error) + type CompileMode string + const Full + const Semantic + const SingleBox + func PossibleCompileModeValues() []CompileMode + type CreateJobParameters struct + DegreeOfParallelism *int32 + DegreeOfParallelismPercent *float64 + LogFilePatterns *[]string + Name *string + Priority *int32 + Properties BasicCreateJobProperties + Related *RelationshipProperties + Type TypeEnum + func (cjp *CreateJobParameters) UnmarshalJSON(body []byte) error + type CreateJobProperties struct + RuntimeVersion *string + Script *string + Type TypeBasicCreateJobProperties + func (cjp CreateJobProperties) AsBasicCreateJobProperties() (BasicCreateJobProperties, bool) + func (cjp CreateJobProperties) AsCreateJobProperties() (*CreateJobProperties, bool) + func (cjp CreateJobProperties) AsCreateUSQLJobProperties() (*CreateUSQLJobProperties, bool) + func (cjp CreateJobProperties) MarshalJSON() ([]byte, error) + type CreateUSQLJobProperties struct + CompileMode CompileMode + RuntimeVersion *string + Script *string + Type TypeBasicCreateJobProperties + func (cusjp CreateUSQLJobProperties) AsBasicCreateJobProperties() (BasicCreateJobProperties, bool) + func (cusjp CreateUSQLJobProperties) AsCreateJobProperties() (*CreateJobProperties, bool) + func (cusjp CreateUSQLJobProperties) AsCreateUSQLJobProperties() (*CreateUSQLJobProperties, bool) + func (cusjp CreateUSQLJobProperties) MarshalJSON() ([]byte, error) + type DataPath struct + Command *string + JobID *uuid.UUID + Paths *[]string + func (dp DataPath) MarshalJSON() ([]byte, error) + type Diagnostics struct + ColumnNumber *int32 + End *int32 + LineNumber *int32 + Message *string + Severity SeverityTypes + Start *int32 + func (d Diagnostics) MarshalJSON() ([]byte, error) + type ErrorDetails struct + Description *string + Details *string + EndOffset *int32 + ErrorID *string + FilePath *string + HelpLink *string + InnerError *InnerError + InternalDiagnostics *string + LineNumber *int32 + Message *string + Resolution *string + Severity SeverityTypes + Source *string + StartOffset *int32 + func (ed ErrorDetails) MarshalJSON() ([]byte, error) + type HiveJobProperties struct + ExecutedStatementCount *int32 + LogsLocation *string + OutputLocation *string + RuntimeVersion *string + Script *string + StatementCount *int32 + Type Type + func (hjp HiveJobProperties) AsBasicProperties() (BasicProperties, bool) + func (hjp HiveJobProperties) AsHiveJobProperties() (*HiveJobProperties, bool) + func (hjp HiveJobProperties) AsProperties() (*Properties, bool) + func (hjp HiveJobProperties) AsUSQLJobProperties() (*USQLJobProperties, bool) + func (hjp HiveJobProperties) MarshalJSON() ([]byte, error) + type InfoListResult struct + NextLink *string + Value *[]InformationBasic + func (ilr InfoListResult) IsEmpty() bool + func (ilr InfoListResult) MarshalJSON() ([]byte, error) + type InfoListResultIterator struct + func NewInfoListResultIterator(page InfoListResultPage) InfoListResultIterator + func (iter *InfoListResultIterator) Next() error + func (iter *InfoListResultIterator) NextWithContext(ctx context.Context) (err error) + func (iter InfoListResultIterator) NotDone() bool + func (iter InfoListResultIterator) Response() InfoListResult + func (iter InfoListResultIterator) Value() InformationBasic + type InfoListResultPage struct + func NewInfoListResultPage(cur InfoListResult, ...) InfoListResultPage + func (page *InfoListResultPage) Next() error + func (page *InfoListResultPage) NextWithContext(ctx context.Context) (err error) + func (page InfoListResultPage) NotDone() bool + func (page InfoListResultPage) Response() InfoListResult + func (page InfoListResultPage) Values() []InformationBasic + type Information struct + DegreeOfParallelism *int32 + DegreeOfParallelismPercent *float64 + EndTime *date.Time + ErrorMessage *[]ErrorDetails + HierarchyQueueNode *string + JobID *uuid.UUID + LogFilePatterns *[]string + LogFolder *string + Name *string + Priority *int32 + Properties BasicProperties + Related *RelationshipProperties + Result Result + StartTime *date.Time + State State + StateAuditRecords *[]StateAuditRecord + SubmitTime *date.Time + Submitter *string + Type TypeEnum + func (i *Information) UnmarshalJSON(body []byte) error + func (i Information) MarshalJSON() ([]byte, error) + type InformationBasic struct + DegreeOfParallelism *int32 + DegreeOfParallelismPercent *float64 + EndTime *date.Time + HierarchyQueueNode *string + JobID *uuid.UUID + LogFilePatterns *[]string + LogFolder *string + Name *string + Priority *int32 + Related *RelationshipProperties + Result Result + StartTime *date.Time + State State + SubmitTime *date.Time + Submitter *string + Type TypeEnum + func (ib InformationBasic) MarshalJSON() ([]byte, error) + type InnerError struct + Component *string + Description *string + Details *string + DiagnosticCode *int32 + ErrorID *string + HelpLink *string + InnerError *InnerError + InternalDiagnostics *string + Message *string + Resolution *string + Severity SeverityTypes + Source *string + func (ie InnerError) MarshalJSON() ([]byte, error) + type PipelineClient struct + func NewPipelineClient() PipelineClient + func (client PipelineClient) Get(ctx context.Context, accountName string, pipelineIdentity uuid.UUID, ...) (result PipelineInformation, err error) + func (client PipelineClient) GetPreparer(ctx context.Context, accountName string, pipelineIdentity uuid.UUID, ...) (*http.Request, error) + func (client PipelineClient) GetResponder(resp *http.Response) (result PipelineInformation, err error) + func (client PipelineClient) GetSender(req *http.Request) (*http.Response, error) + func (client PipelineClient) List(ctx context.Context, accountName string, startDateTime *date.Time, ...) (result PipelineInformationListResultPage, err error) + func (client PipelineClient) ListComplete(ctx context.Context, accountName string, startDateTime *date.Time, ...) (result PipelineInformationListResultIterator, err error) + func (client PipelineClient) ListPreparer(ctx context.Context, accountName string, startDateTime *date.Time, ...) (*http.Request, error) + func (client PipelineClient) ListResponder(resp *http.Response) (result PipelineInformationListResult, err error) + func (client PipelineClient) ListSender(req *http.Request) (*http.Response, error) + type PipelineInformation struct + AuHoursCanceled *float64 + AuHoursFailed *float64 + AuHoursSucceeded *float64 + LastSubmitTime *date.Time + NumJobsCanceled *int32 + NumJobsFailed *int32 + NumJobsSucceeded *int32 + PipelineID *uuid.UUID + PipelineName *string + PipelineURI *string + Recurrences *[]uuid.UUID + Runs *[]PipelineRunInformation + func (pi PipelineInformation) MarshalJSON() ([]byte, error) + type PipelineInformationListResult struct + NextLink *string + Value *[]PipelineInformation + func (pilr PipelineInformationListResult) IsEmpty() bool + func (pilr PipelineInformationListResult) MarshalJSON() ([]byte, error) + type PipelineInformationListResultIterator struct + func NewPipelineInformationListResultIterator(page PipelineInformationListResultPage) PipelineInformationListResultIterator + func (iter *PipelineInformationListResultIterator) Next() error + func (iter *PipelineInformationListResultIterator) NextWithContext(ctx context.Context) (err error) + func (iter PipelineInformationListResultIterator) NotDone() bool + func (iter PipelineInformationListResultIterator) Response() PipelineInformationListResult + func (iter PipelineInformationListResultIterator) Value() PipelineInformation + type PipelineInformationListResultPage struct + func NewPipelineInformationListResultPage(cur PipelineInformationListResult, ...) PipelineInformationListResultPage + func (page *PipelineInformationListResultPage) Next() error + func (page *PipelineInformationListResultPage) NextWithContext(ctx context.Context) (err error) + func (page PipelineInformationListResultPage) NotDone() bool + func (page PipelineInformationListResultPage) Response() PipelineInformationListResult + func (page PipelineInformationListResultPage) Values() []PipelineInformation + type PipelineRunInformation struct + LastSubmitTime *date.Time + RunID *uuid.UUID + func (pri PipelineRunInformation) MarshalJSON() ([]byte, error) + type Properties struct + RuntimeVersion *string + Script *string + Type Type + func (p Properties) AsBasicProperties() (BasicProperties, bool) + func (p Properties) AsHiveJobProperties() (*HiveJobProperties, bool) + func (p Properties) AsProperties() (*Properties, bool) + func (p Properties) AsUSQLJobProperties() (*USQLJobProperties, bool) + func (p Properties) MarshalJSON() ([]byte, error) + type RecurrenceClient struct + func NewRecurrenceClient() RecurrenceClient + func (client RecurrenceClient) Get(ctx context.Context, accountName string, recurrenceIdentity uuid.UUID, ...) (result RecurrenceInformation, err error) + func (client RecurrenceClient) GetPreparer(ctx context.Context, accountName string, recurrenceIdentity uuid.UUID, ...) (*http.Request, error) + func (client RecurrenceClient) GetResponder(resp *http.Response) (result RecurrenceInformation, err error) + func (client RecurrenceClient) GetSender(req *http.Request) (*http.Response, error) + func (client RecurrenceClient) List(ctx context.Context, accountName string, startDateTime *date.Time, ...) (result RecurrenceInformationListResultPage, err error) + func (client RecurrenceClient) ListComplete(ctx context.Context, accountName string, startDateTime *date.Time, ...) (result RecurrenceInformationListResultIterator, err error) + func (client RecurrenceClient) ListPreparer(ctx context.Context, accountName string, startDateTime *date.Time, ...) (*http.Request, error) + func (client RecurrenceClient) ListResponder(resp *http.Response) (result RecurrenceInformationListResult, err error) + func (client RecurrenceClient) ListSender(req *http.Request) (*http.Response, error) + type RecurrenceInformation struct + AuHoursCanceled *float64 + AuHoursFailed *float64 + AuHoursSucceeded *float64 + LastSubmitTime *date.Time + NumJobsCanceled *int32 + NumJobsFailed *int32 + NumJobsSucceeded *int32 + RecurrenceID *uuid.UUID + RecurrenceName *string + func (ri RecurrenceInformation) MarshalJSON() ([]byte, error) + type RecurrenceInformationListResult struct + NextLink *string + Value *[]RecurrenceInformation + func (rilr RecurrenceInformationListResult) IsEmpty() bool + func (rilr RecurrenceInformationListResult) MarshalJSON() ([]byte, error) + type RecurrenceInformationListResultIterator struct + func NewRecurrenceInformationListResultIterator(page RecurrenceInformationListResultPage) RecurrenceInformationListResultIterator + func (iter *RecurrenceInformationListResultIterator) Next() error + func (iter *RecurrenceInformationListResultIterator) NextWithContext(ctx context.Context) (err error) + func (iter RecurrenceInformationListResultIterator) NotDone() bool + func (iter RecurrenceInformationListResultIterator) Response() RecurrenceInformationListResult + func (iter RecurrenceInformationListResultIterator) Value() RecurrenceInformation + type RecurrenceInformationListResultPage struct + func NewRecurrenceInformationListResultPage(cur RecurrenceInformationListResult, ...) RecurrenceInformationListResultPage + func (page *RecurrenceInformationListResultPage) Next() error + func (page *RecurrenceInformationListResultPage) NextWithContext(ctx context.Context) (err error) + func (page RecurrenceInformationListResultPage) NotDone() bool + func (page RecurrenceInformationListResultPage) Response() RecurrenceInformationListResult + func (page RecurrenceInformationListResultPage) Values() []RecurrenceInformation + type RelationshipProperties struct + PipelineID *uuid.UUID + PipelineName *string + PipelineURI *string + RecurrenceID *uuid.UUID + RecurrenceName *string + RunID *uuid.UUID + type Resource struct + Name *string + ResourcePath *string + Type ResourceType + type ResourceType string + const JobManagerResource + const JobManagerResourceInUserFolder + const StatisticsResource + const StatisticsResourceInUserFolder + const VertexResource + const VertexResourceInUserFolder + func PossibleResourceTypeValues() []ResourceType + type Result string + const Cancelled + const Failed + const None + const Succeeded + func PossibleResultValues() []Result + type SeverityTypes string + const Deprecated + const Error + const Info + const SevereWarning + const UserWarning + const Warning + func PossibleSeverityTypesValues() []SeverityTypes + type State string + const StateAccepted + const StateCompiling + const StateEnded + const StateNew + const StatePaused + const StateQueued + const StateRunning + const StateScheduling + const StateStarting + const StateWaitingForCapacity + func PossibleStateValues() []State + type StateAuditRecord struct + Details *string + NewState *string + RequestedByUser *string + TimeStamp *date.Time + func (sar StateAuditRecord) MarshalJSON() ([]byte, error) + type Statistics struct + FinalizingTimeUtc *date.Time + LastUpdateTimeUtc *date.Time + Stages *[]StatisticsVertexStage + func (s Statistics) MarshalJSON() ([]byte, error) + type StatisticsVertexStage struct + DataRead *int64 + DataReadCrossPod *int64 + DataReadIntraPod *int64 + DataToRead *int64 + DataWritten *int64 + DuplicateDiscardCount *int32 + FailedCount *int32 + MaxVertexDataRead *int64 + MinVertexDataRead *int64 + ReadFailureCount *int32 + RevocationCount *int32 + RunningCount *int32 + ScheduledCount *int32 + StageName *string + SucceededCount *int32 + TempDataWritten *int64 + TotalCount *int32 + TotalFailedTime *string + TotalProgress *int32 + TotalSucceededTime *string + func (svs StatisticsVertexStage) MarshalJSON() ([]byte, error) + type Type string + const TypeHive + const TypeJobProperties + const TypeUSQL + func PossibleTypeValues() []Type + type TypeBasicCreateJobProperties string + const TypeBasicCreateJobPropertiesTypeCreateJobProperties + const TypeBasicCreateJobPropertiesTypeUSQL + func PossibleTypeBasicCreateJobPropertiesValues() []TypeBasicCreateJobProperties + type TypeEnum string + const Hive + const USQL + func PossibleTypeEnumValues() []TypeEnum + type USQLJobProperties struct + AlgebraFilePath *string + CompileMode CompileMode + DebugData *DataPath + Diagnostics *[]Diagnostics + Resources *[]Resource + RootProcessNodeID *string + RuntimeVersion *string + Script *string + Statistics *Statistics + TotalCompilationTime *string + TotalPauseTime *string + TotalQueuedTime *string + TotalRunningTime *string + Type Type + YarnApplicationID *string + YarnApplicationTimeStamp *int64 + func (usjp USQLJobProperties) AsBasicProperties() (BasicProperties, bool) + func (usjp USQLJobProperties) AsHiveJobProperties() (*HiveJobProperties, bool) + func (usjp USQLJobProperties) AsProperties() (*Properties, bool) + func (usjp USQLJobProperties) AsUSQLJobProperties() (*USQLJobProperties, bool) + func (usjp USQLJobProperties) MarshalJSON() ([]byte, error)
Go to main page