import_export::ImportStatus Struct Reference

#include <Importer.h>

Collaboration diagram for import_export::ImportStatus:

Public Member Functions
	ImportStatus ()
ImportStatus &	operator+= (const ImportStatus &is)

Public Attributes
std::chrono::steady_clock::time_point	start
std::chrono::steady_clock::time_point	end
size_t	rows_completed
size_t	rows_estimated
size_t	rows_rejected
std::chrono::duration< size_t, std::milli >	elapsed
bool	load_failed = false
std::string	load_msg
int	thread_id

Detailed Description

Definition at line 657 of file Importer.h.

Constructor & Destructor Documentation

import_export::ImportStatus::ImportStatus ( )

inline

Definition at line 667 of file Importer.h.

      : start(std::chrono::steady_clock::now())
      , rows_completed(0)
      , rows_estimated(0)
      , rows_rejected(0)
      , elapsed(0)
      , thread_id(0) {}

Member Function Documentation

ImportStatus& import_export::ImportStatus::operator+= ( const ImportStatus &  is )

inline

Definition at line 675 of file Importer.h.

References load_failed, load_msg, rows_completed, and rows_rejected.

                                                   {
    rows_completed += is.rows_completed;
    rows_rejected += is.rows_rejected;
    if (is.load_failed) {
      load_failed = true;
      load_msg = is.load_msg;
    }

    return *this;
  }

Member Data Documentation

std::chrono::duration<size_t, std::milli> import_export::ImportStatus::elapsed

Definition at line 663 of file Importer.h.

Referenced by heavydb.thrift.ttypes.TImportStatus::read(), import_export::Importer::set_import_status(), and heavydb.thrift.ttypes.TImportStatus::write().

std::chrono::steady_clock::time_point import_export::ImportStatus::end

Definition at line 659 of file Importer.h.

Referenced by import_export::Importer::set_import_status().

bool import_export::ImportStatus::load_failed = false

Definition at line 664 of file Importer.h.

Referenced by import_export::Importer::checkpoint(), Parser::CopyTableStmt::execute(), import_export::ForeignDataImporter::finalize(), import_export::DataStreamSink::import_compressed(), import_export::import_thread_delimited(), import_export::import_thread_shapefile(), import_export::Detector::importDelimited(), import_export::Importer::importDelimited(), import_export::Importer::importGDALGeo(), import_export::Importer::importGDALRaster(), import_export::ForeignDataImporter::importGeneralS3(), import_export::Importer::load(), anonymous_namespace{ForeignDataImporter.cpp}::load_foreign_data_buffers(), and operator+=().

std::string import_export::ImportStatus::load_msg

Definition at line 665 of file Importer.h.

Referenced by import_export::Importer::checkpoint(), Parser::CopyTableStmt::execute(), import_export::ForeignDataImporter::finalize(), import_export::import_thread_delimited(), import_export::import_thread_shapefile(), import_export::Importer::importDelimited(), import_export::Importer::importGDALGeo(), import_export::Importer::importGDALRaster(), import_export::Importer::load(), anonymous_namespace{ForeignDataImporter.cpp}::load_foreign_data_buffers(), and operator+=().

size_t import_export::ImportStatus::rows_completed

Definition at line 660 of file Importer.h.

Referenced by Parser::CopyTableStmt::execute(), import_export::DataStreamSink::import_compressed(), import_export::import_thread_delimited(), import_export::import_thread_shapefile(), import_export::Detector::importDelimited(), import_export::Importer::importDelimited(), import_export::Importer::importGDALGeo(), import_export::Importer::importGDALRaster(), anonymous_namespace{ForeignDataImporter.cpp}::load_foreign_data_buffers(), operator+=(), foreign_storage::ParquetImportBatchResult::populateImportStatus(), heavydb.thrift.ttypes.TImportStatus::read(), and heavydb.thrift.ttypes.TImportStatus::write().

size_t import_export::ImportStatus::rows_estimated

Definition at line 661 of file Importer.h.

Referenced by import_export::Importer::importDelimited(), import_export::Importer::importGDALGeo(), import_export::Importer::importGDALRaster(), heavydb.thrift.ttypes.TImportStatus::read(), and heavydb.thrift.ttypes.TImportStatus::write().

size_t import_export::ImportStatus::rows_rejected

Definition at line 662 of file Importer.h.

Referenced by Parser::CopyTableStmt::execute(), import_export::import_thread_delimited(), import_export::import_thread_shapefile(), import_export::Importer::importDelimited(), import_export::Importer::importGDALGeo(), anonymous_namespace{ForeignDataImporter.cpp}::load_foreign_data_buffers(), operator+=(), foreign_storage::ParquetImportBatchResult::populateImportStatus(), heavydb.thrift.ttypes.TImportStatus::read(), and heavydb.thrift.ttypes.TImportStatus::write().

std::chrono::steady_clock::time_point import_export::ImportStatus::start

Definition at line 658 of file Importer.h.

Referenced by generate_TableFunctionsFactory_init.Tokenize::add_token(), generate_TableFunctionsFactory_init.Tokenize::current_token(), import_export::Importer::set_import_status(), and generate_TableFunctionsFactory_init.Tokenize::tokenize().

int import_export::ImportStatus::thread_id

Definition at line 666 of file Importer.h.

Referenced by import_export::import_thread_delimited(), and import_export::import_thread_shapefile().

---

The documentation for this struct was generated from the following file:

• /home/jenkins-slave/workspace/core-os-doxygen/ImportExport/Importer.h