summaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/interface
diff options
context:
space:
mode:
authorhiddenpath <[email protected]>2024-12-17 01:13:52 +0300
committerhiddenpath <[email protected]>2024-12-17 02:03:47 +0300
commit5935906b0bfd05ea9cf84fc03e1b7d8befd2ff11 (patch)
tree9f72ba6c791e8374a21699eb820767c9fbaa16a8 /yt/cpp/mapreduce/interface
parentb570317a503ddb08ae344d96997c4ebb45002b8d (diff)
[yt/cpp/mapreduce] YT-23616: Move Job methods to THttpRawClient
commit_hash:bd11304f4147ff314372d4ab6049478143f60fd5
Diffstat (limited to 'yt/cpp/mapreduce/interface')
-rw-r--r--yt/cpp/mapreduce/interface/raw_client.h31
1 files changed, 31 insertions, 0 deletions
diff --git a/yt/cpp/mapreduce/interface/raw_client.h b/yt/cpp/mapreduce/interface/raw_client.h
index 2229486a014..d21b3a937a8 100644
--- a/yt/cpp/mapreduce/interface/raw_client.h
+++ b/yt/cpp/mapreduce/interface/raw_client.h
@@ -150,6 +150,37 @@ public:
const TOperationId& operationId,
const TUpdateOperationParametersOptions& options = {}) = 0;
+ virtual NYson::TYsonString GetJob(
+ const TOperationId& operationId,
+ const TJobId& jobId,
+ const TGetJobOptions& options = {}) = 0;
+
+ virtual TListJobsResult ListJobs(
+ const TOperationId& operationId,
+ const TListJobsOptions& options = {}) = 0;
+
+ virtual IFileReaderPtr GetJobInput(
+ const TJobId& jobId,
+ const TGetJobInputOptions& options = {}) = 0;
+
+ virtual IFileReaderPtr GetJobFailContext(
+ const TOperationId& operationId,
+ const TJobId& jobId,
+ const TGetJobFailContextOptions& options = {}) = 0;
+
+ virtual TString GetJobStderrWithRetries(
+ const TOperationId& operationId,
+ const TJobId& jobId,
+ const TGetJobStderrOptions& options = {}) = 0;
+
+ virtual IFileReaderPtr GetJobStderr(
+ const TOperationId& operationId,
+ const TJobId& jobId,
+ const TGetJobStderrOptions& options = {}) = 0;
+
+ virtual std::vector<TJobTraceEvent> GetJobTrace(
+ const TOperationId& operationId,
+ const TGetJobTraceOptions& options = {}) = 0;
};
////////////////////////////////////////////////////////////////////////////////