@@ -1049,13 +1049,80 @@ class TabularDataBySQLResponse extends $pb.GeneratedMessage {
1049
1049
$core.List <$core.List <$core.int >> get rawData => $_getList (0 );
1050
1050
}
1051
1051
1052
+ /// TabularDataSource specifies the data source for user queries to execute on.
1053
+ class TabularDataSource extends $pb.GeneratedMessage {
1054
+ factory TabularDataSource ({
1055
+ TabularDataSourceType ? type,
1056
+ $core.String ? pipelineId,
1057
+ }) {
1058
+ final $result = create ();
1059
+ if (type != null ) {
1060
+ $result.type = type;
1061
+ }
1062
+ if (pipelineId != null ) {
1063
+ $result.pipelineId = pipelineId;
1064
+ }
1065
+ return $result;
1066
+ }
1067
+ TabularDataSource ._() : super ();
1068
+ factory TabularDataSource .fromBuffer ($core.List <$core.int > i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry .EMPTY ]) => create ()..mergeFromBuffer (i, r);
1069
+ factory TabularDataSource .fromJson ($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry .EMPTY ]) => create ()..mergeFromJson (i, r);
1070
+
1071
+ static final $pb.BuilderInfo _i = $pb.BuilderInfo (_omitMessageNames ? '' : 'TabularDataSource' , package: const $pb.PackageName (_omitMessageNames ? '' : 'viam.app.data.v1' ), createEmptyInstance: create)
1072
+ ..e <TabularDataSourceType >(1 , _omitFieldNames ? '' : 'type' , $pb.PbFieldType .OE , defaultOrMaker: TabularDataSourceType .TABULAR_DATA_SOURCE_TYPE_UNSPECIFIED , valueOf: TabularDataSourceType .valueOf, enumValues: TabularDataSourceType .values)
1073
+ ..aOS (2 , _omitFieldNames ? '' : 'pipelineId' )
1074
+ ..hasRequiredFields = false
1075
+ ;
1076
+
1077
+ @$core.Deprecated (
1078
+ 'Using this can add significant overhead to your binary. '
1079
+ 'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
1080
+ 'Will be removed in next major version' )
1081
+ TabularDataSource clone () => TabularDataSource ()..mergeFromMessage (this );
1082
+ @$core.Deprecated (
1083
+ 'Using this can add significant overhead to your binary. '
1084
+ 'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
1085
+ 'Will be removed in next major version' )
1086
+ TabularDataSource copyWith (void Function (TabularDataSource ) updates) => super .copyWith ((message) => updates (message as TabularDataSource )) as TabularDataSource ;
1087
+
1088
+ $pb.BuilderInfo get info_ => _i;
1089
+
1090
+ @$core.pragma ('dart2js:noInline' )
1091
+ static TabularDataSource create () => TabularDataSource ._();
1092
+ TabularDataSource createEmptyInstance () => create ();
1093
+ static $pb.PbList <TabularDataSource > createRepeated () => $pb.PbList <TabularDataSource >();
1094
+ @$core.pragma ('dart2js:noInline' )
1095
+ static TabularDataSource getDefault () => _defaultInstance ?? = $pb.GeneratedMessage .$_defaultFor <TabularDataSource >(create);
1096
+ static TabularDataSource ? _defaultInstance;
1097
+
1098
+ @$pb.TagNumber (1 )
1099
+ TabularDataSourceType get type => $_getN (0 );
1100
+ @$pb.TagNumber (1 )
1101
+ set type (TabularDataSourceType v) { setField (1 , v); }
1102
+ @$pb.TagNumber (1 )
1103
+ $core.bool hasType () => $_has (0 );
1104
+ @$pb.TagNumber (1 )
1105
+ void clearType () => clearField (1 );
1106
+
1107
+ /// pipeline_id is the ID of the pipeline to query. Required when using
1108
+ /// TABULAR_DATA_SOURCE_TYPE_PIPELINE_SINK.
1109
+ @$pb.TagNumber (2 )
1110
+ $core.String get pipelineId => $_getSZ (1 );
1111
+ @$pb.TagNumber (2 )
1112
+ set pipelineId ($core.String v) { $_setString (1 , v); }
1113
+ @$pb.TagNumber (2 )
1114
+ $core.bool hasPipelineId () => $_has (1 );
1115
+ @$pb.TagNumber (2 )
1116
+ void clearPipelineId () => clearField (2 );
1117
+ }
1118
+
1052
1119
/// TabularDataByMQLRequest requests tabular data using an MQL query.
1053
1120
class TabularDataByMQLRequest extends $pb.GeneratedMessage {
1054
1121
factory TabularDataByMQLRequest ({
1055
1122
$core.String ? organizationId,
1056
1123
$core.Iterable <$core.List <$core.int >>? mqlBinary,
1057
1124
$core.bool ? useRecentData,
1058
- $core. String ? useDataPipeline ,
1125
+ TabularDataSource ? dataSource ,
1059
1126
}) {
1060
1127
final $result = create ();
1061
1128
if (organizationId != null ) {
@@ -1067,8 +1134,8 @@ class TabularDataByMQLRequest extends $pb.GeneratedMessage {
1067
1134
if (useRecentData != null ) {
1068
1135
$result.useRecentData = useRecentData;
1069
1136
}
1070
- if (useDataPipeline != null ) {
1071
- $result.useDataPipeline = useDataPipeline ;
1137
+ if (dataSource != null ) {
1138
+ $result.dataSource = dataSource ;
1072
1139
}
1073
1140
return $result;
1074
1141
}
@@ -1080,7 +1147,7 @@ class TabularDataByMQLRequest extends $pb.GeneratedMessage {
1080
1147
..aOS (1 , _omitFieldNames ? '' : 'organizationId' )
1081
1148
..p< $core.List <$core.int >> (3 , _omitFieldNames ? '' : 'mqlBinary' , $pb.PbFieldType .PY )
1082
1149
..aOB (4 , _omitFieldNames ? '' : 'useRecentData' )
1083
- ..aOS ( 5 , _omitFieldNames ? '' : 'useDataPipeline' )
1150
+ ..aOM < TabularDataSource >( 6 , _omitFieldNames ? '' : 'dataSource' , subBuilder : TabularDataSource .create )
1084
1151
..hasRequiredFields = false
1085
1152
;
1086
1153
@@ -1120,6 +1187,7 @@ class TabularDataByMQLRequest extends $pb.GeneratedMessage {
1120
1187
@$pb.TagNumber (3 )
1121
1188
$core.List <$core.List <$core.int >> get mqlBinary => $_getList (1 );
1122
1189
1190
+ /// Deprecated, please use TABULAR_DATA_SOURCE_TYPE_HOT_STORAGE instead.
1123
1191
@$pb.TagNumber (4 )
1124
1192
$core.bool get useRecentData => $_getBF (2 );
1125
1193
@$pb.TagNumber (4 )
@@ -1129,16 +1197,18 @@ class TabularDataByMQLRequest extends $pb.GeneratedMessage {
1129
1197
@$pb.TagNumber (4 )
1130
1198
void clearUseRecentData () => clearField (4 );
1131
1199
1132
- /// if set, MQL query will target the sink collection for the data pipeline name
1133
- /// referenced by this value under the given organization.
1134
- @$pb.TagNumber (5 )
1135
- $core.String get useDataPipeline => $_getSZ (3 );
1136
- @$pb.TagNumber (5 )
1137
- set useDataPipeline ($core.String v) { $_setString (3 , v); }
1138
- @$pb.TagNumber (5 )
1139
- $core.bool hasUseDataPipeline () => $_has (3 );
1140
- @$pb.TagNumber (5 )
1141
- void clearUseDataPipeline () => clearField (5 );
1200
+ /// data_source is an optional field that can be used to specify the data source for the query.
1201
+ /// If not specified, the query will run on "standard" storage.
1202
+ @$pb.TagNumber (6 )
1203
+ TabularDataSource get dataSource => $_getN (3 );
1204
+ @$pb.TagNumber (6 )
1205
+ set dataSource (TabularDataSource v) { setField (6 , v); }
1206
+ @$pb.TagNumber (6 )
1207
+ $core.bool hasDataSource () => $_has (3 );
1208
+ @$pb.TagNumber (6 )
1209
+ void clearDataSource () => clearField (6 );
1210
+ @$pb.TagNumber (6 )
1211
+ TabularDataSource ensureDataSource () => $_ensure (3 );
1142
1212
}
1143
1213
1144
1214
/// TabularDataByMQLResponse provides unified tabular data and metadata, queried with MQL.
0 commit comments