skiff_row.h

Go to the documentation of this file.

#pragma once

 
#include "fwd.h"
 
#include <yt/cpp/mapreduce/skiff/skiff_schema.h>
 
#include <yt/cpp/mapreduce/interface/format.h>
 
#include <library/cpp/skiff/skiff.h>
 
#include <util/generic/maybe.h>
 
namespace NYT {


template<class T>
struct TIsSkiffRow
    : std::false_type
{ };


template <typename T>
NSkiff::TSkiffSchemaPtr GetSkiffSchema(const TMaybe<TSkiffRowHints>& /*hints*/)
{
    static_assert(TDependentFalse<T>, "Unimplemented `GetSkiffSchema` method");
}

template <typename T>
NSkiff::TSkiffSchemaPtr GetParserSkiffSchema(const TMaybe<TSkiffRowHints>& hints)
{
    return GetSkiffSchema<T>(hints);
}


class ISkiffRowParser
    : public TThrRefBase
{
public:
    virtual void Parse(NSkiff::TCheckedInDebugSkiffParser* /*parser*/) = 0;
};

template <typename T>
ISkiffRowParserPtr CreateSkiffParser(T* /*row*/, const TMaybe<TSkiffRowHints>& /*hints*/)
{
    static_assert(TDependentFalse<T>, "Unimplemented `CreateSkiffParser` function");
}


class ISkiffRowSkipper
    : public TThrRefBase
{
public:
    virtual void SkipRow(NSkiff::TCheckedInDebugSkiffParser* /*parser*/) = 0;
};

template <typename T>
class TSkiffRowSkipper : public ISkiffRowSkipper {
public:
    explicit TSkiffRowSkipper(const TMaybe<TSkiffRowHints>& hints)
        : Parser_(CreateSkiffParser<T>(&Row_, hints))
    { }
 
    void SkipRow(NSkiff::TCheckedInDebugSkiffParser* parser) {
        Parser_->Parse(parser);
    }
 
private:
    T Row_;
    ISkiffRowParserPtr Parser_;
};

template <typename T>
ISkiffRowSkipperPtr CreateSkiffSkipper(const TMaybe<TSkiffRowHints>& hints)
{
    return ::MakeIntrusive<TSkiffRowSkipper<T>>(hints);
}

 
} // namespace NYT