pub async fn append_records( &self, table_name: String, source_table_name: String, field_map: HashMap<String, String>, ) -> Result<AppendRecordsResponse, KineticaError>
Append records from a source table to a target table based on the field map
Append (or insert) all records from a source table (specified by source_table_name) to a particular target table (specified by table_name). The field map (specified by field_map) holds the user specified map of target table column names with their mapped source column names.
table_name- The table name for the records to be appended, in [schema_name.]table_name format, using standard name resolution rules. Must be an existing table.source_table_name- The source table name to get records from, in [schema_name.]table_name format, using standard name resolution rules. Must be an existing table name.field_map- Contains the mapping of column names from the target table (specified bytable_name) as the keys, and corresponding column names or expressions (e.g., ‘col_name+1’) from the source table (specified bysource_table_name). Must be existing column names in source table and target table, and their types must be matched. For details on using expressions, see Expressions.
pub async fn append_records_with_opts( &self, table_name: String, source_table_name: String, field_map: HashMap<String, String>, options: AppendRecordsRequestOptions, ) -> Result<AppendRecordsResponse, KineticaError>
Append records from a source table to a target table based on the field map
Append (or insert) all records from a source table (specified by source_table_name) to a particular target table (specified by table_name). The field map (specified by field_map) holds the user specified map of target table column names with their mapped source column names.
table_name- The table name for the records to be appended, in [schema_name.]table_name format, using standard name resolution rules. Must be an existing table.source_table_name- The source table name to get records from, in [schema_name.]table_name format, using standard name resolution rules. Must be an existing table name.field_map- Contains the mapping of column names from the target table (specified bytable_name) as the keys, and corresponding column names or expressions (e.g., ‘col_name+1’) from the source table (specified bysource_table_name). Must be existing column names in source table and target table, and their types must be matched. For details on using expressions, see Expressions.options- The optional parameters; any left unset take the server’s defaults.
pub async fn append_records_raw( &self, request: &AppendRecordsRequest, ) -> Result<AppendRecordsResponse, KineticaError>
Sends a pre-built AppendRecordsRequest to the /append/records endpoint.
pub async fn append_records_from_url( &self, url: &str, request: &AppendRecordsRequest, ) -> Result<AppendRecordsResponse, KineticaError>
Sends a pre-built AppendRecordsRequest to a specific worker URL, bypassing HA head-node selection. Used for multi-head access.