spec

package
v0.0.0-...-94e6dd0 Latest Latest
Warning

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

 Go to latest Published: Apr 12, 2021 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	BatchEnsemblingJob_JobKind_name = map[int32]string{
		0: "BatchEnsemblingJob",
	}
	BatchEnsemblingJob_JobKind_value = map[string]int32{
		"BatchEnsemblingJob": 0,
	}
)

Enum value maps for BatchEnsemblingJob_JobKind.

View Source 
var (
	Dataset_DatasetType_name = map[int32]string{
		0: "BQ",
	}
	Dataset_DatasetType_value = map[string]int32{
		"BQ": 0,
	}
)

Enum value maps for Dataset_DatasetType.

View Source 
var (
	Ensembler_ResultType_name = map[int32]string{
		0:  "DOUBLE",
		1:  "FLOAT",
		2:  "INTEGER",
		3:  "LONG",
		4:  "STRING",
		10: "ARRAY",
	}
	Ensembler_ResultType_value = map[string]int32{
		"DOUBLE":  0,
		"FLOAT":   1,
		"INTEGER": 2,
		"LONG":    3,
		"STRING":  4,
		"ARRAY":   10,
	}
)

Enum value maps for Ensembler_ResultType.

View Source 
var (
	Sink_SinkType_name = map[int32]string{
		0: "CONSOLE",
		1: "BQ",
	}
	Sink_SinkType_value = map[string]int32{
		"CONSOLE": 0,
		"BQ":      1,
	}
)

Enum value maps for Sink_SinkType.

View Source 
var (
	Sink_SaveMode_name = map[int32]string{
		0: "ERRORIFEXISTS",
		1: "OVERWRITE",
		2: "APPEND",
		3: "IGNORE",
		4: "ERROR",
	}
	Sink_SaveMode_value = map[string]int32{
		"ERRORIFEXISTS": 0,
		"OVERWRITE":     1,
		"APPEND":        2,
		"IGNORE":        3,
		"ERROR":         4,
	}
)

Enum value maps for Sink_SaveMode.

View Source 
var File_api_proto_v1_batch_ensembling_job_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BatchEnsemblingJob 

type BatchEnsemblingJob struct {
	Version  string                      `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	Kind     BatchEnsemblingJob_JobKind  `protobuf:"varint,2,opt,name=kind,proto3,enum=turing.batch.spec.BatchEnsemblingJob_JobKind" json:"kind,omitempty"`
	Metadata *BatchEnsemblingJobMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Spec     *BatchEnsemblingJobSpec     `protobuf:"bytes,4,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchEnsemblingJob) Descriptor deprecated 

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

Deprecated: Use BatchEnsemblingJob.ProtoReflect.Descriptor instead.

func (*BatchEnsemblingJob) GetKind 

func (x *BatchEnsemblingJob) GetKind() BatchEnsemblingJob_JobKind

func (*BatchEnsemblingJob) GetMetadata 

func (x *BatchEnsemblingJob) GetMetadata() *BatchEnsemblingJobMetadata

func (*BatchEnsemblingJob) GetSpec 

func (x *BatchEnsemblingJob) GetSpec() *BatchEnsemblingJobSpec

func (*BatchEnsemblingJob) GetVersion 

func (x *BatchEnsemblingJob) GetVersion() string

func (*BatchEnsemblingJob) ProtoMessage 

func (*BatchEnsemblingJob) ProtoMessage()

func (*BatchEnsemblingJob) ProtoReflect 

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

func (*BatchEnsemblingJob) Reset 

func (x *BatchEnsemblingJob) Reset()

func (*BatchEnsemblingJob) String 

func (x *BatchEnsemblingJob) String() string

type BatchEnsemblingJobMetadata 

type BatchEnsemblingJobMetadata struct {
	Name        string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Annotations map[string]string `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*BatchEnsemblingJobMetadata) Descriptor deprecated 

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

Deprecated: Use BatchEnsemblingJobMetadata.ProtoReflect.Descriptor instead.

func (*BatchEnsemblingJobMetadata) GetAnnotations 

func (x *BatchEnsemblingJobMetadata) GetAnnotations() map[string]string

func (*BatchEnsemblingJobMetadata) GetName 

func (x *BatchEnsemblingJobMetadata) GetName() string

func (*BatchEnsemblingJobMetadata) ProtoMessage 

func (*BatchEnsemblingJobMetadata) ProtoMessage()

func (*BatchEnsemblingJobMetadata) ProtoReflect 

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

func (*BatchEnsemblingJobMetadata) Reset 

func (x *BatchEnsemblingJobMetadata) Reset()

func (*BatchEnsemblingJobMetadata) String 

func (x *BatchEnsemblingJobMetadata) String() string

type BatchEnsemblingJobSpec 

type BatchEnsemblingJobSpec struct {
	Source      *Source                      `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Predictions map[string]*PredictionSource `` /* 163-byte string literal not displayed */
	Ensembler   *Ensembler                   `protobuf:"bytes,3,opt,name=ensembler,proto3" json:"ensembler,omitempty"`
	Sink        *Sink                        `protobuf:"bytes,4,opt,name=sink,proto3" json:"sink,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchEnsemblingJobSpec) Descriptor deprecated 

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

Deprecated: Use BatchEnsemblingJobSpec.ProtoReflect.Descriptor instead.

func (*BatchEnsemblingJobSpec) GetEnsembler 

func (x *BatchEnsemblingJobSpec) GetEnsembler() *Ensembler

func (*BatchEnsemblingJobSpec) GetPredictions 

func (x *BatchEnsemblingJobSpec) GetPredictions() map[string]*PredictionSource

func (*BatchEnsemblingJobSpec) GetSink 

func (x *BatchEnsemblingJobSpec) GetSink() *Sink

func (*BatchEnsemblingJobSpec) GetSource 

func (x *BatchEnsemblingJobSpec) GetSource() *Source

func (*BatchEnsemblingJobSpec) ProtoMessage 

func (*BatchEnsemblingJobSpec) ProtoMessage()

func (*BatchEnsemblingJobSpec) ProtoReflect 

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

func (*BatchEnsemblingJobSpec) Reset 

func (x *BatchEnsemblingJobSpec) Reset()

func (*BatchEnsemblingJobSpec) String 

func (x *BatchEnsemblingJobSpec) String() string

type BatchEnsemblingJob_JobKind 

type BatchEnsemblingJob_JobKind int32
const (
	BatchEnsemblingJob_BatchEnsemblingJob BatchEnsemblingJob_JobKind = 0
)

func (BatchEnsemblingJob_JobKind) Descriptor 

func (BatchEnsemblingJob_JobKind) Descriptor() protoreflect.EnumDescriptor

func (BatchEnsemblingJob_JobKind) Enum 

func (x BatchEnsemblingJob_JobKind) Enum() *BatchEnsemblingJob_JobKind

func (BatchEnsemblingJob_JobKind) EnumDescriptor deprecated 

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

Deprecated: Use BatchEnsemblingJob_JobKind.Descriptor instead.

func (BatchEnsemblingJob_JobKind) Number 

func (x BatchEnsemblingJob_JobKind) Number() protoreflect.EnumNumber

func (BatchEnsemblingJob_JobKind) String 

func (x BatchEnsemblingJob_JobKind) String() string

func (BatchEnsemblingJob_JobKind) Type 

func (BatchEnsemblingJob_JobKind) Type() protoreflect.EnumType

type BigQuerySinkConfig 

type BigQuerySinkConfig struct {
	Table         string            `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	StagingBucket string            `protobuf:"bytes,2,opt,name=staging_bucket,json=stagingBucket,proto3" json:"staging_bucket,omitempty"`
	Options       map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*BigQuerySinkConfig) Descriptor deprecated 

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

Deprecated: Use BigQuerySinkConfig.ProtoReflect.Descriptor instead.

func (*BigQuerySinkConfig) GetOptions 

func (x *BigQuerySinkConfig) GetOptions() map[string]string

func (*BigQuerySinkConfig) GetStagingBucket 

func (x *BigQuerySinkConfig) GetStagingBucket() string

func (*BigQuerySinkConfig) GetTable 

func (x *BigQuerySinkConfig) GetTable() string

func (*BigQuerySinkConfig) ProtoMessage 

func (*BigQuerySinkConfig) ProtoMessage()

func (*BigQuerySinkConfig) ProtoReflect 

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

func (*BigQuerySinkConfig) Reset 

func (x *BigQuerySinkConfig) Reset()

func (*BigQuerySinkConfig) String 

func (x *BigQuerySinkConfig) String() string

type Dataset 

type Dataset struct {
	Type Dataset_DatasetType `protobuf:"varint,1,opt,name=type,proto3,enum=turing.batch.spec.Dataset_DatasetType" json:"type,omitempty"`
	// Types that are assignable to Config:
	//	*Dataset_BqConfig
	Config isDataset_Config `protobuf_oneof:"config"`
	// contains filtered or unexported fields
}

func (*Dataset) Descriptor deprecated 

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

Deprecated: Use Dataset.ProtoReflect.Descriptor instead.

func (*Dataset) GetBqConfig 

func (x *Dataset) GetBqConfig() *Dataset_BigQueryDatasetConfig

func (*Dataset) GetConfig 

func (m *Dataset) GetConfig() isDataset_Config

func (*Dataset) GetType 

func (x *Dataset) GetType() Dataset_DatasetType

func (*Dataset) ProtoMessage 

func (*Dataset) ProtoMessage()

func (*Dataset) ProtoReflect 

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

func (*Dataset) Reset 

func (x *Dataset) Reset()

func (*Dataset) String 

func (x *Dataset) String() string

type Dataset_BigQueryDatasetConfig 

type Dataset_BigQueryDatasetConfig struct {
	Table    string            `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	Features []string          `protobuf:"bytes,2,rep,name=features,proto3" json:"features,omitempty"`
	Query    string            `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
	Options  map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Dataset_BigQueryDatasetConfig) Descriptor deprecated 

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

Deprecated: Use Dataset_BigQueryDatasetConfig.ProtoReflect.Descriptor instead.

func (*Dataset_BigQueryDatasetConfig) GetFeatures 

func (x *Dataset_BigQueryDatasetConfig) GetFeatures() []string

func (*Dataset_BigQueryDatasetConfig) GetOptions 

func (x *Dataset_BigQueryDatasetConfig) GetOptions() map[string]string

func (*Dataset_BigQueryDatasetConfig) GetQuery 

func (x *Dataset_BigQueryDatasetConfig) GetQuery() string

func (*Dataset_BigQueryDatasetConfig) GetTable 

func (x *Dataset_BigQueryDatasetConfig) GetTable() string

func (*Dataset_BigQueryDatasetConfig) ProtoMessage 

func (*Dataset_BigQueryDatasetConfig) ProtoMessage()

func (*Dataset_BigQueryDatasetConfig) ProtoReflect 

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

func (*Dataset_BigQueryDatasetConfig) Reset 

func (x *Dataset_BigQueryDatasetConfig) Reset()

func (*Dataset_BigQueryDatasetConfig) String 

func (x *Dataset_BigQueryDatasetConfig) String() string

type Dataset_BqConfig 

type Dataset_BqConfig struct {
	BqConfig *Dataset_BigQueryDatasetConfig `protobuf:"bytes,2,opt,name=bq_config,json=bqConfig,proto3,oneof"`
}

type Dataset_DatasetType 

type Dataset_DatasetType int32
const (
	Dataset_BQ Dataset_DatasetType = 0
)

func (Dataset_DatasetType) Descriptor 

func (Dataset_DatasetType) Descriptor() protoreflect.EnumDescriptor

func (Dataset_DatasetType) Enum 

func (x Dataset_DatasetType) Enum() *Dataset_DatasetType

func (Dataset_DatasetType) EnumDescriptor deprecated 

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

Deprecated: Use Dataset_DatasetType.Descriptor instead.

func (Dataset_DatasetType) Number 

func (x Dataset_DatasetType) Number() protoreflect.EnumNumber

func (Dataset_DatasetType) String 

func (x Dataset_DatasetType) String() string

func (Dataset_DatasetType) Type 

func (Dataset_DatasetType) Type() protoreflect.EnumType

type Ensembler 

type Ensembler struct {
	Uri    string            `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	Result *Ensembler_Result `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*Ensembler) Descriptor deprecated 

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

Deprecated: Use Ensembler.ProtoReflect.Descriptor instead.

func (*Ensembler) GetResult 

func (x *Ensembler) GetResult() *Ensembler_Result

func (*Ensembler) GetUri 

func (x *Ensembler) GetUri() string

func (*Ensembler) ProtoMessage 

func (*Ensembler) ProtoMessage()

func (*Ensembler) ProtoReflect 

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

func (*Ensembler) Reset 

func (x *Ensembler) Reset()

func (*Ensembler) String 

func (x *Ensembler) String() string

type Ensembler_Result 

type Ensembler_Result struct {
	ColumnName string               `protobuf:"bytes,1,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
	Type       Ensembler_ResultType `protobuf:"varint,2,opt,name=type,proto3,enum=turing.batch.spec.Ensembler_ResultType" json:"type,omitempty"`
	// only if type is array
	ItemType Ensembler_ResultType `` /* 130-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Ensembler_Result) Descriptor deprecated 

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

Deprecated: Use Ensembler_Result.ProtoReflect.Descriptor instead.

func (*Ensembler_Result) GetColumnName 

func (x *Ensembler_Result) GetColumnName() string

func (*Ensembler_Result) GetItemType 

func (x *Ensembler_Result) GetItemType() Ensembler_ResultType

func (*Ensembler_Result) GetType 

func (x *Ensembler_Result) GetType() Ensembler_ResultType

func (*Ensembler_Result) ProtoMessage 

func (*Ensembler_Result) ProtoMessage()

func (*Ensembler_Result) ProtoReflect 

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

func (*Ensembler_Result) Reset 

func (x *Ensembler_Result) Reset()

func (*Ensembler_Result) String 

func (x *Ensembler_Result) String() string

type Ensembler_ResultType 

type Ensembler_ResultType int32
const (
	Ensembler_DOUBLE  Ensembler_ResultType = 0
	Ensembler_FLOAT   Ensembler_ResultType = 1
	Ensembler_INTEGER Ensembler_ResultType = 2
	Ensembler_LONG    Ensembler_ResultType = 3
	Ensembler_STRING  Ensembler_ResultType = 4
	Ensembler_ARRAY   Ensembler_ResultType = 10
)

func (Ensembler_ResultType) Descriptor 

func (Ensembler_ResultType) Descriptor() protoreflect.EnumDescriptor

func (Ensembler_ResultType) Enum 

func (x Ensembler_ResultType) Enum() *Ensembler_ResultType

func (Ensembler_ResultType) EnumDescriptor deprecated 

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

Deprecated: Use Ensembler_ResultType.Descriptor instead.

func (Ensembler_ResultType) Number 

func (x Ensembler_ResultType) Number() protoreflect.EnumNumber

func (Ensembler_ResultType) String 

func (x Ensembler_ResultType) String() string

func (Ensembler_ResultType) Type 

func (Ensembler_ResultType) Type() protoreflect.EnumType

type PredictionSource 

type PredictionSource struct {
	Dataset *Dataset `protobuf:"bytes,1,opt,name=dataset,proto3" json:"dataset,omitempty"`
	JoinOn  []string `protobuf:"bytes,2,rep,name=join_on,json=joinOn,proto3" json:"join_on,omitempty"`
	Columns []string `protobuf:"bytes,3,rep,name=columns,proto3" json:"columns,omitempty"`
	// contains filtered or unexported fields
}

func (*PredictionSource) Descriptor deprecated 

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

Deprecated: Use PredictionSource.ProtoReflect.Descriptor instead.

func (*PredictionSource) GetColumns 

func (x *PredictionSource) GetColumns() []string

func (*PredictionSource) GetDataset 

func (x *PredictionSource) GetDataset() *Dataset

func (*PredictionSource) GetJoinOn 

func (x *PredictionSource) GetJoinOn() []string

func (*PredictionSource) ProtoMessage 

func (*PredictionSource) ProtoMessage()

func (*PredictionSource) ProtoReflect 

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

func (*PredictionSource) Reset 

func (x *PredictionSource) Reset()

func (*PredictionSource) String 

func (x *PredictionSource) String() string

type Sink 

type Sink struct {
	Type     Sink_SinkType `protobuf:"varint,1,opt,name=type,proto3,enum=turing.batch.spec.Sink_SinkType" json:"type,omitempty"`
	Columns  []string      `protobuf:"bytes,2,rep,name=columns,proto3" json:"columns,omitempty"`
	SaveMode Sink_SaveMode `protobuf:"varint,3,opt,name=save_mode,json=saveMode,proto3,enum=turing.batch.spec.Sink_SaveMode" json:"save_mode,omitempty"`
	// Types that are assignable to Config:
	//	*Sink_BqConfig
	Config isSink_Config `protobuf_oneof:"config"`
	// contains filtered or unexported fields
}

func (*Sink) Descriptor deprecated 

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

Deprecated: Use Sink.ProtoReflect.Descriptor instead.

func (*Sink) GetBqConfig 

func (x *Sink) GetBqConfig() *BigQuerySinkConfig

func (*Sink) GetColumns 

func (x *Sink) GetColumns() []string

func (*Sink) GetConfig 

func (m *Sink) GetConfig() isSink_Config

func (*Sink) GetSaveMode 

func (x *Sink) GetSaveMode() Sink_SaveMode

func (*Sink) GetType 

func (x *Sink) GetType() Sink_SinkType

func (*Sink) ProtoMessage 

func (*Sink) ProtoMessage()

func (*Sink) ProtoReflect 

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

func (*Sink) Reset 

func (x *Sink) Reset()

func (*Sink) String 

func (x *Sink) String() string

type Sink_BqConfig 

type Sink_BqConfig struct {
	BqConfig *BigQuerySinkConfig `protobuf:"bytes,10,opt,name=bq_config,json=bqConfig,proto3,oneof"`
}

type Sink_SaveMode 

type Sink_SaveMode int32
const (
	Sink_ERRORIFEXISTS Sink_SaveMode = 0
	Sink_OVERWRITE     Sink_SaveMode = 1
	Sink_APPEND        Sink_SaveMode = 2
	Sink_IGNORE        Sink_SaveMode = 3
	Sink_ERROR         Sink_SaveMode = 4
)

func (Sink_SaveMode) Descriptor 

func (Sink_SaveMode) Descriptor() protoreflect.EnumDescriptor

func (Sink_SaveMode) Enum 

func (x Sink_SaveMode) Enum() *Sink_SaveMode

func (Sink_SaveMode) EnumDescriptor deprecated 

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

Deprecated: Use Sink_SaveMode.Descriptor instead.

func (Sink_SaveMode) Number 

func (x Sink_SaveMode) Number() protoreflect.EnumNumber

func (Sink_SaveMode) String 

func (x Sink_SaveMode) String() string

func (Sink_SaveMode) Type 

func (Sink_SaveMode) Type() protoreflect.EnumType

type Sink_SinkType 

type Sink_SinkType int32
const (
	Sink_CONSOLE Sink_SinkType = 0
	Sink_BQ      Sink_SinkType = 1
)

func (Sink_SinkType) Descriptor 

func (Sink_SinkType) Descriptor() protoreflect.EnumDescriptor

func (Sink_SinkType) Enum 

func (x Sink_SinkType) Enum() *Sink_SinkType

func (Sink_SinkType) EnumDescriptor deprecated 

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

Deprecated: Use Sink_SinkType.Descriptor instead.

func (Sink_SinkType) Number 

func (x Sink_SinkType) Number() protoreflect.EnumNumber

func (Sink_SinkType) String 

func (x Sink_SinkType) String() string

func (Sink_SinkType) Type 

func (Sink_SinkType) Type() protoreflect.EnumType

type Source 

type Source struct {
	Dataset *Dataset `protobuf:"bytes,1,opt,name=dataset,proto3" json:"dataset,omitempty"`
	JoinOn  []string `protobuf:"bytes,2,rep,name=join_on,json=joinOn,proto3" json:"join_on,omitempty"`
	// contains filtered or unexported fields
}

func (*Source) Descriptor deprecated 

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

Deprecated: Use Source.ProtoReflect.Descriptor instead.

func (*Source) GetDataset 

func (x *Source) GetDataset() *Dataset

func (*Source) GetJoinOn 

func (x *Source) GetJoinOn() []string

func (*Source) ProtoMessage 

func (*Source) ProtoMessage()

func (*Source) ProtoReflect 

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

func (*Source) Reset 

func (x *Source) Reset()

func (*Source) String 

func (x *Source) 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.