// Path: src/main/java/colossal/pipe/BaseMapper.java
// public class BaseMapper<IN,OUT> extends Configured implements ColMapper<IN,OUT> {
// 
//     /** Override this method for a mapper */      
//     @SuppressWarnings("unchecked")
//     public void map(IN in, OUT out, ColContext<OUT> context) {
//         context.write((OUT)in);
//     }
// 
//     @Override
//     public void close(OUT out, ColContext<OUT> context) {
//         // no op by default
//     }
// 
// }
// 
// Path: src/main/java/colossal/pipe/ColContext.java
// public class ColContext<OUT> {
// 
//     private Reporter reporter;
//     private AvroCollector<OUT> collector;
//     
//     public<IN, K, V, KO, VO> ColContext(AvroCollector<OUT> collector, Reporter reporter) {
//         this.reporter = reporter;
//         this.collector = collector;
//     }
//     
//     public void write(OUT out) {
//         try {
//             collector.collect(out);
//         }
//         catch (IOException e) {
//             throw new RuntimeException(e);
//         }
//     }
// 
//     public Counter getCounter(Enum<?> name) {
//         return reporter.getCounter(name);
//     }
// 
//     public Counter getCounter(String group, String name) {
//         return reporter.getCounter(group, name);
//     }
// 
//     public void incrCounter(Enum<?> key, long amount) {
//         reporter.incrCounter(key, amount);
//     }
// 
//     public void incrCounter(String group, String counter, long amount) {
//         reporter.incrCounter(group, counter, amount);
//     }
// 
//     public InputSplit getInputSplit() throws UnsupportedOperationException {
//         return reporter.getInputSplit();
//     }
// 
//     public void progress() {
//         reporter.progress();
//     }
// 
//     public void setStatus(String status) {
//         reporter.setStatus(status);
//     }
// 
//     public void incrCounter(Enum counter) {
//         reporter.incrCounter(counter, 1L);
//     }
// 
//     public void incrCounter(String group, String counter) {
//         reporter.incrCounter(group, counter, 1L);        
//     }
// 
// }


import org.apache.hadoop.conf.Configuration;
import colossal.pipe.BaseMapper;
import colossal.pipe.ColContext;
/**
 * Copyright (C) 2010-2014 Think Big Analytics, Inc. All Rights Reserved.
 *
 * Licensed 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. See accompanying LICENSE file.
 */
package colossal.pipe.sample;



public class LogClean extends BaseMapper<LogRec,LogRec> {

    @Override
    public void setConf(Configuration conf) {
        super.setConf(conf);
        if (conf != null) {
            //use conf.get
        }
    }
    
    @Override
// Path: src/main/java/colossal/pipe/BaseMapper.java
// public class BaseMapper<IN,OUT> extends Configured implements ColMapper<IN,OUT> {
// 
//     /** Override this method for a mapper */      
//     @SuppressWarnings("unchecked")
//     public void map(IN in, OUT out, ColContext<OUT> context) {
//         context.write((OUT)in);
//     }
// 
//     @Override
//     public void close(OUT out, ColContext<OUT> context) {
//         // no op by default
//     }
// 
// }
// 
// Path: src/main/java/colossal/pipe/ColContext.java
// public class ColContext<OUT> {
// 
//     private Reporter reporter;
//     private AvroCollector<OUT> collector;
//     
//     public<IN, K, V, KO, VO> ColContext(AvroCollector<OUT> collector, Reporter reporter) {
//         this.reporter = reporter;
//         this.collector = collector;
//     }
//     
//     public void write(OUT out) {
//         try {
//             collector.collect(out);
//         }
//         catch (IOException e) {
//             throw new RuntimeException(e);
//         }
//     }
// 
//     public Counter getCounter(Enum<?> name) {
//         return reporter.getCounter(name);
//     }
// 
//     public Counter getCounter(String group, String name) {
//         return reporter.getCounter(group, name);
//     }
// 
//     public void incrCounter(Enum<?> key, long amount) {
//         reporter.incrCounter(key, amount);
//     }
// 
//     public void incrCounter(String group, String counter, long amount) {
//         reporter.incrCounter(group, counter, amount);
//     }
// 
//     public InputSplit getInputSplit() throws UnsupportedOperationException {
//         return reporter.getInputSplit();
//     }
// 
//     public void progress() {
//         reporter.progress();
//     }
// 
//     public void setStatus(String status) {
//         reporter.setStatus(status);
//     }
// 
//     public void incrCounter(Enum counter) {
//         reporter.incrCounter(counter, 1L);
//     }
// 
//     public void incrCounter(String group, String counter) {
//         reporter.incrCounter(group, counter, 1L);        
//     }
// 
// }


// Path: src/sample/java/colossal/pipe/sample/LogClean.java
import org.apache.hadoop.conf.Configuration;
import colossal.pipe.BaseMapper;
import colossal.pipe.ColContext;

/**
 * Copyright (C) 2010-2014 Think Big Analytics, Inc. All Rights Reserved.
 *
 * Licensed 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. See accompanying LICENSE file.
 */
package colossal.pipe.sample;



public class LogClean extends BaseMapper<LogRec,LogRec> {

    @Override
    public void setConf(Configuration conf) {
        super.setConf(conf);
        if (conf != null) {
            //use conf.get
        }
    }
    
    @Override
    public void map(LogRec in, LogRec out, ColContext<LogRec> context) {