@InternalExtensionOnly public class HttpBigQueryRpc extends Object implements BigQueryRpc
BigQueryRpc.Option
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_PROJECTION |
Constructor and Description |
---|
HttpBigQueryRpc(BigQueryOptions options) |
Modifier and Type | Method and Description |
---|---|
boolean |
cancel(String projectId,
String jobId,
String location)
Sends a job cancel request.
|
com.google.api.services.bigquery.model.Dataset |
create(com.google.api.services.bigquery.model.Dataset dataset,
Map<BigQueryRpc.Option,?> options)
Creates a new dataset.
|
com.google.api.services.bigquery.model.Job |
create(com.google.api.services.bigquery.model.Job job,
Map<BigQueryRpc.Option,?> options)
Creates a new job.
|
com.google.api.services.bigquery.model.Table |
create(com.google.api.services.bigquery.model.Table table,
Map<BigQueryRpc.Option,?> options)
Creates a new table.
|
boolean |
deleteDataset(String projectId,
String datasetId,
Map<BigQueryRpc.Option,?> options)
Delete the requested dataset.
|
boolean |
deleteTable(String projectId,
String datasetId,
String tableId)
Delete the requested table.
|
com.google.api.services.bigquery.model.Dataset |
getDataset(String projectId,
String datasetId,
Map<BigQueryRpc.Option,?> options)
Returns the requested dataset or
null if not found. |
com.google.api.services.bigquery.model.Job |
getJob(String projectId,
String jobId,
String location,
Map<BigQueryRpc.Option,?> options)
Returns the requested job or
null if not found. |
com.google.api.services.bigquery.model.GetQueryResultsResponse |
getQueryResults(String projectId,
String jobId,
String location,
Map<BigQueryRpc.Option,?> options)
Returns results of the query associated with the provided job.
|
com.google.api.services.bigquery.model.Table |
getTable(String projectId,
String datasetId,
String tableId,
Map<BigQueryRpc.Option,?> options)
Returns the requested table or
null if not found. |
com.google.api.services.bigquery.model.TableDataInsertAllResponse |
insertAll(String projectId,
String datasetId,
String tableId,
com.google.api.services.bigquery.model.TableDataInsertAllRequest request)
Sends an insert all request.
|
Tuple<String,Iterable<com.google.api.services.bigquery.model.Dataset>> |
listDatasets(String projectId,
Map<BigQueryRpc.Option,?> options)
Lists the provided project's datasets.
|
Tuple<String,Iterable<com.google.api.services.bigquery.model.Job>> |
listJobs(String projectId,
Map<BigQueryRpc.Option,?> options)
Lists the project's jobs.
|
com.google.api.services.bigquery.model.TableDataList |
listTableData(String projectId,
String datasetId,
String tableId,
Map<BigQueryRpc.Option,?> options)
Lists the table's rows.
|
Tuple<String,Iterable<com.google.api.services.bigquery.model.Table>> |
listTables(String projectId,
String datasetId,
Map<BigQueryRpc.Option,?> options)
Lists the dataset's tables.
|
String |
open(com.google.api.services.bigquery.model.Job loadJob)
Opens a resumable upload session to load data into a BigQuery table and returns an upload URI.
|
com.google.api.services.bigquery.model.Dataset |
patch(com.google.api.services.bigquery.model.Dataset dataset,
Map<BigQueryRpc.Option,?> options)
Updates dataset information.
|
com.google.api.services.bigquery.model.Table |
patch(com.google.api.services.bigquery.model.Table table,
Map<BigQueryRpc.Option,?> options)
Updates table information.
|
com.google.api.services.bigquery.model.Job |
write(String uploadId,
byte[] toWrite,
int toWriteOffset,
long destOffset,
int length,
boolean last)
Uploads the provided data to the resumable upload session at the specified position.
|
public static final String DEFAULT_PROJECTION
public HttpBigQueryRpc(BigQueryOptions options)
public com.google.api.services.bigquery.model.Dataset getDataset(String projectId, String datasetId, Map<BigQueryRpc.Option,?> options)
BigQueryRpc
null
if not found.getDataset
in interface BigQueryRpc
public Tuple<String,Iterable<com.google.api.services.bigquery.model.Dataset>> listDatasets(String projectId, Map<BigQueryRpc.Option,?> options)
BigQueryRpc
BigQueryRpc.getDataset(String,
String, Map)
.listDatasets
in interface BigQueryRpc
public com.google.api.services.bigquery.model.Dataset create(com.google.api.services.bigquery.model.Dataset dataset, Map<BigQueryRpc.Option,?> options)
BigQueryRpc
create
in interface BigQueryRpc
public com.google.api.services.bigquery.model.Table create(com.google.api.services.bigquery.model.Table table, Map<BigQueryRpc.Option,?> options)
BigQueryRpc
create
in interface BigQueryRpc
public com.google.api.services.bigquery.model.Job create(com.google.api.services.bigquery.model.Job job, Map<BigQueryRpc.Option,?> options)
BigQueryRpc
create
in interface BigQueryRpc
public boolean deleteDataset(String projectId, String datasetId, Map<BigQueryRpc.Option,?> options)
BigQueryRpc
deleteDataset
in interface BigQueryRpc
true
if dataset was deleted, false
if it was not foundpublic com.google.api.services.bigquery.model.Dataset patch(com.google.api.services.bigquery.model.Dataset dataset, Map<BigQueryRpc.Option,?> options)
BigQueryRpc
patch
in interface BigQueryRpc
public com.google.api.services.bigquery.model.Table patch(com.google.api.services.bigquery.model.Table table, Map<BigQueryRpc.Option,?> options)
BigQueryRpc
patch
in interface BigQueryRpc
public com.google.api.services.bigquery.model.Table getTable(String projectId, String datasetId, String tableId, Map<BigQueryRpc.Option,?> options)
BigQueryRpc
null
if not found.getTable
in interface BigQueryRpc
public Tuple<String,Iterable<com.google.api.services.bigquery.model.Table>> listTables(String projectId, String datasetId, Map<BigQueryRpc.Option,?> options)
BigQueryRpc
BigQueryRpc.getTable(String, String,
String, Map)
.listTables
in interface BigQueryRpc
public boolean deleteTable(String projectId, String datasetId, String tableId)
BigQueryRpc
deleteTable
in interface BigQueryRpc
true
if table was deleted, false
if it was not foundpublic com.google.api.services.bigquery.model.TableDataInsertAllResponse insertAll(String projectId, String datasetId, String tableId, com.google.api.services.bigquery.model.TableDataInsertAllRequest request)
BigQueryRpc
insertAll
in interface BigQueryRpc
public com.google.api.services.bigquery.model.TableDataList listTableData(String projectId, String datasetId, String tableId, Map<BigQueryRpc.Option,?> options)
BigQueryRpc
listTableData
in interface BigQueryRpc
public com.google.api.services.bigquery.model.Job getJob(String projectId, String jobId, String location, Map<BigQueryRpc.Option,?> options)
BigQueryRpc
null
if not found.getJob
in interface BigQueryRpc
public Tuple<String,Iterable<com.google.api.services.bigquery.model.Job>> listJobs(String projectId, Map<BigQueryRpc.Option,?> options)
BigQueryRpc
listJobs
in interface BigQueryRpc
public boolean cancel(String projectId, String jobId, String location)
BigQueryRpc
cancel
in interface BigQueryRpc
true
if cancel was requested successfully, false
if the job was not
foundpublic com.google.api.services.bigquery.model.GetQueryResultsResponse getQueryResults(String projectId, String jobId, String location, Map<BigQueryRpc.Option,?> options)
BigQueryRpc
getQueryResults
in interface BigQueryRpc
public String open(com.google.api.services.bigquery.model.Job loadJob)
BigQueryRpc
open
in interface BigQueryRpc
loadJob
- load jobpublic com.google.api.services.bigquery.model.Job write(String uploadId, byte[] toWrite, int toWriteOffset, long destOffset, int length, boolean last)
BigQueryRpc
last
is true
.write
in interface BigQueryRpc
uploadId
- the resumable upload session URItoWrite
- a byte array of data to uploadtoWriteOffset
- offset in the toWrite
param to start writing fromdestOffset
- offset in the destination where to upload data tolength
- the number of bytes to uploadlast
- true
indicates that the last chunk is being uploadedlast
is true
.
Returns null
otherwiseCopyright © 2019 Google LLC. All rights reserved.