co.cask.cdap.data2.dataset2.lib.partitioned

Class TimePartitionedFileSetDefinition

java.lang.Object

co.cask.cdap.api.dataset.lib.AbstractDatasetDefinition<co.cask.cdap.api.dataset.lib.PartitionedFileSet,co.cask.cdap.api.dataset.DatasetAdmin>

co.cask.cdap.data2.dataset2.lib.partitioned.PartitionedFileSetDefinition

co.cask.cdap.data2.dataset2.lib.partitioned.TimePartitionedFileSetDefinition

All Implemented Interfaces:

co.cask.cdap.api.dataset.DatasetDefinition<co.cask.cdap.api.dataset.lib.PartitionedFileSet,co.cask.cdap.api.dataset.DatasetAdmin>

public class TimePartitionedFileSetDefinition
extends PartitionedFileSetDefinition

Defines the partitioned dataset type. At this time, the partitions are not managed by the partitioned dataset, so all admin is simply on the partition table.

Field Summary

Fields inherited from class co.cask.cdap.data2.dataset2.lib.partitioned.PartitionedFileSetDefinition

FILESET_NAME, filesetDef, indexedTableDef, PARTITION_TABLE_NAME

Fields inherited from interface co.cask.cdap.api.dataset.DatasetDefinition

NO_ARGUMENTS

Constructor Summary

Constructors

Constructor and Description
TimePartitionedFileSetDefinition(String name, co.cask.cdap.api.dataset.DatasetDefinition<? extends co.cask.cdap.api.dataset.lib.FileSet,?> filesetDef, co.cask.cdap.api.dataset.DatasetDefinition<? extends co.cask.cdap.api.dataset.lib.IndexedTable,?> tableDef)

Method Summary

Methods

Modifier and Type	Method and Description
co.cask.cdap.api.dataset.DatasetSpecification	configure(String instanceName, co.cask.cdap.api.dataset.DatasetProperties properties)
co.cask.cdap.api.dataset.lib.PartitionedFileSet	getDataset(co.cask.cdap.api.dataset.DatasetContext datasetContext, co.cask.cdap.api.dataset.DatasetSpecification spec, Map<String,String> arguments, ClassLoader classLoader)
protected Map<String,String>	updateArgumentsIfNeeded(Map<String,String> arguments)

Methods inherited from class co.cask.cdap.data2.dataset2.lib.partitioned.PartitionedFileSetDefinition

getAdmin, getExploreProvider, updateArgumentsIfNeeded

Methods inherited from class co.cask.cdap.api.dataset.lib.AbstractDatasetDefinition

getName

Methods inherited from class java.lang.Object

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

Constructor Detail

TimePartitionedFileSetDefinition

public TimePartitionedFileSetDefinition(String name,
                                co.cask.cdap.api.dataset.DatasetDefinition<? extends co.cask.cdap.api.dataset.lib.FileSet,?> filesetDef,
                                co.cask.cdap.api.dataset.DatasetDefinition<? extends co.cask.cdap.api.dataset.lib.IndexedTable,?> tableDef)

Method Detail

configure

public co.cask.cdap.api.dataset.DatasetSpecification configure(String instanceName,
                                                      co.cask.cdap.api.dataset.DatasetProperties properties)

Specified by:

configure in interface co.cask.cdap.api.dataset.DatasetDefinition<co.cask.cdap.api.dataset.lib.PartitionedFileSet,co.cask.cdap.api.dataset.DatasetAdmin>

Overrides:

configure in class PartitionedFileSetDefinition

getDataset

public co.cask.cdap.api.dataset.lib.PartitionedFileSet getDataset(co.cask.cdap.api.dataset.DatasetContext datasetContext,
                                                         co.cask.cdap.api.dataset.DatasetSpecification spec,
                                                         Map<String,String> arguments,
                                                         ClassLoader classLoader)
                                                           throws IOException

Specified by:

getDataset in interface co.cask.cdap.api.dataset.DatasetDefinition<co.cask.cdap.api.dataset.lib.PartitionedFileSet,co.cask.cdap.api.dataset.DatasetAdmin>

Overrides:

getDataset in class PartitionedFileSetDefinition

Throws:

IOException

updateArgumentsIfNeeded

protected Map<String,String> updateArgumentsIfNeeded(Map<String,String> arguments)