Package viam.app.datapipelines.v1

Class DataPipelines.CreateDataPipelineRequest

java.lang.Object

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

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

viam.app.datapipelines.v1.DataPipelines.CreateDataPipelineRequest

All Implemented Interfaces:

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

Enclosing class:

DataPipelines

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

Protobuf type viam.app.datapipelines.v1.CreateDataPipelineRequest

Nested Class Summary

Nested Classes

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

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	DATA_SOURCE_TYPE_FIELD_NUMBER
static final int	ENABLE_BACKFILL_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

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)
Data.TabularDataSourceType	getDataSourceType()	The type of data source for the pipeline.
int	getDataSourceTypeValue()	The type of data source for the pipeline.
static DataPipelines.CreateDataPipelineRequest	getDefaultInstance()
boolean	getEnableBackfill()	When true, pipeline runs will be scheduled for the organization's past data.
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).
boolean	hasDataSourceType()	The type of data source for the pipeline.
boolean	hasEnableBackfill()	When true, pipeline runs will be scheduled for the organization's past data.
static DataPipelines.CreateDataPipelineRequest.Builder	newBuilder()
static DataPipelines.CreateDataPipelineRequest.Builder	newBuilder(DataPipelines.CreateDataPipelineRequest prototype)
static DataPipelines.CreateDataPipelineRequest	parseDelimitedFrom(InputStream input)
static DataPipelines.CreateDataPipelineRequest	parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static DataPipelines.CreateDataPipelineRequest	parseFrom(byte[] data)
static DataPipelines.CreateDataPipelineRequest	parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static DataPipelines.CreateDataPipelineRequest	parseFrom(com.google.protobuf.ByteString data)
static DataPipelines.CreateDataPipelineRequest	parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static DataPipelines.CreateDataPipelineRequest	parseFrom(com.google.protobuf.CodedInputStream input)
static DataPipelines.CreateDataPipelineRequest	parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static DataPipelines.CreateDataPipelineRequest	parseFrom(InputStream input)
static DataPipelines.CreateDataPipelineRequest	parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static DataPipelines.CreateDataPipelineRequest	parseFrom(ByteBuffer data)
static DataPipelines.CreateDataPipelineRequest	parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static com.google.protobuf.Parser<DataPipelines.CreateDataPipelineRequest>	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

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

ENABLE_BACKFILL_FIELD_NUMBER

public static final int ENABLE_BACKFILL_FIELD_NUMBER

See Also:

• Constant Field Values

DATA_SOURCE_TYPE_FIELD_NUMBER

public static final int DATA_SOURCE_TYPE_FIELD_NUMBER

See Also:

• Constant Field Values

Method Details

getOrganizationId

public String getOrganizationId()

 The associated Viam organization ID.
 

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

Specified by:

getOrganizationId in interface DataPipelines.CreateDataPipelineRequestOrBuilder

Returns:

The organizationId.

getOrganizationIdBytes

public com.google.protobuf.ByteString getOrganizationIdBytes()

 The associated Viam organization ID.
 

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

Specified by:

getOrganizationIdBytes in interface DataPipelines.CreateDataPipelineRequestOrBuilder

Returns:

The bytes for organizationId.

getName

public String getName()

 A unique identifier at the org level.
 

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

Specified by:

getName in interface DataPipelines.CreateDataPipelineRequestOrBuilder

Returns:

The name.

getNameBytes

public com.google.protobuf.ByteString getNameBytes()

 A unique identifier at the org level.
 

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

Specified by:

getNameBytes in interface DataPipelines.CreateDataPipelineRequestOrBuilder

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 = 3 [json_name = "mqlBinary"];

Specified by:

getMqlBinaryList in interface DataPipelines.CreateDataPipelineRequestOrBuilder

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 = 3 [json_name = "mqlBinary"];

Specified by:

getMqlBinaryCount in interface DataPipelines.CreateDataPipelineRequestOrBuilder

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 = 3 [json_name = "mqlBinary"];

Specified by:

getMqlBinary in interface DataPipelines.CreateDataPipelineRequestOrBuilder

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 = 4 [json_name = "schedule"];

Specified by:

getSchedule in interface DataPipelines.CreateDataPipelineRequestOrBuilder

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 = 4 [json_name = "schedule"];

Specified by:

getScheduleBytes in interface DataPipelines.CreateDataPipelineRequestOrBuilder

Returns:

The bytes for schedule.

hasEnableBackfill

public boolean hasEnableBackfill()

 When true, pipeline runs will be scheduled for the organization's past data.
 

optional bool enable_backfill = 5 [json_name = "enableBackfill"];

Specified by:

hasEnableBackfill in interface DataPipelines.CreateDataPipelineRequestOrBuilder

Returns:

Whether the enableBackfill field is set.

getEnableBackfill

public boolean getEnableBackfill()

 When true, pipeline runs will be scheduled for the organization's past data.
 

optional bool enable_backfill = 5 [json_name = "enableBackfill"];

Specified by:

getEnableBackfill in interface DataPipelines.CreateDataPipelineRequestOrBuilder

Returns:

The enableBackfill.

hasDataSourceType

public boolean hasDataSourceType()

 The type of data source for the pipeline. If not specified, default is standard data storage.
 

optional .viam.app.data.v1.TabularDataSourceType data_source_type = 6 [json_name = "dataSourceType"];

Specified by:

hasDataSourceType in interface DataPipelines.CreateDataPipelineRequestOrBuilder

Returns:

Whether the dataSourceType field is set.

getDataSourceTypeValue

public int getDataSourceTypeValue()

 The type of data source for the pipeline. If not specified, default is standard data storage.
 

optional .viam.app.data.v1.TabularDataSourceType data_source_type = 6 [json_name = "dataSourceType"];

Specified by:

getDataSourceTypeValue in interface DataPipelines.CreateDataPipelineRequestOrBuilder

Returns:

The enum numeric value on the wire for dataSourceType.

getDataSourceType

public Data.TabularDataSourceType getDataSourceType()

 The type of data source for the pipeline. If not specified, default is standard data storage.
 

optional .viam.app.data.v1.TabularDataSourceType data_source_type = 6 [json_name = "dataSourceType"];

Specified by:

getDataSourceType in interface DataPipelines.CreateDataPipelineRequestOrBuilder

Returns:

The dataSourceType.

parseFrom

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

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

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

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

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

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static DataPipelines.CreateDataPipelineRequest 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.CreateDataPipelineRequest parseFrom(byte[] data)
                                                         throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

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

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

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

Throws:

IOException

parseFrom

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

Throws:

IOException

parseDelimitedFrom

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

Throws:

IOException

parseDelimitedFrom

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

Throws:

IOException

parseFrom

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

Throws:

IOException

parseFrom

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

Throws:

IOException

newBuilder

public static DataPipelines.CreateDataPipelineRequest.Builder newBuilder()

newBuilder

public static DataPipelines.CreateDataPipelineRequest.Builder newBuilder(DataPipelines.CreateDataPipelineRequest 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.CreateDataPipelineRequest,DataPipelines.CreateDataPipelineRequest.Builder>

getDefaultInstance

public static DataPipelines.CreateDataPipelineRequest getDefaultInstance()

parser

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