Class v1beta1.BigQueryStorageClient (4.6.0)

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. Must be a non-expired session obtained from a call to
   *  CreateReadSession. Only the name field needs to be set.
   */
  // const session = {}
  /**
   *  Required. Number of new streams requested. Must be positive.
   *  Number of added streams may be less than this, see CreateReadSessionRequest
   *  for more information.
   */
  // const requestedStreams = 1234

  // Imports the Storage library
  const {BigQueryStorageClient} = require('@google-cloud/bigquery-storage').v1beta1;

  // Instantiates a client
  const storageClient = new BigQueryStorageClient();

  async function callBatchCreateReadSessionStreams() {
    // Construct request
    const request = {
      session,
      requestedStreams,
    };

    // Run request
    const response = await storageClient.batchCreateReadSessionStreams(request);
    console.log(response);
  }

  callBatchCreateReadSessionStreams();

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. Reference to the table to read.
   */
  // const tableReference = {}
  /**
   *  Required. String of the form `projects/{project_id}` indicating the
   *  project this ReadSession is associated with. This is the project that will
   *  be billed for usage.
   */
  // const parent = 'abc123'
  /**
   *  Any modifiers to the Table (e.g. snapshot timestamp).
   */
  // const tableModifiers = {}
  /**
   *  Initial number of streams. If unset or 0, we will
   *  provide a value of streams so as to produce reasonable throughput. Must be
   *  non-negative. The number of streams may be lower than the requested number,
   *  depending on the amount parallelism that is reasonable for the table and
   *  the maximum amount of parallelism allowed by the system.
   *  Streams must be read starting from offset 0.
   */
  // const requestedStreams = 1234
  /**
   *  Read options for this session (e.g. column selection, filters).
   */
  // const readOptions = {}
  /**
   *  Data output format. Currently default to Avro.
   *  DATA_FORMAT_UNSPECIFIED not supported.
   */
  // const format = {}
  /**
   *  The strategy to use for distributing data among multiple streams. Currently
   *  defaults to liquid sharding.
   */
  // const shardingStrategy = {}

  // Imports the Storage library
  const {BigQueryStorageClient} = require('@google-cloud/bigquery-storage').v1beta1;

  // Instantiates a client
  const storageClient = new BigQueryStorageClient();

  async function callCreateReadSession() {
    // Construct request
    const request = {
      tableReference,
      parent,
    };

    // Run request
    const response = await storageClient.createReadSession(request);
    console.log(response);
  }

  callCreateReadSession();

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. Stream to finalize.
   */
  // const stream = {}

  // Imports the Storage library
  const {BigQueryStorageClient} = require('@google-cloud/bigquery-storage').v1beta1;

  // Instantiates a client
  const storageClient = new BigQueryStorageClient();

  async function callFinalizeStream() {
    // Construct request
    const request = {
      stream,
    };

    // Run request
    const response = await storageClient.finalizeStream(request);
    console.log(response);
  }

  callFinalizeStream();

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. Identifier of the position in the stream to start reading from.
   *  The offset requested must be less than the last row read from ReadRows.
   *  Requesting a larger offset is undefined.
   */
  // const readPosition = {}

  // Imports the Storage library
  const {BigQueryStorageClient} = require('@google-cloud/bigquery-storage').v1beta1;

  // Instantiates a client
  const storageClient = new BigQueryStorageClient();

  async function callReadRows() {
    // Construct request
    const request = {
      readPosition,
    };

    // Run request
    const stream = await storageClient.readRows(request);
    stream.on('data', (response) => { console.log(response) });
    stream.on('error', (err) => { throw(err) });
    stream.on('end', () => { /* API call completed */ });
  }

  callReadRows();

  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. Stream to split.
   */
  // const originalStream = {}
  /**
   *  A value in the range (0.0, 1.0) that specifies the fractional point at
   *  which the original stream should be split. The actual split point is
   *  evaluated on pre-filtered rows, so if a filter is provided, then there is
   *  no guarantee that the division of the rows between the new child streams
   *  will be proportional to this fractional value. Additionally, because the
   *  server-side unit for assigning data is collections of rows, this fraction
   *  will always map to to a data storage boundary on the server side.
   */
  // const fraction = 1234

  // Imports the Storage library
  const {BigQueryStorageClient} = require('@google-cloud/bigquery-storage').v1beta1;

  // Instantiates a client
  const storageClient = new BigQueryStorageClient();

  async function callSplitReadStream() {
    // Construct request
    const request = {
      originalStream,
    };

    // Run request
    const response = await storageClient.splitReadStream(request);
    console.log(response);
  }

  callSplitReadStream();