original_docstring: Start a partitioned query operation.
  
          Uses the ``PartitionQuery`` API request to start a partitioned
          query operation.  Returns a list of batch information needed to
          perform the actual queries.
  
          :type sql: str
          :param sql: SQL query statement
  
          :type params: dict, {str -> column value}
          :param params: values for parameter replacement.  Keys must match
                         the names used in ``sql``.
  
          :type param_types: dict[str -> Union[dict, .types.Type]]
          :param param_types:
              (Optional) maps explicit types for one or more param values;
              required if parameters are passed.
  
          :type partition_size_bytes: int
          :param partition_size_bytes:
              (Optional) desired size for each partition generated.  The service
              uses this as a hint, the actual partition size may differ.
  
          :type partition_size_bytes: int
          :param partition_size_bytes:
              (Optional) desired size for each partition generated.  The service
              uses this as a hint, the actual partition size may differ.
  
          :type max_partitions: int
          :param max_partitions:
              (Optional) desired maximum number of partitions generated. The
              service uses this as a hint, the actual number of partitions may
              differ.
  
          :type query_options:
              :class:`~google.cloud.spanner_v1.types.ExecuteSqlRequest.QueryOptions`
              or :class:`dict`
          :param query_options:
                  (Optional) Query optimizer configuration to use for the given query.
                  If a dict is provided, it must be of the same form as the protobuf
                  message :class:`~google.cloud.spanner_v1.types.QueryOptions`
  
          :type retry: :class:`~google.api_core.retry.Retry`
          :param retry: (Optional) The retry settings for this request.
  
          :type timeout: float
          :param timeout: (Optional) The timeout for this request.
  
          :rtype: iterable of dict
          :returns:
              mappings of information used perform actual partitioned reads via
              :meth:`process_read_batch`.
          
docstring: Start a partitioned query operation.
  Uses the ``PartitionQuery`` API request to start a partitioned
  query operation.  Returns a list of batch information needed to
  perform the actual queries.
docstring_tokens: Start a partitioned query operation . Uses the ` ` PartitionQuery ` ` API request to start a partitioned query operation . Returns a list of batch information needed to perform the actual queries .
code: def generate_query_batches(
          self,
          sql,
          params=None,
          param_types=None,
          partition_size_bytes=None,
          max_partitions=None,
          query_options=None,
          *,
          retry=gapic_v1.method.DEFAULT,
          timeout=gapic_v1.method.DEFAULT,
      ):
          """Start a partitioned query operation.
  
          Uses the ``PartitionQuery`` API request to start a partitioned
          query operation.  Returns a list of batch information needed to
          perform the actual queries.
  
          :type sql: str
          :param sql: SQL query statement
  
          :type params: dict, {str -> column value}
          :param params: values for parameter replacement.  Keys must match
                         the names used in ``sql``.
  
          :type param_types: dict[str -> Union[dict, .types.Type]]
          :param param_types:
              (Optional) maps explicit types for one or more param values;
              required if parameters are passed.
  
          :type partition_size_bytes: int
          :param partition_size_bytes:
              (Optional) desired size for each partition generated.  The service
              uses this as a hint, the actual partition size may differ.
  
          :type partition_size_bytes: int
          :param partition_size_bytes:
              (Optional) desired size for each partition generated.  The service
              uses this as a hint, the actual partition size may differ.
  
          :type max_partitions: int
          :param max_partitions:
              (Optional) desired maximum number of partitions generated. The
              service uses this as a hint, the actual number of partitions may
              differ.
  
          :type query_options:
              :class:`~google.cloud.spanner_v1.types.ExecuteSqlRequest.QueryOptions`
              or :class:`dict`
          :param query_options:
                  (Optional) Query optimizer configuration to use for the given query.
                  If a dict is provided, it must be of the same form as the protobuf
                  message :class:`~google.cloud.spanner_v1.types.QueryOptions`
  
          :type retry: :class:`~google.api_core.retry.Retry`
          :param retry: (Optional) The retry settings for this request.
  
          :type timeout: float
          :param timeout: (Optional) The timeout for this request.
  
          :rtype: iterable of dict
          :returns:
              mappings of information used perform actual partitioned reads via
              :meth:`process_read_batch`.
          """
          partitions = self._get_snapshot().partition_query(
              sql=sql,
              params=params,
              param_types=param_types,
              partition_size_bytes=partition_size_bytes,
              max_partitions=max_partitions,
              retry=retry,
              timeout=timeout,
          )
  
          query_info = {"sql": sql}
          if params:
              query_info["params"] = params
              query_info["param_types"] = param_types
  
          # Query-level options have higher precedence than client-level and
          # environment-level options
          default_query_options = self._database._instance._client._query_options
          query_info["query_options"] = _merge_query_options(
              default_query_options, query_options
          )
  
          for partition in partitions:
              yield {"partition": partition, "query": query_info}
code_tokens: def generate_query_batches ( self , sql , params = None , param_types = None , partition_size_bytes = None , max_partitions = None , query_options = None , * , retry = gapic_v1 . method . DEFAULT , timeout = gapic_v1 . method . DEFAULT , ) : partitions = self . _get_snapshot ( ) . partition_query ( sql = sql , params = params , param_types = param_types , partition_size_bytes = partition_size_bytes , max_partitions = max_partitions , retry = retry , timeout = timeout , ) query_info = { "sql" : sql } if params : query_info [ "params" ] = params query_info [ "param_types" ] = param_types default_query_options = self . _database . _instance . _client . _query_options query_info [ "query_options" ] = _merge_query_options ( default_query_options , query_options ) for partition in partitions : yield { "partition" : partition , "query" : query_info }
short_docstring: Start a partitioned query operation.
short_docstring_tokens: Start a partitioned query operation .
comment: """Start a partitioned query operation.
  
          Uses the ``PartitionQuery`` API request to start a partitioned
          query operation.  Returns a list of batch information needed to
          perform the actual queries.
  
          :type sql: str
          :param sql: SQL query statement
  
          :type params: dict, {str -> column value}
          :param params: values for parameter replacement.  Keys must match
                         the names used in ``sql``.
  
          :type param_types: dict[str -> Union[dict, .types.Type]]
          :param param_types:
              (Optional) maps explicit types for one or more param values;
              required if parameters are passed.
  
          :type partition_size_bytes: int
          :param partition_size_bytes:
              (Optional) desired size for each partition generated.  The service
              uses this as a hint, the actual partition size may differ.
  
          :type partition_size_bytes: int
          :param partition_size_bytes:
              (Optional) desired size for each partition generated.  The service
              uses this as a hint, the actual partition size may differ.
  
          :type max_partitions: int
          :param max_partitions:
              (Optional) desired maximum number of partitions generated. The
              service uses this as a hint, the actual number of partitions may
              differ.
  
          :type query_options:
              :class:`~google.cloud.spanner_v1.types.ExecuteSqlRequest.QueryOptions`
              or :class:`dict`
          :param query_options:
                  (Optional) Query optimizer configuration to use for the given query.
                  If a dict is provided, it must be of the same form as the protobuf
                  message :class:`~google.cloud.spanner_v1.types.QueryOptions`
  
          :type retry: :class:`~google.api_core.retry.Retry`
          :param retry: (Optional) The retry settings for this request.
  
          :type timeout: float
          :param timeout: (Optional) The timeout for this request.
  
          :rtype: iterable of dict
          :returns:
              mappings of information used perform actual partitioned reads via
              :meth:`process_read_batch`.
          """$SEP$# Query-level options have higher precedence than client-level and$SEP$# environment-level options