Package viam.app.datapipelines.v1

Class DataPipelines.DataPipeline

java.lang.Object

com.google.protobuf.AbstractMessageLite<MessageType,BuilderType>

com.google.protobuf.GeneratedMessageLite<DataPipelines.DataPipeline,DataPipelines.DataPipeline.Builder>

viam.app.datapipelines.v1.DataPipelines.DataPipeline

All Implemented Interfaces:

com.google.protobuf.MessageLite, com.google.protobuf.MessageLiteOrBuilder, DataPipelines.DataPipelineOrBuilder

Enclosing class:

DataPipelines

public static final class DataPipelines.DataPipeline
extends com.google.protobuf.GeneratedMessageLite<DataPipelines.DataPipeline,DataPipelines.DataPipeline.Builder>
implements DataPipelines.DataPipelineOrBuilder

Protobuf type viam.app.datapipelines.v1.DataPipeline

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	DataPipelines.DataPipeline.Builder	Protobuf type viam.app.datapipelines.v1.DataPipeline

Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessageLite

com.google.protobuf.GeneratedMessageLite.DefaultInstanceBasedParser<T extends com.google.protobuf.GeneratedMessageLite<T,?>>, com.google.protobuf.GeneratedMessageLite.ExtendableBuilder<MessageType extends com.google.protobuf.GeneratedMessageLite.ExtendableMessage<MessageType,BuilderType>,BuilderType extends com.google.protobuf.GeneratedMessageLite.ExtendableBuilder<MessageType,BuilderType>>, com.google.protobuf.GeneratedMessageLite.ExtendableMessage<MessageType extends com.google.protobuf.GeneratedMessageLite.ExtendableMessage<MessageType,BuilderType>,BuilderType extends com.google.protobuf.GeneratedMessageLite.ExtendableBuilder<MessageType,BuilderType>>, com.google.protobuf.GeneratedMessageLite.ExtendableMessageOrBuilder<MessageType extends com.google.protobuf.GeneratedMessageLite.ExtendableMessage<MessageType,BuilderType>,BuilderType extends com.google.protobuf.GeneratedMessageLite.ExtendableBuilder<MessageType,BuilderType>>, com.google.protobuf.GeneratedMessageLite.GeneratedExtension<ContainingType extends com.google.protobuf.MessageLite,Type extends Object>, com.google.protobuf.GeneratedMessageLite.MethodToInvoke, com.google.protobuf.GeneratedMessageLite.SerializedForm

Nested classes/interfaces inherited from class com.google.protobuf.AbstractMessageLite

com.google.protobuf.AbstractMessageLite.InternalOneOfEnum

Field Summary

Fields

Modifier and Type	Field	Description
static final int	CREATED_ON_FIELD_NUMBER
static final int	ENABLED_FIELD_NUMBER
static final int	ID_FIELD_NUMBER
static final int	MQL_BINARY_FIELD_NUMBER
static final int	NAME_FIELD_NUMBER
static final int	ORGANIZATION_ID_FIELD_NUMBER
static final int	SCHEDULE_FIELD_NUMBER
static final int	UPDATED_AT_FIELD_NUMBER

Fields inherited from class com.google.protobuf.GeneratedMessageLite

unknownFields

Fields inherited from class com.google.protobuf.AbstractMessageLite

memoizedHashCode

Method Summary

Modifier and Type	Method	Description
protected final Object	dynamicMethod(com.google.protobuf.GeneratedMessageLite.MethodToInvoke method, Object arg0, Object arg1)
com.google.protobuf.Timestamp	getCreatedOn()	The time the pipeline was created.
static DataPipelines.DataPipeline	getDefaultInstance()
boolean	getEnabled()	Whether or not the pipeline is enabled.
String	getId()	string id = 1 [json_name = "id"];
com.google.protobuf.ByteString	getIdBytes()	string id = 1 [json_name = "id"];
com.google.protobuf.ByteString	getMqlBinary(int index)	A MongoDB aggregation pipeline as a list of BSON documents, where each document is one stage in the pipeline.
int	getMqlBinaryCount()	A MongoDB aggregation pipeline as a list of BSON documents, where each document is one stage in the pipeline.
List<com.google.protobuf.ByteString>	getMqlBinaryList()	A MongoDB aggregation pipeline as a list of BSON documents, where each document is one stage in the pipeline.
String	getName()	A unique identifier at the org level.
com.google.protobuf.ByteString	getNameBytes()	A unique identifier at the org level.
String	getOrganizationId()	The associated Viam organization ID.
com.google.protobuf.ByteString	getOrganizationIdBytes()	The associated Viam organization ID.
String	getSchedule()	A cron expression representing the expected execution schedule in UTC (note this also defines the input time window; an hourly schedule would process 1 hour of data at a time).
com.google.protobuf.ByteString	getScheduleBytes()	A cron expression representing the expected execution schedule in UTC (note this also defines the input time window; an hourly schedule would process 1 hour of data at a time).
com.google.protobuf.Timestamp	getUpdatedAt()	The time the pipeline was last updated.
boolean	hasCreatedOn()	The time the pipeline was created.
boolean	hasUpdatedAt()	The time the pipeline was last updated.
static DataPipelines.DataPipeline.Builder	newBuilder()
static DataPipelines.DataPipeline.Builder	newBuilder(DataPipelines.DataPipeline prototype)
static DataPipelines.DataPipeline	parseDelimitedFrom(InputStream input)
static DataPipelines.DataPipeline	parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static DataPipelines.DataPipeline	parseFrom(byte[] data)
static DataPipelines.DataPipeline	parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static DataPipelines.DataPipeline	parseFrom(com.google.protobuf.ByteString data)
static DataPipelines.DataPipeline	parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static DataPipelines.DataPipeline	parseFrom(com.google.protobuf.CodedInputStream input)
static DataPipelines.DataPipeline	parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static DataPipelines.DataPipeline	parseFrom(InputStream input)
static DataPipelines.DataPipeline	parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static DataPipelines.DataPipeline	parseFrom(ByteBuffer data)
static DataPipelines.DataPipeline	parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static com.google.protobuf.Parser<DataPipelines.DataPipeline>	parser()

Methods inherited from class com.google.protobuf.GeneratedMessageLite

createBuilder, createBuilder, dynamicMethod, dynamicMethod, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyLongList, emptyProtobufList, equals, getDefaultInstanceForType, getParserForType, getSerializedSize, hashCode, isInitialized, isInitialized, makeImmutable, mergeLengthDelimitedField, mergeUnknownFields, mergeVarintField, mutableCopy, mutableCopy, mutableCopy, mutableCopy, mutableCopy, mutableCopy, newBuilderForType, newMessageInfo, newRepeatedGeneratedExtension, newSingularGeneratedExtension, parseDelimitedFrom, parseDelimitedFrom, parseFrom, parseFrom, parseFrom, parseFrom, parseFrom, parseFrom, parseFrom, parseFrom, parseFrom, parseFrom, parsePartialFrom, parseUnknownField, registerDefaultInstance, toBuilder, toString, writeTo

Methods inherited from class com.google.protobuf.AbstractMessageLite

addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeTo

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.google.protobuf.MessageLiteOrBuilder

getDefaultInstanceForType, isInitialized

Field Details

ID_FIELD_NUMBER

public static final int ID_FIELD_NUMBER

See Also:

• Constant Field Values

ORGANIZATION_ID_FIELD_NUMBER

public static final int ORGANIZATION_ID_FIELD_NUMBER

See Also:

• Constant Field Values

NAME_FIELD_NUMBER

public static final int NAME_FIELD_NUMBER

See Also:

• Constant Field Values

MQL_BINARY_FIELD_NUMBER

public static final int MQL_BINARY_FIELD_NUMBER

See Also:

• Constant Field Values

SCHEDULE_FIELD_NUMBER

public static final int SCHEDULE_FIELD_NUMBER

See Also:

• Constant Field Values

ENABLED_FIELD_NUMBER

public static final int ENABLED_FIELD_NUMBER

See Also:

• Constant Field Values

CREATED_ON_FIELD_NUMBER

public static final int CREATED_ON_FIELD_NUMBER

See Also:

• Constant Field Values

UPDATED_AT_FIELD_NUMBER

public static final int UPDATED_AT_FIELD_NUMBER

See Also:

• Constant Field Values

Method Details

getId

public String getId()

string id = 1 [json_name = "id"];

Specified by:

getId in interface DataPipelines.DataPipelineOrBuilder

Returns:

The id.

getIdBytes

public com.google.protobuf.ByteString getIdBytes()

string id = 1 [json_name = "id"];

Specified by:

getIdBytes in interface DataPipelines.DataPipelineOrBuilder

Returns:

The bytes for id.

getOrganizationId

public String getOrganizationId()

 The associated Viam organization ID.
 

string organization_id = 2 [json_name = "organizationId"];

Specified by:

getOrganizationId in interface DataPipelines.DataPipelineOrBuilder

Returns:

The organizationId.

getOrganizationIdBytes

public com.google.protobuf.ByteString getOrganizationIdBytes()

 The associated Viam organization ID.
 

string organization_id = 2 [json_name = "organizationId"];

Specified by:

getOrganizationIdBytes in interface DataPipelines.DataPipelineOrBuilder

Returns:

The bytes for organizationId.

getName

public String getName()

 A unique identifier at the org level.
 

string name = 3 [json_name = "name"];

Specified by:

getName in interface DataPipelines.DataPipelineOrBuilder

Returns:

The name.

getNameBytes

public com.google.protobuf.ByteString getNameBytes()

 A unique identifier at the org level.
 

string name = 3 [json_name = "name"];

Specified by:

getNameBytes in interface DataPipelines.DataPipelineOrBuilder

Returns:

The bytes for name.

getMqlBinaryList

public List<com.google.protobuf.ByteString> getMqlBinaryList()

 A MongoDB aggregation pipeline as a list of BSON documents, where
 each document is one stage in the pipeline.
 

repeated bytes mql_binary = 4 [json_name = "mqlBinary"];

Specified by:

getMqlBinaryList in interface DataPipelines.DataPipelineOrBuilder

Returns:

A list containing the mqlBinary.

getMqlBinaryCount

public int getMqlBinaryCount()

 A MongoDB aggregation pipeline as a list of BSON documents, where
 each document is one stage in the pipeline.
 

repeated bytes mql_binary = 4 [json_name = "mqlBinary"];

Specified by:

getMqlBinaryCount in interface DataPipelines.DataPipelineOrBuilder

Returns:

The count of mqlBinary.

getMqlBinary

public com.google.protobuf.ByteString getMqlBinary(int index)

 A MongoDB aggregation pipeline as a list of BSON documents, where
 each document is one stage in the pipeline.
 

repeated bytes mql_binary = 4 [json_name = "mqlBinary"];

Specified by:

getMqlBinary in interface DataPipelines.DataPipelineOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The mqlBinary at the given index.

getSchedule

public String getSchedule()

 A cron expression representing the expected execution schedule in UTC (note this also
 defines the input time window; an hourly schedule would process 1 hour of data at a time).
 

string schedule = 5 [json_name = "schedule"];

Specified by:

getSchedule in interface DataPipelines.DataPipelineOrBuilder

Returns:

The schedule.

getScheduleBytes

public com.google.protobuf.ByteString getScheduleBytes()

 A cron expression representing the expected execution schedule in UTC (note this also
 defines the input time window; an hourly schedule would process 1 hour of data at a time).
 

string schedule = 5 [json_name = "schedule"];

Specified by:

getScheduleBytes in interface DataPipelines.DataPipelineOrBuilder

Returns:

The bytes for schedule.

getEnabled

public boolean getEnabled()

 Whether or not the pipeline is enabled.
 

bool enabled = 6 [json_name = "enabled"];

Specified by:

getEnabled in interface DataPipelines.DataPipelineOrBuilder

Returns:

The enabled.

hasCreatedOn

public boolean hasCreatedOn()

 The time the pipeline was created.
 

.google.protobuf.Timestamp created_on = 7 [json_name = "createdOn"];

Specified by:

hasCreatedOn in interface DataPipelines.DataPipelineOrBuilder

Returns:

Whether the createdOn field is set.

getCreatedOn

public com.google.protobuf.Timestamp getCreatedOn()

 The time the pipeline was created.
 

.google.protobuf.Timestamp created_on = 7 [json_name = "createdOn"];

Specified by:

getCreatedOn in interface DataPipelines.DataPipelineOrBuilder

Returns:

The createdOn.

hasUpdatedAt

public boolean hasUpdatedAt()

 The time the pipeline was last updated.
 

.google.protobuf.Timestamp updated_at = 8 [json_name = "updatedAt"];

Specified by:

hasUpdatedAt in interface DataPipelines.DataPipelineOrBuilder

Returns:

Whether the updatedAt field is set.

getUpdatedAt

public com.google.protobuf.Timestamp getUpdatedAt()

 The time the pipeline was last updated.
 

.google.protobuf.Timestamp updated_at = 8 [json_name = "updatedAt"];

Specified by:

getUpdatedAt in interface DataPipelines.DataPipelineOrBuilder

Returns:

The updatedAt.

parseFrom

public static DataPipelines.DataPipeline parseFrom(ByteBuffer data)
                                            throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static DataPipelines.DataPipeline parseFrom(ByteBuffer data,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                            throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static DataPipelines.DataPipeline parseFrom(com.google.protobuf.ByteString data)
                                            throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static DataPipelines.DataPipeline parseFrom(com.google.protobuf.ByteString data,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                            throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static DataPipelines.DataPipeline parseFrom(byte[] data)
                                            throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static DataPipelines.DataPipeline parseFrom(byte[] data,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                            throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static DataPipelines.DataPipeline parseFrom(InputStream input)
                                            throws IOException

Throws:

IOException

parseFrom

public static DataPipelines.DataPipeline parseFrom(InputStream input,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                            throws IOException

Throws:

IOException

parseDelimitedFrom

public static DataPipelines.DataPipeline parseDelimitedFrom(InputStream input)
                                                     throws IOException

Throws:

IOException

parseDelimitedFrom

public static DataPipelines.DataPipeline parseDelimitedFrom(InputStream input,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                     throws IOException

Throws:

IOException

parseFrom

public static DataPipelines.DataPipeline parseFrom(com.google.protobuf.CodedInputStream input)
                                            throws IOException

Throws:

IOException

parseFrom

public static DataPipelines.DataPipeline parseFrom(com.google.protobuf.CodedInputStream input,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                            throws IOException

Throws:

IOException

newBuilder

public static DataPipelines.DataPipeline.Builder newBuilder()

newBuilder

public static DataPipelines.DataPipeline.Builder newBuilder(DataPipelines.DataPipeline prototype)

dynamicMethod

protected final Object dynamicMethod(com.google.protobuf.GeneratedMessageLite.MethodToInvoke method,
 Object arg0,
 Object arg1)

Specified by:

dynamicMethod in class com.google.protobuf.GeneratedMessageLite<DataPipelines.DataPipeline,DataPipelines.DataPipeline.Builder>

getDefaultInstance

public static DataPipelines.DataPipeline getDefaultInstance()

parser

public static com.google.protobuf.Parser<DataPipelines.DataPipeline> parser()