public interface IBatchSpout extends ITridentDataSource
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 open(Map<String,Object> conf, TopologyContext context)
void emitBatch(long batchId, TridentCollector collector)
void ack(long batchId)
void close()
Fields getOutputFields()
Copyright © 2022 The Apache Software Foundation. All rights reserved.