K - the type of a partition keypublic class PartitionTextFileWriter<K> extends AbstractPartitionDataStoreWriter<String,K>
PartitionDataStoreWriter writing text data
 using a partitioning.| Constructor and Description | 
|---|
| PartitionTextFileWriter(Configuration configuration,
                       Path basePath,
                       CodecInfo codec,
                       PartitionStrategy<String,K> partitionStrategy)Instantiates a new text file partitioned writer. | 
| Modifier and Type | Method and Description | 
|---|---|
| protected DataStoreWriter<String> | createWriter(Configuration configuration,
            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(Configuration configuration, Path basePath, CodecInfo codec, PartitionStrategy<String,K> partitionStrategy)
configuration - the hadoop configurationbasePath - the hdfs pathcodec - the compression codec infopartitionStrategy - the partition strategyprotected DataStoreWriter<String> createWriter(Configuration configuration, Path path, CodecInfo codec)
AbstractPartitionDataStoreWritercreateWriter in class AbstractPartitionDataStoreWriter<String,K>configuration - the configurationpath - the base pathcodec - the codec