org.springframework.data.hadoop.store.output
Class TextFileWriter
java.lang.Object
org.springframework.data.hadoop.store.support.LifecycleObjectSupport
org.springframework.data.hadoop.store.support.StoreObjectSupport
org.springframework.data.hadoop.store.support.OutputStoreObjectSupport
org.springframework.data.hadoop.store.output.AbstractDataStreamWriter
org.springframework.data.hadoop.store.output.TextFileWriter
- All Implemented Interfaces:
- Closeable, Flushable, Aware, BeanFactoryAware, InitializingBean, Lifecycle, Phased, SmartLifecycle, DataStoreWriter<String>, DataWriter<String>
public class TextFileWriter
- extends AbstractDataStreamWriter
- implements DataStoreWriter<String>
A TextFileWriter is a DataStoreWriter implementation
able to write Strings into raw hdfs files.
- Author:
- Janne Valkealahti
| Methods inherited from class org.springframework.data.hadoop.store.support.LifecycleObjectSupport |
afterPropertiesSet, getBeanFactory, getPhase, getStoreEventPublisher, getTaskExecutor, getTaskScheduler, isAutoStartup, isRunning, setAutoStartup, setBeanFactory, setPhase, setStoreEventPublisher, setTaskExecutor, setTaskScheduler, start, stop, stop |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TextFileWriter
public TextFileWriter(Configuration configuration,
Path basePath,
CodecInfo codec)
- Instantiates a new text file writer.
- Parameters:
configuration - the hadoop configurationbasePath - the hdfs pathcodec - the compression codec info
TextFileWriter
public TextFileWriter(Configuration configuration,
Path basePath,
CodecInfo codec,
byte[] delimiter)
- Instantiates a new text file writer.
- Parameters:
configuration - the hadoop configurationbasePath - the hdfs pathcodec - the compression codec infodelimiter - the delimiter
flush
public void flush()
throws IOException
- Specified by:
flush in interface Flushable
- Throws:
IOException
close
public void close()
throws IOException
- Specified by:
close in interface Closeable
- Throws:
IOException
write
public void write(String entity)
throws IOException
- Description copied from interface:
DataWriter
- Write an entity.
- Specified by:
write in interface DataWriter<String>
- Throws:
IOException - if an I/O error occurs
handleIdleTimeout
protected void handleIdleTimeout()
- Description copied from class:
StoreObjectSupport
- Handle idle timeout. This method should be overriden
to be notified of idle timeouts. Default implementation
doesn't do anything.
- Overrides:
handleIdleTimeout in class StoreObjectSupport