org.apache.s4.core.adapter
Class AdapterApp

java.lang.Object
  extended by org.apache.s4.core.App
      extended by org.apache.s4.core.adapter.AdapterApp

public abstract class AdapterApp
extends App

Base class for adapters. For now, it provides facilities for automatically creating an output stream.


Nested Class Summary
 
Nested classes/interfaces inherited from class org.apache.s4.core.App
App.ClockType
 
Field Summary
protected  KeyFinder<Event> remoteStreamKeyFinder
           
 
Constructor Summary
AdapterApp()
           
 
Method Summary
 RemoteStream getRemoteStream()
           
protected  void onClose()
          This method is called by the container before unloading the application.
protected  void onInit()
          This method is called by the container to initialize applications.
protected  void onStart()
           
protected  void setKeyFinder(KeyFinder<Event> keyFinder)
          This method allows to specify a keyfinder in order to partition the output stream
 
Methods inherited from class org.apache.s4.core.App
addStream, close, createInputStream, createInputStream, createOutputStream, createOutputStream, createPE, createPE, createSlidingWindowPE, createStream, createStream, createStream, createStream, getCheckpointingFramework, getClockType, getId, getPE, getReceiver, getSender, getSerDeser, getStreams, getTime, getTime, init, setClockType, setId, start
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

remoteStreamKeyFinder

protected KeyFinder<Event> remoteStreamKeyFinder
Constructor Detail

AdapterApp

public AdapterApp()
Method Detail

getRemoteStream

public RemoteStream getRemoteStream()

onStart

protected void onStart()
Specified by:
onStart in class App

onInit

protected void onInit()
Description copied from class: App
This method is called by the container to initialize applications.

Specified by:
onInit in class App

setKeyFinder

protected void setKeyFinder(KeyFinder<Event> keyFinder)
This method allows to specify a keyfinder in order to partition the output stream

Parameters:
keyFinder - used for identifying keys from the events

onClose

protected void onClose()
Description copied from class: App
This method is called by the container before unloading the application.

Specified by:
onClose in class App