Skip to content

Commit

Permalink
remove logger
Browse files Browse the repository at this point in the history
  • Loading branch information
alapha23 committed Apr 17, 2019
1 parent 3f0a3ee commit 303f1cd
Show file tree
Hide file tree
Showing 3 changed files with 2 additions and 21 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -19,20 +19,16 @@
package org.apache.nemo.common.ir.vertex.executionproperty;

import org.apache.nemo.common.ir.executionproperty.VertexExecutionProperty;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;


public final class ResourceLambdaProperty extends VertexExecutionProperty<ResourceLambdaProperty.Value>{
private static final Logger LOG = LoggerFactory.getLogger(ResourceLambdaProperty.class.getName());
/**
* Constructor.
*
* @param value value of the execution property.
*/
private ResourceLambdaProperty(final ResourceLambdaProperty.Value value) {
super(value);
LOG.info("LambdaProperty Instantiated");
}

/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,28 +20,18 @@

import org.apache.nemo.common.ir.IRDAG;
import org.apache.nemo.common.ir.vertex.executionproperty.ResourceLambdaProperty;
import org.apache.nemo.common.ir.executionproperty.ExecutionProperty;
import org.apache.nemo.compiler.optimizer.pass.compiletime.CompileTimePass;
import org.apache.nemo.compiler.optimizer.pass.compiletime.annotating.AnnotatingPass;
import org.apache.nemo.common.ir.edge.executionproperty.DataStoreProperty;

import org.apache.nemo.compiler.optimizer.policy.LambdaPolicy;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/*
* Lambda Policy
* Lambda Pass
* Maintainer: Gao Zhiyuan
* Description: A part of lambda executor, assigning LambdaResourceProperty
*/

@Annotates(ResourceLambdaProperty.class)
public final class LambdaPass extends AnnotatingPass {
private static final Logger LOG = LoggerFactory.getLogger(LambdaPolicy.class.getName());

public LambdaPass() {
super(LambdaPass.class);
LOG.info("LambdaPass initialized");
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,23 +23,18 @@
import org.apache.nemo.compiler.optimizer.pass.compiletime.composite.DefaultCompositePass;
import org.apache.nemo.compiler.optimizer.pass.runtime.Message;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/*
* Lambda Policy
* Maintainer: Gao Zhiyuan
* Description: A part of lambda executor, to support Lambda pass.
* Description: A part of lambda executor, to support Lambda policy.
*/
public final class LambdaPolicy implements Policy {
private final Policy policy;
private static final Logger LOG = LoggerFactory.getLogger(LambdaPolicy.class.getName());

/**
* Default constructor.
*/
public LambdaPolicy() {
LOG.info("LambdaPolicy!!!!!");
final PolicyBuilder builder = new PolicyBuilder();
builder.registerCompileTimePass(new DefaultCompositePass());
builder.registerCompileTimePass(new LambdaPass());
Expand Down

0 comments on commit 303f1cd

Please sign in to comment.