Serialized Form (streams-persist-hdfs 0.5.2-SNAPSHOT API)

Package org.apache.streams.hdfs
- Class org.apache.streams.hdfs.HdfsConfiguration extends LineReadWriteConfiguration implements Serializable
  - Serialized Fields
    - scheme
```
HdfsConfiguration.Scheme scheme
```
      scheme
    - host
```
String host
```
      WebHdfs host
    - port
```
Long port
```
      WebHdfs port
    - path
```
String path
```
      Base path
    - user
```
String user
```
      User
    - password
```
String password
```
      Password
    - additionalProperties
```
Map<K,V> additionalProperties
```
- Class org.apache.streams.hdfs.HdfsReaderConfiguration extends HdfsConfiguration implements Serializable
  - Serialized Fields
    - readerPath
```
String readerPath
```
      Path below root path
    - additionalProperties
```
Map<K,V> additionalProperties
```
- Class org.apache.streams.hdfs.HdfsWriterConfiguration extends HdfsConfiguration implements Serializable
  - Serialized Fields
    - writerPath
```
String writerPath
```
      Path
    - writerFilePrefix
```
String writerFilePrefix
```
      File Prefix
    - linesPerFile
```
Long linesPerFile
```
      Lines Per File
    - compression
```
HdfsWriterConfiguration.Compression compression
```
      compression
    - additionalProperties
```
Map<K,V> additionalProperties
```
- Class org.apache.streams.hdfs.WebHdfsPersistReader extends Object implements Serializable
  - Serialized Fields
    - client
```
org.apache.hadoop.fs.FileSystem client
```
    - path
```
org.apache.hadoop.fs.Path path
```
    - status
```
org.apache.hadoop.fs.FileStatus[] status
```
    - persistQueue
```
Queue<E> persistQueue
```
    - mapper
```
com.fasterxml.jackson.databind.ObjectMapper mapper
```
    - lineReaderUtil
```
LineReadWriteUtil lineReaderUtil
```
    - hdfsConfiguration
```
HdfsReaderConfiguration hdfsConfiguration
```
    - streamsConfiguration
```
StreamsConfiguration streamsConfiguration
```
    - executor
```
ExecutorService executor
```
    - countersTotal
```
DatumStatusCounter countersTotal
```
    - countersCurrent
```
DatumStatusCounter countersCurrent
```
    - task
```
Future<V> task
```
- Class org.apache.streams.hdfs.WebHdfsPersistWriter extends Object implements Serializable
  - Serialized Fields
    - client
```
org.apache.hadoop.fs.FileSystem client
```
    - path
```
org.apache.hadoop.fs.Path path
```
    - linesPerFile
```
int linesPerFile
```
    - totalRecordsWritten
```
int totalRecordsWritten
```
    - writtenFiles
```
List<E> writtenFiles
```
    - fileLineCounter
```
int fileLineCounter
```
    - currentWriter
```
OutputStreamWriter currentWriter
```
    - totalByteCount
```
int totalByteCount
```
    - byteCount
```
int byteCount
```
    - terminate
```
boolean terminate
```
    - persistQueue
```
Queue<E> persistQueue
```
    - mapper
```
com.fasterxml.jackson.databind.ObjectMapper mapper
```
    - lineWriterUtil
```
LineReadWriteUtil lineWriterUtil
```
    - hdfsConfiguration
```
HdfsWriterConfiguration hdfsConfiguration
```

Serialized Form

Package org.apache.streams.hdfs

Class org.apache.streams.hdfs.HdfsConfiguration extends LineReadWriteConfiguration implements Serializable

Serialized Fields

scheme

host

port

path

user

password

additionalProperties

Class org.apache.streams.hdfs.HdfsReaderConfiguration extends HdfsConfiguration implements Serializable

Serialized Fields

readerPath

additionalProperties

Class org.apache.streams.hdfs.HdfsWriterConfiguration extends HdfsConfiguration implements Serializable

Serialized Fields

writerPath

writerFilePrefix

linesPerFile

compression

additionalProperties

Class org.apache.streams.hdfs.WebHdfsPersistReader extends Object implements Serializable

Serialized Fields

client

path

status

persistQueue

mapper

lineReaderUtil

hdfsConfiguration

streamsConfiguration

executor

countersTotal

countersCurrent

task

Class org.apache.streams.hdfs.WebHdfsPersistWriter extends Object implements Serializable

Serialized Fields

client

path

linesPerFile

totalRecordsWritten

writtenFiles

fileLineCounter

currentWriter

totalByteCount

byteCount

terminate

persistQueue

mapper

lineWriterUtil

hdfsConfiguration