Package org.apache.storm.hdfs.trident

# Class HdfsState

java.lang.Object
org.apache.storm.hdfs.trident.HdfsState

All Implemented Interfaces:
  `State`

public class HdfsState extends Object implements State

- ## Nested Class Summary

  Nested Classes
  Modifier and Type
  Class
  Description
  `static class`
  `HdfsState.HdfsFileOptions`
  `static class`
  `HdfsState.Options`
  `static class`
  `HdfsState.SequenceFileOptions`

- ## Field Summary

  Fields
  Modifier and Type
  Field
  Description
  `static final org.slf4j.Logger`
  `LOG`

- ## Method Summary

  Modifier and Type
  Method
  Description
  `void`
  `beginCommit(Long txId)`
  `void`
  `commit(Long txId)`
  `void`
  `updateState(List<TridentTuple> tuples, TridentCollector tridentCollector)`

  ### Methods inherited from class java.lang.Object

  `clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

- ## Field Details

  - ### LOG

    public static final org.slf4j.Logger LOG

- ## Method Details

  - ### beginCommit

    public void beginCommit(Long txId)
    Specified by:
      `beginCommit` in interface `State`

  - ### commit

    public void commit(Long txId)
    Specified by:
      `commit` in interface `State`

  - ### updateState

    public void updateState(List<TridentTuple> tuples, TridentCollector tridentCollector)