public class TransformTask<S,T> extends Configured
Modifier and Type | Class and Description |
---|---|
static class |
TransformTask.CheckEntityClass<E> |
Constructor and Description |
---|
TransformTask(View<S> from,
View<T> to,
DoFn<S,T> transform) |
Modifier and Type | Method and Description |
---|---|
long |
getCount() |
TransformTask |
noCompaction() |
PipelineResult |
run() |
TransformTask |
setNumWriters(int numWriters) |
getConf, setConf
public long getCount()
public TransformTask noCompaction()
public TransformTask setNumWriters(int numWriters)
public PipelineResult run() throws IOException
IOException
Copyright © 2013–2015. All rights reserved.