OmniSciDB  cde582ebc3
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
heavydb.thrift.ttypes.TCopyParams Class Reference
+ Inheritance diagram for heavydb.thrift.ttypes.TCopyParams:
+ Collaboration diagram for heavydb.thrift.ttypes.TCopyParams:

Public Member Functions

def __init__
 
def read
 
def write
 
def validate
 
def __repr__
 
def __eq__
 
def __ne__
 

Public Attributes

 delimiter
 
 null_str
 
 has_header
 
 quoted
 
 quote
 
 escape
 
 line_delim
 
 array_delim
 
 array_begin
 
 array_end
 
 threads
 
 source_type
 
 s3_access_key
 
 s3_secret_key
 
 s3_region
 
 geo_coords_encoding
 
 geo_coords_comp_param
 
 geo_coords_type
 
 geo_coords_srid
 
 sanitize_column_names
 
 geo_layer_name
 
 s3_endpoint
 
 geo_assign_render_groups
 
 geo_explode_collections
 
 source_srid
 
 s3_session_token
 
 raster_point_type
 
 raster_import_bands
 
 raster_scanlines_per_thread
 
 raster_point_transform
 
 raster_point_compute_angle
 
 raster_import_dimensions
 
 odbc_dsn
 
 odbc_connection_string
 
 odbc_sql_select
 
 odbc_username
 
 odbc_password
 
 odbc_credential_string
 
 add_metadata_columns
 

Private Attributes

 __dict__
 

Detailed Description

Attributes:
 - delimiter
 - null_str
 - has_header
 - quoted
 - quote
 - escape
 - line_delim
 - array_delim
 - array_begin
 - array_end
 - threads
 - source_type
 - s3_access_key
 - s3_secret_key
 - s3_region
 - geo_coords_encoding
 - geo_coords_comp_param
 - geo_coords_type
 - geo_coords_srid
 - sanitize_column_names
 - geo_layer_name
 - s3_endpoint
 - geo_assign_render_groups
 - geo_explode_collections
 - source_srid
 - s3_session_token
 - raster_point_type
 - raster_import_bands
 - raster_scanlines_per_thread
 - raster_point_transform
 - raster_point_compute_angle
 - raster_import_dimensions
 - odbc_dsn
 - odbc_connection_string
 - odbc_sql_select
 - odbc_username
 - odbc_password
 - odbc_credential_string
 - add_metadata_columns

Definition at line 1775 of file ttypes.py.

Constructor & Destructor Documentation

def heavydb.thrift.ttypes.TCopyParams.__init__ (   self,
  delimiter = None,
  null_str = None,
  has_header = 0,
  quoted = None,
  quote = None,
  escape = None,
  line_delim = None,
  array_delim = None,
  array_begin = None,
  array_end = None,
  threads = None,
  source_type = 0,
  s3_access_key = None,
  s3_secret_key = None,
  s3_region = None,
  geo_coords_encoding = 6,
  geo_coords_comp_param = 32,
  geo_coords_type = 18,
  geo_coords_srid = 4326,
  sanitize_column_names = True,
  geo_layer_name = None,
  s3_endpoint = None,
  geo_assign_render_groups = True,
  geo_explode_collections = False,
  source_srid = 0,
  s3_session_token = None,
  raster_point_type = 1,
  raster_import_bands = None,
  raster_scanlines_per_thread = None,
  raster_point_transform = 1,
  raster_point_compute_angle = False,
  raster_import_dimensions = None,
  odbc_dsn = None,
  odbc_connection_string = None,
  odbc_sql_select = None,
  odbc_username = None,
  odbc_password = None,
  odbc_credential_string = None,
  add_metadata_columns = None 
)

Definition at line 1821 of file ttypes.py.

1822  def __init__(self, delimiter=None, null_str=None, has_header=0, quoted=None, quote=None, escape=None, line_delim=None, array_delim=None, array_begin=None, array_end=None, threads=None, source_type=0, s3_access_key=None, s3_secret_key=None, s3_region=None, geo_coords_encoding=6, geo_coords_comp_param=32, geo_coords_type=18, geo_coords_srid=4326, sanitize_column_names=True, geo_layer_name=None, s3_endpoint=None, geo_assign_render_groups=True, geo_explode_collections=False, source_srid=0, s3_session_token=None, raster_point_type=1, raster_import_bands=None, raster_scanlines_per_thread=None, raster_point_transform=1, raster_point_compute_angle=False, raster_import_dimensions=None, odbc_dsn=None, odbc_connection_string=None, odbc_sql_select=None, odbc_username=None, odbc_password=None, odbc_credential_string=None, add_metadata_columns=None,):
1823  self.delimiter = delimiter
1824  self.null_str = null_str
1825  self.has_header = has_header
1826  self.quoted = quoted
1827  self.quote = quote
1828  self.escape = escape
1829  self.line_delim = line_delim
1830  self.array_delim = array_delim
1831  self.array_begin = array_begin
1832  self.array_end = array_end
1833  self.threads = threads
1834  self.source_type = source_type
1835  self.s3_access_key = s3_access_key
1836  self.s3_secret_key = s3_secret_key
1837  self.s3_region = s3_region
1838  self.geo_coords_encoding = geo_coords_encoding
1839  self.geo_coords_comp_param = geo_coords_comp_param
1840  self.geo_coords_type = geo_coords_type
1841  self.geo_coords_srid = geo_coords_srid
1842  self.sanitize_column_names = sanitize_column_names
1843  self.geo_layer_name = geo_layer_name
1844  self.s3_endpoint = s3_endpoint
1845  self.geo_assign_render_groups = geo_assign_render_groups
1846  self.geo_explode_collections = geo_explode_collections
1847  self.source_srid = source_srid
1848  self.s3_session_token = s3_session_token
1849  self.raster_point_type = raster_point_type
1850  self.raster_import_bands = raster_import_bands
1851  self.raster_scanlines_per_thread = raster_scanlines_per_thread
1852  self.raster_point_transform = raster_point_transform
1853  self.raster_point_compute_angle = raster_point_compute_angle
1854  self.raster_import_dimensions = raster_import_dimensions
1855  self.odbc_dsn = odbc_dsn
1856  self.odbc_connection_string = odbc_connection_string
1857  self.odbc_sql_select = odbc_sql_select
1858  self.odbc_username = odbc_username
1859  self.odbc_password = odbc_password
1860  self.odbc_credential_string = odbc_credential_string
1861  self.add_metadata_columns = add_metadata_columns

Member Function Documentation

def heavydb.thrift.ttypes.TCopyParams.__eq__ (   self,
  other 
)

Definition at line 2243 of file ttypes.py.

2244  def __eq__(self, other):
2245  return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
def heavydb.thrift.ttypes.TCopyParams.__ne__ (   self,
  other 
)

Definition at line 2246 of file ttypes.py.

2247  def __ne__(self, other):
2248  return not (self == other)
2249 
def heavydb.thrift.ttypes.TCopyParams.__repr__ (   self)

Definition at line 2238 of file ttypes.py.

2239  def __repr__(self):
2240  L = ['%s=%r' % (key, value)
2241  for key, value in self.__dict__.items()]
2242  return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
std::string join(T const &container, std::string const &delim)

+ Here is the call graph for this function:

def heavydb.thrift.ttypes.TCopyParams.read (   self,
  iprot 
)

Definition at line 1862 of file ttypes.py.

References import_export::CopyParams.add_metadata_columns, heavydb.thrift.ttypes.TCopyParams.add_metadata_columns, import_export::CopyParams.array_begin, heavydb.thrift.ttypes.TCopyParams.array_begin, import_export::CopyParams.array_delim, heavydb.thrift.ttypes.TCopyParams.array_delim, import_export::CopyParams.array_end, heavydb.thrift.ttypes.TCopyParams.array_end, DataframeTableDescriptor.delimiter, import_export::CopyParams.delimiter, heavydb.thrift.ttypes.TCopyParams.delimiter, import_export::CopyParams.escape, heavydb.thrift.ttypes.TCopyParams.escape, import_export::CopyParams.geo_assign_render_groups, heavydb.thrift.ttypes.TCopyParams.geo_assign_render_groups, import_export::CopyParams.geo_coords_comp_param, heavydb.thrift.ttypes.TCopyParams.geo_coords_comp_param, import_export::CopyParams.geo_coords_encoding, heavydb.thrift.ttypes.TCopyParams.geo_coords_encoding, import_export::CopyParams.geo_coords_srid, heavydb.thrift.ttypes.TCopyParams.geo_coords_srid, import_export::CopyParams.geo_coords_type, heavydb.thrift.ttypes.TCopyParams.geo_coords_type, import_export::CopyParams.geo_explode_collections, heavydb.thrift.ttypes.TCopyParams.geo_explode_collections, import_export::CopyParams.geo_layer_name, heavydb.thrift.ttypes.TCopyParams.geo_layer_name, import_export::CopyParams.has_header, heavydb.thrift.ttypes.TCopyParams.has_header, import_export::CopyParams.line_delim, heavydb.thrift.ttypes.TCopyParams.line_delim, import_export::CopyParams.null_str, heavydb.thrift.ttypes.TCopyParams.null_str, heavydb.thrift.ttypes.TCopyParams.odbc_connection_string, heavydb.thrift.ttypes.TCopyParams.odbc_credential_string, heavydb.thrift.ttypes.TCopyParams.odbc_dsn, heavydb.thrift.ttypes.TCopyParams.odbc_password, heavydb.thrift.ttypes.TCopyParams.odbc_sql_select, heavydb.thrift.ttypes.TCopyParams.odbc_username, import_export::CopyParams.quote, heavydb.thrift.ttypes.TCopyParams.quote, import_export::CopyParams.quoted, heavydb.thrift.ttypes.TCopyParams.quoted, import_export::CopyParams.raster_import_bands, heavydb.thrift.ttypes.TCopyParams.raster_import_bands, import_export::CopyParams.raster_import_dimensions, heavydb.thrift.ttypes.TCopyParams.raster_import_dimensions, import_export::CopyParams.raster_point_compute_angle, heavydb.thrift.ttypes.TCopyParams.raster_point_compute_angle, import_export::CopyParams.raster_point_transform, heavydb.thrift.ttypes.TCopyParams.raster_point_transform, import_export::CopyParams.raster_point_type, heavydb.thrift.ttypes.TCopyParams.raster_point_type, import_export::CopyParams.raster_scanlines_per_thread, heavydb.thrift.ttypes.TCopyParams.raster_scanlines_per_thread, import_export::CopyParams.s3_access_key, S3Archive.s3_access_key, heavydb.thrift.ttypes.TCopyParams.s3_access_key, import_export::CopyParams.s3_endpoint, S3Archive.s3_endpoint, heavydb.thrift.ttypes.TCopyParams.s3_endpoint, import_export::CopyParams.s3_region, S3Archive.s3_region, heavydb.thrift.ttypes.TCopyParams.s3_region, import_export::CopyParams.s3_secret_key, S3Archive.s3_secret_key, heavydb.thrift.ttypes.TCopyParams.s3_secret_key, import_export::CopyParams.s3_session_token, S3Archive.s3_session_token, heavydb.thrift.ttypes.TCopyParams.s3_session_token, import_export::CopyParams.sanitize_column_names, heavydb.thrift.ttypes.TCopyParams.sanitize_column_names, import_export::CopyParams.source_srid, heavydb.thrift.ttypes.TCopyParams.source_srid, import_export::CopyParams.source_type, heavydb.thrift.ttypes.TCopyParams.source_type, import_export::CopyParams.threads, and heavydb.thrift.ttypes.TCopyParams.threads.

1863  def read(self, iprot):
1864  if iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None:
1865  iprot._fast_decode(self, iprot, [self.__class__, self.thrift_spec])
1866  return
1867  iprot.readStructBegin()
1868  while True:
1869  (fname, ftype, fid) = iprot.readFieldBegin()
1870  if ftype == TType.STOP:
1871  break
1872  if fid == 1:
1873  if ftype == TType.STRING:
1874  self.delimiter = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
1875  else:
1876  iprot.skip(ftype)
1877  elif fid == 2:
1878  if ftype == TType.STRING:
1879  self.null_str = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
1880  else:
1881  iprot.skip(ftype)
1882  elif fid == 3:
1883  if ftype == TType.I32:
1884  self.has_header = iprot.readI32()
1885  else:
1886  iprot.skip(ftype)
1887  elif fid == 4:
1888  if ftype == TType.BOOL:
1889  self.quoted = iprot.readBool()
1890  else:
1891  iprot.skip(ftype)
1892  elif fid == 5:
1893  if ftype == TType.STRING:
1894  self.quote = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
1895  else:
1896  iprot.skip(ftype)
1897  elif fid == 6:
1898  if ftype == TType.STRING:
1899  self.escape = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
1900  else:
1901  iprot.skip(ftype)
1902  elif fid == 7:
1903  if ftype == TType.STRING:
1904  self.line_delim = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
1905  else:
1906  iprot.skip(ftype)
1907  elif fid == 8:
1908  if ftype == TType.STRING:
1909  self.array_delim = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
1910  else:
1911  iprot.skip(ftype)
1912  elif fid == 9:
1913  if ftype == TType.STRING:
1914  self.array_begin = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
1915  else:
1916  iprot.skip(ftype)
1917  elif fid == 10:
1918  if ftype == TType.STRING:
1919  self.array_end = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
1920  else:
1921  iprot.skip(ftype)
1922  elif fid == 11:
1923  if ftype == TType.I32:
1924  self.threads = iprot.readI32()
1925  else:
1926  iprot.skip(ftype)
1927  elif fid == 12:
1928  if ftype == TType.I32:
1929  self.source_type = iprot.readI32()
1930  else:
1931  iprot.skip(ftype)
1932  elif fid == 13:
1933  if ftype == TType.STRING:
1934  self.s3_access_key = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
1935  else:
1936  iprot.skip(ftype)
1937  elif fid == 14:
1938  if ftype == TType.STRING:
1939  self.s3_secret_key = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
1940  else:
1941  iprot.skip(ftype)
1942  elif fid == 15:
1943  if ftype == TType.STRING:
1944  self.s3_region = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
1945  else:
1946  iprot.skip(ftype)
1947  elif fid == 16:
1948  if ftype == TType.I32:
1949  self.geo_coords_encoding = iprot.readI32()
1950  else:
1951  iprot.skip(ftype)
1952  elif fid == 17:
1953  if ftype == TType.I32:
1954  self.geo_coords_comp_param = iprot.readI32()
1955  else:
1956  iprot.skip(ftype)
1957  elif fid == 18:
1958  if ftype == TType.I32:
1959  self.geo_coords_type = iprot.readI32()
1960  else:
1961  iprot.skip(ftype)
1962  elif fid == 19:
1963  if ftype == TType.I32:
1964  self.geo_coords_srid = iprot.readI32()
1965  else:
1966  iprot.skip(ftype)
1967  elif fid == 20:
1968  if ftype == TType.BOOL:
1969  self.sanitize_column_names = iprot.readBool()
1970  else:
1971  iprot.skip(ftype)
1972  elif fid == 21:
1973  if ftype == TType.STRING:
1974  self.geo_layer_name = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
1975  else:
1976  iprot.skip(ftype)
1977  elif fid == 22:
1978  if ftype == TType.STRING:
1979  self.s3_endpoint = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
1980  else:
1981  iprot.skip(ftype)
1982  elif fid == 23:
1983  if ftype == TType.BOOL:
1984  self.geo_assign_render_groups = iprot.readBool()
1985  else:
1986  iprot.skip(ftype)
1987  elif fid == 24:
1988  if ftype == TType.BOOL:
1989  self.geo_explode_collections = iprot.readBool()
1990  else:
1991  iprot.skip(ftype)
1992  elif fid == 25:
1993  if ftype == TType.I32:
1994  self.source_srid = iprot.readI32()
1995  else:
1996  iprot.skip(ftype)
1997  elif fid == 26:
1998  if ftype == TType.STRING:
1999  self.s3_session_token = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2000  else:
2001  iprot.skip(ftype)
2002  elif fid == 27:
2003  if ftype == TType.I32:
2004  self.raster_point_type = iprot.readI32()
2005  else:
2006  iprot.skip(ftype)
2007  elif fid == 28:
2008  if ftype == TType.STRING:
2009  self.raster_import_bands = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2010  else:
2011  iprot.skip(ftype)
2012  elif fid == 29:
2013  if ftype == TType.I32:
2014  self.raster_scanlines_per_thread = iprot.readI32()
2015  else:
2016  iprot.skip(ftype)
2017  elif fid == 30:
2018  if ftype == TType.I32:
2019  self.raster_point_transform = iprot.readI32()
2020  else:
2021  iprot.skip(ftype)
2022  elif fid == 31:
2023  if ftype == TType.BOOL:
2024  self.raster_point_compute_angle = iprot.readBool()
2025  else:
2026  iprot.skip(ftype)
2027  elif fid == 32:
2028  if ftype == TType.STRING:
2029  self.raster_import_dimensions = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2030  else:
2031  iprot.skip(ftype)
2032  elif fid == 33:
2033  if ftype == TType.STRING:
2034  self.odbc_dsn = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2035  else:
2036  iprot.skip(ftype)
2037  elif fid == 34:
2038  if ftype == TType.STRING:
2039  self.odbc_connection_string = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2040  else:
2041  iprot.skip(ftype)
2042  elif fid == 35:
2043  if ftype == TType.STRING:
2044  self.odbc_sql_select = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2045  else:
2046  iprot.skip(ftype)
2047  elif fid == 36:
2048  if ftype == TType.STRING:
2049  self.odbc_username = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2050  else:
2051  iprot.skip(ftype)
2052  elif fid == 37:
2053  if ftype == TType.STRING:
2054  self.odbc_password = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2055  else:
2056  iprot.skip(ftype)
2057  elif fid == 38:
2058  if ftype == TType.STRING:
2059  self.odbc_credential_string = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2060  else:
2061  iprot.skip(ftype)
2062  elif fid == 39:
2063  if ftype == TType.STRING:
2064  self.add_metadata_columns = iprot.readString().decode('utf-8', errors='replace') if sys.version_info[0] == 2 else iprot.readString()
2065  else:
2066  iprot.skip(ftype)
2067  else:
2068  iprot.skip(ftype)
2069  iprot.readFieldEnd()
2070  iprot.readStructEnd()
def heavydb.thrift.ttypes.TCopyParams.validate (   self)

Definition at line 2235 of file ttypes.py.

2236  def validate(self):
2237  return
def heavydb.thrift.ttypes.TCopyParams.write (   self,
  oprot 
)

Definition at line 2071 of file ttypes.py.

References import_export::CopyParams.add_metadata_columns, heavydb.thrift.ttypes.TCopyParams.add_metadata_columns, import_export::CopyParams.array_begin, heavydb.thrift.ttypes.TCopyParams.array_begin, import_export::CopyParams.array_delim, heavydb.thrift.ttypes.TCopyParams.array_delim, import_export::CopyParams.array_end, heavydb.thrift.ttypes.TCopyParams.array_end, DataframeTableDescriptor.delimiter, import_export::CopyParams.delimiter, heavydb.thrift.ttypes.TCopyParams.delimiter, import_export::CopyParams.escape, heavydb.thrift.ttypes.TCopyParams.escape, import_export::CopyParams.geo_assign_render_groups, heavydb.thrift.ttypes.TCopyParams.geo_assign_render_groups, import_export::CopyParams.geo_coords_comp_param, heavydb.thrift.ttypes.TCopyParams.geo_coords_comp_param, import_export::CopyParams.geo_coords_encoding, heavydb.thrift.ttypes.TCopyParams.geo_coords_encoding, import_export::CopyParams.geo_coords_srid, heavydb.thrift.ttypes.TCopyParams.geo_coords_srid, import_export::CopyParams.geo_coords_type, heavydb.thrift.ttypes.TCopyParams.geo_coords_type, import_export::CopyParams.geo_explode_collections, heavydb.thrift.ttypes.TCopyParams.geo_explode_collections, import_export::CopyParams.geo_layer_name, heavydb.thrift.ttypes.TCopyParams.geo_layer_name, import_export::CopyParams.has_header, heavydb.thrift.ttypes.TCopyParams.has_header, import_export::CopyParams.line_delim, heavydb.thrift.ttypes.TCopyParams.line_delim, import_export::CopyParams.null_str, heavydb.thrift.ttypes.TCopyParams.null_str, heavydb.thrift.ttypes.TCopyParams.odbc_connection_string, heavydb.thrift.ttypes.TCopyParams.odbc_credential_string, heavydb.thrift.ttypes.TCopyParams.odbc_dsn, heavydb.thrift.ttypes.TCopyParams.odbc_password, heavydb.thrift.ttypes.TCopyParams.odbc_sql_select, heavydb.thrift.ttypes.TCopyParams.odbc_username, import_export::CopyParams.quote, heavydb.thrift.ttypes.TCopyParams.quote, import_export::CopyParams.quoted, heavydb.thrift.ttypes.TCopyParams.quoted, import_export::CopyParams.raster_import_bands, heavydb.thrift.ttypes.TCopyParams.raster_import_bands, import_export::CopyParams.raster_import_dimensions, heavydb.thrift.ttypes.TCopyParams.raster_import_dimensions, import_export::CopyParams.raster_point_compute_angle, heavydb.thrift.ttypes.TCopyParams.raster_point_compute_angle, import_export::CopyParams.raster_point_transform, heavydb.thrift.ttypes.TCopyParams.raster_point_transform, import_export::CopyParams.raster_point_type, heavydb.thrift.ttypes.TCopyParams.raster_point_type, import_export::CopyParams.raster_scanlines_per_thread, heavydb.thrift.ttypes.TCopyParams.raster_scanlines_per_thread, import_export::CopyParams.s3_access_key, S3Archive.s3_access_key, heavydb.thrift.ttypes.TCopyParams.s3_access_key, import_export::CopyParams.s3_endpoint, S3Archive.s3_endpoint, heavydb.thrift.ttypes.TCopyParams.s3_endpoint, import_export::CopyParams.s3_region, S3Archive.s3_region, heavydb.thrift.ttypes.TCopyParams.s3_region, import_export::CopyParams.s3_secret_key, S3Archive.s3_secret_key, heavydb.thrift.ttypes.TCopyParams.s3_secret_key, import_export::CopyParams.s3_session_token, S3Archive.s3_session_token, heavydb.thrift.ttypes.TCopyParams.s3_session_token, import_export::CopyParams.sanitize_column_names, heavydb.thrift.ttypes.TCopyParams.sanitize_column_names, import_export::CopyParams.source_srid, heavydb.thrift.ttypes.TCopyParams.source_srid, import_export::CopyParams.source_type, heavydb.thrift.ttypes.TCopyParams.source_type, import_export::CopyParams.threads, and heavydb.thrift.ttypes.TCopyParams.threads.

2072  def write(self, oprot):
2073  if oprot._fast_encode is not None and self.thrift_spec is not None:
2074  oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec]))
2075  return
2076  oprot.writeStructBegin('TCopyParams')
2077  if self.delimiter is not None:
2078  oprot.writeFieldBegin('delimiter', TType.STRING, 1)
2079  oprot.writeString(self.delimiter.encode('utf-8') if sys.version_info[0] == 2 else self.delimiter)
2080  oprot.writeFieldEnd()
2081  if self.null_str is not None:
2082  oprot.writeFieldBegin('null_str', TType.STRING, 2)
2083  oprot.writeString(self.null_str.encode('utf-8') if sys.version_info[0] == 2 else self.null_str)
2084  oprot.writeFieldEnd()
2085  if self.has_header is not None:
2086  oprot.writeFieldBegin('has_header', TType.I32, 3)
2087  oprot.writeI32(self.has_header)
2088  oprot.writeFieldEnd()
2089  if self.quoted is not None:
2090  oprot.writeFieldBegin('quoted', TType.BOOL, 4)
2091  oprot.writeBool(self.quoted)
2092  oprot.writeFieldEnd()
2093  if self.quote is not None:
2094  oprot.writeFieldBegin('quote', TType.STRING, 5)
2095  oprot.writeString(self.quote.encode('utf-8') if sys.version_info[0] == 2 else self.quote)
2096  oprot.writeFieldEnd()
2097  if self.escape is not None:
2098  oprot.writeFieldBegin('escape', TType.STRING, 6)
2099  oprot.writeString(self.escape.encode('utf-8') if sys.version_info[0] == 2 else self.escape)
2100  oprot.writeFieldEnd()
2101  if self.line_delim is not None:
2102  oprot.writeFieldBegin('line_delim', TType.STRING, 7)
2103  oprot.writeString(self.line_delim.encode('utf-8') if sys.version_info[0] == 2 else self.line_delim)
2104  oprot.writeFieldEnd()
2105  if self.array_delim is not None:
2106  oprot.writeFieldBegin('array_delim', TType.STRING, 8)
2107  oprot.writeString(self.array_delim.encode('utf-8') if sys.version_info[0] == 2 else self.array_delim)
2108  oprot.writeFieldEnd()
2109  if self.array_begin is not None:
2110  oprot.writeFieldBegin('array_begin', TType.STRING, 9)
2111  oprot.writeString(self.array_begin.encode('utf-8') if sys.version_info[0] == 2 else self.array_begin)
2112  oprot.writeFieldEnd()
2113  if self.array_end is not None:
2114  oprot.writeFieldBegin('array_end', TType.STRING, 10)
2115  oprot.writeString(self.array_end.encode('utf-8') if sys.version_info[0] == 2 else self.array_end)
2116  oprot.writeFieldEnd()
2117  if self.threads is not None:
2118  oprot.writeFieldBegin('threads', TType.I32, 11)
2119  oprot.writeI32(self.threads)
2120  oprot.writeFieldEnd()
2121  if self.source_type is not None:
2122  oprot.writeFieldBegin('source_type', TType.I32, 12)
2123  oprot.writeI32(self.source_type)
2124  oprot.writeFieldEnd()
2125  if self.s3_access_key is not None:
2126  oprot.writeFieldBegin('s3_access_key', TType.STRING, 13)
2127  oprot.writeString(self.s3_access_key.encode('utf-8') if sys.version_info[0] == 2 else self.s3_access_key)
2128  oprot.writeFieldEnd()
2129  if self.s3_secret_key is not None:
2130  oprot.writeFieldBegin('s3_secret_key', TType.STRING, 14)
2131  oprot.writeString(self.s3_secret_key.encode('utf-8') if sys.version_info[0] == 2 else self.s3_secret_key)
2132  oprot.writeFieldEnd()
2133  if self.s3_region is not None:
2134  oprot.writeFieldBegin('s3_region', TType.STRING, 15)
2135  oprot.writeString(self.s3_region.encode('utf-8') if sys.version_info[0] == 2 else self.s3_region)
2136  oprot.writeFieldEnd()
2137  if self.geo_coords_encoding is not None:
2138  oprot.writeFieldBegin('geo_coords_encoding', TType.I32, 16)
2139  oprot.writeI32(self.geo_coords_encoding)
2140  oprot.writeFieldEnd()
2141  if self.geo_coords_comp_param is not None:
2142  oprot.writeFieldBegin('geo_coords_comp_param', TType.I32, 17)
2143  oprot.writeI32(self.geo_coords_comp_param)
2144  oprot.writeFieldEnd()
2145  if self.geo_coords_type is not None:
2146  oprot.writeFieldBegin('geo_coords_type', TType.I32, 18)
2147  oprot.writeI32(self.geo_coords_type)
2148  oprot.writeFieldEnd()
2149  if self.geo_coords_srid is not None:
2150  oprot.writeFieldBegin('geo_coords_srid', TType.I32, 19)
2151  oprot.writeI32(self.geo_coords_srid)
2152  oprot.writeFieldEnd()
2153  if self.sanitize_column_names is not None:
2154  oprot.writeFieldBegin('sanitize_column_names', TType.BOOL, 20)
2155  oprot.writeBool(self.sanitize_column_names)
2156  oprot.writeFieldEnd()
2157  if self.geo_layer_name is not None:
2158  oprot.writeFieldBegin('geo_layer_name', TType.STRING, 21)
2159  oprot.writeString(self.geo_layer_name.encode('utf-8') if sys.version_info[0] == 2 else self.geo_layer_name)
2160  oprot.writeFieldEnd()
2161  if self.s3_endpoint is not None:
2162  oprot.writeFieldBegin('s3_endpoint', TType.STRING, 22)
2163  oprot.writeString(self.s3_endpoint.encode('utf-8') if sys.version_info[0] == 2 else self.s3_endpoint)
2164  oprot.writeFieldEnd()
2165  if self.geo_assign_render_groups is not None:
2166  oprot.writeFieldBegin('geo_assign_render_groups', TType.BOOL, 23)
2167  oprot.writeBool(self.geo_assign_render_groups)
2168  oprot.writeFieldEnd()
2169  if self.geo_explode_collections is not None:
2170  oprot.writeFieldBegin('geo_explode_collections', TType.BOOL, 24)
2171  oprot.writeBool(self.geo_explode_collections)
2172  oprot.writeFieldEnd()
2173  if self.source_srid is not None:
2174  oprot.writeFieldBegin('source_srid', TType.I32, 25)
2175  oprot.writeI32(self.source_srid)
2176  oprot.writeFieldEnd()
2177  if self.s3_session_token is not None:
2178  oprot.writeFieldBegin('s3_session_token', TType.STRING, 26)
2179  oprot.writeString(self.s3_session_token.encode('utf-8') if sys.version_info[0] == 2 else self.s3_session_token)
2180  oprot.writeFieldEnd()
2181  if self.raster_point_type is not None:
2182  oprot.writeFieldBegin('raster_point_type', TType.I32, 27)
2183  oprot.writeI32(self.raster_point_type)
2184  oprot.writeFieldEnd()
2185  if self.raster_import_bands is not None:
2186  oprot.writeFieldBegin('raster_import_bands', TType.STRING, 28)
2187  oprot.writeString(self.raster_import_bands.encode('utf-8') if sys.version_info[0] == 2 else self.raster_import_bands)
2188  oprot.writeFieldEnd()
2189  if self.raster_scanlines_per_thread is not None:
2190  oprot.writeFieldBegin('raster_scanlines_per_thread', TType.I32, 29)
2191  oprot.writeI32(self.raster_scanlines_per_thread)
2192  oprot.writeFieldEnd()
2193  if self.raster_point_transform is not None:
2194  oprot.writeFieldBegin('raster_point_transform', TType.I32, 30)
2195  oprot.writeI32(self.raster_point_transform)
2196  oprot.writeFieldEnd()
2197  if self.raster_point_compute_angle is not None:
2198  oprot.writeFieldBegin('raster_point_compute_angle', TType.BOOL, 31)
2199  oprot.writeBool(self.raster_point_compute_angle)
2200  oprot.writeFieldEnd()
2201  if self.raster_import_dimensions is not None:
2202  oprot.writeFieldBegin('raster_import_dimensions', TType.STRING, 32)
2203  oprot.writeString(self.raster_import_dimensions.encode('utf-8') if sys.version_info[0] == 2 else self.raster_import_dimensions)
2204  oprot.writeFieldEnd()
2205  if self.odbc_dsn is not None:
2206  oprot.writeFieldBegin('odbc_dsn', TType.STRING, 33)
2207  oprot.writeString(self.odbc_dsn.encode('utf-8') if sys.version_info[0] == 2 else self.odbc_dsn)
2208  oprot.writeFieldEnd()
2209  if self.odbc_connection_string is not None:
2210  oprot.writeFieldBegin('odbc_connection_string', TType.STRING, 34)
2211  oprot.writeString(self.odbc_connection_string.encode('utf-8') if sys.version_info[0] == 2 else self.odbc_connection_string)
2212  oprot.writeFieldEnd()
2213  if self.odbc_sql_select is not None:
2214  oprot.writeFieldBegin('odbc_sql_select', TType.STRING, 35)
2215  oprot.writeString(self.odbc_sql_select.encode('utf-8') if sys.version_info[0] == 2 else self.odbc_sql_select)
2216  oprot.writeFieldEnd()
2217  if self.odbc_username is not None:
2218  oprot.writeFieldBegin('odbc_username', TType.STRING, 36)
2219  oprot.writeString(self.odbc_username.encode('utf-8') if sys.version_info[0] == 2 else self.odbc_username)
2220  oprot.writeFieldEnd()
2221  if self.odbc_password is not None:
2222  oprot.writeFieldBegin('odbc_password', TType.STRING, 37)
2223  oprot.writeString(self.odbc_password.encode('utf-8') if sys.version_info[0] == 2 else self.odbc_password)
2224  oprot.writeFieldEnd()
2225  if self.odbc_credential_string is not None:
2226  oprot.writeFieldBegin('odbc_credential_string', TType.STRING, 38)
2227  oprot.writeString(self.odbc_credential_string.encode('utf-8') if sys.version_info[0] == 2 else self.odbc_credential_string)
2228  oprot.writeFieldEnd()
2229  if self.add_metadata_columns is not None:
2230  oprot.writeFieldBegin('add_metadata_columns', TType.STRING, 39)
2231  oprot.writeString(self.add_metadata_columns.encode('utf-8') if sys.version_info[0] == 2 else self.add_metadata_columns)
2232  oprot.writeFieldEnd()
2233  oprot.writeFieldStop()
2234  oprot.writeStructEnd()

Member Data Documentation

heavydb.thrift.ttypes.TCopyParams.__dict__
private

Definition at line 2244 of file ttypes.py.

Referenced by generate_TableFunctionsFactory_init.Node.copy().

heavydb.thrift.ttypes.TCopyParams.add_metadata_columns

Definition at line 1860 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.array_begin

Definition at line 1830 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.array_delim

Definition at line 1829 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.array_end

Definition at line 1831 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.delimiter

Definition at line 1822 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.escape

Definition at line 1827 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.geo_assign_render_groups

Definition at line 1844 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.geo_coords_comp_param

Definition at line 1838 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.geo_coords_encoding

Definition at line 1837 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.geo_coords_srid

Definition at line 1840 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.geo_coords_type

Definition at line 1839 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.geo_explode_collections

Definition at line 1845 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.geo_layer_name

Definition at line 1842 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.has_header

Definition at line 1824 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.line_delim

Definition at line 1828 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.null_str

Definition at line 1823 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.odbc_connection_string

Definition at line 1855 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.odbc_credential_string

Definition at line 1859 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.odbc_dsn

Definition at line 1854 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.odbc_password

Definition at line 1858 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.odbc_sql_select

Definition at line 1856 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.odbc_username

Definition at line 1857 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.quote

Definition at line 1826 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.quoted

Definition at line 1825 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.raster_import_bands

Definition at line 1849 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.raster_import_dimensions

Definition at line 1853 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.raster_point_compute_angle

Definition at line 1852 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.raster_point_transform

Definition at line 1851 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.raster_point_type

Definition at line 1848 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.raster_scanlines_per_thread

Definition at line 1850 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.s3_access_key

Definition at line 1834 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.s3_endpoint

Definition at line 1843 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.s3_region

Definition at line 1836 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.s3_secret_key

Definition at line 1835 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.s3_session_token

Definition at line 1847 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.sanitize_column_names

Definition at line 1841 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.source_srid

Definition at line 1846 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.source_type

Definition at line 1833 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().

heavydb.thrift.ttypes.TCopyParams.threads

Definition at line 1832 of file ttypes.py.

Referenced by heavydb.thrift.ttypes.TCopyParams.read(), and heavydb.thrift.ttypes.TCopyParams.write().


The documentation for this class was generated from the following file: