yql/essentials/minikql/mkql_unboxed_value_stream.cpp


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

#include "mkql_unboxed_value_stream.h"

#include <yql/essentials/minikql/mkql_string_util.h>

namespace NKikimr {
namespace NMiniKQL {

TUnboxedValueStream::TUnboxedValueStream()
    : Value_(NUdf::TUnboxedValuePod::Zero())
{}

NUdf::TUnboxedValuePod TUnboxedValueStream::Value() {
    return Value_.Release();
}

void TUnboxedValueStream::DoWrite(const void* buf, size_t len) {
    Value_ = AppendString(Value_.Release(), NUdf::TStringRef(static_cast<const char*>(buf), len));
}

}
}