diff options
Diffstat (limited to 'yt/cpp/mapreduce/client/client.h')
-rw-r--r-- | yt/cpp/mapreduce/client/client.h | 20 |
1 files changed, 20 insertions, 0 deletions
diff --git a/yt/cpp/mapreduce/client/client.h b/yt/cpp/mapreduce/client/client.h index ef0741044c..71d62965fc 100644 --- a/yt/cpp/mapreduce/client/client.h +++ b/yt/cpp/mapreduce/client/client.h @@ -130,6 +130,11 @@ public: const TFormat& format, const TTableReaderOptions& options) override; + TRawTableReaderPtr CreateRawTablePartitionReader( + const TString& cookie, + const TFormat& format, + const TTablePartitionReaderOptions& options) override; + TRawTableWriterPtr CreateRawWriter( const TRichYPath& path, const TFormat& format, @@ -268,6 +273,21 @@ private: const ISkiffRowSkipperPtr& skipper, const NSkiff::TSkiffSchemaPtr& schema) override; + ::TIntrusivePtr<INodeReaderImpl> CreateNodeTablePartitionReader( + const TString& cookie, + const TTablePartitionReaderOptions& options) override; + + ::TIntrusivePtr<IProtoReaderImpl> CreateProtoTablePartitionReader( + const TString& cookie, + const TTablePartitionReaderOptions& options, + const Message* prototype) override; + + ::TIntrusivePtr<ISkiffRowReaderImpl> CreateSkiffRowTablePartitionReader( + const TString& cookie, + const TTablePartitionReaderOptions& options, + const ISkiffRowSkipperPtr& skipper, + const NSkiff::TSkiffSchemaPtr& schema) override; + ::TIntrusivePtr<INodeWriterImpl> CreateNodeWriter( const TRichYPath& path, const TTableWriterOptions& options) override; |