diff options
Diffstat (limited to 'include/framework/reconstruction/ReconstructionPolicy.h')
| -rw-r--r-- | include/framework/reconstruction/ReconstructionPolicy.h | 30 |
1 files changed, 30 insertions, 0 deletions
diff --git a/include/framework/reconstruction/ReconstructionPolicy.h b/include/framework/reconstruction/ReconstructionPolicy.h new file mode 100644 index 0000000..976091e --- /dev/null +++ b/include/framework/reconstruction/ReconstructionPolicy.h @@ -0,0 +1,30 @@ +/* + * include/framework/reconstruction/ReconstructionPolicy.h + * + * Reconstruction class interface, used to implement custom reconstruction + * policies. + * + * Copyright (C) 2023-2024 Douglas B. Rumbaugh <drumbaugh@psu.edu> + * Dong Xie <dongx@psu.edu> + * + * Distributed under the Modified BSD License. + * + */ +#pragma once + +#include "util/types.h" +#include "framework/structure/ExtensionStructure.h" +#include "framework/scheduling/Epoch.h" + +namespace de { +template<ShardInterface ShardType, QueryInterface<ShardType> QueryType> +class ReconstructionPolicy { + typedef ExtensionStructure<ShardType, QueryType> StructureType; + +public: + ReconstructionPolicy() {} + virtual ReconstructionVector get_reconstruction_tasks(Epoch<ShardType, QueryType> *epoch, + size_t incoming_reccnt) = 0; + virtual ReconstructionTask get_flush_task(Epoch<ShardType, QueryType> *epoch) = 0; + }; +} |