9#include <util/generic/fwd.h>
10#include <util/system/types.h>
15namespace google::protobuf {
26 using TBatchRequestPtr = ::TIntrusivePtr<IBatchRequest>;
40 template <
class TDerived>
72 using ILockPtr = ::TIntrusivePtr<ILock>;
75 using ITransactionPtr = ::TIntrusivePtr<ITransaction>;
77 class ITransactionPinger;
78 using ITransactionPingerPtr = ::TIntrusivePtr<ITransactionPinger>;
81 using IOperationPtr = ::TIntrusivePtr<IOperation>;
87 using IClientPtr = ::TIntrusivePtr<IClient>;
88 using IClientBasePtr = ::TIntrusivePtr<IClientBase>;
95 using TConfigPtr = ::TIntrusivePtr<TConfig>;
155 using TMutationId = TGUID;
156 using TTransactionId = TGUID;
157 using TNodeId = TGUID;
158 using TLockId = TGUID;
159 using TOperationId = TGUID;
160 using TTabletCellId = TGUID;
161 using TReplicaId = TGUID;
162 using TJobId = TGUID;
163 using TJobTraceId = TGUID;
165 using TYPath = TString;
166 using TLocalFilePath = TString;
168 template <
class T,
class TDerived =
void>
214 enum class EFormatType : int;
220 using IFileReaderPtr = ::TIntrusivePtr<IFileReader>;
224 using IFileWriterPtr = ::TIntrusivePtr<IFileWriter>;
228 using IFileFragmentWriterPtr = ::TIntrusivePtr<IFileFragmentWriter>;
230 class IBlobTableReader;
231 using IBlobTableReaderPtr = ::TIntrusivePtr<IBlobTableReader>;
235 using TRawTableReaderPtr = ::TIntrusivePtr<TRawTableReader>;
239 using TRawTableWriterPtr = ::TIntrusivePtr<TRawTableWriter>;
241 template <
class T,
class =
void>
244 template <
class T,
class =
void>
247 template <
typename T>
248 using TTableRangesReaderPtr = ::TIntrusivePtr<TTableRangesReader<T>>;
251 using TTableReaderPtr = ::TIntrusivePtr<TTableReader<T>>;
253 template <
class T,
class =
void>
257 using TTableWriterPtr = ::TIntrusivePtr<TTableWriter<T>>;
263 using ITableFragmentWriterPtr = ::TIntrusivePtr<ITableFragmentWriter<T>>;
267 using ::google::protobuf::Message;
271 using ISkiffRowParserPtr = ::TIntrusivePtr<ISkiffRowParser>;
275 using ISkiffRowSkipperPtr = ::TIntrusivePtr<ISkiffRowSkipper>;
279 class TYdlGenericRowType;
283 template<
class... TYdlRowTypes>
286 template<
class... TProtoRowTypes>
289 template<
class... TSkiffRowTypes>
300 template <
class TDerived>
319 template <
typename T>
342 class IIOperationPreparationContext;
345 using IJobPtr = ::TIntrusivePtr<IJob>;
348 using IRawJobPtr = ::TIntrusivePtr<IRawJob>;
356 template <
class TR,
class TW>
359 template <
class TR,
class TW>
362 template <
class TR,
class TW>
363 class IAggregatorReducer;
391 enum class EFinishedJobState : int;
404 using TJobBinaryConfig = std::variant<
411 using IRetryConfigProviderPtr = ::TIntrusivePtr<IRetryConfigProvider>;
433 using IRawBatchRequestPtr = ::TIntrusivePtr<IRawBatchRequest>;
440 using IRawClientPtr = ::TIntrusivePtr<IRawClient>;
Batch request object.
Definition batch_request.h:188
Base class for NYT::IClient and NYT::ITransaction.
Definition client.h:143
Interface containing non-transactional commands.
Definition client.h:282
Client interface to execute Cypress-related commands.
Definition cypress.h:22
Interface representing YT file reader.
Definition io.h:112
Interface representing YT file writer.
Definition io.h:118
Interface for all user jobs.
Definition operation.h:1942
Interface representing a lock obtained from NYT::ITransaction::Lock.
Definition client.h:108
Base interface for structured (typed) map jobs with given reader and writer.
Definition operation.h:2083
Definition raw_batch_request.h:15
Definition raw_client.h:28
This method is called before feeding input rows to reducer (before Do method). virtual void Start(TWr...
Definition operation.h:2218
Base interface for structured (typed) reduce jobs with given reader and writer.
Definition operation.h:2131
The library uses this class to understand how to retry individual requests.
Definition retry_policy.h:23
Definition skiff_row.h:83
Definition skiff_row.h:103
Class template for distributed table API fragment writer.
Definition io.h:423
Interface representing a master transaction.
Definition client.h:206
Error that is thrown when library detects invalid usage of API.
Definition errors.h:32
Single column description.
Definition common.h:618
Generic error response returned by server.
Definition errors.h:158
Class representing single statistic.
Definition job_statistics.h:168
Class representing a collection of job statistics.
Definition job_statistics.h:35
Error that is thrown when operation watched by library fails.
Definition errors.h:254
"Marker" type to use for several protobuf types in NYT::TTableReader.
Definition io.h:37
Low-level interface to read YT table with retries.
Definition io.h:140
Low-level interface to write YT table.
Definition io.h:174
Definition client_method_options.h:680
"Marker" type to use for several skiff row types in NYT::TTableReader.
Definition io.h:52
Table key column description.
Definition common.h:494
List of TSortColumn.
Definition common.h:558
Class to facilitate reading table rows sorted by key.
Definition io.h:381
Class template to read typed rows from YT tables.
Definition io.h:249
Description of table schema.
Definition common.h:771
Class template to write typed rows to YT tables.
Definition io.h:399
Task name (can either well-known or just a string).
Definition operation.h:2803
Error returned by YT cluster.
Definition errors.h:62
Main namespace of YT client.
Definition abortable_stream.h:7
ETaskName
Well-known task names.
Definition operation.h:2780
EOperationAttribute
Attributes to request for an operation.
Definition operation.h:2352
EMasterReadKind
Enumeration for specifying how reading from master is performed.
Definition common.h:1416
EJobType
Job type.
Definition operation.h:2749
EOperationBriefState
"Coarse-grained" state of an operation.
Definition operation.h:2408
EErasureCodecAttr
Value of "erasure_codec" attribute.
Definition common.h:456
EJobState
Job state.
Definition operation.h:2829
ESchemaModificationAttr
Value of "schema_modification" attribute.
Definition common.h:472
ENodeType
Type of the cypress node.
Definition client_method_options.h:22
ELockMode
Type of the lock.
Definition client_method_options.h:960
EMergeMode
Merge mode.
Definition operation.h:1299
EOptimizeForAttr
Value of "optimize_for" attribute.
Definition common.h:443
ERelation
Enumeration describing comparison operation used in key bound.
Definition common.h:895
ESortOrder
Sort order.
Definition common.h:431
EValueType
Type of the value that can occur in YT table.
Definition common.h:352
Interface of client capable of managing operations.
Definition operation.h:3407
Interface representing an operation.
Definition operation.h:3244
Options for NYT::IClient::AlterTable.
Definition client_method_options.h:1120
Options for NYT::IClient::AlterTableReplica.
Definition client_method_options.h:1462
List of attributes to retrieve in operations like NYT::ICypressClient::Get.
Definition common.h:1389
Options for NYT::IClient::CheckPermission.
Definition client_method_options.h:1558
Result of NYT::IClient::CheckPermission command.
Definition client.h:94
Part of NYT::TCheckPermissionResponse.
Definition client.h:68
Options for NYT::ITransaction::Commit.
Definition client_method_options.h:1029
Options for NYT::ICypressClient::Concatenate.
Definition client_method_options.h:347
Options for NYT::ICypressClient::Copy.
Definition client_method_options.h:276
Options for NYT::CreateClient;.
Definition client_method_options.h:1212
Options for NYT::ICypressClient::Create.
Definition client_method_options.h:126
Options for NYT::IClient::DeleteRows.
Definition client_method_options.h:1439
Definition distributed_session.h:94
Definition distributed_session.h:59
Spec of Erase operation.
Definition operation.h:1367
Options for reading file from YT.
Definition client_method_options.h:569
Options for writing file.
Definition client_method_options.h:647
Definition distributed_session.h:122
Definition distributed_session.h:87
Options for NYT::IClient::GetFileFromCache.
Definition client_method_options.h:1487
Options for NYT::IClient::GetJob.
Definition operation.h:3126
Options for NYT::IClient::GetJobTrace.
Definition operation.h:3187
Options for NYT::IClient::GetOperation call.
Definition operation.h:2393
Options for NYT::ICypressClient::Get.
Definition client_method_options.h:208
Base class for many options related to IO.
Definition client_method_options.h:531
Options for NYT::IClient::InsertRows.
Definition client_method_options.h:1401
Tag class marking that binary from specified Cypress path should be used in operation.
Definition operation.h:136
Tag class marking that current binary should be used in operation.
Definition operation.h:125
Tag class marking that binary from specified local path should be used in operation.
Definition operation.h:129
Spec of JoinReduce operation.
Definition operation.h:1094
Key with relation specifying interval of keys in lower or upper limit of NYT::TReadRange.
Definition common.h:930
Options for NYT::ICypressClient::Link.
Definition client_method_options.h:324
Options for NYT::IClient::ListJobs.
Definition operation.h:2911
Options of NYT::IClient::ListOperations command.
Definition operation.h:2599
Options for NYT::ICypressClient::List.
Definition client_method_options.h:258
Options for locking cypress node.
Definition client_method_options.h:978
Options for NYT::IClient::LookupRows.
Definition client_method_options.h:1143
Spec of Map operation.
Definition operation.h:959
Spec of MapReduce operation.
Definition operation.h:1195
Spec of Merge operation.
Definition operation.h:1311
Options for NYT::IClient::MountTable.
Definition client_method_options.h:1056
Options for NYT::ICypressClient::Move.
Definition client_method_options.h:300
Options for NYT::ICypressClient::MultisetAttributes.
Definition client_method_options.h:242
Convenience class that keeps sequence of items.
Definition common.h:280
Class describing which attributes to request in NYT::IClient::GetOperation or NYT::IClient::ListOpera...
Definition operation.h:2374
Operation info.
Definition operation.h:2516
Options for NYT::IOperationClient::Map and other operation start commands.
Definition operation.h:1511
Definition distributed_session.h:117
Definition distributed_session.h:82
Options for NYT::IClient::GetTableColumnarStatistics.
Definition client_method_options.h:1500
Spec of raw Map operation.
Definition operation.h:968
Description of the read limit.
Definition common.h:951
Range of a table or a file.
Definition common.h:995
Spec of Reduce operation.
Definition operation.h:1030
Options for NYT::IClient::RemountTable.
Definition client_method_options.h:1089
Options for NYT::ICypressClient::Remove.
Definition client_method_options.h:163
Options for NYT::IClient::ReshardTable.
Definition client_method_options.h:1097
Options for NYT::IOperation::ResumeOperation.
Definition client_method_options.h:493
A configuration that controls retries of a single request.
Definition retry_policy.h:12
Path with additional attributes.
Definition common.h:1040
Options for NYT::IClient::SelectRows.
Definition client_method_options.h:1172
Options for NYT::ICypressClient::Set.
Definition client_method_options.h:223
Spec of Sort operation.
Definition operation.h:1241
Definition distributed_session.h:103
Definition distributed_session.h:68
Options for NYT::IClient::StartTransaction.
Definition client_method_options.h:886
Options for NYT::IOperation::SuspendOperation.
Definition client_method_options.h:469
Options for NYT::IClient::CreateTableReader.
Definition client_method_options.h:781
Options for NYT::IClient::CreateTableWriter.
Definition client_method_options.h:825
Contains information about tablet.
Definition common.h:1363
Base class for options that deal with tablets.
Definition client_method_options.h:1038
Options for NYT::IClient::TrimRows.
Definition client_method_options.h:1455
Options for NYT::IClient::UnmountTable.
Definition client_method_options.h:1074
Spec of user job.
Definition operation.h:757
Type representing YaMR table row.
Definition io.h:445