org.apache.asterix.metadata.feeds

Class AdapterRuntimeManager

java.lang.Object

org.apache.asterix.metadata.feeds.AdapterRuntimeManager

All Implemented Interfaces:

IAdapterRuntimeManager

public class AdapterRuntimeManager
extends Object
implements IAdapterRuntimeManager

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.asterix.common.feeds.api.IAdapterRuntimeManager

IAdapterRuntimeManager.State

Constructor Summary

Constructors

Constructor and Description
AdapterRuntimeManager(FeedId feedId, IFeedAdapter feedAdapter, IIntakeProgressTracker tracker, DistributeFeedFrameWriter writer, int partition)

Method Summary

Methods

Modifier and Type	Method and Description
AdapterExecutor	getAdapterExecutor()
IFeedAdapter	getFeedAdapter()
FeedId	getFeedId()
IngestionRuntime	getIngestionRuntime()
int	getPartition()
IIntakeProgressTracker	getProgressTracker()
IAdapterRuntimeManager.State	getState()
IIntakeProgressTracker	getTracker()
void	setState(IAdapterRuntimeManager.State state)
void	start()
void	stop()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

AdapterRuntimeManager

public AdapterRuntimeManager(FeedId feedId,
                     IFeedAdapter feedAdapter,
                     IIntakeProgressTracker tracker,
                     DistributeFeedFrameWriter writer,
                     int partition)

Method Detail

start

public void start()
           throws Exception

Specified by:

start in interface IAdapterRuntimeManager

Throws:

Exception

stop

public void stop()

Specified by:

stop in interface IAdapterRuntimeManager

getFeedId

public FeedId getFeedId()

Specified by:

getFeedId in interface IAdapterRuntimeManager

toString

public String toString()

Overrides:

toString in class Object

getFeedAdapter

public IFeedAdapter getFeedAdapter()

Specified by:

getFeedAdapter in interface IAdapterRuntimeManager

getTracker

public IIntakeProgressTracker getTracker()

getState

public IAdapterRuntimeManager.State getState()

Specified by:

getState in interface IAdapterRuntimeManager

setState

public void setState(IAdapterRuntimeManager.State state)

Specified by:

setState in interface IAdapterRuntimeManager

getAdapterExecutor

public AdapterExecutor getAdapterExecutor()

getPartition

public int getPartition()

Specified by:

getPartition in interface IAdapterRuntimeManager

getIngestionRuntime

public IngestionRuntime getIngestionRuntime()

getProgressTracker

public IIntakeProgressTracker getProgressTracker()

Specified by:

getProgressTracker in interface IAdapterRuntimeManager