co.cask.cdap.data2.dataset2.lib.file

Class FileSetDataset

java.lang.Object

co.cask.cdap.data2.dataset2.lib.file.FileSetDataset

All Implemented Interfaces:

co.cask.cdap.api.data.batch.InputFormatProvider, co.cask.cdap.api.data.batch.OutputFormatProvider, co.cask.cdap.api.dataset.Dataset, co.cask.cdap.api.dataset.lib.FileSet, Closeable, AutoCloseable

public final class FileSetDataset
extends Object
implements co.cask.cdap.api.dataset.lib.FileSet

Implementation of file dataset.

Constructor Summary

Constructors

Constructor and Description
FileSetDataset(co.cask.cdap.api.dataset.DatasetContext datasetContext, CConfiguration cConf, co.cask.cdap.api.dataset.DatasetSpecification spec, LocationFactory absoluteLocationFactory, NamespacedLocationFactory namespacedLocationFactory, Map<String,String> runtimeArguments) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
Location	getBaseLocation()
String	getInputFormatClassName()
Map<String,String>	getInputFormatConfiguration()
Map<String,String>	getInputFormatConfiguration(Iterable<? extends Location> inputLocs)
List<Location>	getInputLocations()
Location	getLocation(String relativePath)
String	getOutputFormatClassName()
Map<String,String>	getOutputFormatConfiguration()
Location	getOutputLocation()
Map<String,String>	getRuntimeArguments()

Methods inherited from class java.lang.Object

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

Constructor Detail

FileSetDataset

public FileSetDataset(co.cask.cdap.api.dataset.DatasetContext datasetContext,
              CConfiguration cConf,
              co.cask.cdap.api.dataset.DatasetSpecification spec,
              LocationFactory absoluteLocationFactory,
              NamespacedLocationFactory namespacedLocationFactory,
              @Nonnull
              Map<String,String> runtimeArguments)
               throws IOException

Constructor.

Parameters:

datasetContext - the context for the dataset

cConf - the CDAP configuration

spec - the dataset specification

namespacedLocationFactory - a factory for namespaced Location

runtimeArguments - the runtime arguments

Throws:

IOException

Method Detail

getBaseLocation

public Location getBaseLocation()

Specified by:

getBaseLocation in interface co.cask.cdap.api.dataset.lib.FileSet

getInputLocations

public List<Location> getInputLocations()

Specified by:

getInputLocations in interface co.cask.cdap.api.dataset.lib.FileSet

getOutputLocation

public Location getOutputLocation()

Specified by:

getOutputLocation in interface co.cask.cdap.api.dataset.lib.FileSet

getLocation

public Location getLocation(String relativePath)

Specified by:

getLocation in interface co.cask.cdap.api.dataset.lib.FileSet

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

getInputFormatClassName

public String getInputFormatClassName()

Specified by:

getInputFormatClassName in interface co.cask.cdap.api.data.batch.InputFormatProvider

getInputFormatConfiguration

public Map<String,String> getInputFormatConfiguration()

Specified by:

getInputFormatConfiguration in interface co.cask.cdap.api.data.batch.InputFormatProvider

getInputFormatConfiguration

public Map<String,String> getInputFormatConfiguration(Iterable<? extends Location> inputLocs)

Specified by:

getInputFormatConfiguration in interface co.cask.cdap.api.dataset.lib.FileSet

getOutputFormatClassName

public String getOutputFormatClassName()

Specified by:

getOutputFormatClassName in interface co.cask.cdap.api.data.batch.OutputFormatProvider

getOutputFormatConfiguration

public Map<String,String> getOutputFormatConfiguration()

Specified by:

getOutputFormatConfiguration in interface co.cask.cdap.api.data.batch.OutputFormatProvider

getRuntimeArguments

public Map<String,String> getRuntimeArguments()

Specified by:

getRuntimeArguments in interface co.cask.cdap.api.dataset.lib.FileSet