public class RandomNumberGeneratorSpout extends Object implements IBatchSpout
This spout generates random whole numbers with given maxNumber
value as maximum with the given fields
.
Constructor and Description |
---|
RandomNumberGeneratorSpout(Fields fields,
int batchSize,
int maxNumber) |
Modifier and Type | Method and Description |
---|---|
void |
ack(long batchId) |
void |
close() |
void |
emitBatch(long batchId,
TridentCollector collector) |
Map<String,Object> |
getComponentConfiguration() |
Fields |
getOutputFields() |
void |
open(Map<String,Object> conf,
TopologyContext context) |
public RandomNumberGeneratorSpout(Fields fields, int batchSize, int maxNumber)
public void open(Map<String,Object> conf, TopologyContext context)
open
in interface IBatchSpout
public void emitBatch(long batchId, TridentCollector collector)
emitBatch
in interface IBatchSpout
public void ack(long batchId)
ack
in interface IBatchSpout
public void close()
close
in interface IBatchSpout
public Map<String,Object> getComponentConfiguration()
getComponentConfiguration
in interface IBatchSpout
public Fields getOutputFields()
getOutputFields
in interface IBatchSpout
Copyright © 2022 The Apache Software Foundation. All rights reserved.