@@ -44,11 +44,11 @@ namespace NYql::NDq {
44
44
45
45
template <typename T>
46
46
T ExtractFromConstFuture (const NThreading::TFuture<T>& f) {
47
- // We want to avoid making a copy of data stored in a future.
48
- // But there is no direct way to extract data from a const future5
49
- // So, we make a copy of the future, that is cheap. Then, extract the value from this copy.
50
- // It destructs the value in the original future, but this trick is legal and documented here:
51
- // https://docs.yandex-team.ru/arcadia-cpp/cookbook/concurrency
47
+ // We want to avoid making a copy of data stored in a future.
48
+ // But there is no direct way to extract data from a const future5
49
+ // So, we make a copy of the future, that is cheap. Then, extract the value from this copy.
50
+ // It destructs the value in the original future, but this trick is legal and documented here:
51
+ // https://docs.yandex-team.ru/arcadia-cpp/cookbook/concurrency
52
52
return NThreading::TFuture<T>(f).ExtractValueSync ();
53
53
}
54
54
@@ -112,7 +112,7 @@ namespace NYql::NDq {
112
112
113
113
static constexpr char ActorName[] = " GENERIC_PROVIDER_LOOKUP_ACTOR" ;
114
114
115
- private: // IDqAsyncLookupSource
115
+ private: // IDqAsyncLookupSource
116
116
size_t GetMaxSupportedKeysInRequest () const override {
117
117
return MaxKeysInRequest;
118
118
}
@@ -121,7 +121,7 @@ namespace NYql::NDq {
121
121
CreateRequest (std::move (request));
122
122
}
123
123
124
- private: // events
124
+ private: // events
125
125
STRICT_STFUNC (StateFunc,
126
126
hFunc (TEvListSplitsIterator, Handle);
127
127
hFunc (TEvListSplitsPart, Handle);
@@ -238,7 +238,7 @@ namespace NYql::NDq {
238
238
void ProcessReceivedData (const NConnector::NApi::TReadSplitsResponse& resp) {
239
239
Y_ABORT_UNLESS (resp.payload_case () == NConnector::NApi::TReadSplitsResponse::PayloadCase::kArrowIpcStreaming );
240
240
auto guard = Guard (*Alloc);
241
- NKikimr::NArrow::NSerialization::TSerializerContainer deser = NKikimr::NArrow::NSerialization::TSerializerContainer::GetDefaultSerializer (); // todo move to class' member
241
+ NKikimr::NArrow::NSerialization::TSerializerContainer deser = NKikimr::NArrow::NSerialization::TSerializerContainer::GetDefaultSerializer (); // todo move to class' member
242
242
const auto & data = deser->Deserialize (resp.arrow_ipc_streaming ());
243
243
Y_ABORT_UNLESS (data.ok ());
244
244
const auto & value = data.ValueOrDie ();
@@ -259,7 +259,7 @@ namespace NYql::NDq {
259
259
(ColumnDestinations[j].first == EColumnDestination::Key ? keyItems : outputItems)[ColumnDestinations[j].second ] = columns[j][i];
260
260
}
261
261
if (auto * v = Request.FindPtr (key)) {
262
- *v = std::move (output); // duplicates will be overwritten
262
+ *v = std::move (output); // duplicates will be overwritten
263
263
}
264
264
}
265
265
}
@@ -316,8 +316,8 @@ namespace NYql::NDq {
316
316
317
317
NYql::NConnector::NApi::TDataSourceInstance GetDataSourceInstanceWithToken () const {
318
318
auto dsi = LookupSource.data_source_instance ();
319
- // Note: returned token may be stale and we have no way to check or recover here
320
- // Consider to redesign ICredentialsProvider
319
+ // Note: returned token may be stale and we have no way to check or recover here
320
+ // Consider to redesign ICredentialsProvider
321
321
TokenProvider->MaybeFillToken (dsi);
322
322
return dsi;
323
323
}
@@ -361,13 +361,13 @@ namespace NYql::NDq {
361
361
const NYql::Generic::TLookupSource LookupSource;
362
362
const NKikimr::NMiniKQL::TStructType* const KeyType;
363
363
const NKikimr::NMiniKQL::TStructType* const PayloadType;
364
- const NKikimr::NMiniKQL::TStructType* const SelectResultType; // columns from KeyType + PayloadType
364
+ const NKikimr::NMiniKQL::TStructType* const SelectResultType; // columns from KeyType + PayloadType
365
365
const NKikimr::NMiniKQL::THolderFactory& HolderFactory;
366
366
const std::vector<std::pair<EColumnDestination, size_t >> ColumnDestinations;
367
367
const size_t MaxKeysInRequest;
368
368
std::atomic_bool InProgress;
369
369
IDqAsyncLookupSource::TUnboxedValueMap Request;
370
- NConnector::IReadSplitsStreamIterator::TPtr ReadSplitsIterator; // TODO move me to TEvReadSplitsPart
370
+ NConnector::IReadSplitsStreamIterator::TPtr ReadSplitsIterator; // TODO move me to TEvReadSplitsPart
371
371
NKikimr::NMiniKQL::TKeyPayloadPairVector LookupResult;
372
372
};
373
373
0 commit comments