OmniSciDB  a5dc49c757
 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_sql_order_by
 
 odbc_username
 
 odbc_password
 
 odbc_credential_string
 
 add_metadata_columns
 
 trim_spaces
 
 geo_validate_geometry
 

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_sql_order_by
 - odbc_username
 - odbc_password
 - odbc_credential_string
 - add_metadata_columns
 - trim_spaces
 - geo_validate_geometry

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 = False,
  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_sql_order_by = None,
  odbc_username = None,
  odbc_password = None,
  odbc_credential_string = None,
  add_metadata_columns = None,
  trim_spaces = True,
  geo_validate_geometry = False 
)

Definition at line 1824 of file ttypes.py.

1825  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=False, 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_sql_order_by=None, odbc_username=None, odbc_password=None, odbc_credential_string=None, add_metadata_columns=None, trim_spaces=True, geo_validate_geometry=False,):
1826  self.delimiter = delimiter
1827  self.null_str = null_str
1828  self.has_header = has_header
1829  self.quoted = quoted
1830  self.quote = quote
1831  self.escape = escape
1832  self.line_delim = line_delim
1833  self.array_delim = array_delim
1834  self.array_begin = array_begin
1835  self.array_end = array_end
1836  self.threads = threads
1837  self.source_type = source_type
1838  self.s3_access_key = s3_access_key
1839  self.s3_secret_key = s3_secret_key
1840  self.s3_region = s3_region
1841  self.geo_coords_encoding = geo_coords_encoding
1842  self.geo_coords_comp_param = geo_coords_comp_param
1843  self.geo_coords_type = geo_coords_type
1844  self.geo_coords_srid = geo_coords_srid
1845  self.sanitize_column_names = sanitize_column_names
1846  self.geo_layer_name = geo_layer_name
1847  self.s3_endpoint = s3_endpoint
1848  self.geo_assign_render_groups = geo_assign_render_groups
1849  self.geo_explode_collections = geo_explode_collections
1850  self.source_srid = source_srid
1851  self.s3_session_token = s3_session_token
1852  self.raster_point_type = raster_point_type
1853  self.raster_import_bands = raster_import_bands
1854  self.raster_scanlines_per_thread = raster_scanlines_per_thread
1855  self.raster_point_transform = raster_point_transform
1856  self.raster_point_compute_angle = raster_point_compute_angle
1857  self.raster_import_dimensions = raster_import_dimensions
1858  self.odbc_dsn = odbc_dsn
1859  self.odbc_connection_string = odbc_connection_string
1860  self.odbc_sql_select = odbc_sql_select
1861  self.odbc_sql_order_by = odbc_sql_order_by
1862  self.odbc_username = odbc_username
1863  self.odbc_password = odbc_password
1864  self.odbc_credential_string = odbc_credential_string
1865  self.add_metadata_columns = add_metadata_columns
1866  self.trim_spaces = trim_spaces
1867  self.geo_validate_geometry = geo_validate_geometry

Member Function Documentation

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

Definition at line 2276 of file ttypes.py.

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

Definition at line 2279 of file ttypes.py.

2280  def __ne__(self, other):
2281  return not (self == other)
2282 
def heavydb.thrift.ttypes.TCopyParams.__repr__ (   self)

Definition at line 2271 of file ttypes.py.

2272  def __repr__(self):
2273  L = ['%s=%r' % (key, value)
2274  for key, value in self.__dict__.items()]
2275  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 1868 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, 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.geo_validate_geometry, heavydb.thrift.ttypes.TCopyParams.geo_validate_geometry, 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_order_by, 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, heavydb.thrift.ttypes.TCopyParams.threads, import_export::CopyParams.trim_spaces, and heavydb.thrift.ttypes.TCopyParams.trim_spaces.

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

Definition at line 2268 of file ttypes.py.

2269  def validate(self):
2270  return
def heavydb.thrift.ttypes.TCopyParams.write (   self,
  oprot 
)

Definition at line 2092 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, 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.geo_validate_geometry, heavydb.thrift.ttypes.TCopyParams.geo_validate_geometry, 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_order_by, 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, heavydb.thrift.ttypes.TCopyParams.threads, import_export::CopyParams.trim_spaces, and heavydb.thrift.ttypes.TCopyParams.trim_spaces.

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

Member Data Documentation

heavydb.thrift.ttypes.TCopyParams.__dict__
private

Definition at line 2277 of file ttypes.py.

Referenced by TableFunctionsFactory_node.Node.copy().

heavydb.thrift.ttypes.TCopyParams.add_metadata_columns

Definition at line 1864 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 1833 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 1832 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 1834 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 1825 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 1830 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 1847 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 1841 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 1840 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 1843 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 1842 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 1848 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 1845 of file ttypes.py.

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

heavydb.thrift.ttypes.TCopyParams.geo_validate_geometry

Definition at line 1866 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 1827 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 1831 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 1826 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 1858 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 1863 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 1857 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 1862 of file ttypes.py.

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

heavydb.thrift.ttypes.TCopyParams.odbc_sql_order_by

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.odbc_sql_select

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_username

Definition at line 1861 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 1829 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 1828 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 1852 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 1856 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 1855 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 1854 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 1851 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 1853 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 1837 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 1846 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 1839 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 1838 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 1850 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 1844 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 1849 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 1836 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 1835 of file ttypes.py.

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

heavydb.thrift.ttypes.TCopyParams.trim_spaces

Definition at line 1865 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: