org.apache.flink.streaming.connectors.fs

Class StringWriter<T>

java.lang.Object

org.apache.flink.streaming.connectors.fs.StreamWriterBase<T>

org.apache.flink.streaming.connectors.fs.StringWriter<T>

Type Parameters:

T - The type of the elements that are being written by the sink.

All Implemented Interfaces:

Serializable, Writer<T>

Deprecated.

@Deprecated
public class StringWriter<T>
extends StreamWriterBase<T>

A Writer that uses toString() on the input elements and writes them to the output bucket file separated by newline.

See Also:

Serialized Form

Constructor Summary

Constructors

Modifier	Constructor and Description
	StringWriter() Deprecated. Creates a new StringWriter that uses "UTF-8" charset to convert strings to bytes.
	StringWriter(String charsetName) Deprecated. Creates a new StringWriter that uses the given charset to convert strings to bytes.
	StringWriter(String charsetName, String rowDelimiter) Deprecated. Creates a new StringWriter that uses the given charset and row delimiter to convert strings to bytes.
protected	StringWriter(StringWriter<T> other) Deprecated.

Method Summary

Modifier and Type	Method and Description
StringWriter<T>	duplicate() Deprecated. Duplicates the Writer.
String	getRowDelimiter() Deprecated.
void	open(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path) Deprecated. Initializes the Writer for a newly opened bucket file.
void	write(T element) Deprecated. Writes one element to the bucket file.

Methods inherited from class org.apache.flink.streaming.connectors.fs.StreamWriterBase

close, flush, getPos, getStream, isSyncOnFlush, setSyncOnFlush

Methods inherited from class java.lang.Object

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

Constructor Detail

StringWriter

public StringWriter()

Deprecated.

Creates a new StringWriter that uses "UTF-8" charset to convert strings to bytes.

StringWriter

public StringWriter(String charsetName)

Deprecated.

Creates a new StringWriter that uses the given charset to convert strings to bytes.

Parameters:

charsetName - Name of the charset to be used, must be valid input for Charset.forName(charsetName)

StringWriter

public StringWriter(String charsetName,
                    String rowDelimiter)

Deprecated.

Creates a new StringWriter that uses the given charset and row delimiter to convert strings to bytes.

Parameters:

charsetName - Name of the charset to be used, must be valid input for Charset.forName(charsetName)

rowDelimiter - Parameter that specifies which character to use for delimiting rows

StringWriter

protected StringWriter(StringWriter<T> other)

Deprecated.

Method Detail

open

public void open(org.apache.hadoop.fs.FileSystem fs,
                 org.apache.hadoop.fs.Path path)
          throws IOException

Deprecated.

Description copied from interface: Writer

Initializes the Writer for a newly opened bucket file. Any internal per-bucket initialization should be performed here.

Specified by:

open in interface Writer<T>

Overrides:

open in class StreamWriterBase<T>

Parameters:

fs - The FileSystem containing the newly opened file.

path - The Path of the newly opened file.

Throws:

IOException

write

public void write(T element)
           throws IOException

Deprecated.

Description copied from interface: Writer

Writes one element to the bucket file.

Throws:

IOException

duplicate

public StringWriter<T> duplicate()

Deprecated.

Description copied from interface: Writer

Duplicates the Writer. This is used to get one Writer for each parallel instance of the sink.

getRowDelimiter

public String getRowDelimiter()

Deprecated.