Modifier and Type | Method and Description |
---|---|
void |
ExclamationTopology.ExclamationBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
ExclamationTopology.FixedOrderWordSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
JoinBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
BaseCassandraBolt.declareOutputFields(OutputFieldsDeclarer declarer)
Declare the output schema for all the streams of this topology.
|
Modifier and Type | Method and Description |
---|---|
void |
RichShellSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
ClojureBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
RichShellBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
ClojureSpout.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 |
DRPCSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
KeyedFairBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
ReturnResults.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
PrepareRequest.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
JoinResult.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
EsIndexTopology.UserDataSpout.declareOutputFields(OutputFieldsDeclarer declarer)
Declares
source , index , type and id . |
void |
EsLookupBolt.declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) |
void |
EsIndexBolt.declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) |
void |
AbstractEsBolt.declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) |
void |
EsPercolateBolt.declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) |
Modifier and Type | Method and Description |
---|---|
void |
EventHubBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
EventHubSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
WordCounter.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
TestWindowBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
TestPrintBolt.declareOutputFields(OutputFieldsDeclarer ofd) |
void |
StatefulWordCounter.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
FluxShellBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
LogInfoBolt.declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) |
Modifier and Type | Method and Description |
---|---|
void |
FluxShellSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
HBaseBolt.declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) |
void |
HBaseLookupBolt.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 |
WordCounter.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
TotalWordCounter.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
WordSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
WordCountValueMapper.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
SequenceFileTopology.SentenceSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
SequenceFileTopology.MyBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
HdfsFileTopology.SentenceSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
HdfsFileTopology.MyBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
AbstractHdfsBolt.declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) |
Modifier and Type | Method and Description |
---|---|
void |
HdfsSpoutTopology.ConstBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
HdfsSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
HiveTopologyPartitioned.UserDataSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
BucketTestHiveTopology.UserDataSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
HiveTopology.UserDataSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
HiveBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
JdbcLookupBolt.declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) |
void |
JdbcInsertBolt.declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) |
Modifier and Type | Method and Description |
---|---|
void |
JdbcLookupMapper.declareOutputFields(OutputFieldsDeclarer declarer)
declare what are the fields that this code will output.
|
void |
SimpleJdbcLookupMapper.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
UserSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
JmsTupleProducer.declareOutputFields(OutputFieldsDeclarer declarer)
Declare the output fields produced by this JmsTupleProducer.
|
Modifier and Type | Method and Description |
---|---|
void |
JmsBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
GenericBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
JsonTupleProducer.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
JmsSpout.declareOutputFields(OutputFieldsDeclarer declarer)
Use the
JmsSpout.tupleProducer to determine which fields are about to be emitted. |
Modifier and Type | Method and Description |
---|---|
void |
KafkaBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
KafkaSpoutTestBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
KafkaSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
KinesisSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
LambdaBiConsumerBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
LambdaConsumerBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
LambdaSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
ThroughputVsLatency.FastRandomSentenceSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
ThroughputVsLatency.SplitSentence.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
ThroughputVsLatency.WordCount.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
LoadBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
LoadSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
MongoLookupBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
MongoInsertBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
MongoUpdateBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
MongoLookupMapper.declareOutputFields(OutputFieldsDeclarer declarer)
declare what are the fields that this code will output.
|
void |
SimpleMongoLookupMapper.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
WordCounter.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
TotalWordCounter.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
WordSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
MqttBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
MqttSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
MetricGenSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
OpenTsdbBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
CountBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
SplitSentenceBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
IdBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
DevNullBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
FileReadSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
StringGenSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
ConstSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
WordGenSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
IdentityBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
RawInputFromCSVSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
PMMLPredictorBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
RedisFilterBolt.declareOutputFields(OutputFieldsDeclarer declarer)
Declare the output schema for all the streams of this topology.
|
void |
RedisLookupBolt.declareOutputFields(OutputFieldsDeclarer declarer)
Declare the output schema for all the streams of this topology.
|
void |
RedisStoreBolt.declareOutputFields(OutputFieldsDeclarer declarer)
Declare the output schema for all the streams of this topology.
|
Modifier and Type | Method and Description |
---|---|
void |
RedisFilterMapper.declareOutputFields(OutputFieldsDeclarer declarer)
declare what are the fields that this code will output.
|
void |
RedisLookupMapper.declareOutputFields(OutputFieldsDeclarer declarer)
declare what are the fields that this code will output.
|
Modifier and Type | Method and Description |
---|---|
void |
WordCounter.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
WhitelistWordCount.PrintWordTotalCountBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
LookupWordCount.PrintWordTotalCountBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
WordSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
WordCountLookupMapper.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
RocketMqBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
RocketMqSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
WordCounter.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
SolrUpdateBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
SolrFieldsSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
SolrJsonSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
CheckpointSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
SocketBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
SocketSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
TimeDataVerificationBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
VerificationBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
IncrementingSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
TimeDataIncrementingSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
ManualDRPC.ExclamationBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
AnchoredWordCount.RandomSentenceSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
AnchoredWordCount.SplitSentence.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
AnchoredWordCount.WordCount.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
StatefulTopology.PrinterBolt.declareOutputFields(OutputFieldsDeclarer ofd) |
void |
FastWordCountTopology.FastRandomSentenceSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
FastWordCountTopology.SplitSentence.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
FastWordCountTopology.WordCount.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
ResourceAwareExampleTopology.ExclamationBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
MultipleLoggerTopology.ExclamationLoggingBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
BasicDRPCTopology.ExclaimBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
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 |
InOrderDeliveryTest.InOrderSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
InOrderDeliveryTest.Check.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 |
ExclamationTopology.ExclamationBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
BlobStoreAPIWordCountTopology.RandomSentenceSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
BlobStoreAPIWordCountTopology.SplitSentence.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
BlobStoreAPIWordCountTopology.FilterWords.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
RollingCountAggBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
RollingCountBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
SingleJoinBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
PrinterBolt.declareOutputFields(OutputFieldsDeclarer ofd) |
void |
SlidingWindowSumBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
AbstractRankerBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
RandomIntegerSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
RandomSentenceSpout.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Class and Description |
---|---|
class |
OutputFieldsGetter |
Modifier and Type | Method and Description |
---|---|
protected void |
BaseStatefulBoltExecutor.declareCheckpointStream(OutputFieldsDeclarer declarer) |
void |
StatefulBoltExecutor.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
IComponent.declareOutputFields(OutputFieldsDeclarer declarer)
Declare the output schema for all the streams of this topology.
|
void |
BasicBoltExecutor.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
CheckpointTupleForwarder.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
WindowedBoltExecutor.declareOutputFields(OutputFieldsDeclarer declarer) |
Modifier and Type | Method and Description |
---|---|
void |
BaseWindowedBolt.declareOutputFields(OutputFieldsDeclarer declarer) |
void |
BaseStatefulBolt.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 © 2019 The Apache Software Foundation. All rights reserved.