Class KafkaTridentSpoutBatchMetadata

    • Constructor Detail

      • KafkaTridentSpoutBatchMetadata

        public KafkaTridentSpoutBatchMetadata​(long firstOffset,
                                              long lastOffset,
                                              String topologyId)
        Builds a metadata object.
        Parameters:
        firstOffset - The first offset for the batch
        lastOffset - The last offset for the batch
    • Method Detail

      • getFirstOffset

        public long getFirstOffset()
      • getLastOffset

        public long getLastOffset()
      • getTopologyId

        public String getTopologyId()
      • toMap

        public Map<String,​Object> toMap()
        Writes this metadata object to a Map so Trident can read/write it to Zookeeper.