Modifier and Type | Method and Description |
---|---|
void |
RichShellSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
RichShellBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
ClojureSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
ClojureBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
CoordinatedBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
BatchBoltExecutor.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
ReturnResults.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
PrepareRequest.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
KeyedFairBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
JoinResult.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
DRPCSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Class and Description |
---|---|
class |
OutputFieldsGetter |
Modifier and Type | Method and Description |
---|---|
void |
IComponent.declareOutputFields(OutputFieldsDeclarer declarer)
Declare the output schema for all the streams of this topology.
|
void |
BasicBoltExecutor.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
TransactionalSpoutCoordinator.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
TransactionalSpoutBatchExecutor.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
PartitionedTransactionalSpoutExecutor.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
OpaquePartitionedTransactionalSpoutExecutor.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
HBaseLookupBolt.declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) |
void |
HBaseBolt.declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) |
Modifier and Type | Method and Description |
---|---|
void |
HBaseValueMapper.declareOutputFields(OutputFieldsDeclarer declarer)
declares the output fields for the lookup bolt.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractHdfsBolt.declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) |
Modifier and Type | Method and Description |
---|---|
void |
KafkaSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
KafkaBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
WordCountTopologyNode.SplitSentence.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
WordCountTopologyNode.RandomSentence.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
WordCountTopologyNode.WordCount.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
WordCountTopology.SplitSentence.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
WordCountTopology.WordCount.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
TransactionalWords.KeyedCountUpdater.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
TransactionalWords.Bucketize.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
TransactionalWords.BucketCountUpdater.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
TransactionalGlobalCount.BatchCount.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
TransactionalGlobalCount.UpdateGlobalCount.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
ReachTopology.GetTweeters.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
ReachTopology.GetFollowers.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
ReachTopology.PartialUniquer.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
ReachTopology.CountAggregator.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
ManualDRPC.ExclamationBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
ExclamationTopology.ExclamationBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
BasicDRPCTopology.ExclaimBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
SingleJoinBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
RollingCountBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
PrinterBolt.declareOutputFields(OutputFieldsDeclarer ofd) |
void |
AbstractRankerBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
TwitterSampleSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
RandomSentenceSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
SubtopologyBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
TridentSpoutExecutor.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
TridentSpoutCoordinator.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
RichSpoutBatchTriggerer.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
TridentBoltExecutor.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
MasterBatchCoordinator.declareOutputFields(OutputFieldsDeclarer declarer) |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.