Uses of Interface
ds.funnel.topic.Topic

Packages that use Topic

Package	Description
ds.funnel.peer
ds.funnel.peer.event
ds.funnel.topic
ds.granules.dataset	This package contains functionality related to datasets that deployed application instances need to operate on.
ds.granules.operation	This package encapsulates functionality related to application instances that will be deployed on the cloud.

Uses of Topic in ds.funnel.peer

Methods in ds.funnel.peer that return Topic

Modifier and Type	Method and Description
Topic	PeerGroup.getTopic()
Topic	PeerGroupImpl.getTopic()
Topic	PeerManager.getTopic(java.lang.String inTopicName) Obtain the topic object for a given string
Topic	PeerManagerImpl.getTopic(java.lang.String inTopicName)

Methods in ds.funnel.peer that return types with arguments of type Topic

Modifier and Type	Method and Description
java.util.List<Topic>	PeerManager.getAvailableTopics()
java.util.List<Topic>	PeerManagerImpl.getAvailableTopics()
java.util.List<Topic>	PeerManager.getCoordinatedTopics()
java.util.List<Topic>	PeerManagerImpl.getCoordinatedTopics()
java.util.List<Topic>	PeerManager.getPublishingTopics()
java.util.List<Topic>	PeerManagerImpl.getPublishingTopics()
java.util.List<Topic>	PeerManager.getSubscribingTopics()
java.util.List<Topic>	PeerManagerImpl.getSubscribingTopics()

Methods in ds.funnel.peer with parameters of type Topic

Modifier and Type	Method and Description
PeerGroup	PeerManager.getKnownGroup(Topic inTopic) Returns the peer group if it is known to exist.
PeerGroup	PeerManagerImpl.getKnownGroup(Topic inTopic)
PeerGroup	PeerManager.getPeerGroup(Topic inTopic) Obtain the peer group for a topic, performing a lookup if it is not known.
PeerGroup	PeerManagerImpl.getPeerGroup(Topic inTopic)

Constructors in ds.funnel.peer with parameters of type Topic

Constructor and Description
PeerGroupImpl(PeerManager inManager, Topic inTopic)

Uses of Topic in ds.funnel.peer.event

Fields in ds.funnel.peer.event declared as Topic

Modifier and Type	Field and Description
Topic	MsgTopicAdvert.advertTopic
Topic	MsgTopicLookup.lookupTopic

Methods in ds.funnel.peer.event that return Topic

Modifier and Type	Method and Description
Topic	MessageBaseTE.getTopic()

Methods in ds.funnel.peer.event with parameters of type Topic

Modifier and Type	Method and Description
void	MessageBaseTE.setTopic(Topic inTopic)

Constructors in ds.funnel.peer.event with parameters of type Topic

Constructor and Description
MsgTopicAdvert(Topic inTopic, NodeDetails inCoord, OverlayPath inPath, int inExpire)
MsgTopicLookup(Topic inTopic, int inSearch, NodeDetails inMember, OverlayPath inPath, java.lang.String inTracker)

Uses of Topic in ds.funnel.topic

Classes in ds.funnel.topic that implement Topic

Modifier and Type	Class and Description
class	StringTopic
class	TopicBase

Fields in ds.funnel.topic with type parameters of type Topic

Modifier and Type	Field and Description
static java.util.Comparator<Topic>	TopicBase.SORT_NAME_ASC

Methods in ds.funnel.topic that return Topic

Modifier and Type	Method and Description
Topic	TopicPublisherImpl.getTopic()
Topic	TopicSubscriptionImpl.getTopic()
Topic	TopicSubscription.getTopic()
Topic	TopicPublisher.getTopic()
Topic	TopicEvent.getTopic()
Topic	TopicBase.TopicType.unmarshall(FormatReader mFormat) Unmarshall this type from a message input object.

Methods in ds.funnel.topic with parameters of type Topic

Modifier and Type	Method and Description
boolean	StringTopic.matchWith(Topic inTopic)

Uses of Topic in ds.granules.dataset

Methods in ds.granules.dataset that return types with arguments of type Topic

Modifier and Type	Method and Description
java.util.Collection<Topic>	StreamDatasetImpl.getInputStreams()
java.util.Collection<Topic>	StreamDataset.getInputStreams() Retrieve a collection of the constituent input streams.
java.util.Collection<Topic>	StreamDatasetImpl.getOutputStreams()
java.util.Collection<Topic>	StreamDataset.getOutputStreams() Retrieve a collection of the constituent output streams.

Methods in ds.granules.dataset with parameters of type Topic

Modifier and Type	Method and Description
int	StreamDatasetImpl.addInputStream(Topic topic)
int	StreamDataset.addInputStream(Topic topic) Add an input stream to this dataset.
int	StreamDatasetImpl.addOutputStream(Topic topic)
int	StreamDataset.addOutputStream(Topic topic) Add an output stream to this dataset.
boolean	StreamDatasetImpl.hasInputStream(Topic topic)
boolean	StreamDataset.hasInputStream(Topic topic) Check to see if this dataset has a specified input stream.
boolean	StreamDatasetImpl.hasOutputStream(Topic topic)
boolean	StreamDataset.hasOutputStream(Topic topic) Check to see if this dataset has a specified output stream.
int	StreamDatasetImpl.removeInputStream(Topic topic)
int	StreamDataset.removeInputStream(Topic topic) Removes an input stream from this dataset.
int	StreamDatasetImpl.removeOutputStream(Topic topic)
int	StreamDataset.removeOutputStream(Topic topic) Removes an output stream from this dataset.
void	StreamDatasetImpl.writeStreamingData(Topic topic, byte[] payload)
void	StreamDataset.writeStreamingData(Topic topic, byte[] payload) This method writes data to the output dataset.

Method parameters in ds.granules.dataset with type arguments of type Topic

Modifier and Type	Method and Description
int	StreamDatasetImpl.addInputStreams(java.util.Collection<Topic> topics)
int	StreamDataset.addInputStreams(java.util.Collection<Topic> topics) Adds a set of input streams to this dataset.
int	StreamDatasetImpl.addOutputStreams(java.util.Collection<Topic> topics)
int	StreamDataset.addOutputStreams(java.util.Collection<Topic> topics) Adds a set of output streams to this dataset.
int	StreamDatasetImpl.removeInputStreams(java.util.Collection<Topic> topics)
int	StreamDataset.removeInputStreams(java.util.Collection<Topic> topics) Removes a set of input streams from this dataset.
int	StreamDatasetImpl.removeOutputStreams(java.util.Collection<Topic> topics)
int	StreamDataset.removeOutputStreams(java.util.Collection<Topic> topics) Removes a set of output streams from this dataset.

Uses of Topic in ds.granules.operation

Methods in ds.granules.operation with parameters of type Topic

Modifier and Type	Method and Description
void	MapReduceBase.writeResults(Topic topic, Results results)
void	MapReduce.writeResults(Topic topic, Results results) Writes the specified results to a specific output stream.