Struct efflux::context::Context

pub struct Context { /* fields omitted */ }

Context structure to represent a Hadoop job context.

This acts as an arbitrarily-typed bag, allowing for easy storage of random types between iterations of the stage. See the module documentation for further details and examples.

Methods

impl Context

pub fn new() -> Self

Creates a new Context.

pub fn get<T: Contextual>(&self) -> Option<&T> where     T: Contextual,

Retrieves a potential reference to a Contextual type.

pub fn get_mut<T>(&mut self) -> Option<&mut T> where     T: Contextual,

Retrieves a potential mutable reference to a Contextual type.

pub fn insert<T>(&mut self, t: T) where     T: Contextual,

Inserts a Contextual type into the context.

pub fn take<T>(&mut self) -> Option<T> where     T: Contextual,

Takes a Contextual type from the context.

pub fn write(&mut self, key: &[u8], val: &[u8])

Writes a key/value pair to the stage output.

pub fn write_fmt<K, V>(&mut self, key: K, val: V) where     K: Display,     V: Display,

Writes a key/value formatted pair to the stage output.

This is a simple sugar API around write which allows callers to provide a type which implements Display to serialize automatically.

Trait Implementations

impl Debug for Context

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.