org.apache.reef.io.watcher

Interface EventStream

All Known Implementing Classes:

FileEventStream, LogEventStream, TestEventStream

@DefaultImplementation(value=LogEventStream.class)
public interface EventStream

Write events to a certain destination.

Method Summary

Modifier and Type	Method and Description
void	onEvent(EventType type, String jsonEncodedEvent) Write an eventRecord with specific type.

Method Detail

onEvent

void onEvent(EventType type,
             String jsonEncodedEvent)

Write an eventRecord with specific type. This should be thread-safe since multiple event handlers can concurrently call the method.

Parameters:

type - a event type

jsonEncodedEvent - an event encoded as json