String key
String secretKey
String bucket
S3Configuration.Protocol protocol
String region
Map<K,V> additionalProperties
S3ReaderConfiguration s3ReaderConfiguration
com.amazonaws.services.s3.AmazonS3Client amazonS3Client
com.fasterxml.jackson.databind.ObjectMapper mapper
LineReadWriteUtil lineReaderUtil
Collection<E> files
ExecutorService executor
Queue<E> persistQueue
DatumStatusCounter countersTotal
DatumStatusCounter countersCurrent
Future<V> task
com.fasterxml.jackson.databind.ObjectMapper objectMapper
com.amazonaws.services.s3.AmazonS3Client amazonS3Client
S3WriterConfiguration s3WriterConfiguration
List<E> writtenFiles
LineReadWriteUtil lineWriterUtil
AtomicLong totalBytesWritten
AtomicLong bytesWrittenThisFile
AtomicInteger totalRecordsWritten
AtomicInteger fileLineCounter
Map<K,V> objectMetaData
OutputStreamWriter currentWriter
String writerPath
String writerFilePrefix
Long maxFileSize
Boolean chunk
S3WriterConfiguration.Compression compression
Map<K,V> additionalProperties
Copyright © 2012–2016 The Apache Software Foundation. All rights reserved.