init_8h_source.html

#pragma once


#include <yt/cpp/mapreduce/interface/wait_proxy.h>


#include <util/generic/fwd.h>


#include <functional>


namespace NYT {


struct TInitializeOptions

{

    using TSelf = TInitializeOptions;


    FLUENT_FIELD_DEFAULT(::TIntrusivePtr<IWaitProxy>, WaitProxy, nullptr);


    FLUENT_FIELD_DEFAULT(bool, CleanupOnTermination, false);


    FLUENT_FIELD_OPTION(std::function<void()>, JobOnExitFunction);

};


void JoblessInitialize(const TInitializeOptions& options = TInitializeOptions());


void Initialize(int argc, const char **argv, const TInitializeOptions &options = TInitializeOptions());


void Initialize(int argc, char **argv, const TInitializeOptions &options = TInitializeOptions());


void Initialize(const TInitializeOptions &options = TInitializeOptions());


} // namespace NYT

NYT
Main namespace of YT client.
Definition abortable_stream.h:7

NYT::Initialize
void Initialize(int argc, const char **argv, const TInitializeOptions &options=TInitializeOptions())
Performs basic initialization and switches to a job mode if required.

NYT::JoblessInitialize
void JoblessInitialize(const TInitializeOptions &options=TInitializeOptions())
Performs basic initialization (logging, termination handlers, etc).

NYT::TInitializeOptions
Options for NYT::Initialize() and NYT::JoblessInitialize() functions.
Definition init.h:20

NYT::TInitializeOptions::CleanupOnTermination
TSelf & CleanupOnTermination(bool)
Enable/disable cleanup when program execution terminates abnormally.

NYT::TInitializeOptions::WaitProxy
TSelf & WaitProxy(::TIntrusivePtr< IWaitProxy >)
Override waiting functions for YT Wrapper.

NYT::TInitializeOptions::JobOnExitFunction
TSelf & JobOnExitFunction(std::function< void()>)
Set callback to be called before exit() in job mode.