co.cask.cdap.etl.mock.common

Class MockMultiOutputEmitter<E>

java.lang.Object

co.cask.cdap.etl.mock.common.MockMultiOutputEmitter<E>

Type Parameters:

E - type of error object

All Implemented Interfaces:

AlertEmitter, ErrorEmitter<E>, MultiOutputEmitter<E>

public class MockMultiOutputEmitter<E>
extends Object
implements MultiOutputEmitter<E>

Mock implementation of MultiOutputEmitter for unit tests.

Constructor Summary

Constructors

Constructor and Description
MockMultiOutputEmitter()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

MockMultiOutputEmitter

public MockMultiOutputEmitter()

Method Detail

emit

public void emit(String port,
                 Object value)

Specified by:

emit in interface MultiOutputEmitter<E>

emitError

public void emitError(InvalidEntry<E> invalidEntry)

Specified by:

emitError in interface ErrorEmitter<E>

emitAlert

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

Specified by:

emitAlert in interface AlertEmitter

getEmitted

public Map<String,List<Object>> getEmitted()

getErrors

public List<InvalidEntry<E>> getErrors()

getAlerts

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

clear

public void clear()