Package com.google.cloud.spring.bigquery.core

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 Summary

Modifier and Type	Method	Description
void	append(org.json.JSONArray data, long offset)
void	close()
void	finalizeWriteStream()	Call this method before committing the stream
String	getStreamName()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception