I - input type.O - output type.public static class EmptyComponents.EmptyTransform<I,O> extends Object implements Transform<I,O>
Transform.Context| Constructor and Description |
|---|
EmptyTransform(String name)
Default constructor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Close the transform.
|
void |
onData(Iterator<I> elements,
String srcVertexId)
On data received.
|
void |
prepare(Transform.Context context,
OutputCollector<O> outputCollector)
Prepare the transform.
|
String |
toString() |
public EmptyTransform(String name)
name - name of the empty transform.public void prepare(Transform.Context context, OutputCollector<O> outputCollector)
Transformpublic void onData(Iterator<I> elements, String srcVertexId)
TransformCopyright © 2018. All rights reserved.