class_docstr: Moves data from Hive to DynamoDB.
  
  Note that for now the data is loaded into memory before being pushed
  to DynamoDB, so this operator should be used for smallish amount of data.
  
  .. seealso::
      For more information on how to use this operator, take a look at the guide:
      :ref:`howto/transfer:HiveToDynamoDBOperator`
  
  :param sql: SQL query to execute against the hive database. (templated)
  :param table_name: target DynamoDB table
  :param table_keys: partition key and sort key
  :param pre_process: implement pre-processing of source data
  :param pre_process_args: list of pre_process function arguments
  :param pre_process_kwargs: dict of pre_process function arguments
  :param region_name: aws region name (example: us-east-1)
  :param schema: hive database schema
  :param hiveserver2_conn_id: Reference to the
      :ref: `Hive Server2 thrift service connection id <howto/connection:hiveserver2>`.
  :param aws_conn_id: aws connection
code: def execute(self, context: Context):
      hive = HiveServer2Hook(
          hiveserver2_conn_id=self.hiveserver2_conn_id
      )
  
      self.log.info("Extracting data from Hive")
      self.log.info(self.sql)
  
      data = hive.get_pandas_df(self.sql, schema=self.schema)
      dynamodb = DynamoDBHook(
          aws_conn_id=self.aws_conn_id,
          table_name=self.table_name,
          table_keys=self.table_keys,
          region_name=self.region_name,
      )
  
      self.log.info("Inserting rows into dynamodb")
  
      if self.pre_process is None:
          dynamodb.write_batch_data(
              json.loads(data.to_json(orient="records"))
          )
      else:
          dynamodb.write_batch_data(
              self.pre_process(
                  data=data,
                  args=self.pre_process_args,
                  kwargs=self.pre_process_kwargs,
              )
          )
  
      self.log.info("Done.")
  
file_path: airflow/airflow/providers/amazon/aws/transfers/hive_to_dynamodb.py
imports: from __future__ import annotations
  import json
  from typing import TYPE_CHECKING, Callable, Sequence
  from airflow.models import BaseOperator
  from airflow.providers.amazon.aws.hooks.dynamodb import DynamoDBHook
  from airflow.providers.apache.hive.hooks.hive import HiveServer2Hook
label_desc: Use image node_id 2 for calling the HiveToDynamoDBOperator obj's underlying member method code with example usage: obj.execute(context) without return types