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" json:"payload,omitempty"`
	// (Required) The target(PCollection or Timer) this setting applies to.
	//
	// Types that are valid to be assigned to Target:
	//	*ExecutableStagePayload_WireCoderSetting_InputOrOutputId
	//	*ExecutableStagePayload_WireCoderSetting_Timer
	Target               isExecutableStagePayload_WireCoderSetting_Target `protobuf_oneof:"target"`
	XXX_NoUnkeyedLiteral struct{}                                         `json:"-"`
	XXX_unrecognized     []byte                                           `json:"-"`
	XXX_sizecache        int32                                            `json:"-"`
}

Settings that decide the coder type of wire coder.

func (*ExecutableStagePayload_WireCoderSetting) Descriptor

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

func (*ExecutableStagePayload_WireCoderSetting) GetInputOrOutputId

func (m *ExecutableStagePayload_WireCoderSetting) GetInputOrOutputId() string

func (*ExecutableStagePayload_WireCoderSetting) GetPayload

func (*ExecutableStagePayload_WireCoderSetting) GetTarget

func (m *ExecutableStagePayload_WireCoderSetting) GetTarget() isExecutableStagePayload_WireCoderSetting_Target

func (*ExecutableStagePayload_WireCoderSetting) GetTimer

func (*ExecutableStagePayload_WireCoderSetting) GetUrn

func (*ExecutableStagePayload_WireCoderSetting) ProtoMessage

func (*ExecutableStagePayload_WireCoderSetting) Reset

func (*ExecutableStagePayload_WireCoderSetting) String

func (*ExecutableStagePayload_WireCoderSetting) XXX_DiscardUnknown

func (m *ExecutableStagePayload_WireCoderSetting) XXX_DiscardUnknown()

func (*ExecutableStagePayload_WireCoderSetting) XXX_Marshal

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

func (*ExecutableStagePayload_WireCoderSetting) XXX_Merge

func (*ExecutableStagePayload_WireCoderSetting) XXX_OneofWrappers

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ExecutableStagePayload_WireCoderSetting) XXX_Size

func (*ExecutableStagePayload_WireCoderSetting) XXX_Unmarshal

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

type ExecutableStagePayload_WireCoderSetting_InputOrOutputId

type ExecutableStagePayload_WireCoderSetting_InputOrOutputId struct {
	InputOrOutputId string `protobuf:"bytes,3,opt,name=input_or_output_id,json=inputOrOutputId,proto3,oneof"`
}

type ExecutableStagePayload_WireCoderSetting_Timer

type ExecutableStagePayload_WireCoderSetting_Timer struct {
	Timer *ExecutableStagePayload_TimerId `protobuf:"bytes,4,opt,name=timer,proto3,oneof"`
}

type ExternalConfigurationPayload

type ExternalConfigurationPayload struct {
	// Configuration key => value
	Configuration        map[string]*ConfigValue `` /* 167-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

A configuration payload for an external transform. Used as the payload of ExternalTransform as part of an ExpansionRequest.

func (*ExternalConfigurationPayload) Descriptor

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

func (*ExternalConfigurationPayload) GetConfiguration

func (m *ExternalConfigurationPayload) GetConfiguration() map[string]*ConfigValue

func (*ExternalConfigurationPayload) ProtoMessage

func (*ExternalConfigurationPayload) ProtoMessage()

func (*ExternalConfigurationPayload) Reset

func (m *ExternalConfigurationPayload) Reset()

func (*ExternalConfigurationPayload) String

func (*ExternalConfigurationPayload) XXX_DiscardUnknown

func (m *ExternalConfigurationPayload) XXX_DiscardUnknown()

func (*ExternalConfigurationPayload) XXX_Marshal

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

func (*ExternalConfigurationPayload) XXX_Merge

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

func (*ExternalConfigurationPayload) XXX_Size

func (m *ExternalConfigurationPayload) XXX_Size() int

func (*ExternalConfigurationPayload) XXX_Unmarshal

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

type ExternalPayload

type ExternalPayload struct {
	Endpoint             *ApiServiceDescriptor `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Params               map[string]string     `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ExternalPayload) Descriptor

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

func (*ExternalPayload) GetEndpoint

func (m *ExternalPayload) GetEndpoint() *ApiServiceDescriptor

func (*ExternalPayload) GetParams

func (m *ExternalPayload) GetParams() map[string]string

func (*ExternalPayload) ProtoMessage

func (*ExternalPayload) ProtoMessage()

func (*ExternalPayload) Reset

func (m *ExternalPayload) Reset()

func (*ExternalPayload) String

func (m *ExternalPayload) String() string

func (*ExternalPayload) XXX_DiscardUnknown

func (m *ExternalPayload) XXX_DiscardUnknown()

func (*ExternalPayload) XXX_Marshal

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

func (*ExternalPayload) XXX_Merge

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

func (*ExternalPayload) XXX_Size

func (m *ExternalPayload) XXX_Size() int

func (*ExternalPayload) XXX_Unmarshal

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

type Field

type Field struct {
	Name                 string     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description          string     `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Type                 *FieldType `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Id                   int32      `protobuf:"varint,4,opt,name=id,proto3" json:"id,omitempty"`
	EncodingPosition     int32      `protobuf:"varint,5,opt,name=encoding_position,json=encodingPosition,proto3" json:"encoding_position,omitempty"`
	Options              []*Option  `protobuf:"bytes,6,rep,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Field) Descriptor

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

func (*Field) GetDescription

func (m *Field) GetDescription() string

func (*Field) GetEncodingPosition

func (m *Field) GetEncodingPosition() int32

func (*Field) GetId

func (m *Field) GetId() int32

func (*Field) GetName

func (m *Field) GetName() string

func (*Field) GetOptions

func (m *Field) GetOptions() []*Option

func (*Field) GetType

func (m *Field) GetType() *FieldType

func (*Field) ProtoMessage

func (*Field) ProtoMessage()

func (*Field) Reset

func (m *Field) Reset()

func (*Field) String

func (m *Field) String() string

func (*Field) XXX_DiscardUnknown

func (m *Field) XXX_DiscardUnknown()

func (*Field) XXX_Marshal

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

func (*Field) XXX_Merge

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

func (*Field) XXX_Size

func (m *Field) XXX_Size() int

func (*Field) XXX_Unmarshal

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

type FieldType

type FieldType struct {
	Nullable bool `protobuf:"varint,1,opt,name=nullable,proto3" json:"nullable,omitempty"`
	// Types that are valid to be assigned to TypeInfo:
	//	*FieldType_AtomicType
	//	*FieldType_ArrayType
	//	*FieldType_IterableType
	//	*FieldType_MapType
	//	*FieldType_RowType
	//	*FieldType_LogicalType
	TypeInfo             isFieldType_TypeInfo `protobuf_oneof:"type_info"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*FieldType) Descriptor

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

func (*FieldType) GetArrayType

func (m *FieldType) GetArrayType() *ArrayType

func (*FieldType) GetAtomicType

func (m *FieldType) GetAtomicType() AtomicType

func (*FieldType) GetIterableType

func (m *FieldType) GetIterableType() *IterableType

func (*FieldType) GetLogicalType

func (m *FieldType) GetLogicalType() *LogicalType

func (*FieldType) GetMapType

func (m *FieldType) GetMapType() *MapType

func (*FieldType) GetNullable

func (m *FieldType) GetNullable() bool

func (*FieldType) GetRowType

func (m *FieldType) GetRowType() *RowType

func (*FieldType) GetTypeInfo

func (m *FieldType) GetTypeInfo() isFieldType_TypeInfo

func (*FieldType) ProtoMessage

func (*FieldType) ProtoMessage()

func (*FieldType) Reset

func (m *FieldType) Reset()

func (*FieldType) String

func (m *FieldType) String() string

func (*FieldType) XXX_DiscardUnknown

func (m *FieldType) XXX_DiscardUnknown()

func (*FieldType) XXX_Marshal

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

func (*FieldType) XXX_Merge

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

func (*FieldType) XXX_OneofWrappers

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*FieldType) XXX_Size

func (m *FieldType) XXX_Size() int

func (*FieldType) XXX_Unmarshal

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

type FieldType_ArrayType

type FieldType_ArrayType struct {
	ArrayType *ArrayType `protobuf:"bytes,3,opt,name=array_type,json=arrayType,proto3,oneof"`
}

type FieldType_AtomicType

type FieldType_AtomicType struct {
	AtomicType AtomicType `protobuf:"varint,2,opt,name=atomic_type,json=atomicType,proto3,enum=org.apache.beam.model.pipeline.v1.AtomicType,oneof"`
}

type FieldType_IterableType

type FieldType_IterableType struct {
	IterableType *IterableType `protobuf:"bytes,4,opt,name=iterable_type,json=iterableType,proto3,oneof"`
}

type FieldType_LogicalType

type FieldType_LogicalType struct {
	LogicalType *LogicalType `protobuf:"bytes,7,opt,name=logical_type,json=logicalType,proto3,oneof"`
}

type FieldType_MapType

type FieldType_MapType struct {
	MapType *MapType `protobuf:"bytes,5,opt,name=map_type,json=mapType,proto3,oneof"`
}

type FieldType_RowType

type FieldType_RowType struct {
	RowType *RowType `protobuf:"bytes,6,opt,name=row_type,json=rowType,proto3,oneof"`
}

type FieldValue

type FieldValue struct {
	// Types that are valid to be assigned to FieldValue:
	//	*FieldValue_AtomicValue
	//	*FieldValue_ArrayValue
	//	*FieldValue_IterableValue
	//	*FieldValue_MapValue
	//	*FieldValue_RowValue
	//	*FieldValue_LogicalTypeValue
	FieldValue           isFieldValue_FieldValue `protobuf_oneof:"field_value"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*FieldValue) Descriptor

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

func (*FieldValue) GetArrayValue

func (m *FieldValue) GetArrayValue() *ArrayTypeValue

func (*FieldValue) GetAtomicValue

func (m *FieldValue) GetAtomicValue() *AtomicTypeValue

func (*FieldValue) GetFieldValue

func (m *FieldValue) GetFieldValue() isFieldValue_FieldValue

func (*FieldValue) GetIterableValue

func (m *FieldValue) GetIterableValue() *IterableTypeValue

func (*FieldValue) GetLogicalTypeValue

func (m *FieldValue) GetLogicalTypeValue() *LogicalTypeValue

func (*FieldValue) GetMapValue

func (m *FieldValue) GetMapValue() *MapTypeValue

func (*FieldValue) GetRowValue

func (m *FieldValue) GetRowValue() *Row

func (*FieldValue) ProtoMessage

func (*FieldValue) ProtoMessage()

func (*FieldValue) Reset

func (m *FieldValue) Reset()

func (*FieldValue) String

func (m *FieldValue) String() string

func (*FieldValue) XXX_DiscardUnknown

func (m *FieldValue) XXX_DiscardUnknown()

func (*FieldValue) XXX_Marshal

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

func (*FieldValue) XXX_Merge

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

func (*FieldValue) XXX_OneofWrappers

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*FieldValue) XXX_Size

func (m *FieldValue) XXX_Size() int

func (*FieldValue) XXX_Unmarshal

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

type FieldValue_ArrayValue

type FieldValue_ArrayValue struct {
	ArrayValue *ArrayTypeValue `protobuf:"bytes,2,opt,name=array_value,json=arrayValue,proto3,oneof"`
}

type FieldValue_AtomicValue

type FieldValue_AtomicValue struct {
	AtomicValue *AtomicTypeValue `protobuf:"bytes,1,opt,name=atomic_value,json=atomicValue,proto3,oneof"`
}

type FieldValue_IterableValue

type FieldValue_IterableValue struct {
	IterableValue *IterableTypeValue `protobuf:"bytes,3,opt,name=iterable_value,json=iterableValue,proto3,oneof"`
}

type FieldValue_LogicalTypeValue

type FieldValue_LogicalTypeValue struct {
	LogicalTypeValue *LogicalTypeValue `protobuf:"bytes,6,opt,name=logical_type_value,json=logicalTypeValue,proto3,oneof"`
}

type FieldValue_MapValue

type FieldValue_MapValue struct {
	MapValue *MapTypeValue `protobuf:"bytes,4,opt,name=map_value,json=mapValue,proto3,oneof"`
}

type FieldValue_RowValue

type FieldValue_RowValue struct {
	RowValue *Row `protobuf:"bytes,5,opt,name=row_value,json=rowValue,proto3,oneof"`
}

type FixedWindowsPayload

type FixedWindowsPayload struct {
	// (Required) Represents the size of the window.
	Size *duration.Duration `protobuf:"bytes,1,opt,name=size,proto3" json:"size,omitempty"`
	// (Required) Represents the timestamp of when the first window begins.
	// Window N will start at offset + N * size.
	Offset               *timestamp.Timestamp `protobuf:"bytes,2,opt,name=offset,proto3" json:"offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

A fixed time window represents a consistent duration size, non overlapping time interval in the data stream.

See https://beam.apache.org/documentation/programming-guide/#fixed-time-windows for additional details.

func (*FixedWindowsPayload) Descriptor

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

func (*FixedWindowsPayload) GetOffset

func (m *FixedWindowsPayload) GetOffset() *timestamp.Timestamp

func (*FixedWindowsPayload) GetSize

func (m *FixedWindowsPayload) GetSize() *duration.Duration

func (*FixedWindowsPayload) ProtoMessage

func (*FixedWindowsPayload) ProtoMessage()

func (*FixedWindowsPayload) Reset

func (m *FixedWindowsPayload) Reset()

func (*FixedWindowsPayload) String

func (m *FixedWindowsPayload) String() string

func (*FixedWindowsPayload) XXX_DiscardUnknown

func (m *FixedWindowsPayload) XXX_DiscardUnknown()

func (*FixedWindowsPayload) XXX_Marshal

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

func (*FixedWindowsPayload) XXX_Merge

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

func (*FixedWindowsPayload) XXX_Size

func (m *FixedWindowsPayload) XXX_Size() int

func (*FixedWindowsPayload) XXX_Unmarshal

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

type FixedWindowsPayload_Enum

type FixedWindowsPayload_Enum int32
const (
	FixedWindowsPayload_PROPERTIES FixedWindowsPayload_Enum = 0
)

func (FixedWindowsPayload_Enum) EnumDescriptor

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

func (FixedWindowsPayload_Enum) String

func (x FixedWindowsPayload_Enum) String() string

type FunctionSpec

type FunctionSpec 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,3,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A URN along with a parameter object whose schema is determined by the URN.

This structure is reused in two distinct, but compatible, ways:

  1. This can be a specification of the function over PCollections that a PTransform computes.
  2. This can be a specification of a user-defined function, possibly SDK-specific. (external to this message must be adequate context to indicate the environment in which the UDF can be understood).

Though not explicit in this proto, there are two possibilities for the relationship of a runner to this specification that one should bear in mind:

  1. The runner understands the URN. For example, it might be a well-known URN like "beam:transform:Top" or "beam:window_fn:FixedWindows" with an agreed-upon payload (e.g. a number or duration, respectively).
  2. The runner does not understand the URN. It might be an SDK specific URN such as "beam:dofn:javasdk:1.0" that indicates to the SDK what the payload is, such as a serialized Java DoFn from a particular version of the Beam Java SDK. The payload will often then be an opaque message such as bytes in a language-specific serialization format.

func (*FunctionSpec) Descriptor

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

func (*FunctionSpec) GetPayload

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

func (*FunctionSpec) GetUrn

func (m *FunctionSpec) GetUrn() string

func (*FunctionSpec) ProtoMessage

func (*FunctionSpec) ProtoMessage()

func (*FunctionSpec) Reset

func (m *FunctionSpec) Reset()

func (*FunctionSpec) String

func (m *FunctionSpec) String() string

func (*FunctionSpec) XXX_DiscardUnknown

func (m *FunctionSpec) XXX_DiscardUnknown()

func (*FunctionSpec) XXX_Marshal

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

func (*FunctionSpec) XXX_Merge

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

func (*FunctionSpec) XXX_Size

func (m *FunctionSpec) XXX_Size() int

func (*FunctionSpec) XXX_Unmarshal

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

type GlobalWindowsPayload

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

By default, all data in a PCollection is assigned to the single global window. See BeamConstants for the time span this window encompasses.

See https://beam.apache.org/documentation/programming-guide/#single-global-window for additional details.

func (*GlobalWindowsPayload) Descriptor

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

func (*GlobalWindowsPayload) ProtoMessage

func (*GlobalWindowsPayload) ProtoMessage()

func (*GlobalWindowsPayload) Reset

func (m *GlobalWindowsPayload) Reset()

func (*GlobalWindowsPayload) String

func (m *GlobalWindowsPayload) String() string

func (*GlobalWindowsPayload) XXX_DiscardUnknown

func (m *GlobalWindowsPayload) XXX_DiscardUnknown()

func (*GlobalWindowsPayload) XXX_Marshal

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

func (*GlobalWindowsPayload) XXX_Merge

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

func (*GlobalWindowsPayload) XXX_Size

func (m *GlobalWindowsPayload) XXX_Size() int

func (*GlobalWindowsPayload) XXX_Unmarshal

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

type GlobalWindowsPayload_Enum

type GlobalWindowsPayload_Enum int32
const (
	GlobalWindowsPayload_PROPERTIES GlobalWindowsPayload_Enum = 0
)

func (GlobalWindowsPayload_Enum) EnumDescriptor

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

func (GlobalWindowsPayload_Enum) String

func (x GlobalWindowsPayload_Enum) String() string

type IsBounded

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

func (*IsBounded) Descriptor

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

func (*IsBounded) ProtoMessage

func (*IsBounded) ProtoMessage()

func (*IsBounded) Reset

func (m *IsBounded) Reset()

func (*IsBounded) String

func (m *IsBounded) String() string

func (*IsBounded) XXX_DiscardUnknown

func (m *IsBounded) XXX_DiscardUnknown()

func (*IsBounded) XXX_Marshal

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

func (*IsBounded) XXX_Merge

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

func (*IsBounded) XXX_Size

func (m *IsBounded) XXX_Size() int

func (*IsBounded) XXX_Unmarshal