Package org.apache.storm.hive.trident
Class TridentHiveTopology.FixedBatchSpout
- java.lang.Object
- 
- org.apache.storm.hive.trident.TridentHiveTopology.FixedBatchSpout
 
- 
- All Implemented Interfaces:
- Serializable,- IBatchSpout,- ITridentDataSource
 - Enclosing class:
- TridentHiveTopology
 
 public static class TridentHiveTopology.FixedBatchSpout extends Object implements IBatchSpout - See Also:
- Serialized Form
 
- 
- 
Constructor SummaryConstructors Constructor Description FixedBatchSpout(int maxBatchSize)
 - 
Method SummaryAll Methods Instance Methods Concrete Methods Modifier and Type Method Description voidack(long batchId)voidclose()voidemitBatch(long batchId, TridentCollector collector)Map<String,Object>getComponentConfiguration()FieldsgetOutputFields()voidopen(Map<String,Object> conf, TopologyContext context)voidsetCycle(boolean cycle)
 
- 
- 
- 
Method Detail- 
setCyclepublic void setCycle(boolean cycle) 
 - 
getOutputFieldspublic Fields getOutputFields() - Specified by:
- getOutputFieldsin interface- IBatchSpout
 
 - 
openpublic void open(Map<String,Object> conf, TopologyContext context) - Specified by:
- openin interface- IBatchSpout
 
 - 
emitBatchpublic void emitBatch(long batchId, TridentCollector collector)- Specified by:
- emitBatchin interface- IBatchSpout
 
 - 
ackpublic void ack(long batchId) - Specified by:
- ackin interface- IBatchSpout
 
 - 
closepublic void close() - Specified by:
- closein interface- IBatchSpout
 
 - 
getComponentConfigurationpublic Map<String,Object> getComponentConfiguration() - Specified by:
- getComponentConfigurationin interface- IBatchSpout
 
 
- 
 
-