@@ -4,32 +4,32 @@ namespace NYql::NDq {
4
4
5
5
using namespace NActors ;
6
6
7
- TDqComputeStorage::TDqComputeStorage (TTxId txId, std::function<void ()> wakeUpCallback, TActorSystem* actorSystem)
8
- : ActorSystem_(actorSystem)
7
+ TDqComputeStorage::TDqComputeStorage (TTxId txId, std::function<void ()> wakeUpCallback, TActorSystem* actorSystem) : ActorSystem_(actorSystem)
9
8
{
10
9
TStringStream spillerName;
11
10
spillerName << " Spiller" << " _" << static_cast <const void *>(this );
12
11
ComputeStorageActor_ = CreateDqComputeStorageActor (txId, spillerName.Str (), wakeUpCallback);
13
12
ComputeStorageActorId_ = ActorSystem_->Register (ComputeStorageActor_->GetActor ());
14
13
}
15
14
16
- TDqComputeStorage::~TDqComputeStorage () {
17
- ActorSystem_->Send (ComputeStorageActorId_, new TEvents::TEvPoison);
18
- }
15
+ TDqComputeStorage::~TDqComputeStorage () {
16
+ ActorSystem_->Send (ComputeStorageActorId_, new TEvents::TEvPoison);
17
+ }
18
+
19
+ NThreading::TFuture<NKikimr::NMiniKQL::ISpiller::TKey> TDqComputeStorage::Put (TRope&& blob) {
20
+ return ComputeStorageActor_->Put (std::move (blob));
21
+ }
19
22
20
- NThreading::TFuture<NKikimr::NMiniKQL::ISpiller::TKey> TDqComputeStorage::Put (TRope&& blob ) {
21
- return ComputeStorageActor_->Put ( std::move (blob) );
22
- }
23
+ std::optional<NThreading::TFuture<TRope>> TDqComputeStorage::Get (TKey key ) {
24
+ return ComputeStorageActor_->Get (key );
25
+ }
23
26
24
- std::optional< NThreading::TFuture<TRope>> TDqComputeStorage::Get (TKey key) {
25
- return ComputeStorageActor_->Get (key);
26
- }
27
+ NThreading::TFuture<void > TDqComputeStorage::Delete (TKey key) {
28
+ return ComputeStorageActor_->Delete (key);
29
+ }
27
30
28
- NThreading::TFuture<void > TDqComputeStorage::Delete (TKey key) {
29
- return ComputeStorageActor_->Delete (key);
30
- }
31
+ std::optional< NThreading::TFuture<TRope>> TDqComputeStorage::Extract (TKey key) {
32
+ return ComputeStorageActor_->Extract (key);
33
+ }
31
34
32
- std::optional<NThreading::TFuture<TRope>> TDqComputeStorage::Extract (TKey key) {
33
- return ComputeStorageActor_->Extract (key);
34
- }
35
35
} // namespace NYql::NDq
0 commit comments