import com.google.cloud.bigquery.BigQuery;

import com.google.cloud.bigquery.BigQueryException;

import com.google.cloud.bigquery.BigQueryOptions;

import com.google.cloud.bigquery.Field;

import com.google.cloud.bigquery.Schema;

import com.google.cloud.bigquery.StandardSQLTypeName;

import com.google.cloud.bigquery.StandardTableDefinition;

import com.google.cloud.bigquery.TableDefinition;

import com.google.cloud.bigquery.TableId;

import com.google.cloud.bigquery.TableInfo;

public class CreateTable {

public static void main(String[] args) {

// TODO(developer): Replace these variables before running the sample.

String datasetName = "MY_DATASET_NAME";

String tableName = "MY_TABLE_NAME2";

Schema schema =

Schema.of(

Field.of("stringField", StandardSQLTypeName.STRING),

Field.of("booleanField", StandardSQLTypeName.BOOL));

// createTable(datasetName, tableName, schema);

createTableWithoutSchema(datasetName,tableName);

}

public static void createTable(String datasetName, String tableName, Schema schema) {

try {

// Initialize client that will be used to send requests. This client only needs to be created

// once, and can be reused for multiple requests.

BigQuery bigquery = BigQueryOptions.getDefaultInstance().getService();

TableId tableId = TableId.of(datasetName, tableName);

TableDefinition tableDefinition = StandardTableDefinition.of(schema);

TableInfo tableInfo = TableInfo.newBuilder(tableId, tableDefinition).build();

bigquery.create(tableInfo);

System.out.println("Table created successfully");

} catch (BigQueryException e) {

System.out.println("Table was not created. \n" + e.toString());

}

}

//sample to create a table without schema

public static void createTableWithoutSchema(String dataSetName,String tableName){

//initialise client that will be used to sed requests. This client only needs to be

//create once, and can be reused for multiple requests

try {

BigQuery bigQuery = BigQueryOptions.getDefaultInstance().getService();

TableId tableId = TableId.of(dataSetName,tableName);

TableDefinition tableDefinition = StandardTableDefinition.of(Schema.of());

TableInfo tableInfo = TableInfo.newBuilder(tableId,tableDefinition).build();

bigQuery.create(tableInfo);

System.out.println("Table created Successfully");

}catch (BigQueryException e){

System.out.println("Table was not created.\n" + e.toString());

}

}

}