org.springframework.data.hadoop.store

Interface PartitionDataStoreWriter<T,K>

Type Parameters:

T - the type of an entity to write

K - the type of a partition key

All Superinterfaces:

java.lang.AutoCloseable, java.io.Closeable, DataStoreWriter<T>, DataWriter<T>, java.io.Flushable

All Known Implementing Classes:

AbstractPartitionDataStoreWriter, PartitionTextFileWriter

public interface PartitionDataStoreWriter<T,K>
extends DataStoreWriter<T>

A DataStorePartitionWriter is an extension of DataStoreWriter adding functionality to write entities using a partition key. A partition key is an object which is used by a PartitionStrategy to determine a partition path to write to.

Author:

Janne Valkealahti, Rodrigo Meneses

Method Summary

Methods

Modifier and Type	Method and Description
void	write(T entity, K partitionKey) Write an entity with an explicit partitioning key.

Methods inherited from interface org.springframework.data.hadoop.store.DataWriter

write

Methods inherited from interface java.io.Flushable

flush

Methods inherited from interface java.io.Closeable

close

Method Detail

write

void write(T entity,
         K partitionKey)
           throws java.io.IOException

Write an entity with an explicit partitioning key.

Parameters:

entity - the entity to write

partitionKey - the partition key

Throws:

java.io.IOException - if an I/O error occurs