org.springframework.xd.hadoop.fs

Class HdfsTextFileWriter

java.lang.Object

org.springframework.xd.hadoop.fs.AbstractHdfsWriter

org.springframework.xd.hadoop.fs.HdfsTextFileWriter

All Implemented Interfaces:

HdfsWriter

public class HdfsTextFileWriter
extends AbstractHdfsWriter
implements HdfsWriter

Author:

Mark Pollack

Constructor Summary

Constructors

Constructor and Description
HdfsTextFileWriter(org.apache.hadoop.fs.FileSystem fileSystem)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	copy(byte[] in, org.apache.hadoop.fs.FSDataOutputStream out) Simple not optimized copy
org.apache.hadoop.fs.FileSystem	getFileSystem()
void	write(org.springframework.messaging.Message<?> message)

Methods inherited from class org.springframework.xd.hadoop.fs.AbstractHdfsWriter

getBaseFilename, getBasePath, getBytesWritten, getCounter, getCounterFromName, getFileName, getFileSuffix, getRolloverThresholdInBytes, incrementBytesWritten, incrementCounter, initializeCounterIfNecessary, resetBytesWritten, setBaseFilename, setBasePath, setCounter, setFileSuffix, setRolloverThresholdInBytes

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HdfsTextFileWriter

public HdfsTextFileWriter(org.apache.hadoop.fs.FileSystem fileSystem)

Method Detail

write

public void write(org.springframework.messaging.Message<?> message)
           throws java.io.IOException

Specified by:

write in interface HdfsWriter

Throws:

java.io.IOException

getFileSystem

public org.apache.hadoop.fs.FileSystem getFileSystem()

Specified by:

getFileSystem in class AbstractHdfsWriter

copy

public void copy(byte[] in,
        org.apache.hadoop.fs.FSDataOutputStream out)
          throws java.io.IOException

Simple not optimized copy

Throws:

java.io.IOException

close

public void close()

Specified by:

close in interface HdfsWriter