@Override
public void setRuntimeContext(RuntimeContext runtimeContext) {
	Preconditions.checkNotNull(runtimeContext);

	if (runtimeContext instanceof IterationRuntimeContext) {
		super.setRuntimeContext(
			new RichAsyncFunctionIterationRuntimeContext(
				(IterationRuntimeContext) runtimeContext));
	} else {
		super.setRuntimeContext(new RichAsyncFunctionRuntimeContext(runtimeContext));
	}
}
 

@Override
public void setRuntimeContext(RuntimeContext runtimeContext) {
	Preconditions.checkNotNull(runtimeContext);

	if (runtimeContext instanceof IterationRuntimeContext) {
		super.setRuntimeContext(
			new RichAsyncFunctionIterationRuntimeContext(
				(IterationRuntimeContext) runtimeContext));
	} else {
		super.setRuntimeContext(new RichAsyncFunctionRuntimeContext(runtimeContext));
	}
}
 

@Override
public void setRuntimeContext(RuntimeContext runtimeContext) {
	Preconditions.checkNotNull(runtimeContext);

	if (runtimeContext instanceof IterationRuntimeContext) {
		super.setRuntimeContext(
			new RichAsyncFunctionIterationRuntimeContext(
				(IterationRuntimeContext) runtimeContext));
	} else {
		super.setRuntimeContext(new RichAsyncFunctionRuntimeContext(runtimeContext));
	}
}
 

@Override
public IterationRuntimeContext getIterationRuntimeContext() {
	throw new UnsupportedOperationException("Not support to get the IterationRuntimeContext in IterativeCondition.");
}
 

void init(IterationRuntimeContext context) {
	this.runtimeContext = context;
	this.outVertex = new Vertex<>();
	this.outMsg = new Tuple2<>();
	this.edgeIterator = new EdgesIterator<>();
}
 

void init(IterationRuntimeContext context) {
	this.runtimeContext = context;
}
 

void init(IterationRuntimeContext context) {
	this.runtimeContext = context;
	this.outValue = new Tuple2<>();
	this.edgeIterator = new EdgesIterator<>();
}
 

public void init(IterationRuntimeContext iterationRuntimeContext) {
	this.runtimeContext = iterationRuntimeContext;
}
 

public void init(IterationRuntimeContext iterationRuntimeContext) {
	this.runtimeContext = iterationRuntimeContext;
}
 

public void init(IterationRuntimeContext iterationRuntimeContext) {
	this.runtimeContext = iterationRuntimeContext;
}
 

@Override
public void setup(AbstractInvokable parent) {
	agg = ((IterationRuntimeContext) getUdfRuntimeContext()).getIterationAggregator(BulkIterationBase.TERMINATION_CRITERION_AGGREGATOR_NAME);
}
 

RichAsyncFunctionIterationRuntimeContext(IterationRuntimeContext iterationRuntimeContext) {
	super(iterationRuntimeContext);

	this.iterationRuntimeContext = Preconditions.checkNotNull(iterationRuntimeContext);
}
 

@Override
public IterationRuntimeContext getIterationRuntimeContext() {
	throw new RuntimeException("This should never be called.");
}
 

@Override
public IterationRuntimeContext getIterationRuntimeContext() {
	throw new RuntimeException("This should never be called.");
}
 

@Override
public IterationRuntimeContext getIterationRuntimeContext() {
	throw new RuntimeException("This should never be called.");
}
 

@Override
public IterationRuntimeContext getIterationRuntimeContext() {
	throw new RuntimeException("This should never be called.");
}
 

@Override
public IterationRuntimeContext getIterationRuntimeContext() {
	throw new RuntimeException("This should never be called.");
}
 

@Override
public IterationRuntimeContext getIterationRuntimeContext() {
	throw new RuntimeException("This should never be called.");
}
 

@Override
public IterationRuntimeContext getIterationRuntimeContext() {
	throw new RuntimeException("This should never be called.");
}
 

@Override
public IterationRuntimeContext getIterationRuntimeContext() {
	throw new RuntimeException("This should never be called.");

}
 

@Override
public IterationRuntimeContext getIterationRuntimeContext() {
	throw new RuntimeException("This should never be called.");

}
 

@Override
public IterationRuntimeContext getIterationRuntimeContext() {
	throw new RuntimeException("This should never be called.");
}
 

@Override
public IterationRuntimeContext getIterationRuntimeContext() {
	throw new UnsupportedOperationException("Not support to get the IterationRuntimeContext in IterativeCondition.");
}
 

void init(IterationRuntimeContext context) {
	this.runtimeContext = context;
	this.outVertex = new Vertex<>();
	this.outMsg = new Tuple2<>();
	this.edgeIterator = new EdgesIterator<>();
}
 

void init(IterationRuntimeContext context) {
	this.runtimeContext = context;
}
 

void init(IterationRuntimeContext context) {
	this.runtimeContext = context;
	this.outValue = new Tuple2<>();
	this.edgeIterator = new EdgesIterator<>();
}
 

public void init(IterationRuntimeContext iterationRuntimeContext) {
	this.runtimeContext = iterationRuntimeContext;
}
 

public void init(IterationRuntimeContext iterationRuntimeContext) {
	this.runtimeContext = iterationRuntimeContext;
}
 

public void init(IterationRuntimeContext iterationRuntimeContext) {
	this.runtimeContext = iterationRuntimeContext;
}
 

@Override
public void setup(AbstractInvokable parent) {
	agg = ((IterationRuntimeContext) getUdfRuntimeContext()).getIterationAggregator(BulkIterationBase.TERMINATION_CRITERION_AGGREGATOR_NAME);
}