co.cask.cdap.etl.mock.common

Class MockEmitter<T>

java.lang.Object

co.cask.cdap.etl.mock.common.MockEmitter<T>

Type Parameters:

T - type of object to emit

All Implemented Interfaces:

AlertEmitter, Emitter<T>, ErrorEmitter<T>

public class MockEmitter<T>
extends Object
implements Emitter<T>

Mock implementation of Emitter for unit tests.

Constructor Summary

Constructors

Constructor and Description
MockEmitter()

Method Summary

Modifier and Type	Method and Description
void	clear()
void	emit(T value)
void	emitAlert(Map<String,String> payload)
void	emitError(InvalidEntry<T> value)
List<Map<String,String>>	getAlerts()
List<T>	getEmitted()
List<InvalidEntry<T>>	getErrors()

Methods inherited from class java.lang.Object

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

Constructor Detail

MockEmitter

public MockEmitter()

Method Detail

emit

public void emit(T value)

Specified by:

emit in interface Emitter<T>

emitError

public void emitError(InvalidEntry<T> value)

Specified by:

emitError in interface ErrorEmitter<T>

emitAlert

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

Specified by:

emitAlert in interface AlertEmitter

getEmitted

public List<T> getEmitted()

getErrors

public List<InvalidEntry<T>> getErrors()

getAlerts

public List<Map<String,String>> getAlerts()

clear

public void clear()