-
Notifications
You must be signed in to change notification settings - Fork 606
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
YQ-2068 YT emu lookup source actor #4869
YQ-2068 YT emu lookup source actor #4869
Conversation
⚪
|
⚪
|
return MaxKeysInRequest; | ||
} | ||
void AsyncLookup(const NKikimr::NMiniKQL::TUnboxedValueVector& keys) override { | ||
YQL_CLOG(INFO, ProviderGeneric) << "ActorId=" << SelfId() << " Got LookupRequest for " << keys.size() << " keys"; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Почему ProviderGeneric? И кажется INFO слишком вербозный для ээтого события
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
fixed
auto guard = Guard(*Alloc); | ||
KeyTypeHelper = TKeyTypeHelper{}; | ||
Data = TTableData(0, KeyTypeHelper.GetValueHash(), KeyTypeHelper.GetValueEqual()); | ||
Data.clear(); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
выглядит лишним вместе с предыдущей строкой
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
fixed
, TypeEnv(typeEnv) | ||
, MaxKeysInRequest(maxKeysInRequest) | ||
, KeyTypeHelper(keyType) | ||
, Data(1000, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Это reserve capacity? Зачем такой большой с учетом использования только для тестов?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
fixed
|
||
|
||
void Bootstrap() { | ||
YQL_CLOG(INFO, ProviderGeneric) << "New Yt proivider lookup source actor(ActorId=" << SelfId() << ") for" |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Почему ProviderGeneric?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
fixed
Y_ABORT_UNLESS(lookupResult.back().first.IsBoxed()); | ||
Y_ABORT_UNLESS(!lookupResult.back().second || lookupResult.back().second.IsBoxed()); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Откуда эти ограничения?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
fixed
|
||
namespace NYql::NDq { | ||
|
||
std::pair<NYql::NDq::IDqAsyncLookupSource*, NActors::IActor*> CreateYtLookupActor( |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Где это подключается кроме ut?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
будет в dq
⚪
|
⚪
|
⚪
|
⚪
|
Changelog category