org.apache.tez.runtime.library.broadcast.output

Class FileBasedKVWriter

java.lang.Object

org.apache.tez.runtime.api.Writer

org.apache.tez.runtime.library.api.KeyValueWriter

org.apache.tez.runtime.library.api.KeyValuesWriter

org.apache.tez.runtime.library.broadcast.output.FileBasedKVWriter

@InterfaceAudience.Private
public class FileBasedKVWriter
extends KeyValuesWriter

Field Summary

Fields

Modifier and Type	Field and Description
static int	INDEX_RECORD_LENGTH

Constructor Summary

Constructors

Constructor and Description
FileBasedKVWriter(org.apache.tez.runtime.api.OutputContext outputContext, org.apache.hadoop.conf.Configuration conf)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	close()
long	getCompressedLength()
byte[]	getData()
long	getRawLength()
void	write(Object key, Iterable<Object> values) Writes a key and its associated values
void	write(Object key, Object value) Writes a key/value pair.

Methods inherited from class java.lang.Object

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

Field Detail

INDEX_RECORD_LENGTH

public static final int INDEX_RECORD_LENGTH

See Also:

Constant Field Values

Constructor Detail

FileBasedKVWriter

public FileBasedKVWriter(org.apache.tez.runtime.api.OutputContext outputContext,
                 org.apache.hadoop.conf.Configuration conf)
                  throws IOException

Throws:

IOException

Method Detail

close

public boolean close()
              throws IOException

Returns:

true if any output was generated. false otherwise

Throws:

IOException

write

public void write(Object key,
         Object value)
           throws IOException

Description copied from class: KeyValueWriter

Writes a key/value pair.

Specified by:

write in class KeyValueWriter

Parameters:

key - the key to write

value - the value to write

Throws:

IOException - if an error occurs

write

public void write(Object key,
         Iterable<Object> values)
           throws IOException

Description copied from class: KeyValuesWriter

Writes a key and its associated values

Specified by:

write in class KeyValuesWriter

Parameters:

key - the key to write

values - values to write

Throws:

IOException

getRawLength

public long getRawLength()

getCompressedLength

public long getCompressedLength()

getData

public byte[] getData()
               throws IOException

Throws:

IOException