org.springframework.data.hadoop.store.dataset

Interface DatasetOperations

All Known Implementing Classes:

DatasetTemplate

public interface DatasetOperations

Interface specifying a basic set of Dataset operations against a specific DatasetRepository. Implemented by DatasetTemplate.

Since:

2.0

Author:

Thomas Risberg

Method Summary

Methods

Modifier and Type	Method and Description
void	execute(DatasetRepositoryCallback callback) Execute a callback for the DatasetRepository
<T> org.kitesdk.data.DatasetDescriptor	getDatasetDescriptor(java.lang.Class<T> targetClass) Get the DatasetDescriptor for the given class
<T> java.lang.String	getDatasetName(java.lang.Class<T> targetClass) Get the dataset name to be used for the given class
<T> java.util.Collection<T>	read(java.lang.Class<T> targetClass) Read all records in the dataset and return as a collection.
<T> void	read(java.lang.Class<T> targetClass, RecordCallback<T> callback) Read all records in the dataset and call the provided callback for each record.
<T> void	read(java.lang.Class<T> targetClass, RecordCallback<T> callback, ViewCallback viewCallback) Read records in the dataset partition based on a RefinableView and call the provided callback for each record.
<T> java.util.Collection<T>	read(java.lang.Class<T> targetClass, ViewCallback viewCallback) Read records in the dataset partition based on the RefinableView and return as a collection.
<T> void	write(java.util.Collection<T> records) Write all records provided in the record collection

Method Detail

read

<T> void read(java.lang.Class<T> targetClass,
            RecordCallback<T> callback)

Read all records in the dataset and call the provided callback for each record.

Type Parameters:

T - the class type

Parameters:

targetClass - the class that is stored in the dataset

callback - the callback to be called for each record

read

<T> java.util.Collection<T> read(java.lang.Class<T> targetClass)

Read all records in the dataset and return as a collection.

Type Parameters:

T - the class type

Parameters:

targetClass - the class that is stored in the dataset

Returns:

collection containing the records as the specified target class

read

<T> void read(java.lang.Class<T> targetClass,
            RecordCallback<T> callback,
            ViewCallback viewCallback)

Read records in the dataset partition based on a RefinableView and call the provided callback for each record.

Type Parameters:

T - the class type

Parameters:

targetClass - the class that is stored in the dataset

callback - the callback to be called for each record

viewCallback - the view callback to create the view

read

<T> java.util.Collection<T> read(java.lang.Class<T> targetClass,
                               ViewCallback viewCallback)

Read records in the dataset partition based on the RefinableView and return as a collection.

Type Parameters:

T - the class type

Parameters:

targetClass - the class that is stored in the dataset

viewCallback - the view callback to create the view

Returns:

collection containing the records as the specified target class

write

<T> void write(java.util.Collection<T> records)

Write all records provided in the record collection

Type Parameters:

T - the class type

Parameters:

records - the records to write

execute

void execute(DatasetRepositoryCallback callback)

Execute a callback for the DatasetRepository

Parameters:

callback - the callback

getDatasetDescriptor

<T> org.kitesdk.data.DatasetDescriptor getDatasetDescriptor(java.lang.Class<T> targetClass)

Get the DatasetDescriptor for the given class

Type Parameters:

T - the class type

Parameters:

targetClass - the class stored in the dataset

Returns:

the DatasetDescriptor

getDatasetName

<T> java.lang.String getDatasetName(java.lang.Class<T> targetClass)

Get the dataset name to be used for the given class

Type Parameters:

T - the class type

Parameters:

targetClass - the class stored in the dataset

Returns:

the dataset name