// Path: kiji-mapreduce/src/test/java/org/kiji/mapreduce/KijiMRTestLayouts.java
// public final class KijiMRTestLayouts {
// 
//   /**
//    * Alias for KijiTableLayouts.getLayout(resource).
//    *
//    * @param resourcePath Path of the resource to load the JSON descriptor from.
//    * @return the decoded TableLayoutDesc.
//    * @throws IOException on I/O error.
//    */
//   public static TableLayoutDesc getLayout(String resourcePath) throws IOException {
//     return KijiTableLayouts.getLayout(resourcePath);
//   }
// 
//   /** Generic test layout with user info, all primitive types, a map-type family of strings. */
//   public static final String TEST_LAYOUT = "org/kiji/mapreduce/layout/test.json";
//   /** Multiple locality group test layout. */
//   public static final String LG_TEST_LAYOUT = "org/kiji/mapreduce/layout/lgtest.json";
// 
//   /**
//    * @return a generic test layout.
//    * @throws IOException on I/O error.
//    */
//   public static TableLayoutDesc getTestLayout() throws IOException {
//     return getLayout(TEST_LAYOUT);
//   }
// 
//   /**
//    * @param tableName For the table name in the layout.
//    * @return a generic test layout.
//    * @throws IOException on I/O error.
//    */
//   public static TableLayoutDesc getTestLayout(String tableName) throws IOException {
//     final TableLayoutDesc desc = getLayout(TEST_LAYOUT);
//     desc.setName(tableName);
//     return desc;
//   }
// 
//   /** Utility class cannot be instantiated. */
//   private KijiMRTestLayouts() {
//   }
// }


import static org.junit.Assert.assertEquals;
import java.io.File;
import java.io.IOException;
import org.apache.commons.codec.binary.Base64;
import org.apache.commons.io.FileUtils;
import org.apache.commons.lang.SerializationUtils;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.mapreduce.Job;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import org.kiji.mapreduce.KijiMRTestLayouts;
import org.kiji.mapreduce.MapReduceJobInput;
import org.kiji.mapreduce.framework.KijiConfKeys;
import org.kiji.schema.EntityId;
import org.kiji.schema.HBaseEntityId;
import org.kiji.schema.KijiClientTest;
import org.kiji.schema.KijiDataRequest;
import org.kiji.schema.KijiDataRequestBuilder;
import org.kiji.schema.KijiTable;
import org.kiji.schema.KijiURI;
import org.kiji.schema.filter.KijiRowFilter;
import org.kiji.schema.filter.StripValueRowFilter;
import org.kiji.schema.util.ResourceUtils;
import org.kiji.schema.util.TestingFileUtils;
/**
 * (c) Copyright 2013 WibiData, Inc.
 *
 * See the NOTICE file distributed with this work for additional
 * information regarding copyright ownership.
 *
 * 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.
 */

package org.kiji.mapreduce.input;





public class TestKijiTableMapReduceJobInput extends KijiClientTest {
  private File mTempDir;
  private Path mTempPath;
  private KijiTable mTable;

  @Before
  public void setUp() throws Exception {
    mTempDir = TestingFileUtils.createTempDir("test", "dir");
    mTempPath = new Path("file://" + mTempDir);

    getConf().set("fs.defaultFS", mTempPath.toString());
    getConf().set("fs.default.name", mTempPath.toString());
// Path: kiji-mapreduce/src/test/java/org/kiji/mapreduce/KijiMRTestLayouts.java
// public final class KijiMRTestLayouts {
// 
//   /**
//    * Alias for KijiTableLayouts.getLayout(resource).
//    *
//    * @param resourcePath Path of the resource to load the JSON descriptor from.
//    * @return the decoded TableLayoutDesc.
//    * @throws IOException on I/O error.
//    */
//   public static TableLayoutDesc getLayout(String resourcePath) throws IOException {
//     return KijiTableLayouts.getLayout(resourcePath);
//   }
// 
//   /** Generic test layout with user info, all primitive types, a map-type family of strings. */
//   public static final String TEST_LAYOUT = "org/kiji/mapreduce/layout/test.json";
//   /** Multiple locality group test layout. */
//   public static final String LG_TEST_LAYOUT = "org/kiji/mapreduce/layout/lgtest.json";
// 
//   /**
//    * @return a generic test layout.
//    * @throws IOException on I/O error.
//    */
//   public static TableLayoutDesc getTestLayout() throws IOException {
//     return getLayout(TEST_LAYOUT);
//   }
// 
//   /**
//    * @param tableName For the table name in the layout.
//    * @return a generic test layout.
//    * @throws IOException on I/O error.
//    */
//   public static TableLayoutDesc getTestLayout(String tableName) throws IOException {
//     final TableLayoutDesc desc = getLayout(TEST_LAYOUT);
//     desc.setName(tableName);
//     return desc;
//   }
// 
//   /** Utility class cannot be instantiated. */
//   private KijiMRTestLayouts() {
//   }
// }


// Path: kiji-mapreduce/src/test/java/org/kiji/mapreduce/input/TestKijiTableMapReduceJobInput.java
import static org.junit.Assert.assertEquals;
import java.io.File;
import java.io.IOException;
import org.apache.commons.codec.binary.Base64;
import org.apache.commons.io.FileUtils;
import org.apache.commons.lang.SerializationUtils;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.mapreduce.Job;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import org.kiji.mapreduce.KijiMRTestLayouts;
import org.kiji.mapreduce.MapReduceJobInput;
import org.kiji.mapreduce.framework.KijiConfKeys;
import org.kiji.schema.EntityId;
import org.kiji.schema.HBaseEntityId;
import org.kiji.schema.KijiClientTest;
import org.kiji.schema.KijiDataRequest;
import org.kiji.schema.KijiDataRequestBuilder;
import org.kiji.schema.KijiTable;
import org.kiji.schema.KijiURI;
import org.kiji.schema.filter.KijiRowFilter;
import org.kiji.schema.filter.StripValueRowFilter;
import org.kiji.schema.util.ResourceUtils;
import org.kiji.schema.util.TestingFileUtils;

/**
 * (c) Copyright 2013 WibiData, Inc.
 *
 * See the NOTICE file distributed with this work for additional
 * information regarding copyright ownership.
 *
 * 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.
 */

package org.kiji.mapreduce.input;





public class TestKijiTableMapReduceJobInput extends KijiClientTest {
  private File mTempDir;
  private Path mTempPath;
  private KijiTable mTable;

  @Before
  public void setUp() throws Exception {
    mTempDir = TestingFileUtils.createTempDir("test", "dir");
    mTempPath = new Path("file://" + mTempDir);

    getConf().set("fs.defaultFS", mTempPath.toString());
    getConf().set("fs.default.name", mTempPath.toString());
    getKiji().createTable(KijiMRTestLayouts.getTestLayout());