K - the type of a partition keypublic class PartitionTextFileWriter<K> extends AbstractPartitionDataStoreWriter<java.lang.String,K>
PartitionDataStoreWriter writing text data
 using a partitioning.| Constructor and Description | 
|---|
| PartitionTextFileWriter(org.apache.hadoop.conf.Configuration configuration,
                       org.apache.hadoop.fs.Path basePath,
                       CodecInfo codec,
                       PartitionStrategy<java.lang.String,K> partitionStrategy)Instantiates a new text file partitioned writer. | 
| Modifier and Type | Method and Description | 
|---|---|
| protected DataStoreWriter<java.lang.String> | createWriter(org.apache.hadoop.conf.Configuration configuration,
            org.apache.hadoop.fs.Path path,
            CodecInfo codec)Need to be implemented by a subclass for an actual writer. | 
close, doStart, doStop, flush, getBasePath, getCodec, getConfiguration, getFileNamingStrategyFactory, getIdleTimeout, getInWritingPrefix, getInWritingSuffix, getMaxOpenAttempts, getRolloverStrategyFactory, isOverwrite, onInit, setFileNamingStrategyFactory, setIdleTimeout, setInWritingPrefix, setInWritingSuffix, setMaxOpenAttempts, setOverwrite, setRolloverStrategyFactory, write, writeafterPropertiesSet, getBeanFactory, getPhase, getStoreEventPublisher, getTaskExecutor, getTaskScheduler, isAutoStartup, isRunning, setAutoStartup, setBeanFactory, setPhase, setStoreEventPublisher, setTaskExecutor, setTaskScheduler, start, stop, stoppublic PartitionTextFileWriter(org.apache.hadoop.conf.Configuration configuration,
                       org.apache.hadoop.fs.Path basePath,
                       CodecInfo codec,
                       PartitionStrategy<java.lang.String,K> partitionStrategy)
configuration - the hadoop configurationbasePath - the hdfs pathcodec - the compression codec infopartitionStrategy - the partition strategyprotected DataStoreWriter<java.lang.String> createWriter(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path path, CodecInfo codec)
AbstractPartitionDataStoreWritercreateWriter in class AbstractPartitionDataStoreWriter<java.lang.String,K>configuration - the configurationpath - the base pathcodec - the codec