// Path: kcbq-api/src/main/java/com/wepay/kafka/connect/bigquery/api/SchemaRetriever.java
// public interface SchemaRetriever {
//   /**
//    * Called with all of the configuration settings passed to the connector via its
//    * {@link org.apache.kafka.connect.sink.SinkConnector#start(Map)} method.
//    * @param properties The configuration settings of the connector.
//    */
//   void configure(Map<String, String> properties);
// 
//   /**
//    * Retrieve the most current key schema for the given sink record.
//    * @param record The record to retrieve a key schema for.
//    * @return The key Schema for the given record.
//    */
//   Schema retrieveKeySchema(SinkRecord record);
// 
//   /**
//    * Retrieve the most current value schema for the given sink record.
//    * @param record The record to retrieve a value schema for.
//    * @return The value Schema for the given record.
//    */
//   Schema retrieveValueSchema(SinkRecord record);
// 
// }


import org.apache.kafka.connect.data.Schema;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
import java.util.Arrays;
import java.util.List;
import java.util.Optional;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
import com.google.cloud.bigquery.BigQuery;
import com.google.cloud.bigquery.Field;
import com.google.cloud.bigquery.LegacySQLTypeName;
import com.google.cloud.bigquery.StandardTableDefinition;
import com.google.cloud.bigquery.TableId;
import com.google.cloud.bigquery.TableInfo;
import com.wepay.kafka.connect.bigquery.api.SchemaRetriever;
import com.wepay.kafka.connect.bigquery.convert.SchemaConverter;
package com.wepay.kafka.connect.bigquery;

/*
 * Copyright 2016 WePay, Inc.
 *
 * 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.
 */








public class SchemaManagerTest {

  private String testTableName = "testTable";
  private String testDatasetName = "testDataset";
  private String testDoc = "test doc";
  private TableId tableId = TableId.of(testDatasetName, testTableName);

// Path: kcbq-api/src/main/java/com/wepay/kafka/connect/bigquery/api/SchemaRetriever.java
// public interface SchemaRetriever {
//   /**
//    * Called with all of the configuration settings passed to the connector via its
//    * {@link org.apache.kafka.connect.sink.SinkConnector#start(Map)} method.
//    * @param properties The configuration settings of the connector.
//    */
//   void configure(Map<String, String> properties);
// 
//   /**
//    * Retrieve the most current key schema for the given sink record.
//    * @param record The record to retrieve a key schema for.
//    * @return The key Schema for the given record.
//    */
//   Schema retrieveKeySchema(SinkRecord record);
// 
//   /**
//    * Retrieve the most current value schema for the given sink record.
//    * @param record The record to retrieve a value schema for.
//    * @return The value Schema for the given record.
//    */
//   Schema retrieveValueSchema(SinkRecord record);
// 
// }


// Path: kcbq-connector/src/test/java/com/wepay/kafka/connect/bigquery/SchemaManagerTest.java
import org.apache.kafka.connect.data.Schema;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
import java.util.Arrays;
import java.util.List;
import java.util.Optional;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
import com.google.cloud.bigquery.BigQuery;
import com.google.cloud.bigquery.Field;
import com.google.cloud.bigquery.LegacySQLTypeName;
import com.google.cloud.bigquery.StandardTableDefinition;
import com.google.cloud.bigquery.TableId;
import com.google.cloud.bigquery.TableInfo;
import com.wepay.kafka.connect.bigquery.api.SchemaRetriever;
import com.wepay.kafka.connect.bigquery.convert.SchemaConverter;

package com.wepay.kafka.connect.bigquery;

/*
 * Copyright 2016 WePay, Inc.
 *
 * 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.
 */








public class SchemaManagerTest {

  private String testTableName = "testTable";
  private String testDatasetName = "testDataset";
  private String testDoc = "test doc";
  private TableId tableId = TableId.of(testDatasetName, testTableName);

  private SchemaRetriever mockSchemaRetriever;