Package org.apache.nemo.common.test
Class EmptyComponents
- java.lang.Object
-
- org.apache.nemo.common.test.EmptyComponents
-
public final class EmptyComponents extends java.lang.Object
Empty components to mock transform and source, for tests and examples.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
EmptyComponents.EmptySourceVertex<T>
An empty Source Vertex.static class
EmptyComponents.EmptyTransform<I,O>
An empty transform.
-
Field Summary
Fields Modifier and Type Field Description static Transform
EMPTY_TRANSFORM
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static IRDAG
buildEmptyDAG()
Builds dummy IR DAG for testing.static IRDAG
buildEmptyDAGForSkew()
Builds dummy IR DAG to test skew handling.static IREdge
newDummyShuffleEdge(IRVertex src, IRVertex dst)
-
-
-
Field Detail
-
EMPTY_TRANSFORM
public static final Transform EMPTY_TRANSFORM
-
-
Method Detail
-
buildEmptyDAG
public static IRDAG buildEmptyDAG()
Builds dummy IR DAG for testing.- Returns:
- the dummy IR DAG.
-
buildEmptyDAGForSkew
public static IRDAG buildEmptyDAGForSkew()
Builds dummy IR DAG to test skew handling. For DataSkewPolicy, shuffle edges needs extra setting for EncoderProperty, DecoderProperty and KeyExtractorProperty by default.- Returns:
- the dummy IR DAG.
-
-