org.apache.storm.trident.spout

## Interface IBatchSpout

- All Superinterfaces:
    ITridentDataSource, Serializable
  All Known Implementing Classes:
    FixedBatchSpout, FixedBatchSpout, MetricGenBatchSpout, RandomNumberGeneratorSpout, TridentEsTopology.FixedBatchSpout, TridentHiveTopology.FixedBatchSpout

      public interface IBatchSpout
      extends ITridentDataSource

- - ### Method Summary

    All Methods Instance Methods Abstract Methods
    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)`

- - ### Method Detail

    - #### open

          void open(Map<String,Object> conf,
                    TopologyContext context)

    - #### emitBatch

          void emitBatch(long batchId,
                         TridentCollector collector)

    - #### ack

          void ack(long batchId)

    - #### close

          void close()

    - #### getComponentConfiguration

          Map<String,Object> getComponentConfiguration()

    - #### getOutputFields

          Fields getOutputFields()

Copyright © 2021 The Apache Software Foundation. All rights reserved.