Index: src/libchcore/TSubTaskFastMove.h =================================================================== diff -u -N -r0b8ae6ab8b538881b651126bf8e6de9c9912a782 -r19925be73ffcadd9f345f10e03e55aadb3f0eeac --- src/libchcore/TSubTaskFastMove.h (.../TSubTaskFastMove.h) (revision 0b8ae6ab8b538881b651126bf8e6de9c9912a782) +++ src/libchcore/TSubTaskFastMove.h (.../TSubTaskFastMove.h) (revision 19925be73ffcadd9f345f10e03e55aadb3f0eeac) @@ -50,8 +50,14 @@ void IncreaseCurrentIndex(); size_t GetCurrentIndex() const; + void Store(const ISerializerRowDataPtr& spRowData) const; + static void InitLoader(const IColumnsDefinitionPtr& spColumns); + void Load(const ISerializerRowReaderPtr& spRowReader); + bool WasSerialized() const; + private: size_t m_stCurrentIndex; + mutable size_t m_stLastStoredIndex; mutable boost::shared_mutex m_lock; }; } @@ -68,7 +74,7 @@ virtual void Reset(); virtual ESubOperationResult Exec(); - virtual ESubOperationType GetSubOperationType() const { return eSubOperation_Scanning; } + virtual ESubOperationType GetSubOperationType() const { return eSubOperation_FastMove; } virtual void Store(const ISerializerPtr& spSerializer) const; virtual void Load(const ISerializerPtr& spSerializer);