pipeline_v1

package
Version: v2.25.0+incompatible Latest Latest
Warning

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

Go to latest
Published: Oct 20, 2020 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var AccumulationMode_Enum_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "DISCARDING",
	2: "ACCUMULATING",
	3: "RETRACTING",
}
View Source
var AccumulationMode_Enum_value = map[string]int32{
	"UNSPECIFIED":  0,
	"DISCARDING":   1,
	"ACCUMULATING": 2,
	"RETRACTING":   3,
}
View Source
var AtomicType_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "BYTE",
	2: "INT16",
	3: "INT32",
	4: "INT64",
	5: "FLOAT",
	6: "DOUBLE",
	7: "STRING",
	8: "BOOLEAN",
	9: "BYTES",
}
View Source
var AtomicType_value = map[string]int32{
	"UNSPECIFIED": 0,
	"BYTE":        1,
	"INT16":       2,
	"INT32":       3,
	"INT64":       4,
	"FLOAT":       5,
	"DOUBLE":      6,
	"STRING":      7,
	"BOOLEAN":     8,
	"BYTES":       9,
}
View Source
var BeamConstants_Constants_name = map[int32]string{
	0: "MIN_TIMESTAMP_MILLIS",
	1: "MAX_TIMESTAMP_MILLIS",
	2: "GLOBAL_WINDOW_MAX_TIMESTAMP_MILLIS",
}
View Source
var BeamConstants_Constants_value = map[string]int32{
	"MIN_TIMESTAMP_MILLIS":               0,
	"MAX_TIMESTAMP_MILLIS":               1,
	"GLOBAL_WINDOW_MAX_TIMESTAMP_MILLIS": 2,
}
View Source
var ClosingBehavior_Enum_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "EMIT_ALWAYS",
	2: "EMIT_IF_NONEMPTY",
}
View Source
var ClosingBehavior_Enum_value = map[string]int32{
	"UNSPECIFIED":      0,
	"EMIT_ALWAYS":      1,
	"EMIT_IF_NONEMPTY": 2,
}
View Source
var E_BeamConstant = &proto.ExtensionDesc{
	ExtendedType:  (*descriptor.EnumValueOptions)(nil),
	ExtensionType: (*string)(nil),
	Field:         185324357,
	Name:          "org.apache.beam.model.pipeline.v1.beam_constant",
	Tag:           "bytes,185324357,opt,name=beam_constant",
	Filename:      "beam_runner_api.proto",
}
View Source
var E_BeamUrn = &proto.ExtensionDesc{
	ExtendedType:  (*descriptor.EnumValueOptions)(nil),
	ExtensionType: (*string)(nil),
	Field:         185324356,
	Name:          "org.apache.beam.model.pipeline.v1.beam_urn",
	Tag:           "bytes,185324356,opt,name=beam_urn",
	Filename:      "beam_runner_api.proto",
}
View Source
var E_LabelProps = &proto.ExtensionDesc{
	ExtendedType:  (*descriptor.EnumValueOptions)(nil),
	ExtensionType: (*MonitoringInfoLabelProps)(nil),
	Field:         127337796,
	Name:          "org.apache.beam.model.pipeline.v1.label_props",
	Tag:           "bytes,127337796,opt,name=label_props",
	Filename:      "metrics.proto",
}
View Source
var E_MonitoringInfoSpec = &proto.ExtensionDesc{
	ExtendedType:  (*descriptor.EnumValueOptions)(nil),
	ExtensionType: (*MonitoringInfoSpec)(nil),
	Field:         207174266,
	Name:          "org.apache.beam.model.pipeline.v1.monitoring_info_spec",
	Tag:           "bytes,207174266,opt,name=monitoring_info_spec",
	Filename:      "metrics.proto",
}
View Source
var FixedWindowsPayload_Enum_name = map[int32]string{
	0: "PROPERTIES",
}
View Source
var FixedWindowsPayload_Enum_value = map[string]int32{
	"PROPERTIES": 0,
}
View Source
var GlobalWindowsPayload_Enum_name = map[int32]string{
	0: "PROPERTIES",
}
View Source
var GlobalWindowsPayload_Enum_value = map[string]int32{
	"PROPERTIES": 0,
}
View Source
var IsBounded_Enum_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "UNBOUNDED",
	2: "BOUNDED",
}
View Source
var IsBounded_Enum_value = map[string]int32{
	"UNSPECIFIED": 0,
	"UNBOUNDED":   1,
	"BOUNDED":     2,
}
View Source
var MergeStatus_Enum_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "NON_MERGING",
	2: "NEEDS_MERGE",
	3: "ALREADY_MERGED",
}
View Source
var MergeStatus_Enum_value = map[string]int32{
	"UNSPECIFIED":    0,
	"NON_MERGING":    1,
	"NEEDS_MERGE":    2,
	"ALREADY_MERGED": 3,
}
View Source
var MonitoringInfoSpecs_Enum_name = map[int32]string{
	0:  "USER_SUM_INT64",
	1:  "USER_SUM_DOUBLE",
	2:  "USER_DISTRIBUTION_INT64",
	3:  "USER_DISTRIBUTION_DOUBLE",
	4:  "USER_LATEST_INT64",
	5:  "USER_LATEST_DOUBLE",
	6:  "USER_TOP_N_INT64",
	7:  "USER_TOP_N_DOUBLE",
	8:  "USER_BOTTOM_N_INT64",
	9:  "USER_BOTTOM_N_DOUBLE",
	10: "ELEMENT_COUNT",
	11: "SAMPLED_BYTE_SIZE",
	12: "START_BUNDLE_MSECS",
	13: "PROCESS_BUNDLE_MSECS",
	14: "FINISH_BUNDLE_MSECS",
	15: "TOTAL_MSECS",
	16: "WORK_REMAINING",
	17: "WORK_COMPLETED",
	18: "DATA_CHANNEL_READ_INDEX",
}
View Source
var MonitoringInfoSpecs_Enum_value = map[string]int32{
	"USER_SUM_INT64":           0,
	"USER_SUM_DOUBLE":          1,
	"USER_DISTRIBUTION_INT64":  2,
	"USER_DISTRIBUTION_DOUBLE": 3,
	"USER_LATEST_INT64":        4,
	"USER_LATEST_DOUBLE":       5,
	"USER_TOP_N_INT64":         6,
	"USER_TOP_N_DOUBLE":        7,
	"USER_BOTTOM_N_INT64":      8,
	"USER_BOTTOM_N_DOUBLE":     9,
	"ELEMENT_COUNT":            10,
	"SAMPLED_BYTE_SIZE":        11,
	"START_BUNDLE_MSECS":       12,
	"PROCESS_BUNDLE_MSECS":     13,
	"FINISH_BUNDLE_MSECS":      14,
	"TOTAL_MSECS":              15,
	"WORK_REMAINING":           16,
	"WORK_COMPLETED":           17,
	"DATA_CHANNEL_READ_INDEX":  18,
}
View Source
var MonitoringInfoTypeUrns_Enum_name = map[int32]string{
	0:  "SUM_INT64_TYPE",
	1:  "SUM_DOUBLE_TYPE",
	2:  "DISTRIBUTION_INT64_TYPE",
	3:  "DISTRIBUTION_DOUBLE_TYPE",
	4:  "LATEST_INT64_TYPE",
	5:  "LATEST_DOUBLE_TYPE",
	6:  "TOP_N_INT64_TYPE",
	7:  "TOP_N_DOUBLE_TYPE",
	8:  "BOTTOM_N_INT64_TYPE",
	9:  "BOTTOM_N_DOUBLE_TYPE",
	10: "PROGRESS_TYPE",
}
View Source
var MonitoringInfoTypeUrns_Enum_value = map[string]int32{
	"SUM_INT64_TYPE":           0,
	"SUM_DOUBLE_TYPE":          1,
	"DISTRIBUTION_INT64_TYPE":  2,
	"DISTRIBUTION_DOUBLE_TYPE": 3,
	"LATEST_INT64_TYPE":        4,
	"LATEST_DOUBLE_TYPE":       5,
	"TOP_N_INT64_TYPE":         6,
	"TOP_N_DOUBLE_TYPE":        7,
	"BOTTOM_N_INT64_TYPE":      8,
	"BOTTOM_N_DOUBLE_TYPE":     9,
	"PROGRESS_TYPE":            10,
}
View Source
var MonitoringInfo_MonitoringInfoLabels_name = map[int32]string{
	0: "TRANSFORM",
	1: "PCOLLECTION",
	2: "WINDOWING_STRATEGY",
	3: "CODER",
	4: "ENVIRONMENT",
	5: "NAMESPACE",
	6: "NAME",
}
View Source
var MonitoringInfo_MonitoringInfoLabels_value = map[string]int32{
	"TRANSFORM":          0,
	"PCOLLECTION":        1,
	"WINDOWING_STRATEGY": 2,
	"CODER":              3,
	"ENVIRONMENT":        4,
	"NAMESPACE":          5,
	"NAME":               6,
}
View Source
var OnTimeBehavior_Enum_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "FIRE_ALWAYS",
	2: "FIRE_IF_NONEMPTY",
}
View Source
var OnTimeBehavior_Enum_value = map[string]int32{
	"UNSPECIFIED":      0,
	"FIRE_ALWAYS":      1,
	"FIRE_IF_NONEMPTY": 2,
}
View Source
var OutputTime_Enum_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "END_OF_WINDOW",
	2: "LATEST_IN_PANE",
	3: "EARLIEST_IN_PANE",
}
View Source
var OutputTime_Enum_value = map[string]int32{
	"UNSPECIFIED":      0,
	"END_OF_WINDOW":    1,
	"LATEST_IN_PANE":   2,
	"EARLIEST_IN_PANE": 3,
}
View Source
var SessionWindowsPayload_Enum_name = map[int32]string{
	0: "PROPERTIES",
}
View Source
var SessionWindowsPayload_Enum_value = map[string]int32{
	"PROPERTIES": 0,
}
View Source
var SlidingWindowsPayload_Enum_name = map[int32]string{
	0: "PROPERTIES",
}
View Source
var SlidingWindowsPayload_Enum_value = map[string]int32{
	"PROPERTIES": 0,
}
View Source
var StandardArtifacts_Roles_name = map[int32]string{
	0: "STAGING_TO",
}
View Source
var StandardArtifacts_Roles_value = map[string]int32{
	"STAGING_TO": 0,
}
View Source
var StandardArtifacts_Types_name = map[int32]string{
	0: "FILE",
	1: "URL",
	2: "EMBEDDED",
	3: "PYPI",
	4: "MAVEN",
	5: "DEFERRED",
}
View Source
var StandardArtifacts_Types_value = map[string]int32{
	"FILE":     0,
	"URL":      1,
	"EMBEDDED": 2,
	"PYPI":     3,
	"MAVEN":    4,
	"DEFERRED": 5,
}
View Source
var StandardCoders_Enum_name = map[int32]string{
	0:  "BYTES",
	10: "STRING_UTF8",
	1:  "KV",
	12: "BOOL",
	2:  "VARINT",
	11: "DOUBLE",
	3:  "ITERABLE",
	4:  "TIMER",
	5:  "INTERVAL_WINDOW",
	6:  "LENGTH_PREFIX",
	7:  "GLOBAL_WINDOW",
	8:  "WINDOWED_VALUE",
	14: "PARAM_WINDOWED_VALUE",
	9:  "STATE_BACKED_ITERABLE",
	13: "ROW",
}
View Source
var StandardCoders_Enum_value = map[string]int32{
	"BYTES":                 0,
	"STRING_UTF8":           10,
	"KV":                    1,
	"BOOL":                  12,
	"VARINT":                2,
	"DOUBLE":                11,
	"ITERABLE":              3,
	"TIMER":                 4,
	"INTERVAL_WINDOW":       5,
	"LENGTH_PREFIX":         6,
	"GLOBAL_WINDOW":         7,
	"WINDOWED_VALUE":        8,
	"PARAM_WINDOWED_VALUE":  14,
	"STATE_BACKED_ITERABLE": 9,
	"ROW":                   13,
}
View Source
var StandardDisplayData_DisplayData_name = map[int32]string{
	0: "LABELLED_STRING",
}
View Source
var StandardDisplayData_DisplayData_value = map[string]int32{
	"LABELLED_STRING": 0,
}
View Source
var StandardEnvironments_Environments_name = map[int32]string{
	0: "DOCKER",
	1: "PROCESS",
	2: "EXTERNAL",
}
View Source
var StandardEnvironments_Environments_value = map[string]int32{
	"DOCKER":   0,
	"PROCESS":  1,
	"EXTERNAL": 2,
}
View Source
var StandardPTransforms_CombineComponents_name = map[int32]string{
	0: "COMBINE_PER_KEY_PRECOMBINE",
	1: "COMBINE_PER_KEY_MERGE_ACCUMULATORS",
	2: "COMBINE_PER_KEY_EXTRACT_OUTPUTS",
	3: "COMBINE_GROUPED_VALUES",
	4: "COMBINE_PER_KEY_CONVERT_TO_ACCUMULATORS",
}
View Source
var StandardPTransforms_CombineComponents_value = map[string]int32{
	"COMBINE_PER_KEY_PRECOMBINE":              0,
	"COMBINE_PER_KEY_MERGE_ACCUMULATORS":      1,
	"COMBINE_PER_KEY_EXTRACT_OUTPUTS":         2,
	"COMBINE_GROUPED_VALUES":                  3,
	"COMBINE_PER_KEY_CONVERT_TO_ACCUMULATORS": 4,
}
View Source
var StandardPTransforms_Composites_name = map[int32]string{
	0: "COMBINE_PER_KEY",
	1: "COMBINE_GLOBALLY",
	2: "RESHUFFLE",
	3: "WRITE_FILES",
}
View Source
var StandardPTransforms_Composites_value = map[string]int32{
	"COMBINE_PER_KEY":  0,
	"COMBINE_GLOBALLY": 1,
	"RESHUFFLE":        2,
	"WRITE_FILES":      3,
}
View Source
var StandardPTransforms_DeprecatedPrimitives_name = map[int32]string{
	0: "READ",
	1: "CREATE_VIEW",
}
View Source
var StandardPTransforms_DeprecatedPrimitives_value = map[string]int32{
	"READ":        0,
	"CREATE_VIEW": 1,
}
View Source
var StandardPTransforms_Primitives_name = map[int32]string{
	0: "PAR_DO",
	1: "FLATTEN",
	2: "GROUP_BY_KEY",
	3: "IMPULSE",
	4: "ASSIGN_WINDOWS",
	5: "TEST_STREAM",
	6: "MAP_WINDOWS",
	7: "MERGE_WINDOWS",
}
View Source
var StandardPTransforms_Primitives_value = map[string]int32{
	"PAR_DO":         0,
	"FLATTEN":        1,
	"GROUP_BY_KEY":   2,
	"IMPULSE":        3,
	"ASSIGN_WINDOWS": 4,
	"TEST_STREAM":    5,
	"MAP_WINDOWS":    6,
	"MERGE_WINDOWS":  7,
}
View Source
var StandardPTransforms_SplittableParDoComponents_name = map[int32]string{
	0: "PAIR_WITH_RESTRICTION",
	1: "SPLIT_RESTRICTION",
	2: "PROCESS_KEYED_ELEMENTS",
	3: "PROCESS_ELEMENTS",
	4: "SPLIT_AND_SIZE_RESTRICTIONS",
	5: "PROCESS_SIZED_ELEMENTS_AND_RESTRICTIONS",
}
View Source
var StandardPTransforms_SplittableParDoComponents_value = map[string]int32{
	"PAIR_WITH_RESTRICTION":                   0,
	"SPLIT_RESTRICTION":                       1,
	"PROCESS_KEYED_ELEMENTS":                  2,
	"PROCESS_ELEMENTS":                        3,
	"SPLIT_AND_SIZE_RESTRICTIONS":             4,
	"PROCESS_SIZED_ELEMENTS_AND_RESTRICTIONS": 5,
}
View Source
var StandardProtocols_Enum_name = map[int32]string{
	0: "LEGACY_PROGRESS_REPORTING",
	1: "PROGRESS_REPORTING",
	2: "WORKER_STATUS",
	3: "MULTI_CORE_BUNDLE_PROCESSING",
}
View Source
var StandardProtocols_Enum_value = map[string]int32{
	"LEGACY_PROGRESS_REPORTING":    0,
	"PROGRESS_REPORTING":           1,
	"WORKER_STATUS":                2,
	"MULTI_CORE_BUNDLE_PROCESSING": 3,
}
View Source
var StandardRequirements_Enum_name = map[int32]string{
	0: "REQUIRES_STATEFUL_PROCESSING",
	1: "REQUIRES_BUNDLE_FINALIZATION",
	2: "REQUIRES_STABLE_INPUT",
	3: "REQUIRES_TIME_SORTED_INPUT",
	4: "REQUIRES_SPLITTABLE_DOFN",
}
View Source
var StandardRequirements_Enum_value = map[string]int32{
	"REQUIRES_STATEFUL_PROCESSING": 0,
	"REQUIRES_BUNDLE_FINALIZATION": 1,
	"REQUIRES_STABLE_INPUT":        2,
	"REQUIRES_TIME_SORTED_INPUT":   3,
	"REQUIRES_SPLITTABLE_DOFN":     4,
}
View Source
var StandardSideInputTypes_Enum_name = map[int32]string{
	0: "ITERABLE",
	1: "MULTIMAP",
}
View Source
var StandardSideInputTypes_Enum_value = map[string]int32{
	"ITERABLE": 0,
	"MULTIMAP": 1,
}
View Source
var TimeDomain_Enum_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "EVENT_TIME",
	2: "PROCESSING_TIME",
	3: "SYNCHRONIZED_PROCESSING_TIME",
}
View Source
var TimeDomain_Enum_value = map[string]int32{
	"UNSPECIFIED":                  0,
	"EVENT_TIME":                   1,
	"PROCESSING_TIME":              2,
	"SYNCHRONIZED_PROCESSING_TIME": 3,
}

Functions

func RegisterTestStreamServiceServer

func RegisterTestStreamServiceServer(s *grpc.Server, srv TestStreamServiceServer)

Types

type AccumulationMode

type AccumulationMode struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Whether or not subsequent outputs of aggregations should be entire replacement values or just the aggregation of inputs received since the prior output.

func (*AccumulationMode) Descriptor

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

func (*AccumulationMode) ProtoMessage

func (*AccumulationMode) ProtoMessage()

func (*AccumulationMode) Reset

func (m *AccumulationMode) Reset()

func (*AccumulationMode) String

func (m *AccumulationMode) String() string

func (*AccumulationMode) XXX_DiscardUnknown

func (m *AccumulationMode) XXX_DiscardUnknown()

func (*AccumulationMode) XXX_Marshal

func (m *AccumulationMode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AccumulationMode) XXX_Merge

func (m *AccumulationMode) XXX_Merge(src proto.Message)

func (*AccumulationMode) XXX_Size

func (m *AccumulationMode) XXX_Size() int

func (*AccumulationMode) XXX_Unmarshal

func (m *AccumulationMode) XXX_Unmarshal(b []byte) error

type AccumulationMode_Enum

type AccumulationMode_Enum int32
const (
	AccumulationMode_UNSPECIFIED AccumulationMode_Enum = 0
	// The aggregation is discarded when it is output
	AccumulationMode_DISCARDING AccumulationMode_Enum = 1
	// The aggregation is accumulated across outputs
	AccumulationMode_ACCUMULATING AccumulationMode_Enum = 2
	// The aggregation emits retractions when it is output
	AccumulationMode_RETRACTING AccumulationMode_Enum = 3
)

func (AccumulationMode_Enum) EnumDescriptor

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

func (AccumulationMode_Enum) String

func (x AccumulationMode_Enum) String() string

type Annotation

type Annotation struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The key name and value string of MonitoringInfo annotations.

func (*Annotation) Descriptor

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

func (*Annotation) GetKey

func (m *Annotation) GetKey() string

func (*Annotation) GetValue

func (m *Annotation) GetValue() string

func (*Annotation) ProtoMessage

func (*Annotation) ProtoMessage()

func (*Annotation) Reset

func (m *Annotation) Reset()

func (*Annotation) String

func (m *Annotation) String() string

func (*Annotation) XXX_DiscardUnknown

func (m *Annotation) XXX_DiscardUnknown()

func (*Annotation) XXX_Marshal

func (m *Annotation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Annotation) XXX_Merge

func (m *Annotation) XXX_Merge(src proto.Message)

func (*Annotation) XXX_Size

func (m *Annotation) XXX_Size() int

func (*Annotation) XXX_Unmarshal

func (m *Annotation) XXX_Unmarshal(b []byte) error

type ApiServiceDescriptor

type ApiServiceDescriptor struct {
	// (Required) The URL to connect to.
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// (Optional) The method for authentication. If unspecified, access to the
	// url is already being performed in a trusted context (e.g. localhost,
	// private network).
	Authentication       *AuthenticationSpec `protobuf:"bytes,2,opt,name=authentication,proto3" json:"authentication,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

A description of how to connect to a Beam API endpoint.

func (*ApiServiceDescriptor) Descriptor

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

func (*ApiServiceDescriptor) GetAuthentication

func (m *ApiServiceDescriptor) GetAuthentication() *AuthenticationSpec

func (*ApiServiceDescriptor) GetUrl

func (m *ApiServiceDescriptor) GetUrl() string

func (*ApiServiceDescriptor) ProtoMessage

func (*ApiServiceDescriptor) ProtoMessage()

func (*ApiServiceDescriptor) Reset

func (m *ApiServiceDescriptor) Reset()

func (*ApiServiceDescriptor) String

func (m *ApiServiceDescriptor) String() string

func (*ApiServiceDescriptor) XXX_DiscardUnknown

func (m *ApiServiceDescriptor) XXX_DiscardUnknown()

func (*ApiServiceDescriptor) XXX_Marshal

func (m *ApiServiceDescriptor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ApiServiceDescriptor) XXX_Merge

func (m *ApiServiceDescriptor) XXX_Merge(src proto.Message)

func (*ApiServiceDescriptor) XXX_Size

func (m *ApiServiceDescriptor) XXX_Size() int

func (*ApiServiceDescriptor) XXX_Unmarshal

func (m *ApiServiceDescriptor) XXX_Unmarshal(b []byte) error

type ArrayType

type ArrayType struct {
	ElementType          *FieldType `protobuf:"bytes,1,opt,name=element_type,json=elementType,proto3" json:"element_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*ArrayType) Descriptor

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

func (*ArrayType) GetElementType

func (m *ArrayType) GetElementType() *FieldType

func (*ArrayType) ProtoMessage

func (*ArrayType) ProtoMessage()

func (*ArrayType) Reset

func (m *ArrayType) Reset()

func (*ArrayType) String

func (m *ArrayType) String() string

func (*ArrayType) XXX_DiscardUnknown

func (m *ArrayType) XXX_DiscardUnknown()

func (*ArrayType) XXX_Marshal

func (m *ArrayType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ArrayType) XXX_Merge

func (m *ArrayType) XXX_Merge(src proto.Message)

func (*ArrayType) XXX_Size

func (m *ArrayType) XXX_Size() int

func (*ArrayType) XXX_Unmarshal

func (m *ArrayType) XXX_Unmarshal(b []byte) error

type ArrayTypeValue

type ArrayTypeValue struct {
	Element              []*FieldValue `protobuf:"bytes,1,rep,name=element,proto3" json:"element,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ArrayTypeValue) Descriptor

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

func (*ArrayTypeValue) GetElement

func (m *ArrayTypeValue) GetElement() []*FieldValue

func (*ArrayTypeValue) ProtoMessage

func (*ArrayTypeValue) ProtoMessage()

func (*ArrayTypeValue) Reset

func (m *ArrayTypeValue) Reset()

func (*ArrayTypeValue) String

func (m *ArrayTypeValue) String() string

func (*ArrayTypeValue) XXX_DiscardUnknown

func (m *ArrayTypeValue) XXX_DiscardUnknown()

func (*ArrayTypeValue) XXX_Marshal

func (m *ArrayTypeValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ArrayTypeValue) XXX_Merge

func (m *ArrayTypeValue) XXX_Merge(src proto.Message)

func (*ArrayTypeValue) XXX_Size

func (m *ArrayTypeValue) XXX_Size() int

func (*ArrayTypeValue) XXX_Unmarshal

func (m *ArrayTypeValue) XXX_Unmarshal(b []byte) error

type ArtifactFilePayload

type ArtifactFilePayload struct {
	// a string for an artifact file path e.g. "/tmp/foo.jar"
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// The hex-encoded sha256 checksum of the artifact.
	Sha256               string   `protobuf:"bytes,2,opt,name=sha256,proto3" json:"sha256,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ArtifactFilePayload) Descriptor

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

func (*ArtifactFilePayload) GetPath

func (m *ArtifactFilePayload) GetPath() string

func (*ArtifactFilePayload) GetSha256

func (m *ArtifactFilePayload) GetSha256() string

func (*ArtifactFilePayload) ProtoMessage

func (*ArtifactFilePayload) ProtoMessage()

func (*ArtifactFilePayload) Reset

func (m *ArtifactFilePayload) Reset()

func (*ArtifactFilePayload) String

func (m *ArtifactFilePayload) String() string

func (*ArtifactFilePayload) XXX_DiscardUnknown

func (m *ArtifactFilePayload) XXX_DiscardUnknown()

func (*ArtifactFilePayload) XXX_Marshal

func (m *ArtifactFilePayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ArtifactFilePayload) XXX_Merge

func (m *ArtifactFilePayload) XXX_Merge(src proto.Message)

func (*ArtifactFilePayload) XXX_Size

func (m *ArtifactFilePayload) XXX_Size() int

func (*ArtifactFilePayload) XXX_Unmarshal

func (m *ArtifactFilePayload) XXX_Unmarshal(b []byte) error

type ArtifactInformation

type ArtifactInformation struct {
	// A URN that describes the type of artifact
	TypeUrn     string `protobuf:"bytes,1,opt,name=type_urn,json=typeUrn,proto3" json:"type_urn,omitempty"`
	TypePayload []byte `protobuf:"bytes,2,opt,name=type_payload,json=typePayload,proto3" json:"type_payload,omitempty"`
	// A URN that describes the role of artifact
	RoleUrn              string   `protobuf:"bytes,3,opt,name=role_urn,json=roleUrn,proto3" json:"role_urn,omitempty"`
	RolePayload          []byte   `protobuf:"bytes,4,opt,name=role_payload,json=rolePayload,proto3" json:"role_payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ArtifactInformation) Descriptor

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

func (*ArtifactInformation) GetRolePayload

func (m *ArtifactInformation) GetRolePayload() []byte

func (*ArtifactInformation) GetRoleUrn

func (m *ArtifactInformation) GetRoleUrn() string

func (*ArtifactInformation) GetTypePayload

func (m *ArtifactInformation) GetTypePayload() []byte

func (*ArtifactInformation) GetTypeUrn

func (m *ArtifactInformation) GetTypeUrn() string

func (*ArtifactInformation) ProtoMessage

func (*ArtifactInformation) ProtoMessage()

func (*ArtifactInformation) Reset

func (m *ArtifactInformation) Reset()

func (*ArtifactInformation) String

func (m *ArtifactInformation) String() string

func (*ArtifactInformation) XXX_DiscardUnknown

func (m *ArtifactInformation) XXX_DiscardUnknown()

func (*ArtifactInformation) XXX_Marshal

func (m *ArtifactInformation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ArtifactInformation) XXX_Merge

func (m *ArtifactInformation) XXX_Merge(src proto.Message)

func (*ArtifactInformation) XXX_Size

func (m *ArtifactInformation) XXX_Size() int

func (*ArtifactInformation) XXX_Unmarshal

func (m *ArtifactInformation) XXX_Unmarshal(b []byte) error

type ArtifactStagingToRolePayload

type ArtifactStagingToRolePayload struct {
	// A generated staged name (relative path under staging directory).
	StagedName           string   `protobuf:"bytes,1,opt,name=staged_name,json=stagedName,proto3" json:"staged_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ArtifactStagingToRolePayload) Descriptor

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

func (*ArtifactStagingToRolePayload) GetStagedName

func (m *ArtifactStagingToRolePayload) GetStagedName() string

func (*ArtifactStagingToRolePayload) ProtoMessage

func (*ArtifactStagingToRolePayload) ProtoMessage()

func (*ArtifactStagingToRolePayload) Reset

func (m *ArtifactStagingToRolePayload) Reset()

func (*ArtifactStagingToRolePayload) String

func (*ArtifactStagingToRolePayload) XXX_DiscardUnknown

func (m *ArtifactStagingToRolePayload) XXX_DiscardUnknown()

func (*ArtifactStagingToRolePayload) XXX_Marshal

func (m *ArtifactStagingToRolePayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ArtifactStagingToRolePayload) XXX_Merge

func (m *ArtifactStagingToRolePayload) XXX_Merge(src proto.Message)

func (*ArtifactStagingToRolePayload) XXX_Size

func (m *ArtifactStagingToRolePayload) XXX_Size() int

func (*ArtifactStagingToRolePayload) XXX_Unmarshal

func (m *ArtifactStagingToRolePayload) XXX_Unmarshal(b []byte) error

type ArtifactUrlPayload

type ArtifactUrlPayload struct {
	// a string for an artifact URL e.g. "https://.../foo.jar" or "gs://tmp/foo.jar"
	Url                  string   `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ArtifactUrlPayload) Descriptor

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

func (*ArtifactUrlPayload) GetUrl

func (m *ArtifactUrlPayload) GetUrl() string

func (*ArtifactUrlPayload) ProtoMessage

func (*ArtifactUrlPayload) ProtoMessage()

func (*ArtifactUrlPayload) Reset

func (m *ArtifactUrlPayload) Reset()

func (*ArtifactUrlPayload) String

func (m *ArtifactUrlPayload) String() string

func (*ArtifactUrlPayload) XXX_DiscardUnknown

func (m *ArtifactUrlPayload) XXX_DiscardUnknown()

func (*ArtifactUrlPayload) XXX_Marshal

func (m *ArtifactUrlPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ArtifactUrlPayload) XXX_Merge

func (m *ArtifactUrlPayload) XXX_Merge(src proto.Message)

func (*ArtifactUrlPayload) XXX_Size

func (m *ArtifactUrlPayload) XXX_Size() int

func (*ArtifactUrlPayload) XXX_Unmarshal

func (m *ArtifactUrlPayload) XXX_Unmarshal(b []byte) error

type AtomicType

type AtomicType int32
const (
	AtomicType_UNSPECIFIED AtomicType = 0
	AtomicType_BYTE        AtomicType = 1
	AtomicType_INT16       AtomicType = 2
	AtomicType_INT32       AtomicType = 3
	AtomicType_INT64       AtomicType = 4
	AtomicType_FLOAT       AtomicType = 5
	AtomicType_DOUBLE      AtomicType = 6
	AtomicType_STRING      AtomicType = 7
	AtomicType_BOOLEAN     AtomicType = 8
	AtomicType_BYTES       AtomicType = 9
)

func (AtomicType) EnumDescriptor

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

func (AtomicType) String

func (x AtomicType) String() string

type AtomicTypeValue

type AtomicTypeValue struct {
	// Types that are valid to be assigned to Value:
	//	*AtomicTypeValue_Byte
	//	*AtomicTypeValue_Int16
	//	*AtomicTypeValue_Int32
	//	*AtomicTypeValue_Int64
	//	*AtomicTypeValue_Float
	//	*AtomicTypeValue_Double
	//	*AtomicTypeValue_String_
	//	*AtomicTypeValue_Boolean
	//	*AtomicTypeValue_Bytes
	Value                isAtomicTypeValue_Value `protobuf_oneof:"value"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*AtomicTypeValue) Descriptor

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

func (*AtomicTypeValue) GetBoolean

func (m *AtomicTypeValue) GetBoolean() bool

func (*AtomicTypeValue) GetByte

func (m *AtomicTypeValue) GetByte() int32

func (*AtomicTypeValue) GetBytes

func (m *AtomicTypeValue) GetBytes() []byte

func (*AtomicTypeValue) GetDouble

func (m *AtomicTypeValue) GetDouble() float64

func (*AtomicTypeValue) GetFloat

func (m *AtomicTypeValue) GetFloat() float32

func (*AtomicTypeValue) GetInt16

func (m *AtomicTypeValue) GetInt16() int32

func (*AtomicTypeValue) GetInt32

func (m *AtomicTypeValue) GetInt32() int32

func (*AtomicTypeValue) GetInt64

func (m *AtomicTypeValue) GetInt64() int64

func (*AtomicTypeValue) GetString_

func (m *AtomicTypeValue) GetString_() string

func (*AtomicTypeValue) GetValue

func (m *AtomicTypeValue) GetValue() isAtomicTypeValue_Value

func (*AtomicTypeValue) ProtoMessage

func (*AtomicTypeValue) ProtoMessage()

func (*AtomicTypeValue) Reset

func (m *AtomicTypeValue) Reset()

func (*AtomicTypeValue) String

func (m *AtomicTypeValue) String() string

func (*AtomicTypeValue) XXX_DiscardUnknown

func (m *AtomicTypeValue) XXX_DiscardUnknown()

func (*AtomicTypeValue) XXX_Marshal

func (m *AtomicTypeValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AtomicTypeValue) XXX_Merge

func (m *AtomicTypeValue) XXX_Merge(src proto.Message)

func (*AtomicTypeValue) XXX_OneofWrappers

func (*AtomicTypeValue) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*AtomicTypeValue) XXX_Size

func (m *AtomicTypeValue) XXX_Size() int

func (*AtomicTypeValue) XXX_Unmarshal

func (m *AtomicTypeValue) XXX_Unmarshal(b []byte) error

type AtomicTypeValue_Boolean

type AtomicTypeValue_Boolean struct {
	Boolean bool `protobuf:"varint,8,opt,name=boolean,proto3,oneof"`
}

type AtomicTypeValue_Byte

type AtomicTypeValue_Byte struct {
	Byte int32 `protobuf:"varint,1,opt,name=byte,proto3,oneof"`
}

type AtomicTypeValue_Bytes

type AtomicTypeValue_Bytes struct {
	Bytes []byte `protobuf:"bytes,9,opt,name=bytes,proto3,oneof"`
}

type AtomicTypeValue_Double

type AtomicTypeValue_Double struct {
	Double float64 `protobuf:"fixed64,6,opt,name=double,proto3,oneof"`
}

type AtomicTypeValue_Float

type AtomicTypeValue_Float struct {
	Float float32 `protobuf:"fixed32,5,opt,name=float,proto3,oneof"`
}

type AtomicTypeValue_Int16

type AtomicTypeValue_Int16 struct {
	Int16 int32 `protobuf:"varint,2,opt,name=int16,proto3,oneof"`
}

type AtomicTypeValue_Int32

type AtomicTypeValue_Int32 struct {
	Int32 int32 `protobuf:"varint,3,opt,name=int32,proto3,oneof"`
}

type AtomicTypeValue_Int64

type AtomicTypeValue_Int64 struct {
	Int64 int64 `protobuf:"varint,4,opt,name=int64,proto3,oneof"`
}

type AtomicTypeValue_String_

type AtomicTypeValue_String_ struct {
	String_ string `protobuf:"bytes,7,opt,name=string,proto3,oneof"`
}

type AuthenticationSpec

type AuthenticationSpec struct {
	// (Required) A URN that describes the accompanying payload.
	// For any URN that is not recognized (by whomever is inspecting
	// it) the parameter payload should be treated as opaque and
	// passed as-is.
	Urn string `protobuf:"bytes,1,opt,name=urn,proto3" json:"urn,omitempty"`
	// (Optional) The data specifying any parameters to the URN. If
	// the URN does not require any arguments, this may be omitted.
	Payload              []byte   `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AuthenticationSpec) Descriptor

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

func (*AuthenticationSpec) GetPayload

func (m *AuthenticationSpec) GetPayload() []byte

func (*AuthenticationSpec) GetUrn

func (m *AuthenticationSpec) GetUrn() string

func (*AuthenticationSpec) ProtoMessage

func (*AuthenticationSpec) ProtoMessage()

func (*AuthenticationSpec) Reset

func (m *AuthenticationSpec) Reset()

func (*AuthenticationSpec) String

func (m *AuthenticationSpec) String() string

func (*AuthenticationSpec) XXX_DiscardUnknown

func (m *AuthenticationSpec) XXX_DiscardUnknown()

func (*AuthenticationSpec) XXX_Marshal

func (m *AuthenticationSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AuthenticationSpec) XXX_Merge

func (m *AuthenticationSpec) XXX_Merge(src proto.Message)

func (*AuthenticationSpec) XXX_Size

func (m *AuthenticationSpec) XXX_Size() int

func (*AuthenticationSpec) XXX_Unmarshal

func (m *AuthenticationSpec) XXX_Unmarshal(b []byte) error

type BagStateSpec

type BagStateSpec struct {
	ElementCoderId       string   `protobuf:"bytes,1,opt,name=element_coder_id,json=elementCoderId,proto3" json:"element_coder_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BagStateSpec) Descriptor

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

func (*BagStateSpec) GetElementCoderId

func (m *BagStateSpec) GetElementCoderId() string

func (*BagStateSpec) ProtoMessage

func (*BagStateSpec) ProtoMessage()

func (*BagStateSpec) Reset

func (m *BagStateSpec) Reset()

func (*BagStateSpec) String

func (m *BagStateSpec) String() string

func (*BagStateSpec) XXX_DiscardUnknown

func (m *BagStateSpec) XXX_DiscardUnknown()

func (*BagStateSpec) XXX_Marshal

func (m *BagStateSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BagStateSpec) XXX_Merge

func (m *BagStateSpec) XXX_Merge(src proto.Message)

func (*BagStateSpec) XXX_Size

func (m *BagStateSpec) XXX_Size() int

func (*BagStateSpec) XXX_Unmarshal

func (m *BagStateSpec) XXX_Unmarshal(b []byte) error

type BeamConstants

type BeamConstants struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BeamConstants) Descriptor

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

func (*BeamConstants) ProtoMessage

func (*BeamConstants) ProtoMessage()

func (*BeamConstants) Reset

func (m *BeamConstants) Reset()

func (*BeamConstants) String

func (m *BeamConstants) String() string

func (*BeamConstants) XXX_DiscardUnknown

func (m *BeamConstants) XXX_DiscardUnknown()

func (*BeamConstants) XXX_Marshal

func (m *BeamConstants) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BeamConstants) XXX_Merge

func (m *BeamConstants) XXX_Merge(src proto.Message)

func (*BeamConstants) XXX_Size

func (m *BeamConstants) XXX_Size() int

func (*BeamConstants) XXX_Unmarshal

func (m *BeamConstants) XXX_Unmarshal(b []byte) error

type BeamConstants_Constants

type BeamConstants_Constants int32
const (
	// All timestamps of elements or window boundaries must be within
	// the interval [MIN_TIMESTAMP_MILLIS, MAX_TIMESTAMP_MILLIS].
	// The smallest representable timestamp of an element or a window boundary.
	BeamConstants_MIN_TIMESTAMP_MILLIS BeamConstants_Constants = 0
	// The largest representable timestamp of an element or a window boundary.
	BeamConstants_MAX_TIMESTAMP_MILLIS BeamConstants_Constants = 1
	// The maximum timestamp for the global window.
	// Triggers use max timestamp to set timers' timestamp. Timers fire when
	// the watermark passes their timestamps. So, the timestamp needs to be
	// smaller than the MAX_TIMESTAMP_MILLIS.
	// One standard day is subtracted from MAX_TIMESTAMP_MILLIS to make sure
	// the max timestamp is smaller than MAX_TIMESTAMP_MILLIS even after rounding up
	// to seconds or minutes.
	BeamConstants_GLOBAL_WINDOW_MAX_TIMESTAMP_MILLIS BeamConstants_Constants = 2
)

func (BeamConstants_Constants) EnumDescriptor

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

func (BeamConstants_Constants) String

func (x BeamConstants_Constants) String() string

type ClosingBehavior

type ClosingBehavior struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Controls whether or not an aggregating transform should output data when a window expires.

func (*ClosingBehavior) Descriptor

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

func (*ClosingBehavior) ProtoMessage

func (*ClosingBehavior) ProtoMessage()

func (*ClosingBehavior) Reset

func (m *ClosingBehavior) Reset()

func (*ClosingBehavior) String

func (m *ClosingBehavior) String() string

func (*ClosingBehavior) XXX_DiscardUnknown

func (m *ClosingBehavior) XXX_DiscardUnknown()

func (*ClosingBehavior) XXX_Marshal

func (m *ClosingBehavior) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClosingBehavior) XXX_Merge

func (m *ClosingBehavior) XXX_Merge(src proto.Message)

func (*ClosingBehavior) XXX_Size

func (m *ClosingBehavior) XXX_Size() int

func (*ClosingBehavior) XXX_Unmarshal

func (m *ClosingBehavior) XXX_Unmarshal(b []byte) error

type ClosingBehavior_Enum

type ClosingBehavior_Enum int32
const (
	ClosingBehavior_UNSPECIFIED ClosingBehavior_Enum = 0
	// Emit output when a window expires, whether or not there has been
	// any new data since the last output.
	ClosingBehavior_EMIT_ALWAYS ClosingBehavior_Enum = 1
	// Only emit output when new data has arrives since the last output
	ClosingBehavior_EMIT_IF_NONEMPTY ClosingBehavior_Enum = 2
)

func (ClosingBehavior_Enum) EnumDescriptor

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

func (ClosingBehavior_Enum) String

func (x ClosingBehavior_Enum) String() string

type Coder

type Coder struct {
	// (Required) A specification for the coder, as a URN plus parameters. This
	// may be a cross-language agreed-upon format, or it may be a "custom coder"
	// that can only be used by a particular SDK. It does not include component
	// coders, as it is beneficial for these to be comprehensible to a runner
	// regardless of whether the binary format is agreed-upon.
	Spec *FunctionSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// (Optional) If this coder is parametric, such as ListCoder(VarIntCoder),
	// this is a list of the components. In order for encodings to be identical,
	// the FunctionSpec and all components must be identical, recursively.
	ComponentCoderIds    []string `protobuf:"bytes,2,rep,name=component_coder_ids,json=componentCoderIds,proto3" json:"component_coder_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A coder, the binary format for serialization and deserialization of data in a pipeline.

func (*Coder) Descriptor

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

func (*Coder) GetComponentCoderIds

func (m *Coder) GetComponentCoderIds() []string

func (*Coder) GetSpec

func (m *Coder) GetSpec() *FunctionSpec

func (*Coder) ProtoMessage

func (*Coder) ProtoMessage()

func (*Coder) Reset

func (m *Coder) Reset()

func (*Coder) String

func (m *Coder) String() string

func (*Coder) XXX_DiscardUnknown

func (m *Coder) XXX_DiscardUnknown()

func (*Coder) XXX_Marshal

func (m *Coder) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Coder) XXX_Merge

func (m *Coder) XXX_Merge(src proto.Message)

func (*Coder) XXX_Size

func (m *Coder) XXX_Size() int

func (*Coder) XXX_Unmarshal

func (m *Coder) XXX_Unmarshal(b []byte) error

type CombinePayload

type CombinePayload struct {
	// (Required) The FunctionSpec of the CombineFn.
	CombineFn *FunctionSpec `protobuf:"bytes,1,opt,name=combine_fn,json=combineFn,proto3" json:"combine_fn,omitempty"`
	// (Required) A reference to the Coder to use for accumulators of the CombineFn
	AccumulatorCoderId   string   `protobuf:"bytes,2,opt,name=accumulator_coder_id,json=accumulatorCoderId,proto3" json:"accumulator_coder_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The payload for the special-but-not-primitive Combine transform.

func (*CombinePayload) Descriptor

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

func (*CombinePayload) GetAccumulatorCoderId

func (m *CombinePayload) GetAccumulatorCoderId() string

func (*CombinePayload) GetCombineFn

func (m *CombinePayload) GetCombineFn() *FunctionSpec

func (*CombinePayload) ProtoMessage

func (*CombinePayload) ProtoMessage()

func (*CombinePayload) Reset

func (m *CombinePayload) Reset()

func (*CombinePayload) String

func (m *CombinePayload) String() string

func (*CombinePayload) XXX_DiscardUnknown

func (m *CombinePayload) XXX_DiscardUnknown()

func (*CombinePayload) XXX_Marshal

func (m *CombinePayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CombinePayload) XXX_Merge

func (m *CombinePayload) XXX_Merge(src proto.Message)

func (*CombinePayload) XXX_Size

func (m *CombinePayload) XXX_Size() int

func (*CombinePayload) XXX_Unmarshal

func (m *CombinePayload) XXX_Unmarshal(b []byte) error

type CombiningStateSpec

type CombiningStateSpec struct {
	AccumulatorCoderId   string        `protobuf:"bytes,1,opt,name=accumulator_coder_id,json=accumulatorCoderId,proto3" json:"accumulator_coder_id,omitempty"`
	CombineFn            *FunctionSpec `protobuf:"bytes,2,opt,name=combine_fn,json=combineFn,proto3" json:"combine_fn,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*CombiningStateSpec) Descriptor

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

func (*CombiningStateSpec) GetAccumulatorCoderId

func (m *CombiningStateSpec) GetAccumulatorCoderId() string

func (*CombiningStateSpec) GetCombineFn

func (m *CombiningStateSpec) GetCombineFn() *FunctionSpec

func (*CombiningStateSpec) ProtoMessage

func (*CombiningStateSpec) ProtoMessage()

func (*CombiningStateSpec) Reset

func (m *CombiningStateSpec) Reset()

func (*CombiningStateSpec) String

func (m *CombiningStateSpec) String() string

func (*CombiningStateSpec) XXX_DiscardUnknown

func (m *CombiningStateSpec) XXX_DiscardUnknown()

func (*CombiningStateSpec) XXX_Marshal

func (m *CombiningStateSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CombiningStateSpec) XXX_Merge

func (m *CombiningStateSpec) XXX_Merge(src proto.Message)

func (*CombiningStateSpec) XXX_Size

func (m *CombiningStateSpec) XXX_Size() int

func (*CombiningStateSpec) XXX_Unmarshal

func (m *CombiningStateSpec) XXX_Unmarshal(b []byte) error

type Components

type Components struct {
	// (Required) A map from pipeline-scoped id to PTransform.
	Transforms map[string]*PTransform `` /* 161-byte string literal not displayed */
	// (Required) A map from pipeline-scoped id to PCollection.
	Pcollections map[string]*PCollection `` /* 165-byte string literal not displayed */
	// (Required) A map from pipeline-scoped id to WindowingStrategy.
	WindowingStrategies map[string]*WindowingStrategy `` /* 206-byte string literal not displayed */
	// (Required) A map from pipeline-scoped id to Coder.
	Coders map[string]*Coder `` /* 153-byte string literal not displayed */
	// (Required) A map from pipeline-scoped id to Environment.
	Environments         map[string]*Environment `` /* 165-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

A set of mappings from id to message. This is included as an optional field on any proto message that may contain references needing resolution.

func (*Components) Descriptor

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

func (*Components) GetCoders

func (m *Components) GetCoders() map[string]*Coder

func (*Components) GetEnvironments

func (m *Components) GetEnvironments() map[string]*Environment

func (*Components) GetPcollections

func (m *Components) GetPcollections() map[string]*PCollection

func (*Components) GetTransforms

func (m *Components) GetTransforms() map[string]*PTransform

func (*Components) GetWindowingStrategies

func (m *Components) GetWindowingStrategies() map[string]*WindowingStrategy

func (*Components) ProtoMessage

func (*Components) ProtoMessage()

func (*Components) Reset

func (m *Components) Reset()

func (*Components) String

func (m *Components) String() string

func (*Components) XXX_DiscardUnknown

func (m *Components) XXX_DiscardUnknown()

func (*Components) XXX_Marshal

func (m *Components) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Components) XXX_Merge

func (m *Components) XXX_Merge(src proto.Message)

func (*Components) XXX_Size

func (m *Components) XXX_Size() int

func (*Components) XXX_Unmarshal

func (m *Components) XXX_Unmarshal(b []byte) error

type ConfigValue

type ConfigValue struct {
	// Coder and its components (in case of a compound Coder)
	CoderUrn []string `protobuf:"bytes,1,rep,name=coder_urn,json=coderUrn,proto3" json:"coder_urn,omitempty"`
	// The Payload which is decoded using the coder_urn
	Payload              []byte   `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ConfigValue) Descriptor

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

func (*ConfigValue) GetCoderUrn

func (m *ConfigValue) GetCoderUrn() []string

func (*ConfigValue) GetPayload

func (m *ConfigValue) GetPayload() []byte

func (*ConfigValue) ProtoMessage

func (*ConfigValue) ProtoMessage()

func (*ConfigValue) Reset

func (m *ConfigValue) Reset()

func (*ConfigValue) String

func (m *ConfigValue) String() string

func (*ConfigValue) XXX_DiscardUnknown

func (m *ConfigValue) XXX_DiscardUnknown()

func (*ConfigValue) XXX_Marshal

func (m *ConfigValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigValue) XXX_Merge

func (m *ConfigValue) XXX_Merge(src proto.Message)

func (*ConfigValue) XXX_Size

func (m *ConfigValue) XXX_Size() int

func (*ConfigValue) XXX_Unmarshal

func (m *ConfigValue) XXX_Unmarshal(b []byte) error

type DeferredArtifactPayload

type DeferredArtifactPayload struct {
	// A unique string identifier assigned by the creator of this payload. The creator may use this key to confirm
	// whether they can parse the data.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Data for deferred artifacts. Interpretation of bytes is delegated to the creator of this payload.
	Data                 []byte   `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeferredArtifactPayload) Descriptor

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

func (*DeferredArtifactPayload) GetData

func (m *DeferredArtifactPayload) GetData() []byte

func (*DeferredArtifactPayload) GetKey

func (m *DeferredArtifactPayload) GetKey() string

func (*DeferredArtifactPayload) ProtoMessage

func (*DeferredArtifactPayload) ProtoMessage()

func (*DeferredArtifactPayload) Reset

func (m *DeferredArtifactPayload) Reset()

func (*DeferredArtifactPayload) String

func (m *DeferredArtifactPayload) String() string

func (*DeferredArtifactPayload) XXX_DiscardUnknown

func (m *DeferredArtifactPayload) XXX_DiscardUnknown()

func (*DeferredArtifactPayload) XXX_Marshal

func (m *DeferredArtifactPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeferredArtifactPayload) XXX_Merge

func (m *DeferredArtifactPayload) XXX_Merge(src proto.Message)

func (*DeferredArtifactPayload) XXX_Size

func (m *DeferredArtifactPayload) XXX_Size() int

func (*DeferredArtifactPayload) XXX_Unmarshal

func (m *DeferredArtifactPayload) XXX_Unmarshal(b []byte) error

type DisplayData

type DisplayData struct {
	// A key used to describe the type of display data. See StandardDisplayData
	// for the set of well known urns describing how the payload is meant to be
	// interpreted.
	Urn string `protobuf:"bytes,1,opt,name=urn,proto3" json:"urn,omitempty"`
	// (Optional) The data specifying any parameters to the URN. If
	// the URN does not require any arguments, this may be omitted.
	Payload              []byte   `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Static display data associated with a pipeline component. Display data is useful for pipeline runners IOs and diagnostic dashboards to display details about annotated components.

func (*DisplayData) Descriptor

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

func (*DisplayData) GetPayload

func (m *DisplayData) GetPayload() []byte

func (*DisplayData) GetUrn

func (m *DisplayData) GetUrn() string

func (*DisplayData) ProtoMessage

func (*DisplayData) ProtoMessage()

func (*DisplayData) Reset

func (m *DisplayData) Reset()

func (*DisplayData) String

func (m *DisplayData) String() string

func (*DisplayData) XXX_DiscardUnknown

func (m *DisplayData) XXX_DiscardUnknown()

func (*DisplayData) XXX_Marshal

func (m *DisplayData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DisplayData) XXX_Merge

func (m *DisplayData) XXX_Merge(src proto.Message)

func (*DisplayData) XXX_Size

func (m *DisplayData) XXX_Size() int

func (*DisplayData) XXX_Unmarshal

func (m *DisplayData) XXX_Unmarshal(b []byte) error

type DockerPayload

type DockerPayload struct {
	ContainerImage       string   `protobuf:"bytes,1,opt,name=container_image,json=containerImage,proto3" json:"container_image,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The payload of a Docker image

func (*DockerPayload) Descriptor

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

func (*DockerPayload) GetContainerImage

func (m *DockerPayload) GetContainerImage() string

func (*DockerPayload) ProtoMessage

func (*DockerPayload) ProtoMessage()

func (*DockerPayload) Reset

func (m *DockerPayload) Reset()

func (*DockerPayload) String

func (m *DockerPayload) String() string

func (*DockerPayload) XXX_DiscardUnknown

func (m *DockerPayload) XXX_DiscardUnknown()

func (*DockerPayload) XXX_Marshal

func (m *DockerPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DockerPayload) XXX_Merge

func (m *DockerPayload) XXX_Merge(src proto.Message)

func (*DockerPayload) XXX_Size

func (m *DockerPayload) XXX_Size() int

func (*DockerPayload) XXX_Unmarshal

func (m *DockerPayload) XXX_Unmarshal(b []byte) error

type EmbeddedFilePayload

type EmbeddedFilePayload struct {
	// raw data bytes for an embedded artifact
	Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EmbeddedFilePayload) Descriptor

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

func (*EmbeddedFilePayload) GetData

func (m *EmbeddedFilePayload) GetData() []byte

func (*EmbeddedFilePayload) ProtoMessage

func (*EmbeddedFilePayload) ProtoMessage()

func (*EmbeddedFilePayload) Reset

func (m *EmbeddedFilePayload) Reset()

func (*EmbeddedFilePayload) String

func (m *EmbeddedFilePayload) String() string

func (*EmbeddedFilePayload) XXX_DiscardUnknown

func (m *EmbeddedFilePayload) XXX_DiscardUnknown()

func (*EmbeddedFilePayload) XXX_Marshal

func (m *EmbeddedFilePayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EmbeddedFilePayload) XXX_Merge

func (m *EmbeddedFilePayload) XXX_Merge(src proto.Message)

func (*EmbeddedFilePayload) XXX_Size

func (m *EmbeddedFilePayload) XXX_Size() int

func (*EmbeddedFilePayload) XXX_Unmarshal

func (m *EmbeddedFilePayload) XXX_Unmarshal(b []byte) error

type Environment

type Environment struct {
	// (Required) The URN of the payload
	Urn string `protobuf:"bytes,2,opt,name=urn,proto3" json:"urn,omitempty"`
	// (Optional) The data specifying any parameters to the URN. If
	// the URN does not require any arguments, this may be omitted.
	Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// (Optional) Static display data for the environment. If there is none,
	// it may be omitted.
	DisplayData []*DisplayData `protobuf:"bytes,4,rep,name=display_data,json=displayData,proto3" json:"display_data,omitempty"`
	// (Optional) A set of capabilities this environment supports. This is
	// typically a list of common URNs designating coders, transforms, etc. that
	// this environment understands (and a runner MAY use) despite not
	// appearing in the pipeline proto. This may also be used to indicate
	// support of optional protocols not tied to a concrete component.
	Capabilities []string `protobuf:"bytes,5,rep,name=capabilities,proto3" json:"capabilities,omitempty"`
	// (Optional) artifact dependency information used for executing UDFs in this environment.
	Dependencies         []*ArtifactInformation `protobuf:"bytes,6,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

An environment for executing UDFs. By default, an SDK container URL, but can also be a process forked by a command, or an externally managed process.

func (*Environment) Descriptor

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

func (*Environment) GetCapabilities

func (m *Environment) GetCapabilities() []string

func (*Environment) GetDependencies

func (m *Environment) GetDependencies() []*ArtifactInformation

func (*Environment) GetDisplayData

func (m *Environment) GetDisplayData() []*DisplayData

func (*Environment) GetPayload

func (m *Environment) GetPayload() []byte

func (*Environment) GetUrn

func (m *Environment) GetUrn() string

func (*Environment) ProtoMessage

func (*Environment) ProtoMessage()

func (*Environment) Reset

func (m *Environment) Reset()

func (*Environment) String

func (m *Environment) String() string

func (*Environment) XXX_DiscardUnknown

func (m *Environment) XXX_DiscardUnknown()

func (*Environment) XXX_Marshal

func (m *Environment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Environment) XXX_Merge

func (m *Environment) XXX_Merge(src proto.Message)

func (*Environment) XXX_Size

func (m *Environment) XXX_Size() int

func (*Environment) XXX_Unmarshal

func (m *Environment) XXX_Unmarshal(b []byte) error

type EventsRequest

type EventsRequest struct {
	// The set of PCollections to read from. These are the PTransform outputs
	// local names. These are a subset of the TestStream's outputs. This allows
	// Interactive Beam to cache many PCollections from a pipeline then replay a
	// subset of them.
	OutputIds            []string `protobuf:"bytes,1,rep,name=output_ids,json=outputIds,proto3" json:"output_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EventsRequest) Descriptor

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

func (*EventsRequest) GetOutputIds

func (m *EventsRequest) GetOutputIds() []string

func (*EventsRequest) ProtoMessage

func (*EventsRequest) ProtoMessage()

func (*EventsRequest) Reset

func (m *EventsRequest) Reset()

func (*EventsRequest) String

func (m *EventsRequest) String() string

func (*EventsRequest) XXX_DiscardUnknown

func (m *EventsRequest) XXX_DiscardUnknown()

func (*EventsRequest) XXX_Marshal

func (m *EventsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventsRequest) XXX_Merge

func (m *EventsRequest) XXX_Merge(src proto.Message)

func (*EventsRequest) XXX_Size

func (m *EventsRequest) XXX_Size() int

func (*EventsRequest) XXX_Unmarshal

func (m *EventsRequest) XXX_Unmarshal(b []byte) error

type ExecutableStagePayload

type ExecutableStagePayload struct {
	// (Required) Environment in which this stage executes.
	//
	// We use an environment rather than environment id
	// because ExecutableStages use environments directly. This may change in the future.
	Environment *Environment `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"`
	// The wire coder settings of this executable stage
	WireCoderSettings []*ExecutableStagePayload_WireCoderSetting `protobuf:"bytes,9,rep,name=wire_coder_settings,json=wireCoderSettings,proto3" json:"wire_coder_settings,omitempty"`
	// (Required) Input PCollection id. This must be present as a value in the inputs of any
	// PTransform the ExecutableStagePayload is the payload of.
	Input string `protobuf:"bytes,2,opt,name=input,proto3" json:"input,omitempty"`
	// The side inputs required for this executable stage. Each side input of each PTransform within
	// this ExecutableStagePayload must be represented within this field.
	SideInputs []*ExecutableStagePayload_SideInputId `protobuf:"bytes,3,rep,name=side_inputs,json=sideInputs,proto3" json:"side_inputs,omitempty"`
	// PTransform ids contained within this executable stage. This must contain at least one
	// PTransform id.
	Transforms []string `protobuf:"bytes,4,rep,name=transforms,proto3" json:"transforms,omitempty"`
	// Output PCollection ids. This must be equal to the values of the outputs of any
	// PTransform the ExecutableStagePayload is the payload of.
	Outputs []string `protobuf:"bytes,5,rep,name=outputs,proto3" json:"outputs,omitempty"`
	// (Required) The components for the Executable Stage. This must contain all of the Transforms
	// in transforms, and the closure of all of the components they recognize.
	Components *Components `protobuf:"bytes,6,opt,name=components,proto3" json:"components,omitempty"`
	// The user states required for this executable stage. Each user state of each PTransform within
	// this ExecutableStagePayload must be represented within this field.
	UserStates []*ExecutableStagePayload_UserStateId `protobuf:"bytes,7,rep,name=user_states,json=userStates,proto3" json:"user_states,omitempty"`
	// The timers required for this executable stage. Each timer of each PTransform within
	// this ExecutableStagePayload must be represented within this field.
	Timers []*ExecutableStagePayload_TimerId `protobuf:"bytes,8,rep,name=timers,proto3" json:"timers,omitempty"`
	// The timerfamilies required for this executable stage. Each timer familyof each PTransform within
	// this ExecutableStagePayload must be represented within this field.
	TimerFamilies        []*ExecutableStagePayload_TimerFamilyId `protobuf:"bytes,10,rep,name=timerFamilies,proto3" json:"timerFamilies,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                `json:"-"`
	XXX_unrecognized     []byte                                  `json:"-"`
	XXX_sizecache        int32                                   `json:"-"`
}

The payload for an executable stage. This will eventually be passed to an SDK in the form of a ProcessBundleDescriptor.

func (*ExecutableStagePayload) Descriptor

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

func (*ExecutableStagePayload) GetComponents

func (m *ExecutableStagePayload) GetComponents() *Components

func (*ExecutableStagePayload) GetEnvironment

func (m *ExecutableStagePayload) GetEnvironment() *Environment

func (*ExecutableStagePayload) GetInput

func (m *ExecutableStagePayload) GetInput() string

func (*ExecutableStagePayload) GetOutputs

func (m *ExecutableStagePayload) GetOutputs() []string

func (*ExecutableStagePayload) GetSideInputs

func (*ExecutableStagePayload) GetTimerFamilies

func (*ExecutableStagePayload) GetTimers

func (*ExecutableStagePayload) GetTransforms

func (m *ExecutableStagePayload) GetTransforms() []string

func (*ExecutableStagePayload) GetUserStates

func (*ExecutableStagePayload) GetWireCoderSettings

func (*ExecutableStagePayload) ProtoMessage

func (*ExecutableStagePayload) ProtoMessage()

func (*ExecutableStagePayload) Reset

func (m *ExecutableStagePayload) Reset()

func (*ExecutableStagePayload) String

func (m *ExecutableStagePayload) String() string

func (*ExecutableStagePayload) XXX_DiscardUnknown

func (m *ExecutableStagePayload) XXX_DiscardUnknown()

func (*ExecutableStagePayload) XXX_Marshal

func (m *ExecutableStagePayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecutableStagePayload) XXX_Merge

func (m *ExecutableStagePayload) XXX_Merge(src proto.Message)

func (*ExecutableStagePayload) XXX_Size

func (m *ExecutableStagePayload) XXX_Size() int

func (*ExecutableStagePayload) XXX_Unmarshal

func (m *ExecutableStagePayload) XXX_Unmarshal(b []byte) error

type ExecutableStagePayload_SideInputId

type ExecutableStagePayload_SideInputId struct {
	// (Required) The id of the PTransform that references this side input.
	TransformId string `protobuf:"bytes,1,opt,name=transform_id,json=transformId,proto3" json:"transform_id,omitempty"`
	// (Required) The local name of this side input from the PTransform that references it.
	LocalName            string   `protobuf:"bytes,2,opt,name=local_name,json=localName,proto3" json:"local_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A reference to a side input. Side inputs are uniquely identified by PTransform id and local name.

func (*ExecutableStagePayload_SideInputId) Descriptor

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

func (*ExecutableStagePayload_SideInputId) GetLocalName

func (m *ExecutableStagePayload_SideInputId) GetLocalName() string

func (*ExecutableStagePayload_SideInputId) GetTransformId

func (m *ExecutableStagePayload_SideInputId) GetTransformId() string

func (*ExecutableStagePayload_SideInputId) ProtoMessage

func (*ExecutableStagePayload_SideInputId) ProtoMessage()

func (*ExecutableStagePayload_SideInputId) Reset

func (*ExecutableStagePayload_SideInputId) String

func (*ExecutableStagePayload_SideInputId) XXX_DiscardUnknown

func (m *ExecutableStagePayload_SideInputId) XXX_DiscardUnknown()

func (*ExecutableStagePayload_SideInputId) XXX_Marshal

func (m *ExecutableStagePayload_SideInputId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecutableStagePayload_SideInputId) XXX_Merge

func (*ExecutableStagePayload_SideInputId) XXX_Size

func (*ExecutableStagePayload_SideInputId) XXX_Unmarshal

func (m *ExecutableStagePayload_SideInputId) XXX_Unmarshal(b []byte) error

type ExecutableStagePayload_TimerFamilyId

type ExecutableStagePayload_TimerFamilyId struct {
	// (Required) The id of the PTransform that references this timer family.
	TransformId string `protobuf:"bytes,1,opt,name=transform_id,json=transformId,proto3" json:"transform_id,omitempty"`
	// (Required) The local name of this timer family for the PTransform that references it.
	LocalName            string   `protobuf:"bytes,2,opt,name=local_name,json=localName,proto3" json:"local_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A reference to a timer. Timers are uniquely identified by PTransform id and local name.

func (*ExecutableStagePayload_TimerFamilyId) Descriptor

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

func (*ExecutableStagePayload_TimerFamilyId) GetLocalName

func (m *ExecutableStagePayload_TimerFamilyId) GetLocalName() string

func (*ExecutableStagePayload_TimerFamilyId) GetTransformId

func (m *ExecutableStagePayload_TimerFamilyId) GetTransformId() string

func (*ExecutableStagePayload_TimerFamilyId) ProtoMessage

func (*ExecutableStagePayload_TimerFamilyId) ProtoMessage()

func (*ExecutableStagePayload_TimerFamilyId) Reset

func (*ExecutableStagePayload_TimerFamilyId) String

func (*ExecutableStagePayload_TimerFamilyId) XXX_DiscardUnknown

func (m *ExecutableStagePayload_TimerFamilyId) XXX_DiscardUnknown()

func (*ExecutableStagePayload_TimerFamilyId) XXX_Marshal

func (m *ExecutableStagePayload_TimerFamilyId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecutableStagePayload_TimerFamilyId) XXX_Merge

func (*ExecutableStagePayload_TimerFamilyId) XXX_Size

func (*ExecutableStagePayload_TimerFamilyId) XXX_Unmarshal

func (m *ExecutableStagePayload_TimerFamilyId) XXX_Unmarshal(b []byte) error

type ExecutableStagePayload_TimerId

type ExecutableStagePayload_TimerId struct {
	// (Required) The id of the PTransform that references this timer.
	TransformId string `protobuf:"bytes,1,opt,name=transform_id,json=transformId,proto3" json:"transform_id,omitempty"`
	// (Required) The local name of this timer for the PTransform that references it.
	LocalName            string   `protobuf:"bytes,2,opt,name=local_name,json=localName,proto3" json:"local_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A reference to a timer. Timers are uniquely identified by PTransform id and local name.

func (*ExecutableStagePayload_TimerId) Descriptor

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

func (*ExecutableStagePayload_TimerId) GetLocalName

func (m *ExecutableStagePayload_TimerId) GetLocalName() string

func (*ExecutableStagePayload_TimerId) GetTransformId

func (m *ExecutableStagePayload_TimerId) GetTransformId() string

func (*ExecutableStagePayload_TimerId) ProtoMessage

func (*ExecutableStagePayload_TimerId) ProtoMessage()

func (*ExecutableStagePayload_TimerId) Reset

func (m *ExecutableStagePayload_TimerId) Reset()

func (*ExecutableStagePayload_TimerId) String

func (*ExecutableStagePayload_TimerId) XXX_DiscardUnknown

func (m *ExecutableStagePayload_TimerId) XXX_DiscardUnknown()

func (*ExecutableStagePayload_TimerId) XXX_Marshal

func (m *ExecutableStagePayload_TimerId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecutableStagePayload_TimerId) XXX_Merge

func (m *ExecutableStagePayload_TimerId) XXX_Merge(src proto.Message)

func (*ExecutableStagePayload_TimerId) XXX_Size

func (m *ExecutableStagePayload_TimerId) XXX_Size() int

func (*ExecutableStagePayload_TimerId) XXX_Unmarshal

func (m *ExecutableStagePayload_TimerId) XXX_Unmarshal(b []byte) error

type ExecutableStagePayload_UserStateId

type ExecutableStagePayload_UserStateId struct {
	// (Required) The id of the PTransform that references this user state.
	TransformId string `protobuf:"bytes,1,opt,name=transform_id,json=transformId,proto3" json:"transform_id,omitempty"`
	// (Required) The local name of this user state for the PTransform that references it.
	LocalName            string   `protobuf:"bytes,2,opt,name=local_name,json=localName,proto3" json:"local_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A reference to user state. User states are uniquely identified by PTransform id and local name.

func (*ExecutableStagePayload_UserStateId) Descriptor

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

func (*ExecutableStagePayload_UserStateId) GetLocalName

func (m *ExecutableStagePayload_UserStateId) GetLocalName() string

func (*ExecutableStagePayload_UserStateId) GetTransformId

func (m *ExecutableStagePayload_UserStateId) GetTransformId() string

func (*ExecutableStagePayload_UserStateId) ProtoMessage

func (*ExecutableStagePayload_UserStateId) ProtoMessage()

func (*ExecutableStagePayload_UserStateId) Reset

func (*ExecutableStagePayload_UserStateId) String

func (*ExecutableStagePayload_UserStateId) XXX_DiscardUnknown

func (m *ExecutableStagePayload_UserStateId) XXX_DiscardUnknown()

func (*ExecutableStagePayload_UserStateId) XXX_Marshal

func (m *ExecutableStagePayload_UserStateId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecutableStagePayload_UserStateId) XXX_Merge

func (*ExecutableStagePayload_UserStateId) XXX_Size

func (*ExecutableStagePayload_UserStateId) XXX_Unmarshal

func (m *ExecutableStagePayload_UserStateId) XXX_Unmarshal(b []byte) error

type ExecutableStagePayload_WireCoderSetting

type ExecutableStagePayload_WireCoderSetting struct {
	// (Required) The URN of the wire coder.
	// Note that only windowed value coder or parameterized windowed value coder are supported.
	Urn string `protobuf:"bytes,1,opt,name=urn,proto3" json:"urn,omitempty"`
	// (Optional) The data specifying any parameters to the URN. If
	// the URN is beam:coder:windowed_value:v1, this may be omitted. If the URN is
	// beam:coder:param_windowed_value:v1, the payload is an encoded windowed
	// value using the beam:coder:windowed_value:v1 coder parameterized by
	// a beam:coder:bytes:v1 element coder and the window coder that this
	// param_windowed_value coder uses.
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" j