KineticaRecord

use gpudb_api::{KineticaRecord, AvroSchemaBuilder, AvroType, TypePropertiesBuilder, avro_schema};
use std::collections::HashMap;

#[derive(serde::Serialize, Clone, Default)]
struct MyRecord {
    id: i32,
    name: String,
}

impl KineticaRecord for MyRecord {
    fn avro_schema(&self) -> &'static str {
        avro_schema!(
            AvroSchemaBuilder::new("MyRecord")
                .int_field("id")
                .string_field("name")
        )
    }

    fn type_properties() -> HashMap<String, Vec<String>> {
        TypePropertiesBuilder::new()
            .primary_key("id")
            .data("name")
            .build()
    }
}

use gpudb_api::KineticaRecord;
use std::collections::HashMap;

#[derive(serde::Serialize, Clone, Default)]
struct MyRecord {
    id: i32,
    name: String,
}

impl KineticaRecord for MyRecord {
    fn avro_schema(&self) -> &'static str {
        r#"{"type":"record","name":"MyRecord","fields":[
            {"name":"id","type":"int"},
            {"name":"name","type":"string"}
        ]}"#
    }

    fn type_properties() -> HashMap<String, Vec<String>> {
        let mut m = HashMap::new();
        m.insert("id".into(), vec!["int".into(), "primary_key".into()]);
        m
    }
}