org.apache.flink.streaming.connectors.fs

Interface Writer<T>

Type Parameters:

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

All Superinterfaces:

Serializable

All Known Implementing Classes:

AvroKeyValueSinkWriter, SequenceFileWriter, StreamWriterBase, StringWriter

Deprecated.

@Deprecated
public interface Writer<T>
extends Serializable

An implementation of Writer is used in conjunction with a BucketingSink to perform the actual writing to the bucket files.

Method Summary

Modifier and Type	Method and Description
void	close() Deprecated. Closes the Writer.
Writer<T>	duplicate() Deprecated. Duplicates the Writer.
long	flush() Deprecated. Flushes out any internally held data, and returns the offset that the file must be truncated to at recovery.
long	getPos() Deprecated. Retrieves the current position, and thus size, of the output file.
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.

Method Detail

open

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

Deprecated.

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

Parameters:

fs - The FileSystem containing the newly opened file.

path - The Path of the newly opened file.

Throws:

IOException

flush

long flush()
    throws IOException

Deprecated.

Flushes out any internally held data, and returns the offset that the file must be truncated to at recovery.

Throws:

IOException

getPos

long getPos()
     throws IOException

Deprecated.

Retrieves the current position, and thus size, of the output file.

Throws:

IOException

close

void close()
    throws IOException

Deprecated.

Closes the Writer. If the writer is already closed, no action will be taken. The call should close all state related to the current output file, including the output stream opened in open.

Throws:

IOException

write

void write(T element)
    throws IOException

Deprecated.

Writes one element to the bucket file.

Throws:

IOException

duplicate

Writer<T> duplicate()

Deprecated.

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