':param conn_id: str
:param cmd_type: str specify command to execute "export" or "import"
:param table: Table to read
:param target_dir: HDFS destination directory where the data
from the rdbms will be written
:param append: Append data to an existing dataset in HDFS
:param file_type: "avro", "sequence", "text" Imports data to
into the specified format. Defaults to text.
:param columns: <col,col,col> Columns to import from table
:param num_mappers: Use n mapper tasks to import/export in parallel
:param split_by: Column of the table used to split work units
:param where: WHERE clause to use during import
:param export_dir: HDFS Hive database directory to export to the rdbms
:param input_null_string: The string to be interpreted as null
for string columns
:param input_null_non_string: The string to be interpreted as null
for non-string columns
:param staging_table: The table in which data will be staged before
being inserted into the destination table
:param clear_staging_table: Indicate that any data present in the
staging table can be deleted
:param enclosed_by: Sets a required field enclosing character
:param escaped_by: Sets the escape character
:param input_fields_terminated_by: Sets the input field separator
:param input_lines_terminated_by: Sets the input end-of-line character
:param input_optionally_enclosed_by: Sets a field enclosing character
:param batch: Use batch mode for underlying statement execution
:param direct: Use direct export fast path
:param driver: Manually specify JDBC driver class to use
:param verbose: Switch to more verbose logging for debug purposes
:param relaxed_isolation: use read uncommitted isolation level
:param hcatalog_database: Specifies the database name for the HCatalog table
:param hcatalog_table: The argument value for this option is the HCatalog table
:param properties: additional JVM properties passed to sqoop'

@apply_defaults
def __init__(self, conn_id='sqoop_default', cmd_type='import', table=None, query=None, target_dir=None, append=None, file_type=None, columns=None, num_mappers=None, split_by=None, where=None, export_dir=None, input_null_string=None, input_null_non_string=None, staging_table=None, clear_staging_table=False, enclosed_by=None, escaped_by=None, input_fields_terminated_by=None, input_lines_terminated_by=None, input_optionally_enclosed_by=None, batch=False, direct=False, driver=None, verbose=False, relaxed_isolation=False, properties=None, hcatalog_database=None, hcatalog_table=None, *args, **kwargs):

    super(SqoopOperator, self).__init__(*args, **kwargs)
    self.conn_id = conn_id
    self.cmd_type = cmd_type
    self.table = table
    self.query = query
    self.target_dir = target_dir
    self.append = append
    self.file_type = file_type
    self.columns = columns
    self.num_mappers = num_mappers
    self.split_by = split_by
    self.where = where
    self.export_dir = export_dir
    self.input_null_string = input_null_string
    self.input_null_non_string = input_null_non_string
    self.staging_table = staging_table
    self.clear_staging_table = clear_staging_table
    self.enclosed_by = enclosed_by
    self.escaped_by = escaped_by
    self.input_fields_terminated_by = input_fields_terminated_by
    self.input_lines_terminated_by = input_lines_terminated_by
    self.input_optionally_enclosed_by = input_optionally_enclosed_by
    self.batch = batch
    self.direct = direct
    self.driver = driver
    self.verbose = verbose
    self.relaxed_isolation = relaxed_isolation
    self.hcatalog_database = hcatalog_database
    self.hcatalog_table = hcatalog_table
    if (properties is None):
        properties = {}
    self.properties = properties
