This repository has been archived by the owner on Nov 29, 2023. It is now read-only.
/
__init__.py
282 lines (279 loc) · 11.6 KB
/
__init__.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
# -*- coding: utf-8 -*-
# Copyright 2020 Google LLC
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#
from google.cloud.dataproc_v1.services.autoscaling_policy_service.client import (
AutoscalingPolicyServiceClient,
)
from google.cloud.dataproc_v1.services.autoscaling_policy_service.async_client import (
AutoscalingPolicyServiceAsyncClient,
)
from google.cloud.dataproc_v1.services.cluster_controller.client import (
ClusterControllerClient,
)
from google.cloud.dataproc_v1.services.cluster_controller.async_client import (
ClusterControllerAsyncClient,
)
from google.cloud.dataproc_v1.services.job_controller.client import JobControllerClient
from google.cloud.dataproc_v1.services.job_controller.async_client import (
JobControllerAsyncClient,
)
from google.cloud.dataproc_v1.services.workflow_template_service.client import (
WorkflowTemplateServiceClient,
)
from google.cloud.dataproc_v1.services.workflow_template_service.async_client import (
WorkflowTemplateServiceAsyncClient,
)
from google.cloud.dataproc_v1.types.autoscaling_policies import AutoscalingPolicy
from google.cloud.dataproc_v1.types.autoscaling_policies import (
BasicAutoscalingAlgorithm,
)
from google.cloud.dataproc_v1.types.autoscaling_policies import (
BasicYarnAutoscalingConfig,
)
from google.cloud.dataproc_v1.types.autoscaling_policies import (
CreateAutoscalingPolicyRequest,
)
from google.cloud.dataproc_v1.types.autoscaling_policies import (
DeleteAutoscalingPolicyRequest,
)
from google.cloud.dataproc_v1.types.autoscaling_policies import (
GetAutoscalingPolicyRequest,
)
from google.cloud.dataproc_v1.types.autoscaling_policies import (
InstanceGroupAutoscalingPolicyConfig,
)
from google.cloud.dataproc_v1.types.autoscaling_policies import (
ListAutoscalingPoliciesRequest,
)
from google.cloud.dataproc_v1.types.autoscaling_policies import (
ListAutoscalingPoliciesResponse,
)
from google.cloud.dataproc_v1.types.autoscaling_policies import (
UpdateAutoscalingPolicyRequest,
)
from google.cloud.dataproc_v1.types.clusters import AcceleratorConfig
from google.cloud.dataproc_v1.types.clusters import AutoscalingConfig
from google.cloud.dataproc_v1.types.clusters import Cluster
from google.cloud.dataproc_v1.types.clusters import ClusterConfig
from google.cloud.dataproc_v1.types.clusters import ClusterMetrics
from google.cloud.dataproc_v1.types.clusters import ClusterStatus
from google.cloud.dataproc_v1.types.clusters import ConfidentialInstanceConfig
from google.cloud.dataproc_v1.types.clusters import CreateClusterRequest
from google.cloud.dataproc_v1.types.clusters import DeleteClusterRequest
from google.cloud.dataproc_v1.types.clusters import DiagnoseClusterRequest
from google.cloud.dataproc_v1.types.clusters import DiagnoseClusterResults
from google.cloud.dataproc_v1.types.clusters import DiskConfig
from google.cloud.dataproc_v1.types.clusters import EncryptionConfig
from google.cloud.dataproc_v1.types.clusters import EndpointConfig
from google.cloud.dataproc_v1.types.clusters import GceClusterConfig
from google.cloud.dataproc_v1.types.clusters import GetClusterRequest
from google.cloud.dataproc_v1.types.clusters import GkeClusterConfig
from google.cloud.dataproc_v1.types.clusters import IdentityConfig
from google.cloud.dataproc_v1.types.clusters import InstanceGroupConfig
from google.cloud.dataproc_v1.types.clusters import KerberosConfig
from google.cloud.dataproc_v1.types.clusters import LifecycleConfig
from google.cloud.dataproc_v1.types.clusters import ListClustersRequest
from google.cloud.dataproc_v1.types.clusters import ListClustersResponse
from google.cloud.dataproc_v1.types.clusters import ManagedGroupConfig
from google.cloud.dataproc_v1.types.clusters import MetastoreConfig
from google.cloud.dataproc_v1.types.clusters import NodeGroupAffinity
from google.cloud.dataproc_v1.types.clusters import NodeInitializationAction
from google.cloud.dataproc_v1.types.clusters import ReservationAffinity
from google.cloud.dataproc_v1.types.clusters import SecurityConfig
from google.cloud.dataproc_v1.types.clusters import ShieldedInstanceConfig
from google.cloud.dataproc_v1.types.clusters import SoftwareConfig
from google.cloud.dataproc_v1.types.clusters import StartClusterRequest
from google.cloud.dataproc_v1.types.clusters import StopClusterRequest
from google.cloud.dataproc_v1.types.clusters import UpdateClusterRequest
from google.cloud.dataproc_v1.types.jobs import CancelJobRequest
from google.cloud.dataproc_v1.types.jobs import DeleteJobRequest
from google.cloud.dataproc_v1.types.jobs import GetJobRequest
from google.cloud.dataproc_v1.types.jobs import HadoopJob
from google.cloud.dataproc_v1.types.jobs import HiveJob
from google.cloud.dataproc_v1.types.jobs import Job
from google.cloud.dataproc_v1.types.jobs import JobMetadata
from google.cloud.dataproc_v1.types.jobs import JobPlacement
from google.cloud.dataproc_v1.types.jobs import JobReference
from google.cloud.dataproc_v1.types.jobs import JobScheduling
from google.cloud.dataproc_v1.types.jobs import JobStatus
from google.cloud.dataproc_v1.types.jobs import ListJobsRequest
from google.cloud.dataproc_v1.types.jobs import ListJobsResponse
from google.cloud.dataproc_v1.types.jobs import LoggingConfig
from google.cloud.dataproc_v1.types.jobs import PigJob
from google.cloud.dataproc_v1.types.jobs import PrestoJob
from google.cloud.dataproc_v1.types.jobs import PySparkJob
from google.cloud.dataproc_v1.types.jobs import QueryList
from google.cloud.dataproc_v1.types.jobs import SparkJob
from google.cloud.dataproc_v1.types.jobs import SparkRJob
from google.cloud.dataproc_v1.types.jobs import SparkSqlJob
from google.cloud.dataproc_v1.types.jobs import SubmitJobRequest
from google.cloud.dataproc_v1.types.jobs import UpdateJobRequest
from google.cloud.dataproc_v1.types.jobs import YarnApplication
from google.cloud.dataproc_v1.types.operations import BatchOperationMetadata
from google.cloud.dataproc_v1.types.operations import ClusterOperationMetadata
from google.cloud.dataproc_v1.types.operations import ClusterOperationStatus
from google.cloud.dataproc_v1.types.shared import EnvironmentConfig
from google.cloud.dataproc_v1.types.shared import ExecutionConfig
from google.cloud.dataproc_v1.types.shared import PeripheralsConfig
from google.cloud.dataproc_v1.types.shared import RuntimeConfig
from google.cloud.dataproc_v1.types.shared import RuntimeInfo
from google.cloud.dataproc_v1.types.shared import SparkHistoryServerConfig
from google.cloud.dataproc_v1.types.shared import Component
from google.cloud.dataproc_v1.types.shared import FailureAction
from google.cloud.dataproc_v1.types.workflow_templates import ClusterOperation
from google.cloud.dataproc_v1.types.workflow_templates import ClusterSelector
from google.cloud.dataproc_v1.types.workflow_templates import (
CreateWorkflowTemplateRequest,
)
from google.cloud.dataproc_v1.types.workflow_templates import (
DeleteWorkflowTemplateRequest,
)
from google.cloud.dataproc_v1.types.workflow_templates import GetWorkflowTemplateRequest
from google.cloud.dataproc_v1.types.workflow_templates import (
InstantiateInlineWorkflowTemplateRequest,
)
from google.cloud.dataproc_v1.types.workflow_templates import (
InstantiateWorkflowTemplateRequest,
)
from google.cloud.dataproc_v1.types.workflow_templates import (
ListWorkflowTemplatesRequest,
)
from google.cloud.dataproc_v1.types.workflow_templates import (
ListWorkflowTemplatesResponse,
)
from google.cloud.dataproc_v1.types.workflow_templates import ManagedCluster
from google.cloud.dataproc_v1.types.workflow_templates import OrderedJob
from google.cloud.dataproc_v1.types.workflow_templates import ParameterValidation
from google.cloud.dataproc_v1.types.workflow_templates import RegexValidation
from google.cloud.dataproc_v1.types.workflow_templates import TemplateParameter
from google.cloud.dataproc_v1.types.workflow_templates import (
UpdateWorkflowTemplateRequest,
)
from google.cloud.dataproc_v1.types.workflow_templates import ValueValidation
from google.cloud.dataproc_v1.types.workflow_templates import WorkflowGraph
from google.cloud.dataproc_v1.types.workflow_templates import WorkflowMetadata
from google.cloud.dataproc_v1.types.workflow_templates import WorkflowNode
from google.cloud.dataproc_v1.types.workflow_templates import WorkflowTemplate
from google.cloud.dataproc_v1.types.workflow_templates import WorkflowTemplatePlacement
__all__ = (
"AutoscalingPolicyServiceClient",
"AutoscalingPolicyServiceAsyncClient",
"ClusterControllerClient",
"ClusterControllerAsyncClient",
"JobControllerClient",
"JobControllerAsyncClient",
"WorkflowTemplateServiceClient",
"WorkflowTemplateServiceAsyncClient",
"AutoscalingPolicy",
"BasicAutoscalingAlgorithm",
"BasicYarnAutoscalingConfig",
"CreateAutoscalingPolicyRequest",
"DeleteAutoscalingPolicyRequest",
"GetAutoscalingPolicyRequest",
"InstanceGroupAutoscalingPolicyConfig",
"ListAutoscalingPoliciesRequest",
"ListAutoscalingPoliciesResponse",
"UpdateAutoscalingPolicyRequest",
"AcceleratorConfig",
"AutoscalingConfig",
"Cluster",
"ClusterConfig",
"ClusterMetrics",
"ClusterStatus",
"ConfidentialInstanceConfig",
"CreateClusterRequest",
"DeleteClusterRequest",
"DiagnoseClusterRequest",
"DiagnoseClusterResults",
"DiskConfig",
"EncryptionConfig",
"EndpointConfig",
"GceClusterConfig",
"GetClusterRequest",
"GkeClusterConfig",
"IdentityConfig",
"InstanceGroupConfig",
"KerberosConfig",
"LifecycleConfig",
"ListClustersRequest",
"ListClustersResponse",
"ManagedGroupConfig",
"MetastoreConfig",
"NodeGroupAffinity",
"NodeInitializationAction",
"ReservationAffinity",
"SecurityConfig",
"ShieldedInstanceConfig",
"SoftwareConfig",
"StartClusterRequest",
"StopClusterRequest",
"UpdateClusterRequest",
"CancelJobRequest",
"DeleteJobRequest",
"GetJobRequest",
"HadoopJob",
"HiveJob",
"Job",
"JobMetadata",
"JobPlacement",
"JobReference",
"JobScheduling",
"JobStatus",
"ListJobsRequest",
"ListJobsResponse",
"LoggingConfig",
"PigJob",
"PrestoJob",
"PySparkJob",
"QueryList",
"SparkJob",
"SparkRJob",
"SparkSqlJob",
"SubmitJobRequest",
"UpdateJobRequest",
"YarnApplication",
"BatchOperationMetadata",
"ClusterOperationMetadata",
"ClusterOperationStatus",
"EnvironmentConfig",
"ExecutionConfig",
"PeripheralsConfig",
"RuntimeConfig",
"RuntimeInfo",
"SparkHistoryServerConfig",
"Component",
"FailureAction",
"ClusterOperation",
"ClusterSelector",
"CreateWorkflowTemplateRequest",
"DeleteWorkflowTemplateRequest",
"GetWorkflowTemplateRequest",
"InstantiateInlineWorkflowTemplateRequest",
"InstantiateWorkflowTemplateRequest",
"ListWorkflowTemplatesRequest",
"ListWorkflowTemplatesResponse",
"ManagedCluster",
"OrderedJob",
"ParameterValidation",
"RegexValidation",
"TemplateParameter",
"UpdateWorkflowTemplateRequest",
"ValueValidation",
"WorkflowGraph",
"WorkflowMetadata",
"WorkflowNode",
"WorkflowTemplate",
"WorkflowTemplatePlacement",
)