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:

Emitter<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

Methods

Modifier and Type	Method and Description
void	clear()
void	emit(T value)
void	emitError(InvalidEntry<T> value)
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 Emitter<T>

getEmitted

public List<T> getEmitted()

getErrors

public List<InvalidEntry<T>> getErrors()

clear

public void clear()