Crate athena_udf 

Re-exports

pub use arrow_conversions::FromArrow;

pub use arrow_conversions::ToArrow;

pub use process_macro::UDFProcessor;

pub use request::AthenaUDFRequest;

pub use request::Identity;

pub use request::InputRecords;

pub use request::OutputSchemaWrapper;

pub use request::PingRequest;

pub use response::AthenaResponse;

pub use response::AthenaUDFResponse;

pub use response::OutputRecords;

pub use response::PingResponse;

Modules

arrow_conversions

process_macro

register_macro

request

response

serde_base64

serialization

Macros

athena_udf_handler

Declarative macro for registering multiple Athena UDFs with their type signatures.

impl_process

Generates process methods for UDF execution with varying numbers of input parameters.

register_udfs

Lower-level macro for registering UDFs inside a closure.

Structs

LambdaEvent

Incoming Lambda request containing the event payload and context.

Enums

Value

Represents any valid JSON value.

Traits

Deserialize

A data structure that can be deserialized from any data format supported by Serde.

Serialize

A data structure that can be serialized into any data format supported by Serde.

Functions

handle_athena_request

Main entry point for Athena UDF Lambda handlers.

run

Starts the Lambda Rust runtime and begins polling for events on the Lambda Runtime APIs.

service_fn

Returns a new ServiceFn with the given closure.

wrap_response

Type Aliases

UDFHandler

A handler function type for processing UDF requests.

Derive Macros

Deserialize

Serialize