#include <LoadDataSourceStdin.h>
Public Member Functions | |
LoadDataSourceStdin (const String &header_fname, int row_uniquify_chars=0, int load_flags=0) | |
~LoadDataSourceStdin () | |
uint64_t | incr_consumed () |
Public Member Functions inherited from Hypertable::LoadDataSource | |
LoadDataSource (const std::string &header_fname, int row_uniquify_chars=0, int load_flags=0) | |
virtual | ~LoadDataSource () |
bool | has_timestamps () |
virtual bool | next (KeySpec *keyp, uint8_t **valuep, uint32_t *value_lenp, bool *is_deletep, uint32_t *consumedp) |
virtual void | init (const std::vector< String > &key_columns, const std::string ×tamp_column, char field_separator) |
int64_t | get_current_lineno () |
unsigned long | get_source_size () const |
Protected Member Functions | |
void | init_src () |
Protected Member Functions inherited from Hypertable::LoadDataSource | |
bool | get_next_line (String &line) |
virtual void | parse_header (const String &header, const std::vector< String > &key_columns, const std::string ×tamp_column) |
bool | should_skip (int idx, const uint32_t *masks) |
std::string | get_header () |
bool | parse_date_format (const char *str, int64_t ×tamp) |
bool | parse_sec (const char *str, char **end_ptr, int64_t &ns) |
bool | add_row_component (int index) |
Additional Inherited Members | |
Protected Types inherited from Hypertable::LoadDataSource | |
enum | TypeMask { ROW_KEY = (1 << 0), TIMESTAMP = (1 << 1) } |
Protected Attributes inherited from Hypertable::LoadDataSource | |
std::vector< ColumnInfo > | m_column_info |
std::vector< const char * > | m_values |
std::vector< KeyComponentInfo > | m_key_comps |
uint32_t * | m_type_mask |
size_t | m_next_value |
boost::iostreams::filtering_istream | m_fin |
int64_t | m_cur_line |
DynamicBuffer | m_line_buffer |
DynamicBuffer | m_row_key_buffer |
bool | m_hyperformat |
bool | m_leading_timestamps |
int | m_timestamp_index |
int64_t | m_timestamp |
size_t | m_limit |
uint64_t | m_offset |
bool | m_zipped |
FixedRandomStringGenerator * | m_rsgen |
std::string | m_header_fname |
int | m_row_uniquify_chars |
int | m_load_flags |
std::string | m_first_line |
unsigned long | m_source_size |
bool | m_first_line_cached |
char | m_field_separator |
Definition at line 44 of file LoadDataSourceStdin.h.
LoadDataSourceStdin::LoadDataSourceStdin | ( | const String & | header_fname, |
int | row_uniquify_chars = 0 , |
||
int | load_flags = 0 |
||
) |
Definition at line 56 of file LoadDataSourceStdin.cc.
|
inline |
Definition at line 50 of file LoadDataSourceStdin.h.
|
virtual |
Implements Hypertable::LoadDataSource.
Definition at line 74 of file LoadDataSourceStdin.cc.
|
protectedvirtual |
Implements Hypertable::LoadDataSource.
Definition at line 64 of file LoadDataSourceStdin.cc.