K
- パーティションキーの型 public class PartitionTextFileWriter<K> extends AbstractPartitionDataStoreWriter<java.lang.String,K>
PartitionDataStoreWriter
の実装。コンストラクターと説明 |
---|
PartitionTextFileWriter(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path basePath, CodecInfo codec, PartitionStrategy<java.lang.String,K> partitionStrategy) 新しいテキストファイルパーティションライターをインスタンス化します。 |
修飾子と型 | メソッドと説明 |
---|---|
protected DataStoreWriter<java.lang.String> | createWriter(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path path, CodecInfo codec) 実際のライターのサブクラスによって実装する必要があります。 |
close, destroyWriter, doStart, doStop, flush, getBasePath, getCloseTimeout, getCodec, getConfiguration, getFileNamingStrategyFactory, getFlushTimeout, getIdleTimeout, getInWritingPrefix, getInWritingSuffix, getMaxOpenAttempts, getRolloverStrategyFactory, isAppendable, isClosed, isOverwrite, isSyncable, onInit, setAppendable, setCloseTimeout, setFileNamingStrategyFactory, setFlushTimeout, setIdleTimeout, setInWritingPrefix, setInWritingSuffix, setMaxOpenAttempts, setOverwrite, setRolloverStrategyFactory, setSyncable, write, write
afterPropertiesSet, getBeanFactory, getPhase, getStoreEventPublisher, getTaskExecutor, getTaskScheduler, isAutoStartup, isRunning, setAutoStartup, setBeanFactory, setPhase, setStoreEventPublisher, setTaskExecutor, setTaskScheduler, start, stop, stop
public PartitionTextFileWriter(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path basePath, CodecInfo codec, PartitionStrategy<java.lang.String,K> partitionStrategy)
configuration
- Hadoop の設定 basePath
- HDFs パス codec
- 圧縮コーデック情報 partitionStrategy
- 分割戦略 protected DataStoreWriter<java.lang.String> createWriter(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path path, CodecInfo codec)
AbstractPartitionDataStoreWriter
AbstractPartitionDataStoreWriter<java.lang.String,K>
の createWriter
configuration
- 構成 path
- 基本パス codec
- コーデック