Class BigQueryJsonDataWriter

java.lang.Object
com.google.cloud.spring.bigquery.core.BigQueryJsonDataWriter
All Implemented Interfaces:
AutoCloseable

public class BigQueryJsonDataWriter extends Object implements AutoCloseable
Helper class for using BigQuery storage write API in exactly once delivery mode.
  • Method Details

    • append

      public void append(org.json.JSONArray data, long offset) throws com.google.protobuf.Descriptors.DescriptorValidationException, IOException
      Parameters:
      data - JSONArray to be appended
      offset - offset at which data has to be added
      Throws:
      com.google.protobuf.Descriptors.DescriptorValidationException
      IOException
    • finalizeWriteStream

      public void finalizeWriteStream()
      Call this method before committing the stream
    • getStreamName

      public String getStreamName()
    • close

      public void close()
      Specified by:
      close in interface AutoCloseable