org.apache.asterix.metadata.feeds

Class PrepareStallMessage

java.lang.Object

org.apache.asterix.common.feeds.message.FeedMessage

org.apache.asterix.metadata.feeds.PrepareStallMessage

All Implemented Interfaces:

Serializable, IFeedMessage, org.apache.hyracks.api.dataflow.value.JSONSerializable

public class PrepareStallMessage
extends FeedMessage

A feed control message indicating the need to end the feed. This message is dispatched to all locations that host an operator involved in the feed pipeline.

See Also:

Serialized Form

Nested Class Summary

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

IFeedMessage.MessageType

Field Summary

Fields inherited from class org.apache.asterix.common.feeds.message.FeedMessage

messageType

Constructor Summary

Constructors

Constructor and Description
PrepareStallMessage(FeedConnectionId connectionId, int computePartitionsRetainLimit)

Method Summary

Methods

Modifier and Type	Method and Description
int	getComputePartitionsRetainLimit()
FeedConnectionId	getConnectionId()
org.json.JSONObject	toJSON()
String	toString()

Methods inherited from class org.apache.asterix.common.feeds.message.FeedMessage

getMessageType

Methods inherited from class java.lang.Object

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

Constructor Detail

PrepareStallMessage

public PrepareStallMessage(FeedConnectionId connectionId,
                   int computePartitionsRetainLimit)

Method Detail

toString

public String toString()

Overrides:

toString in class Object

toJSON

public org.json.JSONObject toJSON()
                           throws org.json.JSONException

Throws:

org.json.JSONException

getConnectionId

public FeedConnectionId getConnectionId()

getComputePartitionsRetainLimit

public int getComputePartitionsRetainLimit()