public static class TridentHiveTopology.FixedBatchSpout extends Object implements IBatchSpout
| Constructor and Description |
|---|
FixedBatchSpout(int maxBatchSize) |
| 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) |
void |
setCycle(boolean cycle) |
public void setCycle(boolean cycle)
public Fields getOutputFields()
getOutputFields in interface IBatchSpoutpublic void open(Map<String,Object> conf, TopologyContext context)
open in interface IBatchSpoutpublic void emitBatch(long batchId,
TridentCollector collector)
emitBatch in interface IBatchSpoutpublic void ack(long batchId)
ack in interface IBatchSpoutpublic void close()
close in interface IBatchSpoutpublic Map<String,Object> getComponentConfiguration()
getComponentConfiguration in interface IBatchSpoutCopyright © 2021 The Apache Software Foundation. All rights reserved.