Versions in this module Expand all Collapse all v1 v1.0.1 Sep 13, 2022 v1.0.0 Sep 12, 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 BasicProperties interface + AsHiveJobProperties func() (*HiveJobProperties, bool) + AsProperties func() (*Properties, bool) + AsUSQLJobProperties func() (*USQLJobProperties, bool) + type Client struct + func NewClient() Client + func (client Client) Build(ctx context.Context, accountName string, parameters Information) (result Information, err error) + func (client Client) BuildPreparer(ctx context.Context, accountName string, parameters Information) (*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 DataPath struct + Command *string + JobID *uuid.UUID + Paths *[]string + func (dp DataPath) 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 + RuntimeVersion *string + Script *string + StatementCount *int32 + StatementInfo *[]HiveJobStatementInfo + Type Type + WarehouseLocation *string + 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 HiveJobStatementInfo struct + ErrorMessage *string + LogLocation *string + ResultLocation *string + ResultPreviewLocation *string + type InfoListResult struct + Count *int64 + NextLink *string + Value *[]Information + 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() Information + 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() []Information + type Information struct + DegreeOfParallelism *int32 + DegreeOfParallelismPercent *float64 + EndTime *date.Time + ErrorMessage *[]ErrorDetails + HierarchyQueueNode *string + JobID *uuid.UUID + Name *string + Priority *int32 + Properties BasicProperties + 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 InnerError struct + Component *string + Description *string + Details *string + DiagnosticCode *int32 + ErrorID *string + HelpLink *string + InternalDiagnostics *string + Message *string + Resolution *string + Severity SeverityTypes + Source *string + func (ie InnerError) 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 Resource struct + Name *string + ResourcePath *string + Type ResourceType + type ResourceType string + const StatisticsResource + const VertexResource + func PossibleResourceTypeValues() []ResourceType + type Result string + const Cancelled + const Failed + const None + const Succeeded + func PossibleResultValues() []Result + type SeverityTypes string + const Error + 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 + 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 TypeEnum string + const Hive + const USQL + func PossibleTypeEnumValues() []TypeEnum + type USQLJobProperties struct + AlgebraFilePath *string + CompileMode CompileMode + DebugData *DataPath + 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