use super::prelude::*;
impl NodeCodegen for onnx_ir::topk::TopKNode {
fn inputs(&self) -> &[Argument] {
&self.inputs
}
fn outputs(&self) -> &[Argument] {
&self.outputs
}
fn forward(&self, scope: &mut ScopeAtPosition<'_>) -> TokenStream {
let input = scope.arg(self.inputs.first().unwrap());
let values_output = arg_to_ident(&self.outputs[0]);
let indices_output = arg_to_ident(&self.outputs[1]);
let axis = self.config.axis.to_tokens();
let k = match &self.config.k {
onnx_ir::topk::TopKInput::Static(k_value) => k_value.to_tokens(),
onnx_ir::topk::TopKInput::Runtime(_) => {
panic!("Runtime k value is not supported in burn-import")
}
};
quote! {
let (#values_output, #indices_output) = #input.topk_with_indices(#k, #axis);
}
}
}
#[cfg(test)]
mod tests {
use super::super::test_helpers::*;
use burn::tensor::DType;
use insta::assert_snapshot;
use onnx_ir::topk::{TopKConfig, TopKInput, TopKNodeBuilder};
#[test]
fn test_top_k() {
let config = TopKConfig::new(1, TopKInput::Static(5));
let node = TopKNodeBuilder::new("topk1")
.input_tensor("input", 2, DType::F32)
.output_tensor("values", 2, DType::F32)
.output_tensor("indices", 2, DType::I64)
.config(config)
.build();
let code = codegen_forward_default(&node);
assert_snapshot!(code, @r"
pub fn forward(&self, input: Tensor<B, 2>) -> (Tensor<B, 2>, Tensor<B, 2, Int>) {
let (values, indices) = input.topk_with_indices(5, 1);
(values, indices)
}
");
}
}