|
18 | 18 | __version__ = package_version.__version__
|
19 | 19 |
|
20 | 20 |
|
21 |
| -from google.cloud.dataproc_v1.services.autoscaling_policy_service.client import ( |
22 |
| - AutoscalingPolicyServiceClient, |
23 |
| -) |
24 | 21 | from google.cloud.dataproc_v1.services.autoscaling_policy_service.async_client import (
|
25 | 22 | AutoscalingPolicyServiceAsyncClient,
|
26 | 23 | )
|
27 |
| -from google.cloud.dataproc_v1.services.batch_controller.client import ( |
28 |
| - BatchControllerClient, |
| 24 | +from google.cloud.dataproc_v1.services.autoscaling_policy_service.client import ( |
| 25 | + AutoscalingPolicyServiceClient, |
29 | 26 | )
|
30 | 27 | from google.cloud.dataproc_v1.services.batch_controller.async_client import (
|
31 | 28 | BatchControllerAsyncClient,
|
32 | 29 | )
|
33 |
| -from google.cloud.dataproc_v1.services.cluster_controller.client import ( |
34 |
| - ClusterControllerClient, |
| 30 | +from google.cloud.dataproc_v1.services.batch_controller.client import ( |
| 31 | + BatchControllerClient, |
35 | 32 | )
|
36 | 33 | from google.cloud.dataproc_v1.services.cluster_controller.async_client import (
|
37 | 34 | ClusterControllerAsyncClient,
|
38 | 35 | )
|
39 |
| -from google.cloud.dataproc_v1.services.job_controller.client import JobControllerClient |
| 36 | +from google.cloud.dataproc_v1.services.cluster_controller.client import ( |
| 37 | + ClusterControllerClient, |
| 38 | +) |
40 | 39 | from google.cloud.dataproc_v1.services.job_controller.async_client import (
|
41 | 40 | JobControllerAsyncClient,
|
42 | 41 | )
|
43 |
| -from google.cloud.dataproc_v1.services.node_group_controller.client import ( |
44 |
| - NodeGroupControllerClient, |
45 |
| -) |
| 42 | +from google.cloud.dataproc_v1.services.job_controller.client import JobControllerClient |
46 | 43 | from google.cloud.dataproc_v1.services.node_group_controller.async_client import (
|
47 | 44 | NodeGroupControllerAsyncClient,
|
48 | 45 | )
|
49 |
| -from google.cloud.dataproc_v1.services.workflow_template_service.client import ( |
50 |
| - WorkflowTemplateServiceClient, |
| 46 | +from google.cloud.dataproc_v1.services.node_group_controller.client import ( |
| 47 | + NodeGroupControllerClient, |
51 | 48 | )
|
52 | 49 | from google.cloud.dataproc_v1.services.workflow_template_service.async_client import (
|
53 | 50 | WorkflowTemplateServiceAsyncClient,
|
54 | 51 | )
|
55 |
| - |
56 |
| -from google.cloud.dataproc_v1.types.autoscaling_policies import AutoscalingPolicy |
57 |
| -from google.cloud.dataproc_v1.types.autoscaling_policies import ( |
58 |
| - BasicAutoscalingAlgorithm, |
| 52 | +from google.cloud.dataproc_v1.services.workflow_template_service.client import ( |
| 53 | + WorkflowTemplateServiceClient, |
59 | 54 | )
|
60 | 55 | from google.cloud.dataproc_v1.types.autoscaling_policies import (
|
| 56 | + AutoscalingPolicy, |
| 57 | + BasicAutoscalingAlgorithm, |
61 | 58 | BasicYarnAutoscalingConfig,
|
62 |
| -) |
63 |
| -from google.cloud.dataproc_v1.types.autoscaling_policies import ( |
64 | 59 | CreateAutoscalingPolicyRequest,
|
65 |
| -) |
66 |
| -from google.cloud.dataproc_v1.types.autoscaling_policies import ( |
67 | 60 | DeleteAutoscalingPolicyRequest,
|
68 |
| -) |
69 |
| -from google.cloud.dataproc_v1.types.autoscaling_policies import ( |
70 | 61 | GetAutoscalingPolicyRequest,
|
71 |
| -) |
72 |
| -from google.cloud.dataproc_v1.types.autoscaling_policies import ( |
73 | 62 | InstanceGroupAutoscalingPolicyConfig,
|
74 |
| -) |
75 |
| -from google.cloud.dataproc_v1.types.autoscaling_policies import ( |
76 | 63 | ListAutoscalingPoliciesRequest,
|
77 |
| -) |
78 |
| -from google.cloud.dataproc_v1.types.autoscaling_policies import ( |
79 | 64 | ListAutoscalingPoliciesResponse,
|
80 |
| -) |
81 |
| -from google.cloud.dataproc_v1.types.autoscaling_policies import ( |
82 | 65 | UpdateAutoscalingPolicyRequest,
|
83 | 66 | )
|
84 |
| -from google.cloud.dataproc_v1.types.batches import Batch |
85 |
| -from google.cloud.dataproc_v1.types.batches import CreateBatchRequest |
86 |
| -from google.cloud.dataproc_v1.types.batches import DeleteBatchRequest |
87 |
| -from google.cloud.dataproc_v1.types.batches import GetBatchRequest |
88 |
| -from google.cloud.dataproc_v1.types.batches import ListBatchesRequest |
89 |
| -from google.cloud.dataproc_v1.types.batches import ListBatchesResponse |
90 |
| -from google.cloud.dataproc_v1.types.batches import PySparkBatch |
91 |
| -from google.cloud.dataproc_v1.types.batches import SparkBatch |
92 |
| -from google.cloud.dataproc_v1.types.batches import SparkRBatch |
93 |
| -from google.cloud.dataproc_v1.types.batches import SparkSqlBatch |
94 |
| -from google.cloud.dataproc_v1.types.clusters import AcceleratorConfig |
95 |
| -from google.cloud.dataproc_v1.types.clusters import AutoscalingConfig |
96 |
| -from google.cloud.dataproc_v1.types.clusters import AuxiliaryNodeGroup |
97 |
| -from google.cloud.dataproc_v1.types.clusters import AuxiliaryServicesConfig |
98 |
| -from google.cloud.dataproc_v1.types.clusters import Cluster |
99 |
| -from google.cloud.dataproc_v1.types.clusters import ClusterConfig |
100 |
| -from google.cloud.dataproc_v1.types.clusters import ClusterMetrics |
101 |
| -from google.cloud.dataproc_v1.types.clusters import ClusterStatus |
102 |
| -from google.cloud.dataproc_v1.types.clusters import ConfidentialInstanceConfig |
103 |
| -from google.cloud.dataproc_v1.types.clusters import CreateClusterRequest |
104 |
| -from google.cloud.dataproc_v1.types.clusters import DataprocMetricConfig |
105 |
| -from google.cloud.dataproc_v1.types.clusters import DeleteClusterRequest |
106 |
| -from google.cloud.dataproc_v1.types.clusters import DiagnoseClusterRequest |
107 |
| -from google.cloud.dataproc_v1.types.clusters import DiagnoseClusterResults |
108 |
| -from google.cloud.dataproc_v1.types.clusters import DiskConfig |
109 |
| -from google.cloud.dataproc_v1.types.clusters import EncryptionConfig |
110 |
| -from google.cloud.dataproc_v1.types.clusters import EndpointConfig |
111 |
| -from google.cloud.dataproc_v1.types.clusters import GceClusterConfig |
112 |
| -from google.cloud.dataproc_v1.types.clusters import GetClusterRequest |
113 |
| -from google.cloud.dataproc_v1.types.clusters import IdentityConfig |
114 |
| -from google.cloud.dataproc_v1.types.clusters import InstanceFlexibilityPolicy |
115 |
| -from google.cloud.dataproc_v1.types.clusters import InstanceGroupConfig |
116 |
| -from google.cloud.dataproc_v1.types.clusters import InstanceReference |
117 |
| -from google.cloud.dataproc_v1.types.clusters import KerberosConfig |
118 |
| -from google.cloud.dataproc_v1.types.clusters import LifecycleConfig |
119 |
| -from google.cloud.dataproc_v1.types.clusters import ListClustersRequest |
120 |
| -from google.cloud.dataproc_v1.types.clusters import ListClustersResponse |
121 |
| -from google.cloud.dataproc_v1.types.clusters import ManagedGroupConfig |
122 |
| -from google.cloud.dataproc_v1.types.clusters import MetastoreConfig |
123 |
| -from google.cloud.dataproc_v1.types.clusters import NodeGroup |
124 |
| -from google.cloud.dataproc_v1.types.clusters import NodeGroupAffinity |
125 |
| -from google.cloud.dataproc_v1.types.clusters import NodeInitializationAction |
126 |
| -from google.cloud.dataproc_v1.types.clusters import ReservationAffinity |
127 |
| -from google.cloud.dataproc_v1.types.clusters import SecurityConfig |
128 |
| -from google.cloud.dataproc_v1.types.clusters import ShieldedInstanceConfig |
129 |
| -from google.cloud.dataproc_v1.types.clusters import SoftwareConfig |
130 |
| -from google.cloud.dataproc_v1.types.clusters import StartClusterRequest |
131 |
| -from google.cloud.dataproc_v1.types.clusters import StopClusterRequest |
132 |
| -from google.cloud.dataproc_v1.types.clusters import UpdateClusterRequest |
133 |
| -from google.cloud.dataproc_v1.types.clusters import VirtualClusterConfig |
134 |
| -from google.cloud.dataproc_v1.types.jobs import CancelJobRequest |
135 |
| -from google.cloud.dataproc_v1.types.jobs import DeleteJobRequest |
136 |
| -from google.cloud.dataproc_v1.types.jobs import DriverSchedulingConfig |
137 |
| -from google.cloud.dataproc_v1.types.jobs import GetJobRequest |
138 |
| -from google.cloud.dataproc_v1.types.jobs import HadoopJob |
139 |
| -from google.cloud.dataproc_v1.types.jobs import HiveJob |
140 |
| -from google.cloud.dataproc_v1.types.jobs import Job |
141 |
| -from google.cloud.dataproc_v1.types.jobs import JobMetadata |
142 |
| -from google.cloud.dataproc_v1.types.jobs import JobPlacement |
143 |
| -from google.cloud.dataproc_v1.types.jobs import JobReference |
144 |
| -from google.cloud.dataproc_v1.types.jobs import JobScheduling |
145 |
| -from google.cloud.dataproc_v1.types.jobs import JobStatus |
146 |
| -from google.cloud.dataproc_v1.types.jobs import ListJobsRequest |
147 |
| -from google.cloud.dataproc_v1.types.jobs import ListJobsResponse |
148 |
| -from google.cloud.dataproc_v1.types.jobs import LoggingConfig |
149 |
| -from google.cloud.dataproc_v1.types.jobs import PigJob |
150 |
| -from google.cloud.dataproc_v1.types.jobs import PrestoJob |
151 |
| -from google.cloud.dataproc_v1.types.jobs import PySparkJob |
152 |
| -from google.cloud.dataproc_v1.types.jobs import QueryList |
153 |
| -from google.cloud.dataproc_v1.types.jobs import SparkJob |
154 |
| -from google.cloud.dataproc_v1.types.jobs import SparkRJob |
155 |
| -from google.cloud.dataproc_v1.types.jobs import SparkSqlJob |
156 |
| -from google.cloud.dataproc_v1.types.jobs import SubmitJobRequest |
157 |
| -from google.cloud.dataproc_v1.types.jobs import TrinoJob |
158 |
| -from google.cloud.dataproc_v1.types.jobs import UpdateJobRequest |
159 |
| -from google.cloud.dataproc_v1.types.jobs import YarnApplication |
160 |
| -from google.cloud.dataproc_v1.types.node_groups import CreateNodeGroupRequest |
161 |
| -from google.cloud.dataproc_v1.types.node_groups import GetNodeGroupRequest |
162 |
| -from google.cloud.dataproc_v1.types.node_groups import ResizeNodeGroupRequest |
163 |
| -from google.cloud.dataproc_v1.types.operations import BatchOperationMetadata |
164 |
| -from google.cloud.dataproc_v1.types.operations import ClusterOperationMetadata |
165 |
| -from google.cloud.dataproc_v1.types.operations import ClusterOperationStatus |
166 |
| -from google.cloud.dataproc_v1.types.operations import NodeGroupOperationMetadata |
167 |
| -from google.cloud.dataproc_v1.types.shared import EnvironmentConfig |
168 |
| -from google.cloud.dataproc_v1.types.shared import ExecutionConfig |
169 |
| -from google.cloud.dataproc_v1.types.shared import GkeClusterConfig |
170 |
| -from google.cloud.dataproc_v1.types.shared import GkeNodePoolConfig |
171 |
| -from google.cloud.dataproc_v1.types.shared import GkeNodePoolTarget |
172 |
| -from google.cloud.dataproc_v1.types.shared import KubernetesClusterConfig |
173 |
| -from google.cloud.dataproc_v1.types.shared import KubernetesSoftwareConfig |
174 |
| -from google.cloud.dataproc_v1.types.shared import PeripheralsConfig |
175 |
| -from google.cloud.dataproc_v1.types.shared import RuntimeConfig |
176 |
| -from google.cloud.dataproc_v1.types.shared import RuntimeInfo |
177 |
| -from google.cloud.dataproc_v1.types.shared import SparkHistoryServerConfig |
178 |
| -from google.cloud.dataproc_v1.types.shared import UsageMetrics |
179 |
| -from google.cloud.dataproc_v1.types.shared import UsageSnapshot |
180 |
| -from google.cloud.dataproc_v1.types.shared import Component |
181 |
| -from google.cloud.dataproc_v1.types.shared import FailureAction |
182 |
| -from google.cloud.dataproc_v1.types.workflow_templates import ClusterOperation |
183 |
| -from google.cloud.dataproc_v1.types.workflow_templates import ClusterSelector |
184 |
| -from google.cloud.dataproc_v1.types.workflow_templates import ( |
185 |
| - CreateWorkflowTemplateRequest, |
| 67 | +from google.cloud.dataproc_v1.types.batches import ( |
| 68 | + Batch, |
| 69 | + CreateBatchRequest, |
| 70 | + DeleteBatchRequest, |
| 71 | + GetBatchRequest, |
| 72 | + ListBatchesRequest, |
| 73 | + ListBatchesResponse, |
| 74 | + PySparkBatch, |
| 75 | + SparkBatch, |
| 76 | + SparkRBatch, |
| 77 | + SparkSqlBatch, |
186 | 78 | )
|
187 |
| -from google.cloud.dataproc_v1.types.workflow_templates import ( |
188 |
| - DeleteWorkflowTemplateRequest, |
| 79 | +from google.cloud.dataproc_v1.types.clusters import ( |
| 80 | + AcceleratorConfig, |
| 81 | + AutoscalingConfig, |
| 82 | + AuxiliaryNodeGroup, |
| 83 | + AuxiliaryServicesConfig, |
| 84 | + Cluster, |
| 85 | + ClusterConfig, |
| 86 | + ClusterMetrics, |
| 87 | + ClusterStatus, |
| 88 | + ConfidentialInstanceConfig, |
| 89 | + CreateClusterRequest, |
| 90 | + DataprocMetricConfig, |
| 91 | + DeleteClusterRequest, |
| 92 | + DiagnoseClusterRequest, |
| 93 | + DiagnoseClusterResults, |
| 94 | + DiskConfig, |
| 95 | + EncryptionConfig, |
| 96 | + EndpointConfig, |
| 97 | + GceClusterConfig, |
| 98 | + GetClusterRequest, |
| 99 | + IdentityConfig, |
| 100 | + InstanceFlexibilityPolicy, |
| 101 | + InstanceGroupConfig, |
| 102 | + InstanceReference, |
| 103 | + KerberosConfig, |
| 104 | + LifecycleConfig, |
| 105 | + ListClustersRequest, |
| 106 | + ListClustersResponse, |
| 107 | + ManagedGroupConfig, |
| 108 | + MetastoreConfig, |
| 109 | + NodeGroup, |
| 110 | + NodeGroupAffinity, |
| 111 | + NodeInitializationAction, |
| 112 | + ReservationAffinity, |
| 113 | + SecurityConfig, |
| 114 | + ShieldedInstanceConfig, |
| 115 | + SoftwareConfig, |
| 116 | + StartClusterRequest, |
| 117 | + StopClusterRequest, |
| 118 | + UpdateClusterRequest, |
| 119 | + VirtualClusterConfig, |
189 | 120 | )
|
190 |
| -from google.cloud.dataproc_v1.types.workflow_templates import GetWorkflowTemplateRequest |
191 |
| -from google.cloud.dataproc_v1.types.workflow_templates import ( |
192 |
| - InstantiateInlineWorkflowTemplateRequest, |
| 121 | +from google.cloud.dataproc_v1.types.jobs import ( |
| 122 | + CancelJobRequest, |
| 123 | + DeleteJobRequest, |
| 124 | + DriverSchedulingConfig, |
| 125 | + GetJobRequest, |
| 126 | + HadoopJob, |
| 127 | + HiveJob, |
| 128 | + Job, |
| 129 | + JobMetadata, |
| 130 | + JobPlacement, |
| 131 | + JobReference, |
| 132 | + JobScheduling, |
| 133 | + JobStatus, |
| 134 | + ListJobsRequest, |
| 135 | + ListJobsResponse, |
| 136 | + LoggingConfig, |
| 137 | + PigJob, |
| 138 | + PrestoJob, |
| 139 | + PySparkJob, |
| 140 | + QueryList, |
| 141 | + SparkJob, |
| 142 | + SparkRJob, |
| 143 | + SparkSqlJob, |
| 144 | + SubmitJobRequest, |
| 145 | + TrinoJob, |
| 146 | + UpdateJobRequest, |
| 147 | + YarnApplication, |
193 | 148 | )
|
194 |
| -from google.cloud.dataproc_v1.types.workflow_templates import ( |
195 |
| - InstantiateWorkflowTemplateRequest, |
| 149 | +from google.cloud.dataproc_v1.types.node_groups import ( |
| 150 | + CreateNodeGroupRequest, |
| 151 | + GetNodeGroupRequest, |
| 152 | + ResizeNodeGroupRequest, |
196 | 153 | )
|
197 |
| -from google.cloud.dataproc_v1.types.workflow_templates import ( |
198 |
| - ListWorkflowTemplatesRequest, |
| 154 | +from google.cloud.dataproc_v1.types.operations import ( |
| 155 | + BatchOperationMetadata, |
| 156 | + ClusterOperationMetadata, |
| 157 | + ClusterOperationStatus, |
| 158 | + NodeGroupOperationMetadata, |
199 | 159 | )
|
200 |
| -from google.cloud.dataproc_v1.types.workflow_templates import ( |
201 |
| - ListWorkflowTemplatesResponse, |
| 160 | +from google.cloud.dataproc_v1.types.shared import ( |
| 161 | + Component, |
| 162 | + EnvironmentConfig, |
| 163 | + ExecutionConfig, |
| 164 | + FailureAction, |
| 165 | + GkeClusterConfig, |
| 166 | + GkeNodePoolConfig, |
| 167 | + GkeNodePoolTarget, |
| 168 | + KubernetesClusterConfig, |
| 169 | + KubernetesSoftwareConfig, |
| 170 | + PeripheralsConfig, |
| 171 | + RuntimeConfig, |
| 172 | + RuntimeInfo, |
| 173 | + SparkHistoryServerConfig, |
| 174 | + UsageMetrics, |
| 175 | + UsageSnapshot, |
202 | 176 | )
|
203 |
| -from google.cloud.dataproc_v1.types.workflow_templates import ManagedCluster |
204 |
| -from google.cloud.dataproc_v1.types.workflow_templates import OrderedJob |
205 |
| -from google.cloud.dataproc_v1.types.workflow_templates import ParameterValidation |
206 |
| -from google.cloud.dataproc_v1.types.workflow_templates import RegexValidation |
207 |
| -from google.cloud.dataproc_v1.types.workflow_templates import TemplateParameter |
208 | 177 | from google.cloud.dataproc_v1.types.workflow_templates import (
|
| 178 | + ClusterOperation, |
| 179 | + ClusterSelector, |
| 180 | + CreateWorkflowTemplateRequest, |
| 181 | + DeleteWorkflowTemplateRequest, |
| 182 | + GetWorkflowTemplateRequest, |
| 183 | + InstantiateInlineWorkflowTemplateRequest, |
| 184 | + InstantiateWorkflowTemplateRequest, |
| 185 | + ListWorkflowTemplatesRequest, |
| 186 | + ListWorkflowTemplatesResponse, |
| 187 | + ManagedCluster, |
| 188 | + OrderedJob, |
| 189 | + ParameterValidation, |
| 190 | + RegexValidation, |
| 191 | + TemplateParameter, |
209 | 192 | UpdateWorkflowTemplateRequest,
|
| 193 | + ValueValidation, |
| 194 | + WorkflowGraph, |
| 195 | + WorkflowMetadata, |
| 196 | + WorkflowNode, |
| 197 | + WorkflowTemplate, |
| 198 | + WorkflowTemplatePlacement, |
210 | 199 | )
|
211 |
| -from google.cloud.dataproc_v1.types.workflow_templates import ValueValidation |
212 |
| -from google.cloud.dataproc_v1.types.workflow_templates import WorkflowGraph |
213 |
| -from google.cloud.dataproc_v1.types.workflow_templates import WorkflowMetadata |
214 |
| -from google.cloud.dataproc_v1.types.workflow_templates import WorkflowNode |
215 |
| -from google.cloud.dataproc_v1.types.workflow_templates import WorkflowTemplate |
216 |
| -from google.cloud.dataproc_v1.types.workflow_templates import WorkflowTemplatePlacement |
217 | 200 |
|
218 | 201 | __all__ = (
|
219 | 202 | "AutoscalingPolicyServiceClient",
|
|
0 commit comments