co.cask.cdap.etl.spark

Class CombinedEmitter<T>

java.lang.Object

co.cask.cdap.etl.spark.CombinedEmitter<T>

Type Parameters:

T - the type of object to emit

All Implemented Interfaces:

AlertEmitter, Emitter<T>, ErrorEmitter<T>, MultiOutputEmitter<T>

public class CombinedEmitter<T>
extends Object
implements Emitter<T>, MultiOutputEmitter<T>

An emitter used in Spark to collect all output and errors emitted.

Constructor Summary

Constructors

Constructor and Description
CombinedEmitter(String stageName)

Method Summary

Modifier and Type	Method and Description
void	emit(String port, Object value)
void	emit(T value)
void	emitAlert(Map<String,String> payload)
void	emitError(InvalidEntry<T> invalidEntry)
Iterable<RecordInfo<Object>>	getEmitted()
void	reset()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CombinedEmitter

public CombinedEmitter(String stageName)

Method Detail

emit

public void emit(T value)

Specified by:

emit in interface Emitter<T>

emit

public void emit(String port,
                 Object value)

Specified by:

emit in interface MultiOutputEmitter<T>

emitError

public void emitError(InvalidEntry<T> invalidEntry)

Specified by:

emitError in interface ErrorEmitter<T>

emitAlert

public void emitAlert(Map<String,String> payload)

Specified by:

emitAlert in interface AlertEmitter

getEmitted

public Iterable<RecordInfo<Object>> getEmitted()

Returns:

all output and errors emitted.

reset

public void reset()