File tree 1 file changed +6
-2
lines changed
1 file changed +6
-2
lines changed Original file line number Diff line number Diff line change @@ -2169,7 +2169,7 @@ class TConverter : public IPGParseEvents {
2169
2169
AddError (TStringBuilder () << " VariableSetStmt, expected string literal for " << value->name << " option" );
2170
2170
return nullptr ;
2171
2171
}
2172
- } else if (name.StartsWith (" dq." ) || name.StartsWith (" yt." ) || name.StartsWith (" s3." )) {
2172
+ } else if (name.StartsWith (" dq." ) || name.StartsWith (" yt." ) || name.StartsWith (" s3." ) || name. StartsWith ( " ydb. " ) ) {
2173
2173
if (ListLength (value->args ) != 1 ) {
2174
2174
AddError (TStringBuilder () << " VariableSetStmt, expected 1 arg, but got: " << ListLength (value->args ));
2175
2175
return nullptr ;
@@ -2184,8 +2184,12 @@ class TConverter : public IPGParseEvents {
2184
2184
providerName = NYql::DqProviderName;
2185
2185
} else if (name.StartsWith (" yt." )) {
2186
2186
providerName = NYql::YtProviderName;
2187
- } else {
2187
+ } else if (name. StartsWith ( " s3. " )) {
2188
2188
providerName = NYql::S3ProviderName;
2189
+ } else if (name.StartsWith (" ydb." )) {
2190
+ providerName = NYql::YdbProviderName;
2191
+ } else {
2192
+ Y_ASSERT (0 );
2189
2193
}
2190
2194
2191
2195
auto providerSource = L (A (" DataSource" ), QA (providerName), QA (" $all" ));
You can’t perform that action at this time.
0 commit comments