File tree Expand file tree Collapse file tree 1 file changed +4
-1
lines changed
ydb/library/yql/providers/yt/comp_nodes/dq Expand file tree Collapse file tree 1 file changed +4
-1
lines changed Original file line number Diff line number Diff line change 66#include < ydb/library/yql/utils/yql_panic.h>
77#include < ydb/library/yql/minikql/mkql_type_builder.h>
88#include < ydb/library/yql/minikql/mkql_type_ops.h>
9+ #include < ydb/library/yql/minikql/mkql_node_cast.h>
910
1011#include < library/cpp/yson/node/node_io.h>
1112#include < library/cpp/yson/detail.h>
@@ -622,7 +623,9 @@ class TYtColumnConverter final : public IYtColumnConverter {
622623 , DictPrimitiveConverter_(Settings_)
623624 {
624625 auto type = Settings_.Type ;
625- IsJson_ = type->IsData () && static_cast <NKikimr::NMiniKQL::TDataType*>(type)->GetDataSlot () == NUdf::EDataSlot::Json || (Native && type->IsOptional () && static_cast <NKikimr::NMiniKQL::TDataType*>(static_cast <NKikimr::NMiniKQL::TOptionalType*>(type)->GetItemType ())->GetDataSlot () == NUdf::EDataSlot::Json);
626+ IsJson_ = type->IsData () && AS_TYPE (TDataType, type)->GetDataSlot () == NUdf::EDataSlot::Json
627+ || (Native && type->IsOptional () && AS_TYPE (TOptionalType, type)->GetItemType ()->IsData ()
628+ && AS_TYPE (TDataType, AS_TYPE (TOptionalType, type)->GetItemType ())->GetDataSlot () == NUdf::EDataSlot::Json);
626629 }
627630
628631 arrow::Datum Convert (std::shared_ptr<arrow::ArrayData> block) override {
You can’t perform that action at this time.
0 commit comments