Versions in this module Expand all Collapse all v25 v25.1.0 Feb 6, 2019 v25.0.0 Jan 30, 2019 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 + type Diagnostics struct + ColumnNumber *int32 + End *int32 + LineNumber *int32 + Message *string + Severity SeverityTypes + Start *int32 + 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 + 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 + Count *int64 + NextLink *string + Value *[]Information + func (ilr InfoListResult) IsEmpty() bool + 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(getNextPage func(context.Context, InfoListResult) (InfoListResult, error)) 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 + LogFilePatterns *[]string + LogFolder *string + 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 + 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 + 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 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 Error + const Info + 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 + type Statistics struct + FinalizingTimeUtc *date.Time + LastUpdateTimeUtc *date.Time + Stages *[]StatisticsVertexStage + 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 + 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 + 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) Other modules containing this package gopkg.in/Azure/azure-sdk-for-go.v16 gopkg.in/Azure/azure-sdk-for-go.v17 gopkg.in/Azure/azure-sdk-for-go.v18 gopkg.in/Azure/azure-sdk-for-go.v19 gopkg.in/Azure/azure-sdk-for-go.v20 gopkg.in/Azure/azure-sdk-for-go.v21 gopkg.in/Azure/azure-sdk-for-go.v22 gopkg.in/Azure/azure-sdk-for-go.v23 gopkg.in/Azure/azure-sdk-for-go.v24 gopkg.in/Azure/azure-sdk-for-go.v26 gopkg.in/Azure/azure-sdk-for-go.v27 gopkg.in/Azure/azure-sdk-for-go.v28 gopkg.in/Azure/azure-sdk-for-go.v29 gopkg.in/Azure/azure-sdk-for-go.v30 gopkg.in/Azure/azure-sdk-for-go.v31 gopkg.in/Azure/azure-sdk-for-go.v32 gopkg.in/Azure/azure-sdk-for-go.v33 gopkg.in/Azure/azure-sdk-for-go.v34 gopkg.in/Azure/azure-sdk-for-go.v35 gopkg.in/Azure/azure-sdk-for-go.v36 gopkg.in/Azure/azure-sdk-for-go.v37 gopkg.in/Azure/azure-sdk-for-go.v38 gopkg.in/Azure/azure-sdk-for-go.v39 gopkg.in/Azure/azure-sdk-for-go.v40 gopkg.in/Azure/azure-sdk-for-go.v41 gopkg.in/Azure/azure-sdk-for-go.v42 gopkg.in/Azure/azure-sdk-for-go.v43 gopkg.in/Azure/azure-sdk-for-go.v44 gopkg.in/Azure/azure-sdk-for-go.v45 gopkg.in/Azure/azure-sdk-for-go.v46 gopkg.in/Azure/azure-sdk-for-go.v48
Go to main page