Emitter (Apache Crunch 0.8.0 API)

This project has retired. For details please refer to its Attic page.

Overview

Package

Class

Use

Tree

Deprecated

Index

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

org.apache.crunch
Interface Emitter<T>

public interface Emitter<T>

Interface for writing outputs from a DoFn.

Method Summary

void emit(T emitted)
Write the emitted value to the next stage of the pipeline.

void flush()
Flushes any values cached by this emitter.

Method Summary
`void`	`emit(T emitted)` Write the emitted value to the next stage of the pipeline.
`void`	`flush()` Flushes any values cached by this emitter.

Method Detail

emit

void emit(T emitted)

Write the emitted value to the next stage of the pipeline.

Parameters:: emitted - The value to write

flush

void flush()

Flushes any values cached by this emitter. Called during the cleanup stage.