![]() |
Project
|
#include "Framework/CompilerBuiltins.h"
#include "Framework/TableBuilder.h"
#include "Framework/TableTreeHelpers.h"
#include "Framework/DataAllocator.h"
#include "Framework/MessageContext.h"
#include "Framework/ArrowContext.h"
#include "Framework/DataSpecUtils.h"
#include "Framework/DataProcessingHeader.h"
#include "Framework/FairMQResizableBuffer.h"
#include "Framework/DataProcessingContext.h"
#include "Framework/DeviceSpec.h"
#include "Framework/StreamContext.h"
#include "Framework/Signpost.h"
#include "Headers/DataHeader.h"
#include "Headers/DataHeaderHelpers.h"
#include "Headers/Stack.h"
#include <fairmq/Device.h>
#include <arrow/ipc/writer.h>
#include <arrow/type.h>
#include <arrow/io/memory.h>
#include <arrow/util/config.h>
#include <TClonesArray.h>
#include <utility>
Go to the source code of this file.
Namespaces | |
namespace | o2 |
a couple of static helper functions to create timestamp values for CCDB queries or override obsolete objects | |
namespace | o2::framework |
Defining PrimaryVertex explicitly as messageable. | |
Functions | |
O2_DECLARE_DYNAMIC_LOG (stream_context) | |
O2_DECLARE_DYNAMIC_LOG (parts) | |
void | o2::framework::doWriteTable (std::shared_ptr< FairMQResizableBuffer > b, arrow::Table *table) |
void | o2::framework::doWriteBatch (std::shared_ptr< FairMQResizableBuffer > b, arrow::RecordBatch *batch) |
O2_DECLARE_DYNAMIC_LOG | ( | parts | ) |
O2_DECLARE_DYNAMIC_LOG | ( | stream_context | ) |