aboutsummaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/client/client.h
diff options
context:
space:
mode:
Diffstat (limited to 'yt/cpp/mapreduce/client/client.h')
-rw-r--r--yt/cpp/mapreduce/client/client.h20
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;