Package org.apache.beam.sdk.io.xml

Class XmlIO.Sink<T>

java.lang.Object

org.apache.beam.sdk.io.xml.XmlIO.Sink<T>

All Implemented Interfaces:

java.io.Serializable, org.apache.beam.sdk.io.FileIO.Sink<T>

Enclosing class:

XmlIO

public abstract static class XmlIO.Sink<T>
extends java.lang.Object
implements org.apache.beam.sdk.io.FileIO.Sink<T>

Implementation of XmlIO.sink(java.lang.Class<T>).

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
Sink()

Method Summary

Modifier and Type	Method	Description
void	flush()
void	open(java.nio.channels.WritableByteChannel channel)
XmlIO.Sink<T>	withCharset(java.nio.charset.Charset charset)
XmlIO.Sink<T>	withRootElement(java.lang.String rootElement)
void	write(T element)

Methods inherited from class java.lang.Object

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

Constructor Detail

Sink

public Sink()

Method Detail

withRootElement

public XmlIO.Sink<T> withRootElement(java.lang.String rootElement)

withCharset

public XmlIO.Sink<T> withCharset(java.nio.charset.Charset charset)

open

public void open(java.nio.channels.WritableByteChannel channel)
          throws java.io.IOException

Specified by:

open in interface org.apache.beam.sdk.io.FileIO.Sink<T>

Throws:

java.io.IOException

write

public void write(T element)
           throws java.io.IOException

Specified by:

write in interface org.apache.beam.sdk.io.FileIO.Sink<T>

Throws:

java.io.IOException

flush

public void flush()
           throws java.io.IOException

Specified by:

flush in interface org.apache.beam.sdk.io.FileIO.Sink<T>

Throws:

java.io.IOException