infra_adapter

package
v2.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 6, 2023 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	FileMetaData_FileType_name = map[int32]string{
		0: "Unspecified",
		1: "Csv",
	}
	FileMetaData_FileType_value = map[string]int32{
		"Unspecified": 0,
		"Csv":         1,
	}
)

Enum value maps for FileMetaData_FileType.

View Source 
var (
	MetaData_FileType_name = map[int32]string{
		0: "Unspecified",
		1: "Csv",
	}
	MetaData_FileType_value = map[string]int32{
		"Unspecified": 0,
		"Csv":         1,
	}
)

Enum value maps for MetaData_FileType.

View Source 
var (
	ColumnMetaData_DataType_name = map[int32]string{
		0: "Unspecified",
		1: "Int",
		2: "Float",
		3: "String",
		4: "Date",
	}
	ColumnMetaData_DataType_value = map[string]int32{
		"Unspecified": 0,
		"Int":         1,
		"Float":       2,
		"String":      3,
		"Date":        4,
	}
)

Enum value maps for ColumnMetaData_DataType.

View Source 
var File_sudo_protobuf_infra_adapter_location_location_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ColumnMetaData 

type ColumnMetaData struct {
	Datatype ColumnMetaData_DataType `` /* 136-byte string literal not displayed */
	// default "YYYY-MM-DD"
	DateFormat string `protobuf:"bytes,2,opt,name=date_format,json=dateFormat,proto3" json:"date_format,omitempty"`
	// mostly affect reports.json
	// TODO: feed this info back when complete_stage
	Alias string `protobuf:"bytes,3,opt,name=alias,proto3" json:"alias,omitempty"`
	// contains filtered or unexported fields
}

func (*ColumnMetaData) Descriptor deprecated 

func (*ColumnMetaData) Descriptor() ([]byte, []int)

Deprecated: Use ColumnMetaData.ProtoReflect.Descriptor instead.

func (*ColumnMetaData) GetAlias 

func (x *ColumnMetaData) GetAlias() string

func (*ColumnMetaData) GetDatatype 

func (x *ColumnMetaData) GetDatatype() ColumnMetaData_DataType

func (*ColumnMetaData) GetDateFormat 

func (x *ColumnMetaData) GetDateFormat() string

func (*ColumnMetaData) ProtoMessage 

func (*ColumnMetaData) ProtoMessage()

func (*ColumnMetaData) ProtoReflect 

func (x *ColumnMetaData) ProtoReflect() protoreflect.Message

func (*ColumnMetaData) Reset 

func (x *ColumnMetaData) Reset()

func (*ColumnMetaData) String 

func (x *ColumnMetaData) String() string

type ColumnMetaData_DataType 

type ColumnMetaData_DataType int32

non_exhausive 

const (
	ColumnMetaData_Unspecified ColumnMetaData_DataType = 0
	ColumnMetaData_Int         ColumnMetaData_DataType = 1
	ColumnMetaData_Float       ColumnMetaData_DataType = 2
	ColumnMetaData_String      ColumnMetaData_DataType = 3
	ColumnMetaData_Date        ColumnMetaData_DataType = 4
)

func (ColumnMetaData_DataType) Descriptor 

func (ColumnMetaData_DataType) Descriptor() protoreflect.EnumDescriptor

func (ColumnMetaData_DataType) Enum 

func (x ColumnMetaData_DataType) Enum() *ColumnMetaData_DataType

func (ColumnMetaData_DataType) EnumDescriptor deprecated 

func (ColumnMetaData_DataType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ColumnMetaData_DataType.Descriptor instead.

func (ColumnMetaData_DataType) Number 

func (x ColumnMetaData_DataType) Number() protoreflect.EnumNumber

func (ColumnMetaData_DataType) String 

func (x ColumnMetaData_DataType) String() string

func (ColumnMetaData_DataType) Type 

func (ColumnMetaData_DataType) Type() protoreflect.EnumType

type DataLocation 

type DataLocation struct {

	// data is for operator usage, furnace property is used to track
	// corresponding
	//
	// Types that are assignable to Data:
	//	*DataLocation_LocalFile
	//	*DataLocation_DbTable
	//	*DataLocation_Memory_
	Data            isDataLocation_Data `protobuf_oneof:"data"`
	FurnaceProperty *FurnaceProperty    `protobuf:"bytes,4,opt,name=furnace_property,json=furnaceProperty,proto3" json:"furnace_property,omitempty"`
	IsTmpData       bool                `protobuf:"varint,5,opt,name=is_tmp_data,json=isTmpData,proto3" json:"is_tmp_data,omitempty"`
	Metadata        *MetaData           `protobuf:"bytes,6,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*DataLocation) Descriptor deprecated 

func (*DataLocation) Descriptor() ([]byte, []int)

Deprecated: Use DataLocation.ProtoReflect.Descriptor instead.

func (*DataLocation) GetData 

func (m *DataLocation) GetData() isDataLocation_Data

func (*DataLocation) GetDbTable 

func (x *DataLocation) GetDbTable() *DataLocation_DB

func (*DataLocation) GetFurnaceProperty 

func (x *DataLocation) GetFurnaceProperty() *FurnaceProperty

func (*DataLocation) GetIsTmpData 

func (x *DataLocation) GetIsTmpData() bool

func (*DataLocation) GetLocalFile 

func (x *DataLocation) GetLocalFile() *DataLocation_File

func (*DataLocation) GetMemory 

func (x *DataLocation) GetMemory() *DataLocation_Memory

func (*DataLocation) GetMetadata 

func (x *DataLocation) GetMetadata() *MetaData

func (*DataLocation) ProtoMessage 

func (*DataLocation) ProtoMessage()

func (*DataLocation) ProtoReflect 

func (x *DataLocation) ProtoReflect() protoreflect.Message

func (*DataLocation) Reset 

func (x *DataLocation) Reset()

func (*DataLocation) String 

func (x *DataLocation) String() string

type DataLocation_DB 

type DataLocation_DB struct {

	// data source name is an identifier to get db settings from odbc.ini config file.
	// it's deprecated now, use connection instead.
	//
	// Deprecated: Do not use.
	DataSourceName string `protobuf:"bytes,1,opt,name=data_source_name,json=dataSourceName,proto3" json:"data_source_name,omitempty"`
	// Types that are assignable to Path:
	//	*DataLocation_DB_Query
	//	*DataLocation_DB_Table
	Path     isDataLocation_DB_Path `protobuf_oneof:"path"`
	VtableId uint64                 `protobuf:"varint,4,opt,name=vtable_id,json=vtableId,proto3" json:"vtable_id,omitempty"`
	// Types that are assignable to Connection:
	//	*DataLocation_DB_Dsn
	//	*DataLocation_DB_OdbcConnection
	Connection   isDataLocation_DB_Connection `protobuf_oneof:"connection"`
	DbConnection *DataLocation_DBConnection   `protobuf:"bytes,7,opt,name=db_connection,json=dbConnection,proto3" json:"db_connection,omitempty"`
	// contains filtered or unexported fields
}

func (*DataLocation_DB) Descriptor deprecated 

func (*DataLocation_DB) Descriptor() ([]byte, []int)

Deprecated: Use DataLocation_DB.ProtoReflect.Descriptor instead.

func (*DataLocation_DB) GetConnection 

func (m *DataLocation_DB) GetConnection() isDataLocation_DB_Connection

func (*DataLocation_DB) GetDataSourceName deprecated 

func (x *DataLocation_DB) GetDataSourceName() string

Deprecated: Do not use.

func (*DataLocation_DB) GetDbConnection 

func (x *DataLocation_DB) GetDbConnection() *DataLocation_DBConnection

func (*DataLocation_DB) GetDsn 

func (x *DataLocation_DB) GetDsn() string

func (*DataLocation_DB) GetOdbcConnection 

func (x *DataLocation_DB) GetOdbcConnection() *DataLocation_ODBCConnection

func (*DataLocation_DB) GetPath 

func (m *DataLocation_DB) GetPath() isDataLocation_DB_Path

func (*DataLocation_DB) GetQuery 

func (x *DataLocation_DB) GetQuery() string

func (*DataLocation_DB) GetTable 

func (x *DataLocation_DB) GetTable() *DataLocation_Table

func (*DataLocation_DB) GetVtableId 

func (x *DataLocation_DB) GetVtableId() uint64

func (*DataLocation_DB) ProtoMessage 

func (*DataLocation_DB) ProtoMessage()

func (*DataLocation_DB) ProtoReflect 

func (x *DataLocation_DB) ProtoReflect() protoreflect.Message

func (*DataLocation_DB) Reset 

func (x *DataLocation_DB) Reset()

func (*DataLocation_DB) String 

func (x *DataLocation_DB) String() string

type DataLocation_DBConnection 

type DataLocation_DBConnection struct {

	// Types that are assignable to Connection:
	//	*DataLocation_DBConnection_DataSourceName
	//	*DataLocation_DBConnection_OdbcConnection
	//	*DataLocation_DBConnection_FullConnection
	Connection isDataLocation_DBConnection_Connection `protobuf_oneof:"connection"`
	// contains filtered or unexported fields
}

func (*DataLocation_DBConnection) Descriptor deprecated 

func (*DataLocation_DBConnection) Descriptor() ([]byte, []int)

Deprecated: Use DataLocation_DBConnection.ProtoReflect.Descriptor instead.

func (*DataLocation_DBConnection) GetConnection 

func (m *DataLocation_DBConnection) GetConnection() isDataLocation_DBConnection_Connection

func (*DataLocation_DBConnection) GetDataSourceName 

func (x *DataLocation_DBConnection) GetDataSourceName() string

func (*DataLocation_DBConnection) GetFullConnection 

func (x *DataLocation_DBConnection) GetFullConnection() *DataLocation_FullConnectionInfo

func (*DataLocation_DBConnection) GetOdbcConnection 

func (x *DataLocation_DBConnection) GetOdbcConnection() *DataLocation_ODBCConnection

func (*DataLocation_DBConnection) ProtoMessage 

func (*DataLocation_DBConnection) ProtoMessage()

func (*DataLocation_DBConnection) ProtoReflect 

func (x *DataLocation_DBConnection) ProtoReflect() protoreflect.Message

func (*DataLocation_DBConnection) Reset 

func (x *DataLocation_DBConnection) Reset()

func (*DataLocation_DBConnection) String 

func (x *DataLocation_DBConnection) String() string

type DataLocation_DBConnection_DataSourceName 

type DataLocation_DBConnection_DataSourceName struct {
	DataSourceName string `protobuf:"bytes,1,opt,name=data_source_name,json=dataSourceName,proto3,oneof"`
}

type DataLocation_DBConnection_FullConnection 

type DataLocation_DBConnection_FullConnection struct {
	FullConnection *DataLocation_FullConnectionInfo `protobuf:"bytes,3,opt,name=full_connection,json=fullConnection,proto3,oneof"`
}

type DataLocation_DBConnection_OdbcConnection 

type DataLocation_DBConnection_OdbcConnection struct {
	OdbcConnection *DataLocation_ODBCConnection `protobuf:"bytes,2,opt,name=odbc_connection,json=odbcConnection,proto3,oneof"`
}

type DataLocation_DB_Dsn 

type DataLocation_DB_Dsn struct {
	Dsn string `protobuf:"bytes,5,opt,name=dsn,proto3,oneof"`
}

type DataLocation_DB_OdbcConnection 

type DataLocation_DB_OdbcConnection struct {
	OdbcConnection *DataLocation_ODBCConnection `protobuf:"bytes,6,opt,name=odbc_connection,json=odbcConnection,proto3,oneof"`
}

type DataLocation_DB_Query 

type DataLocation_DB_Query struct {
	Query string `protobuf:"bytes,2,opt,name=query,proto3,oneof"` // for input
}

type DataLocation_DB_Table 

type DataLocation_DB_Table struct {
	Table *DataLocation_Table `protobuf:"bytes,3,opt,name=table,proto3,oneof"` // for output
}

type DataLocation_DbTable 

type DataLocation_DbTable struct {
	DbTable *DataLocation_DB `protobuf:"bytes,2,opt,name=db_table,json=dbTable,proto3,oneof"`
}

type DataLocation_File 

type DataLocation_File struct {

	// Path is a relative file path, need root path from data source info to build a complete file path.
	Path           string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	VtableId       uint64 `protobuf:"varint,2,opt,name=vtable_id,json=vtableId,proto3" json:"vtable_id,omitempty"`
	DataSourceName string `protobuf:"bytes,3,opt,name=data_source_name,json=dataSourceName,proto3" json:"data_source_name,omitempty"`
	// deprecated
	//
	// Deprecated: Do not use.
	XDeprecatedSelectedCols []string `` /* 131-byte string literal not displayed */
	// deprecated: merged to upper levels
	//
	// Deprecated: Do not use.
	Metadata *FileMetaData `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Full path to locate a file. don't need data source info to complete the path. You can locate a file either by path and data source name or full_path.
	FullPath string `protobuf:"bytes,6,opt,name=full_path,json=fullPath,proto3" json:"full_path,omitempty"`
	// contains filtered or unexported fields
}

func (*DataLocation_File) Descriptor deprecated 

func (*DataLocation_File) Descriptor() ([]byte, []int)

Deprecated: Use DataLocation_File.ProtoReflect.Descriptor instead.

func (*DataLocation_File) GetDataSourceName 

func (x *DataLocation_File) GetDataSourceName() string

func (*DataLocation_File) GetFullPath 

func (x *DataLocation_File) GetFullPath() string

func (*DataLocation_File) GetMetadata deprecated 

func (x *DataLocation_File) GetMetadata() *FileMetaData

Deprecated: Do not use.

func (*DataLocation_File) GetPath 

func (x *DataLocation_File) GetPath() string

func (*DataLocation_File) GetVtableId 

func (x *DataLocation_File) GetVtableId() uint64

func (*DataLocation_File) GetXDeprecatedSelectedCols deprecated 

func (x *DataLocation_File) GetXDeprecatedSelectedCols() []string

Deprecated: Do not use.

func (*DataLocation_File) ProtoMessage 

func (*DataLocation_File) ProtoMessage()

func (*DataLocation_File) ProtoReflect 

func (x *DataLocation_File) ProtoReflect() protoreflect.Message

func (*DataLocation_File) Reset 

func (x *DataLocation_File) Reset()

func (*DataLocation_File) String 

func (x *DataLocation_File) String() string

type DataLocation_FullConnectionInfo 

type DataLocation_FullConnectionInfo struct {
	ConnectionName string                `protobuf:"bytes,1,opt,name=connection_name,json=connectionName,proto3" json:"connection_name,omitempty"`
	Host           string                `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	Port           int64                 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	DbName         string                `protobuf:"bytes,4,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	DatasourceType enums.Datasource_Type `` /* 145-byte string literal not displayed */
	// Types that are assignable to Authorization:
	//	*DataLocation_FullConnectionInfo_General
	//	*DataLocation_FullConnectionInfo_Kerberos
	Authorization isDataLocation_FullConnectionInfo_Authorization `protobuf_oneof:"authorization"`
	// for hive write. TODO: remove
	HdfsConf *DataLocation_HdfsConf `protobuf:"bytes,8,opt,name=hdfs_conf,json=hdfsConf,proto3" json:"hdfs_conf,omitempty"`
	// contains filtered or unexported fields
}

FullConnectionInfo, full info to connect a dataSource.

func (*DataLocation_FullConnectionInfo) Descriptor deprecated 

func (*DataLocation_FullConnectionInfo) Descriptor() ([]byte, []int)

Deprecated: Use DataLocation_FullConnectionInfo.ProtoReflect.Descriptor instead.

func (*DataLocation_FullConnectionInfo) GetAuthorization 

func (m *DataLocation_FullConnectionInfo) GetAuthorization() isDataLocation_FullConnectionInfo_Authorization

func (*DataLocation_FullConnectionInfo) GetConnectionName 

func (x *DataLocation_FullConnectionInfo) GetConnectionName() string

func (*DataLocation_FullConnectionInfo) GetDatasourceType 

func (x *DataLocation_FullConnectionInfo) GetDatasourceType() enums.Datasource_Type

func (*DataLocation_FullConnectionInfo) GetDbName 

func (x *DataLocation_FullConnectionInfo) GetDbName() string

func (*DataLocation_FullConnectionInfo) GetGeneral 

func (x *DataLocation_FullConnectionInfo) GetGeneral() *DataLocation_General

func (*DataLocation_FullConnectionInfo) GetHdfsConf 

func (x *DataLocation_FullConnectionInfo) GetHdfsConf() *DataLocation_HdfsConf

func (*DataLocation_FullConnectionInfo) GetHost 

func (x *DataLocation_FullConnectionInfo) GetHost() string

func (*DataLocation_FullConnectionInfo) GetKerberos 

func (x *DataLocation_FullConnectionInfo) GetKerberos() *DataLocation_Kerberos

func (*DataLocation_FullConnectionInfo) GetPort 

func (x *DataLocation_FullConnectionInfo) GetPort() int64

func (*DataLocation_FullConnectionInfo) ProtoMessage 

func (*DataLocation_FullConnectionInfo) ProtoMessage()

func (*DataLocation_FullConnectionInfo) ProtoReflect 

func (x *DataLocation_FullConnectionInfo) ProtoReflect() protoreflect.Message

func (*DataLocation_FullConnectionInfo) Reset 

func (x *DataLocation_FullConnectionInfo) Reset()

func (*DataLocation_FullConnectionInfo) String 

func (x *DataLocation_FullConnectionInfo) String() string

type DataLocation_FullConnectionInfo_General 

type DataLocation_FullConnectionInfo_General struct {
	General *DataLocation_General `protobuf:"bytes,6,opt,name=general,proto3,oneof"`
}

type DataLocation_FullConnectionInfo_Kerberos 

type DataLocation_FullConnectionInfo_Kerberos struct {
	Kerberos *DataLocation_Kerberos `protobuf:"bytes,7,opt,name=kerberos,proto3,oneof"`
}

type DataLocation_General 

type DataLocation_General struct {
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*DataLocation_General) Descriptor deprecated 

func (*DataLocation_General) Descriptor() ([]byte, []int)

Deprecated: Use DataLocation_General.ProtoReflect.Descriptor instead.

func (*DataLocation_General) GetPassword 

func (x *DataLocation_General) GetPassword() string

func (*DataLocation_General) GetUsername 

func (x *DataLocation_General) GetUsername() string

func (*DataLocation_General) ProtoMessage 

func (*DataLocation_General) ProtoMessage()

func (*DataLocation_General) ProtoReflect 

func (x *DataLocation_General) ProtoReflect() protoreflect.Message

func (*DataLocation_General) Reset 

func (x *DataLocation_General) Reset()

func (*DataLocation_General) String 

func (x *DataLocation_General) String() string

type DataLocation_HdfsConf 

type DataLocation_HdfsConf struct {
	Uri           string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	Username      string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	UploadDir     string `protobuf:"bytes,3,opt,name=upload_dir,json=uploadDir,proto3" json:"upload_dir,omitempty"`
	RpcProtection string `protobuf:"bytes,4,opt,name=rpc_protection,json=rpcProtection,proto3" json:"rpc_protection,omitempty"`
	// contains filtered or unexported fields
}

func (*DataLocation_HdfsConf) Descriptor deprecated 

func (*DataLocation_HdfsConf) Descriptor() ([]byte, []int)

Deprecated: Use DataLocation_HdfsConf.ProtoReflect.Descriptor instead.

func (*DataLocation_HdfsConf) GetRpcProtection 

func (x *DataLocation_HdfsConf) GetRpcProtection() string

func (*DataLocation_HdfsConf) GetUploadDir 

func (x *DataLocation_HdfsConf) GetUploadDir() string

func (*DataLocation_HdfsConf) GetUri 

func (x *DataLocation_HdfsConf) GetUri() string

func (*DataLocation_HdfsConf) GetUsername 

func (x *DataLocation_HdfsConf) GetUsername() string

func (*DataLocation_HdfsConf) ProtoMessage 

func (*DataLocation_HdfsConf) ProtoMessage()

func (*DataLocation_HdfsConf) ProtoReflect 

func (x *DataLocation_HdfsConf) ProtoReflect() protoreflect.Message

func (*DataLocation_HdfsConf) Reset 

func (x *DataLocation_HdfsConf) Reset()

func (*DataLocation_HdfsConf) String 

func (x *DataLocation_HdfsConf) String() string

type DataLocation_Kerberos 

type DataLocation_Kerberos struct {
	Principal           string `protobuf:"bytes,1,opt,name=principal,proto3" json:"principal,omitempty"`
	Krb5Path            string `protobuf:"bytes,2,opt,name=krb5_path,json=krb5Path,proto3" json:"krb5_path,omitempty"`
	KeytabPath          string `protobuf:"bytes,3,opt,name=keytab_path,json=keytabPath,proto3" json:"keytab_path,omitempty"`
	HiveServerPrincipal string `protobuf:"bytes,4,opt,name=hive_server_principal,json=hiveServerPrincipal,proto3" json:"hive_server_principal,omitempty"`
	HdfsServerPrincipal string `protobuf:"bytes,5,opt,name=hdfs_server_principal,json=hdfsServerPrincipal,proto3" json:"hdfs_server_principal,omitempty"`
	// contains filtered or unexported fields
}

func (*DataLocation_Kerberos) Descriptor deprecated 

func (*DataLocation_Kerberos) Descriptor() ([]byte, []int)

Deprecated: Use DataLocation_Kerberos.ProtoReflect.Descriptor instead.

func (*DataLocation_Kerberos) GetHdfsServerPrincipal 

func (x *DataLocation_Kerberos) GetHdfsServerPrincipal() string

func (*DataLocation_Kerberos) GetHiveServerPrincipal 

func (x *DataLocation_Kerberos) GetHiveServerPrincipal() string

func (*DataLocation_Kerberos) GetKeytabPath 

func (x *DataLocation_Kerberos) GetKeytabPath() string

func (*DataLocation_Kerberos) GetKrb5Path 

func (x *DataLocation_Kerberos) GetKrb5Path() string

func (*DataLocation_Kerberos) GetPrincipal 

func (x *DataLocation_Kerberos) GetPrincipal() string

func (*DataLocation_Kerberos) ProtoMessage 

func (*DataLocation_Kerberos) ProtoMessage()

func (*DataLocation_Kerberos) ProtoReflect 

func (x *DataLocation_Kerberos) ProtoReflect() protoreflect.Message

func (*DataLocation_Kerberos) Reset 

func (x *DataLocation_Kerberos) Reset()

func (*DataLocation_Kerberos) String 

func (x *DataLocation_Kerberos) String() string

type DataLocation_LocalFile 

type DataLocation_LocalFile struct {
	LocalFile *DataLocation_File `protobuf:"bytes,1,opt,name=local_file,json=localFile,proto3,oneof"`
}

type DataLocation_Memory 

type DataLocation_Memory struct {
	OperatorIndex uint64   `protobuf:"varint,1,opt,name=operator_index,json=operatorIndex,proto3" json:"operator_index,omitempty"`
	Key           string   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	SelectedCols  []string `protobuf:"bytes,4,rep,name=selected_cols,json=selectedCols,proto3" json:"selected_cols,omitempty"`
	// contains filtered or unexported fields
}

func (*DataLocation_Memory) Descriptor deprecated 

func (*DataLocation_Memory) Descriptor() ([]byte, []int)

Deprecated: Use DataLocation_Memory.ProtoReflect.Descriptor instead.

func (*DataLocation_Memory) GetKey 

func (x *DataLocation_Memory) GetKey() string

func (*DataLocation_Memory) GetOperatorIndex 

func (x *DataLocation_Memory) GetOperatorIndex() uint64

func (*DataLocation_Memory) GetSelectedCols 

func (x *DataLocation_Memory) GetSelectedCols() []string

func (*DataLocation_Memory) ProtoMessage 

func (*DataLocation_Memory) ProtoMessage()

func (*DataLocation_Memory) ProtoReflect 

func (x *DataLocation_Memory) ProtoReflect() protoreflect.Message

func (*DataLocation_Memory) Reset 

func (x *DataLocation_Memory) Reset()

func (*DataLocation_Memory) String 

func (x *DataLocation_Memory) String() string

type DataLocation_Memory_ 

type DataLocation_Memory_ struct {
	Memory *DataLocation_Memory `protobuf:"bytes,3,opt,name=memory,proto3,oneof"` // Todo
}

type DataLocation_ODBCConnection 

type DataLocation_ODBCConnection struct {
	Connection     string `protobuf:"bytes,1,opt,name=connection,proto3" json:"connection,omitempty"`
	DataSourceType int32  `protobuf:"varint,2,opt,name=data_source_type,json=dataSourceType,proto3" json:"data_source_type,omitempty"`
	// contains filtered or unexported fields
}

func (*DataLocation_ODBCConnection) Descriptor deprecated 

func (*DataLocation_ODBCConnection) Descriptor() ([]byte, []int)

Deprecated: Use DataLocation_ODBCConnection.ProtoReflect.Descriptor instead.

func (*DataLocation_ODBCConnection) GetConnection 

func (x *DataLocation_ODBCConnection) GetConnection() string

func (*DataLocation_ODBCConnection) GetDataSourceType 

func (x *DataLocation_ODBCConnection) GetDataSourceType() int32

func (*DataLocation_ODBCConnection) ProtoMessage 

func (*DataLocation_ODBCConnection) ProtoMessage()

func (*DataLocation_ODBCConnection) ProtoReflect 

func (x *DataLocation_ODBCConnection) ProtoReflect() protoreflect.Message

func (*DataLocation_ODBCConnection) Reset 

func (x *DataLocation_ODBCConnection) Reset()

func (*DataLocation_ODBCConnection) String 

func (x *DataLocation_ODBCConnection) String() string

type DataLocation_Table 

type DataLocation_Table struct {
	Path         string   `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	SelectedCols []string `protobuf:"bytes,2,rep,name=selected_cols,json=selectedCols,proto3" json:"selected_cols,omitempty"`
	// contains filtered or unexported fields
}

func (*DataLocation_Table) Descriptor deprecated 

func (*DataLocation_Table) Descriptor() ([]byte, []int)

Deprecated: Use DataLocation_Table.ProtoReflect.Descriptor instead.

func (*DataLocation_Table) GetPath 

func (x *DataLocation_Table) GetPath() string

func (*DataLocation_Table) GetSelectedCols 

func (x *DataLocation_Table) GetSelectedCols() []string

func (*DataLocation_Table) ProtoMessage 

func (*DataLocation_Table) ProtoMessage()

func (*DataLocation_Table) ProtoReflect 

func (x *DataLocation_Table) ProtoReflect() protoreflect.Message

func (*DataLocation_Table) Reset 

func (x *DataLocation_Table) Reset()

func (*DataLocation_Table) String 

func (x *DataLocation_Table) String() string

type FileMetaData 

type FileMetaData struct {

	// for debugging. furnace may provide a way to input this.
	AdditionalConfigs map[string]string     `` /* 200-byte string literal not displayed */
	FileType          FileMetaData_FileType `` /* 150-byte string literal not displayed */
	TableSelectedCols []string              `protobuf:"bytes,3,rep,name=table_selected_cols,json=tableSelectedCols,proto3" json:"table_selected_cols,omitempty"`
	// actually uint8
	CsvSeparator uint32 `protobuf:"varint,4,opt,name=csv_separator,json=csvSeparator,proto3" json:"csv_separator,omitempty"`
	// contains filtered or unexported fields
}

func (*FileMetaData) Descriptor deprecated 

func (*FileMetaData) Descriptor() ([]byte, []int)

Deprecated: Use FileMetaData.ProtoReflect.Descriptor instead.

func (*FileMetaData) GetAdditionalConfigs 

func (x *FileMetaData) GetAdditionalConfigs() map[string]string

func (*FileMetaData) GetCsvSeparator 

func (x *FileMetaData) GetCsvSeparator() uint32

func (*FileMetaData) GetFileType 

func (x *FileMetaData) GetFileType() FileMetaData_FileType

func (*FileMetaData) GetTableSelectedCols 

func (x *FileMetaData) GetTableSelectedCols() []string

func (*FileMetaData) ProtoMessage 

func (*FileMetaData) ProtoMessage()

func (*FileMetaData) ProtoReflect 

func (x *FileMetaData) ProtoReflect() protoreflect.Message

func (*FileMetaData) Reset 

func (x *FileMetaData) Reset()

func (*FileMetaData) String 

func (x *FileMetaData) String() string

type FileMetaData_FileType 

type FileMetaData_FileType int32
const (
	FileMetaData_Unspecified FileMetaData_FileType = 0
	FileMetaData_Csv         FileMetaData_FileType = 1 // Parquet = 2;
)

func (FileMetaData_FileType) Descriptor 

func (FileMetaData_FileType) Descriptor() protoreflect.EnumDescriptor

func (FileMetaData_FileType) Enum 

func (x FileMetaData_FileType) Enum() *FileMetaData_FileType

func (FileMetaData_FileType) EnumDescriptor deprecated 

func (FileMetaData_FileType) EnumDescriptor() ([]byte, []int)

Deprecated: Use FileMetaData_FileType.Descriptor instead.

func (FileMetaData_FileType) Number 

func (x FileMetaData_FileType) Number() protoreflect.EnumNumber

func (FileMetaData_FileType) String 

func (x FileMetaData_FileType) String() string

func (FileMetaData_FileType) Type 

func (FileMetaData_FileType) Type() protoreflect.EnumType

type FurnaceProperty 

type FurnaceProperty struct {
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// its datasrc id if type == upstream
	Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// upstream_info only useful if type == upstream,
	UpstreamInfo string `protobuf:"bytes,3,opt,name=upstream_info,json=upstreamInfo,proto3" json:"upstream_info,omitempty"`
	// selected columns in the vtable
	SelectedVtableCols []string `protobuf:"bytes,4,rep,name=selected_vtable_cols,json=selectedVtableCols,proto3" json:"selected_vtable_cols,omitempty"`
	// self-defining uri if type == datauri
	Datauri    string      `protobuf:"bytes,5,opt,name=datauri,proto3" json:"datauri,omitempty"`
	UpstreamV2 *UpstreamV2 `protobuf:"bytes,6,opt,name=upstream_v2,json=upstreamV2,proto3" json:"upstream_v2,omitempty"`
	// only useful when type == vtable and id == 0
	VtableWithPath *VtableWithPath `protobuf:"bytes,7,opt,name=vtable_with_path,json=vtableWithPath,proto3" json:"vtable_with_path,omitempty"`
	// contains filtered or unexported fields
}

func (*FurnaceProperty) Descriptor deprecated 

func (*FurnaceProperty) Descriptor() ([]byte, []int)

Deprecated: Use FurnaceProperty.ProtoReflect.Descriptor instead.

func (*FurnaceProperty) GetDatauri 

func (x *FurnaceProperty) GetDatauri() string

func (*FurnaceProperty) GetId 

func (x *FurnaceProperty) GetId() uint64

func (*FurnaceProperty) GetSelectedVtableCols 

func (x *FurnaceProperty) GetSelectedVtableCols() []string

func (*FurnaceProperty) GetType 

func (x *FurnaceProperty) GetType() string

func (*FurnaceProperty) GetUpstreamInfo 

func (x *FurnaceProperty) GetUpstreamInfo() string

func (*FurnaceProperty) GetUpstreamV2 

func (x *FurnaceProperty) GetUpstreamV2() *UpstreamV2

func (*FurnaceProperty) GetVtableWithPath 

func (x *FurnaceProperty) GetVtableWithPath() *VtableWithPath

func (*FurnaceProperty) ProtoMessage 

func (*FurnaceProperty) ProtoMessage()

func (*FurnaceProperty) ProtoReflect 

func (x *FurnaceProperty) ProtoReflect() protoreflect.Message

func (*FurnaceProperty) Reset 

func (x *FurnaceProperty) Reset()

func (*FurnaceProperty) String 

func (x *FurnaceProperty) String() string

type MetaData 

type MetaData struct {

	// for debugging. furnace may provide a way to input this.
	AdditionalConfigs map[string]string `` /* 200-byte string literal not displayed */
	FileType          MetaData_FileType `` /* 146-byte string literal not displayed */
	TableSelectedCols []string          `protobuf:"bytes,3,rep,name=table_selected_cols,json=tableSelectedCols,proto3" json:"table_selected_cols,omitempty"`
	// actually uint8
	// 0 means using comma
	CsvSeparator uint32 `protobuf:"varint,4,opt,name=csv_separator,json=csvSeparator,proto3" json:"csv_separator,omitempty"`
	// Do not try to guess a column's type
	// e.g. When reading csv, all columns' type will be string
	TableNoInferSchema bool `protobuf:"varint,5,opt,name=table_no_infer_schema,json=tableNoInferSchema,proto3" json:"table_no_infer_schema,omitempty"`
	// A (partial) schema to help determine column type
	// may not include all columns
	TableSchema map[string]*ColumnMetaData `` /* 182-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MetaData) Descriptor deprecated 

func (*MetaData) Descriptor() ([]byte, []int)

Deprecated: Use MetaData.ProtoReflect.Descriptor instead.

func (*MetaData) GetAdditionalConfigs 

func (x *MetaData) GetAdditionalConfigs() map[string]string

func (*MetaData) GetCsvSeparator 

func (x *MetaData) GetCsvSeparator() uint32

func (*MetaData) GetFileType 

func (x *MetaData) GetFileType() MetaData_FileType

func (*MetaData) GetTableNoInferSchema 

func (x *MetaData) GetTableNoInferSchema() bool

func (*MetaData) GetTableSchema 

func (x *MetaData) GetTableSchema() map[string]*ColumnMetaData

func (*MetaData) GetTableSelectedCols 

func (x *MetaData) GetTableSelectedCols() []string

func (*MetaData) ProtoMessage 

func (*MetaData) ProtoMessage()

func (*MetaData) ProtoReflect 

func (x *MetaData) ProtoReflect() protoreflect.Message

func (*MetaData) Reset 

func (x *MetaData) Reset()

func (*MetaData) String 

func (x *MetaData) String() string

type MetaData_FileType 

type MetaData_FileType int32
const (
	MetaData_Unspecified MetaData_FileType = 0
	MetaData_Csv         MetaData_FileType = 1 // Parquet = 2;
)

func (MetaData_FileType) Descriptor 

func (MetaData_FileType) Descriptor() protoreflect.EnumDescriptor

func (MetaData_FileType) Enum 

func (x MetaData_FileType) Enum() *MetaData_FileType

func (MetaData_FileType) EnumDescriptor deprecated 

func (MetaData_FileType) EnumDescriptor() ([]byte, []int)

Deprecated: Use MetaData_FileType.Descriptor instead.

func (MetaData_FileType) Number 

func (x MetaData_FileType) Number() protoreflect.EnumNumber

func (MetaData_FileType) String 

func (x MetaData_FileType) String() string

func (MetaData_FileType) Type 

func (MetaData_FileType) Type() protoreflect.EnumType

type UpstreamV2 

type UpstreamV2 struct {

	// id of each step，unique in canvas
	Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	// m-th party in current step
	InnerId uint64 `protobuf:"varint,2,opt,name=inner_id,json=innerId,proto3" json:"inner_id,omitempty"`
	// n-th key for current party
	Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// supplemented by back end: k-th execution of the step
	JobId uint64 `protobuf:"varint,4,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UpstreamV2) Descriptor deprecated 

func (*UpstreamV2) Descriptor() ([]byte, []int)

Deprecated: Use UpstreamV2.ProtoReflect.Descriptor instead.

func (*UpstreamV2) GetIndex 

func (x *UpstreamV2) GetIndex() uint64

func (*UpstreamV2) GetInnerId 

func (x *UpstreamV2) GetInnerId() uint64

func (*UpstreamV2) GetJobId 

func (x *UpstreamV2) GetJobId() uint64

func (*UpstreamV2) GetKey 

func (x *UpstreamV2) GetKey() string

func (*UpstreamV2) ProtoMessage 

func (*UpstreamV2) ProtoMessage()

func (*UpstreamV2) ProtoReflect 

func (x *UpstreamV2) ProtoReflect() protoreflect.Message

func (*UpstreamV2) Reset 

func (x *UpstreamV2) Reset()

func (*UpstreamV2) String 

func (x *UpstreamV2) String() string

type VtableWithPath 

type VtableWithPath struct {
	Path      string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Name      string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	DatasrcId uint64 `protobuf:"varint,3,opt,name=datasrc_id,json=datasrcId,proto3" json:"datasrc_id,omitempty"`
	// only useful when datasrc_id == 0
	DatasrcName string `protobuf:"bytes,4,opt,name=datasrc_name,json=datasrcName,proto3" json:"datasrc_name,omitempty"`
	// contains filtered or unexported fields
}

func (*VtableWithPath) Descriptor deprecated 

func (*VtableWithPath) Descriptor() ([]byte, []int)

Deprecated: Use VtableWithPath.ProtoReflect.Descriptor instead.

func (*VtableWithPath) GetDatasrcId 

func (x *VtableWithPath) GetDatasrcId() uint64

func (*VtableWithPath) GetDatasrcName 

func (x *VtableWithPath) GetDatasrcName() string

func (*VtableWithPath) GetName 

func (x *VtableWithPath) GetName() string

func (*VtableWithPath) GetPath 

func (x *VtableWithPath) GetPath() string

func (*VtableWithPath) ProtoMessage 

func (*VtableWithPath) ProtoMessage()

func (*VtableWithPath) ProtoReflect 

func (x *VtableWithPath) ProtoReflect() protoreflect.Message

func (*VtableWithPath) Reset 

func (x *VtableWithPath) Reset()

func (*VtableWithPath) String 

func (x *VtableWithPath) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.