summaryrefslogtreecommitdiffstats
path: root/yql/essentials/minikql/computation/mkql_value_builder.cpp
diff options
context:
space:
mode:
authorvvvv <[email protected]>2025-10-09 12:25:18 +0300
committervvvv <[email protected]>2025-10-09 12:57:17 +0300
commitcb77d014972b2cdb27d2e6d979fc3a2772b27ad4 (patch)
tree7f3bcd8ce71c6bd0f3ccc11e31b9f665475b819e /yql/essentials/minikql/computation/mkql_value_builder.cpp
parentd58a8990d353b051c27e1069141117fdfde64358 (diff)
YQL-20086 minikql
commit_hash:e96f7390db5fcbe7e9f64f898141a263ad522daa
Diffstat (limited to 'yql/essentials/minikql/computation/mkql_value_builder.cpp')
-rw-r--r--yql/essentials/minikql/computation/mkql_value_builder.cpp76
1 files changed, 30 insertions, 46 deletions
diff --git a/yql/essentials/minikql/computation/mkql_value_builder.cpp b/yql/essentials/minikql/computation/mkql_value_builder.cpp
index e0bda9dd048..0f4eebca115 100644
--- a/yql/essentials/minikql/computation/mkql_value_builder.cpp
+++ b/yql/essentials/minikql/computation/mkql_value_builder.cpp
@@ -24,7 +24,8 @@ TDefaultValueBuilder::TDefaultValueBuilder(const THolderFactory& holderFactory,
: HolderFactory_(holderFactory)
, Policy_(policy)
, PgBuilder_(NYql::CreatePgBuilder())
-{}
+{
+}
void TDefaultValueBuilder::SetSecureParamsProvider(const NUdf::ISecureParamsProvider* provider) {
SecureParamsProvider_ = provider;
@@ -40,8 +41,7 @@ void TDefaultValueBuilder::SetCalleePositionHolder(const NUdf::TSourcePosition*&
void TDefaultValueBuilder::Terminate(const char* message) const {
TStringBuf reason = (message ? TStringBuf(message) : TStringBuf("(unknown)"));
- TString fullMessage = TStringBuilder() <<
- "Terminate was called, reason(" << reason.size() << "): " << reason << Endl;
+ TString fullMessage = TStringBuilder() << "Terminate was called, reason(" << reason.size() << "): " << reason << Endl;
HolderFactory_.CleanupModulesOnTerminate();
if (Policy_ == NUdf::EValidatePolicy::Exception) {
if (Rethrow_ && std::current_exception()) {
@@ -56,33 +56,27 @@ void TDefaultValueBuilder::Terminate(const char* message) const {
_exit(1);
}
-NUdf::TUnboxedValue TDefaultValueBuilder::NewStringNotFilled(ui32 size) const
-{
+NUdf::TUnboxedValue TDefaultValueBuilder::NewStringNotFilled(ui32 size) const {
return MakeStringNotFilled(size);
}
-NUdf::TUnboxedValue TDefaultValueBuilder::NewString(const NUdf::TStringRef& ref) const
-{
+NUdf::TUnboxedValue TDefaultValueBuilder::NewString(const NUdf::TStringRef& ref) const {
return MakeString(ref);
}
-NUdf::TUnboxedValue TDefaultValueBuilder::ConcatStrings(NUdf::TUnboxedValuePod first, NUdf::TUnboxedValuePod second) const
-{
+NUdf::TUnboxedValue TDefaultValueBuilder::ConcatStrings(NUdf::TUnboxedValuePod first, NUdf::TUnboxedValuePod second) const {
return ::NKikimr::NMiniKQL::ConcatStrings(first, second);
}
-NUdf::TUnboxedValue TDefaultValueBuilder::AppendString(NUdf::TUnboxedValuePod value, const NUdf::TStringRef& ref) const
-{
+NUdf::TUnboxedValue TDefaultValueBuilder::AppendString(NUdf::TUnboxedValuePod value, const NUdf::TStringRef& ref) const {
return ::NKikimr::NMiniKQL::AppendString(value, ref);
}
-NUdf::TUnboxedValue TDefaultValueBuilder::PrependString(const NUdf::TStringRef& ref, NUdf::TUnboxedValuePod value) const
-{
+NUdf::TUnboxedValue TDefaultValueBuilder::PrependString(const NUdf::TStringRef& ref, NUdf::TUnboxedValuePod value) const {
return ::NKikimr::NMiniKQL::PrependString(ref, value);
}
-NUdf::TUnboxedValue TDefaultValueBuilder::SubString(NUdf::TUnboxedValuePod value, ui32 offset, ui32 size) const
-{
+NUdf::TUnboxedValue TDefaultValueBuilder::SubString(NUdf::TUnboxedValuePod value, ui32 offset, ui32 size) const {
return ::NKikimr::NMiniKQL::SubString(value, offset, size);
}
@@ -98,23 +92,19 @@ NUdf::TUnboxedValue TDefaultValueBuilder::NewList(NUdf::TUnboxedValue* items, ui
return array;
}
-NUdf::TUnboxedValue TDefaultValueBuilder::ReverseList(const NUdf::TUnboxedValuePod& list) const
-{
+NUdf::TUnboxedValue TDefaultValueBuilder::ReverseList(const NUdf::TUnboxedValuePod& list) const {
return HolderFactory_.ReverseList(this, list);
}
-NUdf::TUnboxedValue TDefaultValueBuilder::SkipList(const NUdf::TUnboxedValuePod& list, ui64 count) const
-{
+NUdf::TUnboxedValue TDefaultValueBuilder::SkipList(const NUdf::TUnboxedValuePod& list, ui64 count) const {
return HolderFactory_.SkipList(this, list, count);
}
-NUdf::TUnboxedValue TDefaultValueBuilder::TakeList(const NUdf::TUnboxedValuePod& list, ui64 count) const
-{
+NUdf::TUnboxedValue TDefaultValueBuilder::TakeList(const NUdf::TUnboxedValuePod& list, ui64 count) const {
return HolderFactory_.TakeList(this, list, count);
}
-NUdf::TUnboxedValue TDefaultValueBuilder::ToIndexDict(const NUdf::TUnboxedValuePod& list) const
-{
+NUdf::TUnboxedValue TDefaultValueBuilder::ToIndexDict(const NUdf::TUnboxedValuePod& list) const {
return HolderFactory_.ToIndexDict(this, list);
}
@@ -130,8 +120,7 @@ NUdf::TUnboxedValue TDefaultValueBuilder::NewVariant(ui32 index, NUdf::TUnboxedV
return HolderFactory_.CreateVariantHolder(value.Release(), index);
}
-NUdf::IDictValueBuilder::TPtr TDefaultValueBuilder::NewDict(const NUdf::TType* dictType, ui32 flags) const
-{
+NUdf::IDictValueBuilder::TPtr TDefaultValueBuilder::NewDict(const NUdf::TType* dictType, ui32 flags) const {
return HolderFactory_.NewDict(dictType, flags);
}
@@ -143,35 +132,33 @@ bool TDefaultValueBuilder::SplitDate(ui16 value, ui32& year, ui32& month, ui32&
return ::NKikimr::NMiniKQL::SplitDate(value, year, month, day);
}
-bool TDefaultValueBuilder::MakeDatetime(ui32 year, ui32 month, ui32 day, ui32 hour, ui32 minute, ui32 second, ui32& value, ui16 tzId) const
-{
+bool TDefaultValueBuilder::MakeDatetime(ui32 year, ui32 month, ui32 day, ui32 hour, ui32 minute, ui32 second, ui32& value, ui16 tzId) const {
return ::NKikimr::NMiniKQL::MakeTzDatetime(year, month, day, hour, minute, second, value, tzId);
}
-bool TDefaultValueBuilder::SplitDatetime(ui32 value, ui32& year, ui32& month, ui32& day, ui32& hour, ui32& minute, ui32& second, ui16 tzId) const
-{
+bool TDefaultValueBuilder::SplitDatetime(ui32 value, ui32& year, ui32& month, ui32& day, ui32& hour, ui32& minute, ui32& second, ui16 tzId) const {
return ::NKikimr::NMiniKQL::SplitTzDatetime(value, year, month, day, hour, minute, second, tzId);
}
bool TDefaultValueBuilder::FullSplitDate(ui16 value, ui32& year, ui32& month, ui32& day,
- ui32& dayOfYear, ui32& weekOfYear, ui32& dayOfWeek, ui16 tzId) const {
+ ui32& dayOfYear, ui32& weekOfYear, ui32& dayOfWeek, ui16 tzId) const {
ui32 unusedWeekOfYearIso8601 = 0;
return ::NKikimr::NMiniKQL::SplitTzDate(value, year, month, day, dayOfYear, weekOfYear, unusedWeekOfYearIso8601, dayOfWeek, tzId);
}
bool TDefaultValueBuilder::FullSplitDate2(ui16 value, ui32& year, ui32& month, ui32& day,
- ui32& dayOfYear, ui32& weekOfYear, ui32& weekOfYearIso8601, ui32& dayOfWeek, ui16 tzId) const {
+ ui32& dayOfYear, ui32& weekOfYear, ui32& weekOfYearIso8601, ui32& dayOfWeek, ui16 tzId) const {
return ::NKikimr::NMiniKQL::SplitTzDate(value, year, month, day, dayOfYear, weekOfYear, weekOfYearIso8601, dayOfWeek, tzId);
}
bool TDefaultValueBuilder::FullSplitDatetime(ui32 value, ui32& year, ui32& month, ui32& day, ui32& hour, ui32& minute, ui32& second,
- ui32& dayOfYear, ui32& weekOfYear, ui32& dayOfWeek, ui16 tzId) const {
+ ui32& dayOfYear, ui32& weekOfYear, ui32& dayOfWeek, ui16 tzId) const {
ui32 unusedWeekOfYearIso8601 = 0;
return ::NKikimr::NMiniKQL::SplitTzDatetime(value, year, month, day, hour, minute, second, dayOfYear, weekOfYear, unusedWeekOfYearIso8601, dayOfWeek, tzId);
}
bool TDefaultValueBuilder::FullSplitDatetime2(ui32 value, ui32& year, ui32& month, ui32& day, ui32& hour, ui32& minute, ui32& second,
- ui32& dayOfYear, ui32& weekOfYear, ui32& weekOfYearIso8601, ui32& dayOfWeek, ui16 tzId) const {
+ ui32& dayOfYear, ui32& weekOfYear, ui32& weekOfYearIso8601, ui32& dayOfWeek, ui16 tzId) const {
return ::NKikimr::NMiniKQL::SplitTzDatetime(value, year, month, day, hour, minute, second, dayOfYear, weekOfYear, weekOfYearIso8601, dayOfWeek, tzId);
}
@@ -184,8 +171,7 @@ bool TDefaultValueBuilder::EnrichDate2(ui16 date, ui32& dayOfYear, ui32& weekOfY
return ::NKikimr::NMiniKQL::EnrichDate(date, dayOfYear, weekOfYear, weekOfYearIso8601, dayOfWeek);
}
-bool TDefaultValueBuilder::GetTimezoneShift(ui32 year, ui32 month, ui32 day, ui32 hour, ui32 minute, ui32 second, ui16 tzId, i32& value) const
-{
+bool TDefaultValueBuilder::GetTimezoneShift(ui32 year, ui32 month, ui32 day, ui32 hour, ui32 minute, ui32 second, ui16 tzId, i32& value) const {
return ::NKikimr::NMiniKQL::GetTimezoneShift(year, month, day, hour, minute, second, tzId, value);
}
@@ -318,24 +304,23 @@ bool TDefaultValueBuilder::FindTimezoneId(const NUdf::TStringRef& name, ui32& id
}
bool TDefaultValueBuilder::GetSecureParam(NUdf::TStringRef key, NUdf::TStringRef& value) const {
- if (SecureParamsProvider_)
+ if (SecureParamsProvider_) {
return SecureParamsProvider_->GetSecureParam(key, value);
+ }
return false;
}
bool TDefaultValueBuilder::SplitTzDate32(i32 date, i32& year, ui32& month, ui32& day,
- ui32& dayOfYear, ui32& weekOfYear, ui32& weekOfYearIso8601, ui32& dayOfWeek, ui16 timezoneId) const
-{
+ ui32& dayOfYear, ui32& weekOfYear, ui32& weekOfYearIso8601, ui32& dayOfWeek, ui16 timezoneId) const {
return ::NKikimr::NMiniKQL::SplitTzDate32(date, year, month, day, dayOfYear, weekOfYear, weekOfYearIso8601, dayOfWeek, timezoneId);
}
bool TDefaultValueBuilder::SplitTzDatetime64(i64 datetime, i32& year, ui32& month, ui32& day,
- ui32& hour, ui32& minute, ui32& second,
- ui32& dayOfYear, ui32& weekOfYear, ui32& weekOfYearIso8601, ui32& dayOfWeek, ui16 timezoneId) const
-{
+ ui32& hour, ui32& minute, ui32& second,
+ ui32& dayOfYear, ui32& weekOfYear, ui32& weekOfYearIso8601, ui32& dayOfWeek, ui16 timezoneId) const {
return ::NKikimr::NMiniKQL::SplitTzDatetime64(
- datetime, year, month, day, hour, minute, second,
- dayOfYear, weekOfYear, weekOfYearIso8601, dayOfWeek, timezoneId);
+ datetime, year, month, day, hour, minute, second,
+ dayOfYear, weekOfYear, weekOfYearIso8601, dayOfWeek, timezoneId);
}
bool TDefaultValueBuilder::MakeTzDate32(i32 year, ui32 month, ui32 day, i32& date, ui16 timezoneId) const {
@@ -343,8 +328,7 @@ bool TDefaultValueBuilder::MakeTzDate32(i32 year, ui32 month, ui32 day, i32& dat
}
bool TDefaultValueBuilder::MakeTzDatetime64(i32 year, ui32 month, ui32 day,
- ui32 hour, ui32 minute, ui32 second, i64& datetime, ui16 timezoneId) const
-{
+ ui32 hour, ui32 minute, ui32 second, i64& datetime, ui16 timezoneId) const {
return ::NKikimr::NMiniKQL::MakeTzDatetime64(year, month, day, hour, minute, second, datetime, timezoneId);
}
@@ -353,4 +337,4 @@ NUdf::IListValueBuilder::TPtr TDefaultValueBuilder::NewListBuilder() const {
}
} // namespace NMiniKQL
-} // namespace Nkikimr
+} // namespace NKikimr