Summary of entries of Methods for dataproc.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient
AutoscalingPolicyServiceAsyncClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.dataproc_v1.services.autoscaling_policy_service.transports.base.AutoscalingPolicyServiceTransport, typing.Callable[[...], google.cloud.dataproc_v1.services.autoscaling_policy_service.transports.base.AutoscalingPolicyServiceTransport]]] = 'grpc_asyncio', client_options: typing.Optional[google.api_core.client_options.ClientOptions] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo = Instantiates the autoscaling policy service async client.
See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.autoscaling_policy_path
autoscaling_policy_path( project: str, location: str, autoscaling_policy: str ) -> strReturns a fully-qualified autoscaling_policy string.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.cancel_operation
cancel_operation( request: typing.Optional[ google.longrunning.operations_pb2.CancelOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneStarts asynchronous cancellation on a long-running operation.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.create_autoscaling_policy
create_autoscaling_policy( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.autoscaling_policies.CreateAutoscalingPolicyRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, policy: typing.Optional[ google.cloud.dataproc_v1.types.autoscaling_policies.AutoscalingPolicy ] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.autoscaling_policies.AutoscalingPolicyCreates new autoscaling policy.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.delete_autoscaling_policy
delete_autoscaling_policy( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.autoscaling_policies.DeleteAutoscalingPolicyRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneDeletes an autoscaling policy.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.delete_operation
delete_operation( request: typing.Optional[ google.longrunning.operations_pb2.DeleteOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneDeletes a long-running operation.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.get_autoscaling_policy
get_autoscaling_policy( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.autoscaling_policies.GetAutoscalingPolicyRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.autoscaling_policies.AutoscalingPolicyRetrieves autoscaling policy.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.get_iam_policy
get_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source( client_options: typing.Optional[ google.api_core.client_options.ClientOptions ] = None, )Return the API endpoint and client cert source for mutual TLS.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.get_operation
get_operation( request: typing.Optional[ google.longrunning.operations_pb2.GetOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.get_transport_class
get_transport_class( label: typing.Optional[str] = None, ) -> typing.Type[ google.cloud.dataproc_v1.services.autoscaling_policy_service.transports.base.AutoscalingPolicyServiceTransport ]Returns an appropriate transport class.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.list_autoscaling_policies
list_autoscaling_policies( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.autoscaling_policies.ListAutoscalingPoliciesRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> ( google.cloud.dataproc_v1.services.autoscaling_policy_service.pagers.ListAutoscalingPoliciesAsyncPager )Lists autoscaling policies in the project.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.list_operations
list_operations( request: typing.Optional[ google.longrunning.operations_pb2.ListOperationsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.parse_autoscaling_policy_path
parse_autoscaling_policy_path(path: str) -> typing.Dict[str, str]Parses a autoscaling_policy path into its component segments.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.set_iam_policy
set_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.test_iam_permissions
test_iam_permissions( request: typing.Optional[ google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceAsyncClient.update_autoscaling_policy
update_autoscaling_policy( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.autoscaling_policies.UpdateAutoscalingPolicyRequest, dict, ] ] = None, *, policy: typing.Optional[ google.cloud.dataproc_v1.types.autoscaling_policies.AutoscalingPolicy ] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.autoscaling_policies.AutoscalingPolicyUpdates (replaces) autoscaling policy.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient
AutoscalingPolicyServiceClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.dataproc_v1.services.autoscaling_policy_service.transports.base.AutoscalingPolicyServiceTransport, typing.Callable[[...], google.cloud.dataproc_v1.services.autoscaling_policy_service.transports.base.AutoscalingPolicyServiceTransport]]] = None, client_options: typing.Optional[typing.Union[google.api_core.client_options.ClientOptions, dict]] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo = Instantiates the autoscaling policy service client.
See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.__exit__
__exit__(type, value, traceback)Releases underlying transport's resources.
See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.exit
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.autoscaling_policy_path
autoscaling_policy_path( project: str, location: str, autoscaling_policy: str ) -> strReturns a fully-qualified autoscaling_policy string.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.cancel_operation
cancel_operation( request: typing.Optional[ google.longrunning.operations_pb2.CancelOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneStarts asynchronous cancellation on a long-running operation.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.create_autoscaling_policy
create_autoscaling_policy( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.autoscaling_policies.CreateAutoscalingPolicyRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, policy: typing.Optional[ google.cloud.dataproc_v1.types.autoscaling_policies.AutoscalingPolicy ] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.autoscaling_policies.AutoscalingPolicyCreates new autoscaling policy.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.delete_autoscaling_policy
delete_autoscaling_policy( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.autoscaling_policies.DeleteAutoscalingPolicyRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneDeletes an autoscaling policy.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.delete_operation
delete_operation( request: typing.Optional[ google.longrunning.operations_pb2.DeleteOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneDeletes a long-running operation.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.get_autoscaling_policy
get_autoscaling_policy( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.autoscaling_policies.GetAutoscalingPolicyRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.autoscaling_policies.AutoscalingPolicyRetrieves autoscaling policy.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.get_iam_policy
get_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source( client_options: typing.Optional[ google.api_core.client_options.ClientOptions ] = None, )Deprecated.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.get_operation
get_operation( request: typing.Optional[ google.longrunning.operations_pb2.GetOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.list_autoscaling_policies
list_autoscaling_policies( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.autoscaling_policies.ListAutoscalingPoliciesRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> ( google.cloud.dataproc_v1.services.autoscaling_policy_service.pagers.ListAutoscalingPoliciesPager )Lists autoscaling policies in the project.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.list_operations
list_operations( request: typing.Optional[ google.longrunning.operations_pb2.ListOperationsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.parse_autoscaling_policy_path
parse_autoscaling_policy_path(path: str) -> typing.Dict[str, str]Parses a autoscaling_policy path into its component segments.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.set_iam_policy
set_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.test_iam_permissions
test_iam_permissions( request: typing.Optional[ google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
google.cloud.dataproc_v1.services.autoscaling_policy_service.AutoscalingPolicyServiceClient.update_autoscaling_policy
update_autoscaling_policy( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.autoscaling_policies.UpdateAutoscalingPolicyRequest, dict, ] ] = None, *, policy: typing.Optional[ google.cloud.dataproc_v1.types.autoscaling_policies.AutoscalingPolicy ] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.autoscaling_policies.AutoscalingPolicyUpdates (replaces) autoscaling policy.
google.cloud.dataproc_v1.services.autoscaling_policy_service.pagers.ListAutoscalingPoliciesAsyncPager
ListAutoscalingPoliciesAsyncPager( method: typing.Callable[ [...], typing.Awaitable[ google.cloud.dataproc_v1.types.autoscaling_policies.ListAutoscalingPoliciesResponse ], ], request: google.cloud.dataproc_v1.types.autoscaling_policies.ListAutoscalingPoliciesRequest, response: google.cloud.dataproc_v1.types.autoscaling_policies.ListAutoscalingPoliciesResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () )Instantiates the pager.
google.cloud.dataproc_v1.services.autoscaling_policy_service.pagers.ListAutoscalingPoliciesPager
ListAutoscalingPoliciesPager( method: typing.Callable[ [...], google.cloud.dataproc_v1.types.autoscaling_policies.ListAutoscalingPoliciesResponse, ], request: google.cloud.dataproc_v1.types.autoscaling_policies.ListAutoscalingPoliciesRequest, response: google.cloud.dataproc_v1.types.autoscaling_policies.ListAutoscalingPoliciesResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () )Instantiate the pager.
See more: google.cloud.dataproc_v1.services.autoscaling_policy_service.pagers.ListAutoscalingPoliciesPager
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient
BatchControllerAsyncClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.dataproc_v1.services.batch_controller.transports.base.BatchControllerTransport, typing.Callable[[...], google.cloud.dataproc_v1.services.batch_controller.transports.base.BatchControllerTransport]]] = 'grpc_asyncio', client_options: typing.Optional[google.api_core.client_options.ClientOptions] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo = Instantiates the batch controller async client.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.batch_path
batch_path(project: str, location: str, batch: str) -> strReturns a fully-qualified batch string.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.batch_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.cancel_operation
cancel_operation( request: typing.Optional[ google.longrunning.operations_pb2.CancelOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneStarts asynchronous cancellation on a long-running operation.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.cancel_operation
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.common_folder_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.common_location_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.common_project_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.create_batch
create_batch( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.batches.CreateBatchRequest, dict] ] = None, *, parent: typing.Optional[str] = None, batch: typing.Optional[google.cloud.dataproc_v1.types.batches.Batch] = None, batch_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationCreates a batch workload that executes asynchronously.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.create_batch
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.delete_batch
delete_batch( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.batches.DeleteBatchRequest, dict] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneDeletes the batch workload resource.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.delete_batch
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.delete_operation
delete_operation( request: typing.Optional[ google.longrunning.operations_pb2.DeleteOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneDeletes a long-running operation.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.delete_operation
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.get_batch
get_batch( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.batches.GetBatchRequest, dict] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.batches.BatchGets the batch workload resource representation.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.get_batch
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.get_iam_policy
get_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.get_iam_policy
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source( client_options: typing.Optional[ google.api_core.client_options.ClientOptions ] = None, )Return the API endpoint and client cert source for mutual TLS.
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.get_operation
get_operation( request: typing.Optional[ google.longrunning.operations_pb2.GetOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.get_operation
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.get_transport_class
get_transport_class( label: typing.Optional[str] = None, ) -> typing.Type[ google.cloud.dataproc_v1.services.batch_controller.transports.base.BatchControllerTransport ]Returns an appropriate transport class.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.get_transport_class
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.list_batches
list_batches( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.batches.ListBatchesRequest, dict] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.services.batch_controller.pagers.ListBatchesAsyncPagerLists batch workloads.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.list_batches
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.list_operations
list_operations( request: typing.Optional[ google.longrunning.operations_pb2.ListOperationsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.list_operations
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.parse_batch_path
parse_batch_path(path: str) -> typing.Dict[str, str]Parses a batch path into its component segments.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.parse_batch_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.parse_service_path
parse_service_path(path: str) -> typing.Dict[str, str]Parses a service path into its component segments.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.parse_service_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.service_path
service_path(project: str, location: str, service: str) -> strReturns a fully-qualified service string.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.service_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.set_iam_policy
set_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.set_iam_policy
google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.test_iam_permissions
test_iam_permissions( request: typing.Optional[ google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerAsyncClient.test_iam_permissions
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient
BatchControllerClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.dataproc_v1.services.batch_controller.transports.base.BatchControllerTransport, typing.Callable[[...], google.cloud.dataproc_v1.services.batch_controller.transports.base.BatchControllerTransport]]] = None, client_options: typing.Optional[typing.Union[google.api_core.client_options.ClientOptions, dict]] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo = Instantiates the batch controller client.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.__exit__
__exit__(type, value, traceback)Releases underlying transport's resources.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.exit
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.batch_path
batch_path(project: str, location: str, batch: str) -> strReturns a fully-qualified batch string.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.batch_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.cancel_operation
cancel_operation( request: typing.Optional[ google.longrunning.operations_pb2.CancelOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneStarts asynchronous cancellation on a long-running operation.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.cancel_operation
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.common_billing_account_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.common_folder_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.common_location_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.common_organization_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.common_project_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.create_batch
create_batch( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.batches.CreateBatchRequest, dict] ] = None, *, parent: typing.Optional[str] = None, batch: typing.Optional[google.cloud.dataproc_v1.types.batches.Batch] = None, batch_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationCreates a batch workload that executes asynchronously.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.create_batch
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.delete_batch
delete_batch( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.batches.DeleteBatchRequest, dict] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneDeletes the batch workload resource.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.delete_batch
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.delete_operation
delete_operation( request: typing.Optional[ google.longrunning.operations_pb2.DeleteOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneDeletes a long-running operation.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.delete_operation
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.from_service_account_file
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.from_service_account_info
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.from_service_account_json
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.get_batch
get_batch( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.batches.GetBatchRequest, dict] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.batches.BatchGets the batch workload resource representation.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.get_batch
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.get_iam_policy
get_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.get_iam_policy
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source( client_options: typing.Optional[ google.api_core.client_options.ClientOptions ] = None, )Deprecated.
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.get_operation
get_operation( request: typing.Optional[ google.longrunning.operations_pb2.GetOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.get_operation
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.list_batches
list_batches( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.batches.ListBatchesRequest, dict] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.services.batch_controller.pagers.ListBatchesPagerLists batch workloads.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.list_batches
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.list_operations
list_operations( request: typing.Optional[ google.longrunning.operations_pb2.ListOperationsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.list_operations
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.parse_batch_path
parse_batch_path(path: str) -> typing.Dict[str, str]Parses a batch path into its component segments.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.parse_batch_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.parse_common_folder_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.parse_common_location_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.parse_common_project_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.parse_service_path
parse_service_path(path: str) -> typing.Dict[str, str]Parses a service path into its component segments.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.parse_service_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.service_path
service_path(project: str, location: str, service: str) -> strReturns a fully-qualified service string.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.service_path
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.set_iam_policy
set_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.set_iam_policy
google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.test_iam_permissions
test_iam_permissions( request: typing.Optional[ google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.batch_controller.BatchControllerClient.test_iam_permissions
google.cloud.dataproc_v1.services.batch_controller.pagers.ListBatchesAsyncPager
ListBatchesAsyncPager( method: typing.Callable[ [...], typing.Awaitable[google.cloud.dataproc_v1.types.batches.ListBatchesResponse], ], request: google.cloud.dataproc_v1.types.batches.ListBatchesRequest, response: google.cloud.dataproc_v1.types.batches.ListBatchesResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () )Instantiates the pager.
See more: google.cloud.dataproc_v1.services.batch_controller.pagers.ListBatchesAsyncPager
google.cloud.dataproc_v1.services.batch_controller.pagers.ListBatchesPager
ListBatchesPager( method: typing.Callable[ [...], google.cloud.dataproc_v1.types.batches.ListBatchesResponse ], request: google.cloud.dataproc_v1.types.batches.ListBatchesRequest, response: google.cloud.dataproc_v1.types.batches.ListBatchesResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () )Instantiate the pager.
See more: google.cloud.dataproc_v1.services.batch_controller.pagers.ListBatchesPager
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient
ClusterControllerAsyncClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.dataproc_v1.services.cluster_controller.transports.base.ClusterControllerTransport, typing.Callable[[...], google.cloud.dataproc_v1.services.cluster_controller.transports.base.ClusterControllerTransport]]] = 'grpc_asyncio', client_options: typing.Optional[google.api_core.client_options.ClientOptions] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo = Instantiates the cluster controller async client.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.cancel_operation
cancel_operation( request: typing.Optional[ google.longrunning.operations_pb2.CancelOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneStarts asynchronous cancellation on a long-running operation.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.cancel_operation
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.cluster_path
cluster_path(project: str, location: str, cluster: str) -> strReturns a fully-qualified cluster string.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.cluster_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.common_folder_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.create_cluster
create_cluster( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.clusters.CreateClusterRequest, dict] ] = None, *, project_id: typing.Optional[str] = None, region: typing.Optional[str] = None, cluster: typing.Optional[google.cloud.dataproc_v1.types.clusters.Cluster] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationCreates a cluster in a project.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.create_cluster
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.crypto_key_path
crypto_key_path(project: str, location: str, key_ring: str, crypto_key: str) -> strReturns a fully-qualified crypto_key string.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.crypto_key_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.delete_cluster
delete_cluster( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.clusters.DeleteClusterRequest, dict] ] = None, *, project_id: typing.Optional[str] = None, region: typing.Optional[str] = None, cluster_name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationDeletes a cluster in a project.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.delete_cluster
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.delete_operation
delete_operation( request: typing.Optional[ google.longrunning.operations_pb2.DeleteOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneDeletes a long-running operation.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.delete_operation
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.diagnose_cluster
diagnose_cluster( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.clusters.DiagnoseClusterRequest, dict ] ] = None, *, project_id: typing.Optional[str] = None, region: typing.Optional[str] = None, cluster_name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationGets cluster diagnostic information.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.diagnose_cluster
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.get_cluster
get_cluster( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.clusters.GetClusterRequest, dict] ] = None, *, project_id: typing.Optional[str] = None, region: typing.Optional[str] = None, cluster_name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.clusters.ClusterGets the resource representation for a cluster in a project.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.get_cluster
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.get_iam_policy
get_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.get_iam_policy
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source( client_options: typing.Optional[ google.api_core.client_options.ClientOptions ] = None, )Return the API endpoint and client cert source for mutual TLS.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.get_operation
get_operation( request: typing.Optional[ google.longrunning.operations_pb2.GetOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.get_operation
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.get_transport_class
get_transport_class( label: typing.Optional[str] = None, ) -> typing.Type[ google.cloud.dataproc_v1.services.cluster_controller.transports.base.ClusterControllerTransport ]Returns an appropriate transport class.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.list_clusters
list_clusters( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.clusters.ListClustersRequest, dict] ] = None, *, project_id: typing.Optional[str] = None, region: typing.Optional[str] = None, filter: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.services.cluster_controller.pagers.ListClustersAsyncPagerLists all regions/{region}/clusters in a project alphabetically.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.list_clusters
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.list_operations
list_operations( request: typing.Optional[ google.longrunning.operations_pb2.ListOperationsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.list_operations
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.node_group_path
node_group_path(project: str, region: str, cluster: str, node_group: str) -> strReturns a fully-qualified node_group string.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.node_group_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.parse_cluster_path
parse_cluster_path(path: str) -> typing.Dict[str, str]Parses a cluster path into its component segments.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.parse_cluster_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.parse_crypto_key_path
parse_crypto_key_path(path: str) -> typing.Dict[str, str]Parses a crypto_key path into its component segments.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.parse_node_group_path
parse_node_group_path(path: str) -> typing.Dict[str, str]Parses a node_group path into its component segments.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.parse_service_path
parse_service_path(path: str) -> typing.Dict[str, str]Parses a service path into its component segments.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.parse_service_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.service_path
service_path(project: str, location: str, service: str) -> strReturns a fully-qualified service string.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.service_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.set_iam_policy
set_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.set_iam_policy
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.start_cluster
start_cluster( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.clusters.StartClusterRequest, dict] ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationStarts a cluster in a project.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.start_cluster
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.stop_cluster
stop_cluster( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.clusters.StopClusterRequest, dict] ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationStops a cluster in a project.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.stop_cluster
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.test_iam_permissions
test_iam_permissions( request: typing.Optional[ google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.update_cluster
update_cluster( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.clusters.UpdateClusterRequest, dict] ] = None, *, project_id: typing.Optional[str] = None, region: typing.Optional[str] = None, cluster_name: typing.Optional[str] = None, cluster: typing.Optional[google.cloud.dataproc_v1.types.clusters.Cluster] = None, update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationUpdates a cluster in a project.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerAsyncClient.update_cluster
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient
ClusterControllerClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.dataproc_v1.services.cluster_controller.transports.base.ClusterControllerTransport, typing.Callable[[...], google.cloud.dataproc_v1.services.cluster_controller.transports.base.ClusterControllerTransport]]] = None, client_options: typing.Optional[typing.Union[google.api_core.client_options.ClientOptions, dict]] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo = Instantiates the cluster controller client.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.__exit__
__exit__(type, value, traceback)Releases underlying transport's resources.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.exit
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.cancel_operation
cancel_operation( request: typing.Optional[ google.longrunning.operations_pb2.CancelOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneStarts asynchronous cancellation on a long-running operation.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.cancel_operation
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.cluster_path
cluster_path(project: str, location: str, cluster: str) -> strReturns a fully-qualified cluster string.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.cluster_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.common_folder_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.common_location_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.common_project_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.create_cluster
create_cluster( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.clusters.CreateClusterRequest, dict] ] = None, *, project_id: typing.Optional[str] = None, region: typing.Optional[str] = None, cluster: typing.Optional[google.cloud.dataproc_v1.types.clusters.Cluster] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationCreates a cluster in a project.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.create_cluster
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.crypto_key_path
crypto_key_path(project: str, location: str, key_ring: str, crypto_key: str) -> strReturns a fully-qualified crypto_key string.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.crypto_key_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.delete_cluster
delete_cluster( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.clusters.DeleteClusterRequest, dict] ] = None, *, project_id: typing.Optional[str] = None, region: typing.Optional[str] = None, cluster_name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationDeletes a cluster in a project.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.delete_cluster
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.delete_operation
delete_operation( request: typing.Optional[ google.longrunning.operations_pb2.DeleteOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneDeletes a long-running operation.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.delete_operation
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.diagnose_cluster
diagnose_cluster( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.clusters.DiagnoseClusterRequest, dict ] ] = None, *, project_id: typing.Optional[str] = None, region: typing.Optional[str] = None, cluster_name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationGets cluster diagnostic information.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.diagnose_cluster
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.get_cluster
get_cluster( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.clusters.GetClusterRequest, dict] ] = None, *, project_id: typing.Optional[str] = None, region: typing.Optional[str] = None, cluster_name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.clusters.ClusterGets the resource representation for a cluster in a project.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.get_cluster
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.get_iam_policy
get_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.get_iam_policy
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source( client_options: typing.Optional[ google.api_core.client_options.ClientOptions ] = None, )Deprecated.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.get_operation
get_operation( request: typing.Optional[ google.longrunning.operations_pb2.GetOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.get_operation
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.list_clusters
list_clusters( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.clusters.ListClustersRequest, dict] ] = None, *, project_id: typing.Optional[str] = None, region: typing.Optional[str] = None, filter: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.services.cluster_controller.pagers.ListClustersPagerLists all regions/{region}/clusters in a project alphabetically.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.list_clusters
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.list_operations
list_operations( request: typing.Optional[ google.longrunning.operations_pb2.ListOperationsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.list_operations
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.node_group_path
node_group_path(project: str, region: str, cluster: str, node_group: str) -> strReturns a fully-qualified node_group string.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.node_group_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_cluster_path
parse_cluster_path(path: str) -> typing.Dict[str, str]Parses a cluster path into its component segments.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_cluster_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_crypto_key_path
parse_crypto_key_path(path: str) -> typing.Dict[str, str]Parses a crypto_key path into its component segments.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_crypto_key_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_node_group_path
parse_node_group_path(path: str) -> typing.Dict[str, str]Parses a node_group path into its component segments.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_node_group_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_service_path
parse_service_path(path: str) -> typing.Dict[str, str]Parses a service path into its component segments.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.parse_service_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.service_path
service_path(project: str, location: str, service: str) -> strReturns a fully-qualified service string.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.service_path
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.set_iam_policy
set_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.set_iam_policy
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.start_cluster
start_cluster( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.clusters.StartClusterRequest, dict] ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationStarts a cluster in a project.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.start_cluster
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.stop_cluster
stop_cluster( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.clusters.StopClusterRequest, dict] ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationStops a cluster in a project.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.stop_cluster
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.test_iam_permissions
test_iam_permissions( request: typing.Optional[ google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.test_iam_permissions
google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.update_cluster
update_cluster( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.clusters.UpdateClusterRequest, dict] ] = None, *, project_id: typing.Optional[str] = None, region: typing.Optional[str] = None, cluster_name: typing.Optional[str] = None, cluster: typing.Optional[google.cloud.dataproc_v1.types.clusters.Cluster] = None, update_mask: typing.Optional[google.protobuf.field_mask_pb2.FieldMask] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationUpdates a cluster in a project.
See more: google.cloud.dataproc_v1.services.cluster_controller.ClusterControllerClient.update_cluster
google.cloud.dataproc_v1.services.cluster_controller.pagers.ListClustersAsyncPager
ListClustersAsyncPager( method: typing.Callable[ [...], typing.Awaitable[google.cloud.dataproc_v1.types.clusters.ListClustersResponse], ], request: google.cloud.dataproc_v1.types.clusters.ListClustersRequest, response: google.cloud.dataproc_v1.types.clusters.ListClustersResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () )Instantiates the pager.
See more: google.cloud.dataproc_v1.services.cluster_controller.pagers.ListClustersAsyncPager
google.cloud.dataproc_v1.services.cluster_controller.pagers.ListClustersPager
ListClustersPager( method: typing.Callable[ [...], google.cloud.dataproc_v1.types.clusters.ListClustersResponse ], request: google.cloud.dataproc_v1.types.clusters.ListClustersRequest, response: google.cloud.dataproc_v1.types.clusters.ListClustersResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () )Instantiate the pager.
See more: google.cloud.dataproc_v1.services.cluster_controller.pagers.ListClustersPager
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient
JobControllerAsyncClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.dataproc_v1.services.job_controller.transports.base.JobControllerTransport, typing.Callable[[...], google.cloud.dataproc_v1.services.job_controller.transports.base.JobControllerTransport]]] = 'grpc_asyncio', client_options: typing.Optional[google.api_core.client_options.ClientOptions] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo = Instantiates the job controller async client.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.cancel_job
cancel_job( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.jobs.CancelJobRequest, dict] ] = None, *, project_id: typing.Optional[str] = None, region: typing.Optional[str] = None, job_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.jobs.JobStarts a job cancellation request.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.cancel_job
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.cancel_operation
cancel_operation( request: typing.Optional[ google.longrunning.operations_pb2.CancelOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneStarts asynchronous cancellation on a long-running operation.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.cancel_operation
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.common_folder_path
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.common_location_path
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.common_organization_path
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.common_project_path
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.delete_job
delete_job( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.jobs.DeleteJobRequest, dict] ] = None, *, project_id: typing.Optional[str] = None, region: typing.Optional[str] = None, job_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneDeletes the job from the project.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.delete_job
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.delete_operation
delete_operation( request: typing.Optional[ google.longrunning.operations_pb2.DeleteOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneDeletes a long-running operation.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.delete_operation
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.from_service_account_file
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.from_service_account_info
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.from_service_account_json
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.get_iam_policy
get_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.get_iam_policy
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.get_job
get_job( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.jobs.GetJobRequest, dict] ] = None, *, project_id: typing.Optional[str] = None, region: typing.Optional[str] = None, job_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.jobs.JobGets the resource representation for a job in a project.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.get_job
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source( client_options: typing.Optional[ google.api_core.client_options.ClientOptions ] = None, )Return the API endpoint and client cert source for mutual TLS.
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.get_operation
get_operation( request: typing.Optional[ google.longrunning.operations_pb2.GetOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.get_operation
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.get_transport_class
get_transport_class( label: typing.Optional[str] = None, ) -> typing.Type[ google.cloud.dataproc_v1.services.job_controller.transports.base.JobControllerTransport ]Returns an appropriate transport class.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.get_transport_class
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.list_jobs
list_jobs( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.jobs.ListJobsRequest, dict] ] = None, *, project_id: typing.Optional[str] = None, region: typing.Optional[str] = None, filter: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.services.job_controller.pagers.ListJobsAsyncPagerLists regions/{region}/jobs in a project.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.list_jobs
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.list_operations
list_operations( request: typing.Optional[ google.longrunning.operations_pb2.ListOperationsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.list_operations
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.parse_common_folder_path
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.parse_common_location_path
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.parse_common_project_path
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.set_iam_policy
set_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.set_iam_policy
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.submit_job
submit_job( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.jobs.SubmitJobRequest, dict] ] = None, *, project_id: typing.Optional[str] = None, region: typing.Optional[str] = None, job: typing.Optional[google.cloud.dataproc_v1.types.jobs.Job] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.jobs.JobSubmits a job to a cluster.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.submit_job
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.submit_job_as_operation
submit_job_as_operation( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.jobs.SubmitJobRequest, dict] ] = None, *, project_id: typing.Optional[str] = None, region: typing.Optional[str] = None, job: typing.Optional[google.cloud.dataproc_v1.types.jobs.Job] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationSubmits job to a cluster.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.submit_job_as_operation
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.test_iam_permissions
test_iam_permissions( request: typing.Optional[ google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.test_iam_permissions
google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.update_job
update_job( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.jobs.UpdateJobRequest, dict] ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.jobs.JobUpdates a job in a project.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerAsyncClient.update_job
google.cloud.dataproc_v1.services.job_controller.JobControllerClient
JobControllerClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.dataproc_v1.services.job_controller.transports.base.JobControllerTransport, typing.Callable[[...], google.cloud.dataproc_v1.services.job_controller.transports.base.JobControllerTransport]]] = None, client_options: typing.Optional[typing.Union[google.api_core.client_options.ClientOptions, dict]] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo = Instantiates the job controller client.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.__exit__
__exit__(type, value, traceback)Releases underlying transport's resources.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.exit
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.cancel_job
cancel_job( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.jobs.CancelJobRequest, dict] ] = None, *, project_id: typing.Optional[str] = None, region: typing.Optional[str] = None, job_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.jobs.JobStarts a job cancellation request.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.cancel_job
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.cancel_operation
cancel_operation( request: typing.Optional[ google.longrunning.operations_pb2.CancelOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneStarts asynchronous cancellation on a long-running operation.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.cancel_operation
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.common_billing_account_path
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.common_folder_path
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.common_location_path
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.common_organization_path
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.common_project_path
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.delete_job
delete_job( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.jobs.DeleteJobRequest, dict] ] = None, *, project_id: typing.Optional[str] = None, region: typing.Optional[str] = None, job_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneDeletes the job from the project.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.delete_job
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.delete_operation
delete_operation( request: typing.Optional[ google.longrunning.operations_pb2.DeleteOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneDeletes a long-running operation.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.delete_operation
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.from_service_account_file
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.from_service_account_info
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.from_service_account_json
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.get_iam_policy
get_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.get_iam_policy
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.get_job
get_job( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.jobs.GetJobRequest, dict] ] = None, *, project_id: typing.Optional[str] = None, region: typing.Optional[str] = None, job_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.jobs.JobGets the resource representation for a job in a project.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.get_job
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source( client_options: typing.Optional[ google.api_core.client_options.ClientOptions ] = None, )Deprecated.
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.get_operation
get_operation( request: typing.Optional[ google.longrunning.operations_pb2.GetOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.get_operation
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.list_jobs
list_jobs( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.jobs.ListJobsRequest, dict] ] = None, *, project_id: typing.Optional[str] = None, region: typing.Optional[str] = None, filter: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.services.job_controller.pagers.ListJobsPagerLists regions/{region}/jobs in a project.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.list_jobs
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.list_operations
list_operations( request: typing.Optional[ google.longrunning.operations_pb2.ListOperationsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.list_operations
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.parse_common_folder_path
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.parse_common_location_path
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.parse_common_organization_path
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.parse_common_project_path
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.set_iam_policy
set_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.set_iam_policy
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.submit_job
submit_job( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.jobs.SubmitJobRequest, dict] ] = None, *, project_id: typing.Optional[str] = None, region: typing.Optional[str] = None, job: typing.Optional[google.cloud.dataproc_v1.types.jobs.Job] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.jobs.JobSubmits a job to a cluster.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.submit_job
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.submit_job_as_operation
submit_job_as_operation( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.jobs.SubmitJobRequest, dict] ] = None, *, project_id: typing.Optional[str] = None, region: typing.Optional[str] = None, job: typing.Optional[google.cloud.dataproc_v1.types.jobs.Job] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationSubmits job to a cluster.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.submit_job_as_operation
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.test_iam_permissions
test_iam_permissions( request: typing.Optional[ google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.test_iam_permissions
google.cloud.dataproc_v1.services.job_controller.JobControllerClient.update_job
update_job( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.jobs.UpdateJobRequest, dict] ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.jobs.JobUpdates a job in a project.
See more: google.cloud.dataproc_v1.services.job_controller.JobControllerClient.update_job
google.cloud.dataproc_v1.services.job_controller.pagers.ListJobsAsyncPager
ListJobsAsyncPager( method: typing.Callable[ [...], typing.Awaitable[google.cloud.dataproc_v1.types.jobs.ListJobsResponse] ], request: google.cloud.dataproc_v1.types.jobs.ListJobsRequest, response: google.cloud.dataproc_v1.types.jobs.ListJobsResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () )Instantiates the pager.
See more: google.cloud.dataproc_v1.services.job_controller.pagers.ListJobsAsyncPager
google.cloud.dataproc_v1.services.job_controller.pagers.ListJobsPager
ListJobsPager( method: typing.Callable[ [...], google.cloud.dataproc_v1.types.jobs.ListJobsResponse ], request: google.cloud.dataproc_v1.types.jobs.ListJobsRequest, response: google.cloud.dataproc_v1.types.jobs.ListJobsResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () )Instantiate the pager.
See more: google.cloud.dataproc_v1.services.job_controller.pagers.ListJobsPager
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient
NodeGroupControllerAsyncClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.dataproc_v1.services.node_group_controller.transports.base.NodeGroupControllerTransport, typing.Callable[[...], google.cloud.dataproc_v1.services.node_group_controller.transports.base.NodeGroupControllerTransport]]] = 'grpc_asyncio', client_options: typing.Optional[google.api_core.client_options.ClientOptions] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo = Instantiates the node group controller async client.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.cancel_operation
cancel_operation( request: typing.Optional[ google.longrunning.operations_pb2.CancelOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneStarts asynchronous cancellation on a long-running operation.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.create_node_group
create_node_group( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.node_groups.CreateNodeGroupRequest, dict ] ] = None, *, parent: typing.Optional[str] = None, node_group: typing.Optional[ google.cloud.dataproc_v1.types.clusters.NodeGroup ] = None, node_group_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationCreates a node group in a cluster.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.delete_operation
delete_operation( request: typing.Optional[ google.longrunning.operations_pb2.DeleteOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneDeletes a long-running operation.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.get_iam_policy
get_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source( client_options: typing.Optional[ google.api_core.client_options.ClientOptions ] = None, )Return the API endpoint and client cert source for mutual TLS.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.get_node_group
get_node_group( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.node_groups.GetNodeGroupRequest, dict ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.clusters.NodeGroupGets the resource representation for a node group in a cluster.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.get_operation
get_operation( request: typing.Optional[ google.longrunning.operations_pb2.GetOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.get_operation
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.get_transport_class
get_transport_class( label: typing.Optional[str] = None, ) -> typing.Type[ google.cloud.dataproc_v1.services.node_group_controller.transports.base.NodeGroupControllerTransport ]Returns an appropriate transport class.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.list_operations
list_operations( request: typing.Optional[ google.longrunning.operations_pb2.ListOperationsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.node_group_path
node_group_path(project: str, region: str, cluster: str, node_group: str) -> strReturns a fully-qualified node_group string.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.parse_node_group_path
parse_node_group_path(path: str) -> typing.Dict[str, str]Parses a node_group path into its component segments.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.resize_node_group
resize_node_group( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.node_groups.ResizeNodeGroupRequest, dict ] ] = None, *, name: typing.Optional[str] = None, size: typing.Optional[int] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationResizes a node group in a cluster.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.set_iam_policy
set_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerAsyncClient.test_iam_permissions
test_iam_permissions( request: typing.Optional[ google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient
NodeGroupControllerClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.dataproc_v1.services.node_group_controller.transports.base.NodeGroupControllerTransport, typing.Callable[[...], google.cloud.dataproc_v1.services.node_group_controller.transports.base.NodeGroupControllerTransport]]] = None, client_options: typing.Optional[typing.Union[google.api_core.client_options.ClientOptions, dict]] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo = Instantiates the node group controller client.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.__exit__
__exit__(type, value, traceback)Releases underlying transport's resources.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.exit
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.cancel_operation
cancel_operation( request: typing.Optional[ google.longrunning.operations_pb2.CancelOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneStarts asynchronous cancellation on a long-running operation.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.cancel_operation
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.common_folder_path
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.create_node_group
create_node_group( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.node_groups.CreateNodeGroupRequest, dict ] ] = None, *, parent: typing.Optional[str] = None, node_group: typing.Optional[ google.cloud.dataproc_v1.types.clusters.NodeGroup ] = None, node_group_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationCreates a node group in a cluster.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.create_node_group
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.delete_operation
delete_operation( request: typing.Optional[ google.longrunning.operations_pb2.DeleteOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneDeletes a long-running operation.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.delete_operation
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.get_iam_policy
get_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.get_iam_policy
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source( client_options: typing.Optional[ google.api_core.client_options.ClientOptions ] = None, )Deprecated.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.get_node_group
get_node_group( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.node_groups.GetNodeGroupRequest, dict ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.clusters.NodeGroupGets the resource representation for a node group in a cluster.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.get_node_group
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.get_operation
get_operation( request: typing.Optional[ google.longrunning.operations_pb2.GetOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.get_operation
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.list_operations
list_operations( request: typing.Optional[ google.longrunning.operations_pb2.ListOperationsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.list_operations
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.node_group_path
node_group_path(project: str, region: str, cluster: str, node_group: str) -> strReturns a fully-qualified node_group string.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.node_group_path
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.parse_node_group_path
parse_node_group_path(path: str) -> typing.Dict[str, str]Parses a node_group path into its component segments.
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.resize_node_group
resize_node_group( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.node_groups.ResizeNodeGroupRequest, dict ] ] = None, *, name: typing.Optional[str] = None, size: typing.Optional[int] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationResizes a node group in a cluster.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.resize_node_group
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.set_iam_policy
set_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
See more: google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.set_iam_policy
google.cloud.dataproc_v1.services.node_group_controller.NodeGroupControllerClient.test_iam_permissions
test_iam_permissions( request: typing.Optional[ google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient
SessionControllerAsyncClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.dataproc_v1.services.session_controller.transports.base.SessionControllerTransport, typing.Callable[[...], google.cloud.dataproc_v1.services.session_controller.transports.base.SessionControllerTransport]]] = 'grpc_asyncio', client_options: typing.Optional[google.api_core.client_options.ClientOptions] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo = Instantiates the session controller async client.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.cancel_operation
cancel_operation( request: typing.Optional[ google.longrunning.operations_pb2.CancelOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneStarts asynchronous cancellation on a long-running operation.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.cancel_operation
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.common_folder_path
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.create_session
create_session( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.sessions.CreateSessionRequest, dict] ] = None, *, parent: typing.Optional[str] = None, session: typing.Optional[google.cloud.dataproc_v1.types.sessions.Session] = None, session_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationCreate an interactive session asynchronously.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.create_session
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.delete_operation
delete_operation( request: typing.Optional[ google.longrunning.operations_pb2.DeleteOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneDeletes a long-running operation.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.delete_operation
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.delete_session
delete_session( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.sessions.DeleteSessionRequest, dict] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationDeletes the interactive session resource.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.delete_session
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.get_iam_policy
get_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.get_iam_policy
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source( client_options: typing.Optional[ google.api_core.client_options.ClientOptions ] = None, )Return the API endpoint and client cert source for mutual TLS.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.get_operation
get_operation( request: typing.Optional[ google.longrunning.operations_pb2.GetOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.get_operation
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.get_session
get_session( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.sessions.GetSessionRequest, dict] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.sessions.SessionGets the resource representation for an interactive session.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.get_session
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.get_transport_class
get_transport_class( label: typing.Optional[str] = None, ) -> typing.Type[ google.cloud.dataproc_v1.services.session_controller.transports.base.SessionControllerTransport ]Returns an appropriate transport class.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.list_operations
list_operations( request: typing.Optional[ google.longrunning.operations_pb2.ListOperationsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.list_operations
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.list_sessions
list_sessions( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.sessions.ListSessionsRequest, dict] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.services.session_controller.pagers.ListSessionsAsyncPagerLists interactive sessions.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.list_sessions
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.parse_service_path
parse_service_path(path: str) -> typing.Dict[str, str]Parses a service path into its component segments.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.parse_service_path
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.parse_session_path
parse_session_path(path: str) -> typing.Dict[str, str]Parses a session path into its component segments.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.parse_session_path
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.parse_session_template_path
parse_session_template_path(path: str) -> typing.Dict[str, str]Parses a session_template path into its component segments.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.service_path
service_path(project: str, location: str, service: str) -> strReturns a fully-qualified service string.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.service_path
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.session_path
session_path(project: str, location: str, session: str) -> strReturns a fully-qualified session string.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.session_path
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.session_template_path
session_template_path(project: str, location: str, template: str) -> strReturns a fully-qualified session_template string.
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.set_iam_policy
set_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.set_iam_policy
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.terminate_session
terminate_session( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.sessions.TerminateSessionRequest, dict ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationTerminates the interactive session.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.terminate_session
google.cloud.dataproc_v1.services.session_controller.SessionControllerAsyncClient.test_iam_permissions
test_iam_permissions( request: typing.Optional[ google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient
SessionControllerClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.dataproc_v1.services.session_controller.transports.base.SessionControllerTransport, typing.Callable[[...], google.cloud.dataproc_v1.services.session_controller.transports.base.SessionControllerTransport]]] = None, client_options: typing.Optional[typing.Union[google.api_core.client_options.ClientOptions, dict]] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo = Instantiates the session controller client.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.__exit__
__exit__(type, value, traceback)Releases underlying transport's resources.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.exit
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.cancel_operation
cancel_operation( request: typing.Optional[ google.longrunning.operations_pb2.CancelOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneStarts asynchronous cancellation on a long-running operation.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.cancel_operation
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.common_folder_path
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.common_location_path
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.common_project_path
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.create_session
create_session( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.sessions.CreateSessionRequest, dict] ] = None, *, parent: typing.Optional[str] = None, session: typing.Optional[google.cloud.dataproc_v1.types.sessions.Session] = None, session_id: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationCreate an interactive session asynchronously.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.create_session
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.delete_operation
delete_operation( request: typing.Optional[ google.longrunning.operations_pb2.DeleteOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneDeletes a long-running operation.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.delete_operation
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.delete_session
delete_session( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.sessions.DeleteSessionRequest, dict] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationDeletes the interactive session resource.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.delete_session
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.get_iam_policy
get_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.get_iam_policy
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source( client_options: typing.Optional[ google.api_core.client_options.ClientOptions ] = None, )Deprecated.
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.get_operation
get_operation( request: typing.Optional[ google.longrunning.operations_pb2.GetOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.get_operation
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.get_session
get_session( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.sessions.GetSessionRequest, dict] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.sessions.SessionGets the resource representation for an interactive session.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.get_session
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.list_operations
list_operations( request: typing.Optional[ google.longrunning.operations_pb2.ListOperationsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.list_operations
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.list_sessions
list_sessions( request: typing.Optional[ typing.Union[google.cloud.dataproc_v1.types.sessions.ListSessionsRequest, dict] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.services.session_controller.pagers.ListSessionsPagerLists interactive sessions.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.list_sessions
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.parse_service_path
parse_service_path(path: str) -> typing.Dict[str, str]Parses a service path into its component segments.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.parse_service_path
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.parse_session_path
parse_session_path(path: str) -> typing.Dict[str, str]Parses a session path into its component segments.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.parse_session_path
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.parse_session_template_path
parse_session_template_path(path: str) -> typing.Dict[str, str]Parses a session_template path into its component segments.
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.service_path
service_path(project: str, location: str, service: str) -> strReturns a fully-qualified service string.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.service_path
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.session_path
session_path(project: str, location: str, session: str) -> strReturns a fully-qualified session string.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.session_path
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.session_template_path
session_template_path(project: str, location: str, template: str) -> strReturns a fully-qualified session_template string.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.session_template_path
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.set_iam_policy
set_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.set_iam_policy
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.terminate_session
terminate_session( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.sessions.TerminateSessionRequest, dict ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationTerminates the interactive session.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.terminate_session
google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.test_iam_permissions
test_iam_permissions( request: typing.Optional[ google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
See more: google.cloud.dataproc_v1.services.session_controller.SessionControllerClient.test_iam_permissions
google.cloud.dataproc_v1.services.session_controller.pagers.ListSessionsAsyncPager
ListSessionsAsyncPager( method: typing.Callable[ [...], typing.Awaitable[google.cloud.dataproc_v1.types.sessions.ListSessionsResponse], ], request: google.cloud.dataproc_v1.types.sessions.ListSessionsRequest, response: google.cloud.dataproc_v1.types.sessions.ListSessionsResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () )Instantiates the pager.
See more: google.cloud.dataproc_v1.services.session_controller.pagers.ListSessionsAsyncPager
google.cloud.dataproc_v1.services.session_controller.pagers.ListSessionsPager
ListSessionsPager( method: typing.Callable[ [...], google.cloud.dataproc_v1.types.sessions.ListSessionsResponse ], request: google.cloud.dataproc_v1.types.sessions.ListSessionsRequest, response: google.cloud.dataproc_v1.types.sessions.ListSessionsResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () )Instantiate the pager.
See more: google.cloud.dataproc_v1.services.session_controller.pagers.ListSessionsPager
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient
SessionTemplateControllerAsyncClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.dataproc_v1.services.session_template_controller.transports.base.SessionTemplateControllerTransport, typing.Callable[[...], google.cloud.dataproc_v1.services.session_template_controller.transports.base.SessionTemplateControllerTransport]]] = 'grpc_asyncio', client_options: typing.Optional[google.api_core.client_options.ClientOptions] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo = Instantiates the session template controller async client.
See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.cancel_operation
cancel_operation( request: typing.Optional[ google.longrunning.operations_pb2.CancelOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneStarts asynchronous cancellation on a long-running operation.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.create_session_template
create_session_template( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.session_templates.CreateSessionTemplateRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, session_template: typing.Optional[ google.cloud.dataproc_v1.types.session_templates.SessionTemplate ] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.session_templates.SessionTemplateCreate a session template synchronously.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.delete_operation
delete_operation( request: typing.Optional[ google.longrunning.operations_pb2.DeleteOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneDeletes a long-running operation.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.delete_session_template
delete_session_template( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.session_templates.DeleteSessionTemplateRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneDeletes a session template.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.get_iam_policy
get_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source( client_options: typing.Optional[ google.api_core.client_options.ClientOptions ] = None, )Return the API endpoint and client cert source for mutual TLS.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.get_operation
get_operation( request: typing.Optional[ google.longrunning.operations_pb2.GetOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.get_session_template
get_session_template( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.session_templates.GetSessionTemplateRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.session_templates.SessionTemplateGets the resource representation for a session template.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.get_transport_class
get_transport_class( label: typing.Optional[str] = None, ) -> typing.Type[ google.cloud.dataproc_v1.services.session_template_controller.transports.base.SessionTemplateControllerTransport ]Returns an appropriate transport class.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.list_operations
list_operations( request: typing.Optional[ google.longrunning.operations_pb2.ListOperationsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.list_session_templates
list_session_templates( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.session_templates.ListSessionTemplatesRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> ( google.cloud.dataproc_v1.services.session_template_controller.pagers.ListSessionTemplatesAsyncPager )Lists session templates.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.parse_service_path
parse_service_path(path: str) -> typing.Dict[str, str]Parses a service path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.parse_session_template_path
parse_session_template_path(path: str) -> typing.Dict[str, str]Parses a session_template path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.service_path
service_path(project: str, location: str, service: str) -> strReturns a fully-qualified service string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.session_template_path
session_template_path(project: str, location: str, template: str) -> strReturns a fully-qualified session_template string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.set_iam_policy
set_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.test_iam_permissions
test_iam_permissions( request: typing.Optional[ google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerAsyncClient.update_session_template
update_session_template( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.session_templates.UpdateSessionTemplateRequest, dict, ] ] = None, *, session_template: typing.Optional[ google.cloud.dataproc_v1.types.session_templates.SessionTemplate ] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.session_templates.SessionTemplateUpdates the session template synchronously.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient
SessionTemplateControllerClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.dataproc_v1.services.session_template_controller.transports.base.SessionTemplateControllerTransport, typing.Callable[[...], google.cloud.dataproc_v1.services.session_template_controller.transports.base.SessionTemplateControllerTransport]]] = None, client_options: typing.Optional[typing.Union[google.api_core.client_options.ClientOptions, dict]] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo = Instantiates the session template controller client.
See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.__exit__
__exit__(type, value, traceback)Releases underlying transport's resources.
See more: google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.exit
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.cancel_operation
cancel_operation( request: typing.Optional[ google.longrunning.operations_pb2.CancelOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneStarts asynchronous cancellation on a long-running operation.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.create_session_template
create_session_template( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.session_templates.CreateSessionTemplateRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, session_template: typing.Optional[ google.cloud.dataproc_v1.types.session_templates.SessionTemplate ] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.session_templates.SessionTemplateCreate a session template synchronously.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.delete_operation
delete_operation( request: typing.Optional[ google.longrunning.operations_pb2.DeleteOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneDeletes a long-running operation.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.delete_session_template
delete_session_template( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.session_templates.DeleteSessionTemplateRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneDeletes a session template.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.get_iam_policy
get_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source( client_options: typing.Optional[ google.api_core.client_options.ClientOptions ] = None, )Deprecated.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.get_operation
get_operation( request: typing.Optional[ google.longrunning.operations_pb2.GetOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.get_session_template
get_session_template( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.session_templates.GetSessionTemplateRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.session_templates.SessionTemplateGets the resource representation for a session template.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.list_operations
list_operations( request: typing.Optional[ google.longrunning.operations_pb2.ListOperationsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.list_session_templates
list_session_templates( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.session_templates.ListSessionTemplatesRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> ( google.cloud.dataproc_v1.services.session_template_controller.pagers.ListSessionTemplatesPager )Lists session templates.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.parse_service_path
parse_service_path(path: str) -> typing.Dict[str, str]Parses a service path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.parse_session_template_path
parse_session_template_path(path: str) -> typing.Dict[str, str]Parses a session_template path into its component segments.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.service_path
service_path(project: str, location: str, service: str) -> strReturns a fully-qualified service string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.session_template_path
session_template_path(project: str, location: str, template: str) -> strReturns a fully-qualified session_template string.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.set_iam_policy
set_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.test_iam_permissions
test_iam_permissions( request: typing.Optional[ google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
google.cloud.dataproc_v1.services.session_template_controller.SessionTemplateControllerClient.update_session_template
update_session_template( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.session_templates.UpdateSessionTemplateRequest, dict, ] ] = None, *, session_template: typing.Optional[ google.cloud.dataproc_v1.types.session_templates.SessionTemplate ] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.session_templates.SessionTemplateUpdates the session template synchronously.
google.cloud.dataproc_v1.services.session_template_controller.pagers.ListSessionTemplatesAsyncPager
ListSessionTemplatesAsyncPager( method: typing.Callable[ [...], typing.Awaitable[ google.cloud.dataproc_v1.types.session_templates.ListSessionTemplatesResponse ], ], request: google.cloud.dataproc_v1.types.session_templates.ListSessionTemplatesRequest, response: google.cloud.dataproc_v1.types.session_templates.ListSessionTemplatesResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () )Instantiates the pager.
See more: google.cloud.dataproc_v1.services.session_template_controller.pagers.ListSessionTemplatesAsyncPager
google.cloud.dataproc_v1.services.session_template_controller.pagers.ListSessionTemplatesPager
ListSessionTemplatesPager( method: typing.Callable[ [...], google.cloud.dataproc_v1.types.session_templates.ListSessionTemplatesResponse, ], request: google.cloud.dataproc_v1.types.session_templates.ListSessionTemplatesRequest, response: google.cloud.dataproc_v1.types.session_templates.ListSessionTemplatesResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () )Instantiate the pager.
See more: google.cloud.dataproc_v1.services.session_template_controller.pagers.ListSessionTemplatesPager
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient
WorkflowTemplateServiceAsyncClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.dataproc_v1.services.workflow_template_service.transports.base.WorkflowTemplateServiceTransport, typing.Callable[[...], google.cloud.dataproc_v1.services.workflow_template_service.transports.base.WorkflowTemplateServiceTransport]]] = 'grpc_asyncio', client_options: typing.Optional[google.api_core.client_options.ClientOptions] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo = Instantiates the workflow template service async client.
See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.cancel_operation
cancel_operation( request: typing.Optional[ google.longrunning.operations_pb2.CancelOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneStarts asynchronous cancellation on a long-running operation.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.create_workflow_template
create_workflow_template( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.workflow_templates.CreateWorkflowTemplateRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, template: typing.Optional[ google.cloud.dataproc_v1.types.workflow_templates.WorkflowTemplate ] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.workflow_templates.WorkflowTemplateCreates new workflow template.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.crypto_key_path
crypto_key_path(project: str, location: str, key_ring: str, crypto_key: str) -> strReturns a fully-qualified crypto_key string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.delete_operation
delete_operation( request: typing.Optional[ google.longrunning.operations_pb2.DeleteOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneDeletes a long-running operation.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.delete_workflow_template
delete_workflow_template( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.workflow_templates.DeleteWorkflowTemplateRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneDeletes a workflow template.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.get_iam_policy
get_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source( client_options: typing.Optional[ google.api_core.client_options.ClientOptions ] = None, )Return the API endpoint and client cert source for mutual TLS.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.get_operation
get_operation( request: typing.Optional[ google.longrunning.operations_pb2.GetOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.get_transport_class
get_transport_class( label: typing.Optional[str] = None, ) -> typing.Type[ google.cloud.dataproc_v1.services.workflow_template_service.transports.base.WorkflowTemplateServiceTransport ]Returns an appropriate transport class.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.get_workflow_template
get_workflow_template( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.workflow_templates.GetWorkflowTemplateRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.workflow_templates.WorkflowTemplateRetrieves the latest workflow template.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.instantiate_inline_workflow_template
instantiate_inline_workflow_template( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.workflow_templates.InstantiateInlineWorkflowTemplateRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, template: typing.Optional[ google.cloud.dataproc_v1.types.workflow_templates.WorkflowTemplate ] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationInstantiates a template and begins execution.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.instantiate_workflow_template
instantiate_workflow_template( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.workflow_templates.InstantiateWorkflowTemplateRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, parameters: typing.Optional[typing.MutableMapping[str, str]] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation_async.AsyncOperationInstantiates a template and begins execution.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.list_operations
list_operations( request: typing.Optional[ google.longrunning.operations_pb2.ListOperationsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.list_workflow_templates
list_workflow_templates( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.workflow_templates.ListWorkflowTemplatesRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> ( google.cloud.dataproc_v1.services.workflow_template_service.pagers.ListWorkflowTemplatesAsyncPager )Lists workflows that match the specified filter in the request.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.node_group_path
node_group_path(project: str, region: str, cluster: str, node_group: str) -> strReturns a fully-qualified node_group string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.parse_crypto_key_path
parse_crypto_key_path(path: str) -> typing.Dict[str, str]Parses a crypto_key path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.parse_node_group_path
parse_node_group_path(path: str) -> typing.Dict[str, str]Parses a node_group path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.parse_service_path
parse_service_path(path: str) -> typing.Dict[str, str]Parses a service path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.parse_workflow_template_path
parse_workflow_template_path(path: str) -> typing.Dict[str, str]Parses a workflow_template path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.service_path
service_path(project: str, location: str, service: str) -> strReturns a fully-qualified service string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.set_iam_policy
set_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.test_iam_permissions
test_iam_permissions( request: typing.Optional[ google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.update_workflow_template
update_workflow_template( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.workflow_templates.UpdateWorkflowTemplateRequest, dict, ] ] = None, *, template: typing.Optional[ google.cloud.dataproc_v1.types.workflow_templates.WorkflowTemplate ] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.workflow_templates.WorkflowTemplateUpdates (replaces) workflow template.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceAsyncClient.workflow_template_path
workflow_template_path(project: str, region: str, workflow_template: str) -> strReturns a fully-qualified workflow_template string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient
WorkflowTemplateServiceClient(*, credentials: typing.Optional[google.auth.credentials.Credentials] = None, transport: typing.Optional[typing.Union[str, google.cloud.dataproc_v1.services.workflow_template_service.transports.base.WorkflowTemplateServiceTransport, typing.Callable[[...], google.cloud.dataproc_v1.services.workflow_template_service.transports.base.WorkflowTemplateServiceTransport]]] = None, client_options: typing.Optional[typing.Union[google.api_core.client_options.ClientOptions, dict]] = None, client_info: google.api_core.gapic_v1.client_info.ClientInfo = Instantiates the workflow template service client.
See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.__exit__
__exit__(type, value, traceback)Releases underlying transport's resources.
See more: google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.exit
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.cancel_operation
cancel_operation( request: typing.Optional[ google.longrunning.operations_pb2.CancelOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneStarts asynchronous cancellation on a long-running operation.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.common_billing_account_path
common_billing_account_path(billing_account: str) -> strReturns a fully-qualified billing_account string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.common_folder_path
common_folder_path(folder: str) -> strReturns a fully-qualified folder string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.common_location_path
common_location_path(project: str, location: str) -> strReturns a fully-qualified location string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.common_organization_path
common_organization_path(organization: str) -> strReturns a fully-qualified organization string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.common_project_path
common_project_path(project: str) -> strReturns a fully-qualified project string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.create_workflow_template
create_workflow_template( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.workflow_templates.CreateWorkflowTemplateRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, template: typing.Optional[ google.cloud.dataproc_v1.types.workflow_templates.WorkflowTemplate ] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.workflow_templates.WorkflowTemplateCreates new workflow template.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.crypto_key_path
crypto_key_path(project: str, location: str, key_ring: str, crypto_key: str) -> strReturns a fully-qualified crypto_key string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.delete_operation
delete_operation( request: typing.Optional[ google.longrunning.operations_pb2.DeleteOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneDeletes a long-running operation.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.delete_workflow_template
delete_workflow_template( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.workflow_templates.DeleteWorkflowTemplateRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> NoneDeletes a workflow template.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.from_service_account_file
from_service_account_file(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.from_service_account_info
from_service_account_info(info: dict, *args, **kwargs)Creates an instance of this client using the provided credentials info.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.from_service_account_json
from_service_account_json(filename: str, *args, **kwargs)Creates an instance of this client using the provided credentials file.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.get_iam_policy
get_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.GetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicyGets the IAM access control policy for a function.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.get_mtls_endpoint_and_cert_source
get_mtls_endpoint_and_cert_source( client_options: typing.Optional[ google.api_core.client_options.ClientOptions ] = None, )Deprecated.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.get_operation
get_operation( request: typing.Optional[ google.longrunning.operations_pb2.GetOperationRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.OperationGets the latest state of a long-running operation.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.get_workflow_template
get_workflow_template( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.workflow_templates.GetWorkflowTemplateRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.workflow_templates.WorkflowTemplateRetrieves the latest workflow template.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.instantiate_inline_workflow_template
instantiate_inline_workflow_template( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.workflow_templates.InstantiateInlineWorkflowTemplateRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, template: typing.Optional[ google.cloud.dataproc_v1.types.workflow_templates.WorkflowTemplate ] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationInstantiates a template and begins execution.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.instantiate_workflow_template
instantiate_workflow_template( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.workflow_templates.InstantiateWorkflowTemplateRequest, dict, ] ] = None, *, name: typing.Optional[str] = None, parameters: typing.Optional[typing.MutableMapping[str, str]] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.api_core.operation.OperationInstantiates a template and begins execution.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.list_operations
list_operations( request: typing.Optional[ google.longrunning.operations_pb2.ListOperationsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.longrunning.operations_pb2.ListOperationsResponseLists operations that match the specified filter in the request.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.list_workflow_templates
list_workflow_templates( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.workflow_templates.ListWorkflowTemplatesRequest, dict, ] ] = None, *, parent: typing.Optional[str] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> ( google.cloud.dataproc_v1.services.workflow_template_service.pagers.ListWorkflowTemplatesPager )Lists workflows that match the specified filter in the request.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.node_group_path
node_group_path(project: str, region: str, cluster: str, node_group: str) -> strReturns a fully-qualified node_group string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.parse_common_billing_account_path
parse_common_billing_account_path(path: str) -> typing.Dict[str, str]Parse a billing_account path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.parse_common_folder_path
parse_common_folder_path(path: str) -> typing.Dict[str, str]Parse a folder path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.parse_common_location_path
parse_common_location_path(path: str) -> typing.Dict[str, str]Parse a location path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.parse_common_organization_path
parse_common_organization_path(path: str) -> typing.Dict[str, str]Parse a organization path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.parse_common_project_path
parse_common_project_path(path: str) -> typing.Dict[str, str]Parse a project path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.parse_crypto_key_path
parse_crypto_key_path(path: str) -> typing.Dict[str, str]Parses a crypto_key path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.parse_node_group_path
parse_node_group_path(path: str) -> typing.Dict[str, str]Parses a node_group path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.parse_service_path
parse_service_path(path: str) -> typing.Dict[str, str]Parses a service path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.parse_workflow_template_path
parse_workflow_template_path(path: str) -> typing.Dict[str, str]Parses a workflow_template path into its component segments.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.service_path
service_path(project: str, location: str, service: str) -> strReturns a fully-qualified service string.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.set_iam_policy
set_iam_policy( request: typing.Optional[google.iam.v1.iam_policy_pb2.SetIamPolicyRequest] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.policy_pb2.PolicySets the IAM access control policy on the specified function.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.test_iam_permissions
test_iam_permissions( request: typing.Optional[ google.iam.v1.iam_policy_pb2.TestIamPermissionsRequest ] = None, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.iam.v1.iam_policy_pb2.TestIamPermissionsResponseTests the specified IAM permissions against the IAM access control policy for a function.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.update_workflow_template
update_workflow_template( request: typing.Optional[ typing.Union[ google.cloud.dataproc_v1.types.workflow_templates.UpdateWorkflowTemplateRequest, dict, ] ] = None, *, template: typing.Optional[ google.cloud.dataproc_v1.types.workflow_templates.WorkflowTemplate ] = None, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () ) -> google.cloud.dataproc_v1.types.workflow_templates.WorkflowTemplateUpdates (replaces) workflow template.
google.cloud.dataproc_v1.services.workflow_template_service.WorkflowTemplateServiceClient.workflow_template_path
workflow_template_path(project: str, region: str, workflow_template: str) -> strReturns a fully-qualified workflow_template string.
google.cloud.dataproc_v1.services.workflow_template_service.pagers.ListWorkflowTemplatesAsyncPager
ListWorkflowTemplatesAsyncPager( method: typing.Callable[ [...], typing.Awaitable[ google.cloud.dataproc_v1.types.workflow_templates.ListWorkflowTemplatesResponse ], ], request: google.cloud.dataproc_v1.types.workflow_templates.ListWorkflowTemplatesRequest, response: google.cloud.dataproc_v1.types.workflow_templates.ListWorkflowTemplatesResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary_async.AsyncRetry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () )Instantiates the pager.
See more: google.cloud.dataproc_v1.services.workflow_template_service.pagers.ListWorkflowTemplatesAsyncPager
google.cloud.dataproc_v1.services.workflow_template_service.pagers.ListWorkflowTemplatesPager
ListWorkflowTemplatesPager( method: typing.Callable[ [...], google.cloud.dataproc_v1.types.workflow_templates.ListWorkflowTemplatesResponse, ], request: google.cloud.dataproc_v1.types.workflow_templates.ListWorkflowTemplatesRequest, response: google.cloud.dataproc_v1.types.workflow_templates.ListWorkflowTemplatesResponse, *, retry: typing.Optional[ typing.Union[ google.api_core.retry.retry_unary.Retry, google.api_core.gapic_v1.method._MethodDefault, ] ] = _MethodDefault._DEFAULT_VALUE, timeout: typing.Union[float, object] = _MethodDefault._DEFAULT_VALUE, metadata: typing.Sequence[typing.Tuple[str, typing.Union[str, bytes]]] = () )Instantiate the pager.
See more: google.cloud.dataproc_v1.services.workflow_template_service.pagers.ListWorkflowTemplatesPager