org.springframework.data.hadoop.store.dataset

Class DatasetDefinition

java.lang.Object

org.springframework.data.hadoop.store.dataset.DatasetDefinition

public class DatasetDefinition
extends java.lang.Object

Class to define the options for a Dataset

Since:

2.0

Author:

Thomas Risberg, Janne Valkealahti

Constructor Summary

Constructors

Constructor and Description
DatasetDefinition()
DatasetDefinition(boolean allowNullValues)
DatasetDefinition(boolean allowNullValues, java.lang.String format)
DatasetDefinition(java.lang.Class<?> targetClass, boolean allowNullValues, java.lang.String format)
DatasetDefinition(java.lang.Class<?> targetClass, org.kitesdk.data.PartitionStrategy partitionStrategy)
DatasetDefinition(java.lang.Class<?> targetClass, java.lang.String format, org.kitesdk.data.PartitionStrategy partitionStrategy)

Method Summary

Methods

Modifier and Type	Method and Description
org.kitesdk.data.CompressionType	getCompressionType()
org.kitesdk.data.Format	getFormat()
org.kitesdk.data.PartitionStrategy	getPartitionStrategy()
org.apache.avro.Schema	getSchema(java.lang.Class<?> datasetClass)
java.lang.Class<?>	getTargetClass()
java.lang.Integer	getWriterCacheSize()
boolean	isAllowNullValues()
void	setAllowNullValues(boolean allowNullValues)
void	setCompressionType(java.lang.String compressionType)
void	setFormat(java.lang.String format)
void	setPartitionStrategy(org.kitesdk.data.PartitionStrategy partitionStrategy)
void	setSchema(org.apache.avro.Schema schema)
void	setTargetClass(java.lang.Class<?> targetClass)
void	setWriterCacheSize(java.lang.Integer writerCacheSize)

Methods inherited from class java.lang.Object

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

Constructor Detail

DatasetDefinition

public DatasetDefinition()

DatasetDefinition

public DatasetDefinition(boolean allowNullValues)

DatasetDefinition

public DatasetDefinition(boolean allowNullValues,
                 java.lang.String format)

DatasetDefinition

public DatasetDefinition(java.lang.Class<?> targetClass,
                 boolean allowNullValues,
                 java.lang.String format)

DatasetDefinition

public DatasetDefinition(java.lang.Class<?> targetClass,
                 org.kitesdk.data.PartitionStrategy partitionStrategy)

DatasetDefinition

public DatasetDefinition(java.lang.Class<?> targetClass,
                 java.lang.String format,
                 org.kitesdk.data.PartitionStrategy partitionStrategy)

Method Detail

setTargetClass

public void setTargetClass(java.lang.Class<?> targetClass)

setAllowNullValues

public void setAllowNullValues(boolean allowNullValues)

setFormat

public void setFormat(java.lang.String format)

setPartitionStrategy

public void setPartitionStrategy(org.kitesdk.data.PartitionStrategy partitionStrategy)

setWriterCacheSize

public void setWriterCacheSize(java.lang.Integer writerCacheSize)

setCompressionType

public void setCompressionType(java.lang.String compressionType)

setSchema

public void setSchema(org.apache.avro.Schema schema)

getTargetClass

public java.lang.Class<?> getTargetClass()

isAllowNullValues

public boolean isAllowNullValues()

getFormat

public org.kitesdk.data.Format getFormat()

getPartitionStrategy

public org.kitesdk.data.PartitionStrategy getPartitionStrategy()

getWriterCacheSize

public java.lang.Integer getWriterCacheSize()

getCompressionType

public org.kitesdk.data.CompressionType getCompressionType()

getSchema

public org.apache.avro.Schema getSchema(java.lang.Class<?> datasetClass)