org.springframework.data.hadoop.store.dataset

Class DatasetUtils

java.lang.Object

org.springframework.data.hadoop.store.dataset.DatasetUtils

public abstract class DatasetUtils
extends java.lang.Object

This is a utility class in the store.dataset package. It provides static utility methods for working with Datasets, DatasetReaders and DatasetWriters

Since:

2.0

Author:

Thomas Risberg, Janne Valkealahti

Constructor Summary

Constructors

Constructor and Description
DatasetUtils()

Method Summary

Methods

Modifier and Type	Method and Description
static <T> org.kitesdk.data.Dataset<T>	getDataset(DatasetRepositoryFactory dsFactory, java.lang.Class<T> pojoClass) Gets the dataset using a DatasetRepositoryFactory and a pojo class.
static <T> java.lang.String	getDatasetName(java.lang.Class<T> clazz) Gets the dataset name.
static <T> org.kitesdk.data.Dataset<T>	getOrCreateDataset(DatasetRepositoryFactory dsFactory, DatasetDefinition datasetDefinition, java.lang.Class<?> pojoClass, java.lang.Class<T> recordClass) Gets a Dataset using a DatasetRepositoryFactory, DatasetDefinition, pojo class and a record class.

Methods inherited from class java.lang.Object

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

Constructor Detail

DatasetUtils

public DatasetUtils()

Method Detail

getDatasetName

public static <T> java.lang.String getDatasetName(java.lang.Class<T> clazz)

Gets the dataset name. This method simply delegates to Class.getSimpleName() and gets a lower case name.

Type Parameters:

T - the generic class type

Parameters:

clazz - the clazz

Returns:

the dataset name

getOrCreateDataset

public static <T> org.kitesdk.data.Dataset<T> getOrCreateDataset(DatasetRepositoryFactory dsFactory,
                                                 DatasetDefinition datasetDefinition,
                                                 java.lang.Class<?> pojoClass,
                                                 java.lang.Class<T> recordClass)

Gets a Dataset using a DatasetRepositoryFactory, DatasetDefinition, pojo class and a record class. Dataset is created if it doesn't exist.

Type Parameters:

T - the generic record class type

Parameters:

dsFactory - the dataset repository factory

datasetDefinition - the dataset definition

pojoClass - the pojo class

recordClass - the record class

Returns:

the dataset

getDataset

public static <T> org.kitesdk.data.Dataset<T> getDataset(DatasetRepositoryFactory dsFactory,
                                         java.lang.Class<T> pojoClass)

Gets the dataset using a DatasetRepositoryFactory and a pojo class. Passed class is a same used in "pojoClass"

Type Parameters:

T - the generic type

Parameters:

dsFactory - the ds factory

pojoClass - the pojo class

Returns:

the dataset