org.kitesdk.tools

Class TransformTask<S,T>

java.lang.Object

org.apache.hadoop.conf.Configured

org.kitesdk.tools.TransformTask<S,T>

All Implemented Interfaces:

Configurable

Direct Known Subclasses:

CopyTask

public class TransformTask<S,T>
extends Configured

Since:

0.16.0

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TransformTask.CheckEntityClass<E>

Constructor Summary

Constructors

Constructor and Description
TransformTask(View<S> from, View<T> to, DoFn<S,T> transform)

Method Summary

Methods

Modifier and Type	Method and Description
long	getCount()
TransformTask	noCompaction()
PipelineResult	run()
TransformTask	setNumWriters(int numWriters)

Methods inherited from class org.apache.hadoop.conf.Configured

getConf, setConf

Methods inherited from class java.lang.Object

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

Constructor Detail

TransformTask

public TransformTask(View<S> from,
             View<T> to,
             DoFn<S,T> transform)

Method Detail

getCount

public long getCount()

noCompaction

public TransformTask noCompaction()

setNumWriters

public TransformTask setNumWriters(int numWriters)

run

public PipelineResult run()
                   throws IOException

Throws:

IOException