Index: src/examples/org/apache/hama/examples/SerializePrinting.java =================================================================== --- src/examples/org/apache/hama/examples/SerializePrinting.java (리비전 1005310) +++ src/examples/org/apache/hama/examples/SerializePrinting.java (작업 사본) @@ -1,3 +1,20 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ package org.apache.hama.examples; import java.io.IOException; Index: src/java/org/apache/hama/bsp/BSPJob.java =================================================================== --- src/java/org/apache/hama/bsp/BSPJob.java (리비전 1005310) +++ src/java/org/apache/hama/bsp/BSPJob.java (작업 사본) @@ -15,7 +15,6 @@ * See the License for the specific language governing permissions and * limitations under the License. */ - package org.apache.hama.bsp; import java.io.IOException; Index: src/java/org/apache/hama/bsp/BSPRunner.java =================================================================== --- src/java/org/apache/hama/bsp/BSPRunner.java (리비전 1005310) +++ src/java/org/apache/hama/bsp/BSPRunner.java (작업 사본) @@ -1,39 +0,0 @@ -package org.apache.hama.bsp; - -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; -import org.apache.hadoop.conf.Configurable; -import org.apache.hadoop.conf.Configuration; -import org.apache.hadoop.util.ReflectionUtils; - -public class BSPRunner extends Thread implements Configurable { - private static final Log LOG = LogFactory.getLog(BSPRunner.class); - private Configuration conf; - private BSP bsp; - private boolean isDone; - - public void run(BSPPeer bspPeer) { - try { - bsp.bsp(bspPeer); - } catch (Exception e) { - LOG.error(e); - } - } - - @Override - public Configuration getConf() { - return this.conf; - } - - @Override - public void setConf(Configuration conf) { - this.conf = conf; - - bsp = (BSP) ReflectionUtils.newInstance(conf.getClass("bsp.work.class", - BSP.class), conf); - } - - public boolean isDone() { - return this.isDone; - } -} Index: src/java/org/apache/hama/bsp/BSPTask.java =================================================================== --- src/java/org/apache/hama/bsp/BSPTask.java (리비전 1005310) +++ src/java/org/apache/hama/bsp/BSPTask.java (작업 사본) @@ -1,3 +1,20 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ package org.apache.hama.bsp; import org.apache.hadoop.conf.Configuration; Index: src/java/org/apache/hama/bsp/JobInProgress.java =================================================================== --- src/java/org/apache/hama/bsp/JobInProgress.java (리비전 1005310) +++ src/java/org/apache/hama/bsp/JobInProgress.java (작업 사본) @@ -71,13 +71,12 @@ this.jobId = jobId; this.tasks = new ArrayList(); - this.localFs = (LocalFileSystem) FileSystem.getNamed("local", conf); + this.localFs = FileSystem.getLocal(conf); this.master = master; this.status = new JobStatus(jobId, 0.0f, 0.0f, JobStatus.PREP); this.startTime = System.currentTimeMillis(); status.setStartTime(startTime); - // this.localFs = FileSystem.getLocal(conf); this.localJobFile = master.getLocalPath(BSPMaster.SUBDIR + "/" + jobId + ".xml"); Index: src/java/org/apache/hama/bsp/LocalBSPCluster.java =================================================================== --- src/java/org/apache/hama/bsp/LocalBSPCluster.java (리비전 1005310) +++ src/java/org/apache/hama/bsp/LocalBSPCluster.java (작업 사본) @@ -1,3 +1,20 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ package org.apache.hama.bsp; import java.io.IOException; Index: src/java/org/apache/hama/bsp/LocalJobRunner.java =================================================================== --- src/java/org/apache/hama/bsp/LocalJobRunner.java (리비전 1005315) +++ src/java/org/apache/hama/bsp/LocalJobRunner.java (작업 사본) @@ -1,3 +1,20 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ package org.apache.hama.bsp; import java.io.IOException; Index: src/java/org/apache/hama/util/Bytes.java =================================================================== --- src/java/org/apache/hama/util/Bytes.java (리비전 1005310) +++ src/java/org/apache/hama/util/Bytes.java (작업 사본) @@ -1,3 +1,20 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ package org.apache.hama.util; import java.io.DataInput; Index: src/java/org/apache/hama/util/ClusterUtil.java =================================================================== --- src/java/org/apache/hama/util/ClusterUtil.java (리비전 1005310) +++ src/java/org/apache/hama/util/ClusterUtil.java (작업 사본) @@ -1,3 +1,20 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ package org.apache.hama.util; import java.io.IOException; Index: src/java/org/apache/hama/util/RunJar.java =================================================================== --- src/java/org/apache/hama/util/RunJar.java (리비전 1005310) +++ src/java/org/apache/hama/util/RunJar.java (작업 사본) @@ -1,3 +1,20 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ package org.apache.hama.util; import java.io.File; Index: src/java/org/apache/hama/zookeeper/QuorumPeer.java =================================================================== --- src/java/org/apache/hama/zookeeper/QuorumPeer.java (리비전 1005310) +++ src/java/org/apache/hama/zookeeper/QuorumPeer.java (작업 사본) @@ -1,3 +1,20 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ package org.apache.hama.zookeeper; import java.io.File; Index: src/java/org/apache/hama/zookeeper/ZKServerTool.java =================================================================== --- src/java/org/apache/hama/zookeeper/ZKServerTool.java (리비전 1005310) +++ src/java/org/apache/hama/zookeeper/ZKServerTool.java (작업 사본) @@ -1,3 +1,20 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ package org.apache.hama.zookeeper; import java.util.Properties;