Package org.apache.drill.exec.store.googlesheets

Class GoogleSheetsBatchWriter

java.lang.Object

org.apache.drill.exec.store.AbstractRecordWriter

org.apache.drill.exec.store.googlesheets.GoogleSheetsBatchWriter

All Implemented Interfaces:

RecordWriter

Direct Known Subclasses:

GoogleSheetsBatchInsertWriter

public class GoogleSheetsBatchWriter
extends AbstractRecordWriter

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	GoogleSheetsBatchWriter.BigIntGSConverter
class	GoogleSheetsBatchWriter.BitGSConverter
class	GoogleSheetsBatchWriter.DateGSConverter
class	GoogleSheetsBatchWriter.Float4GSConverter
class	GoogleSheetsBatchWriter.Float8GSConverter
class	GoogleSheetsBatchWriter.IntGSConverter
class	GoogleSheetsBatchWriter.NullableBigIntGSConverter
class	GoogleSheetsBatchWriter.NullableBitGSConverter
class	GoogleSheetsBatchWriter.NullableDateGSConverter
class	GoogleSheetsBatchWriter.NullableFloat4GSConverter
class	GoogleSheetsBatchWriter.NullableFloat8GSConverter
class	GoogleSheetsBatchWriter.NullableIntGSConverter
class	GoogleSheetsBatchWriter.NullableSmallIntGSConverter
class	GoogleSheetsBatchWriter.NullableTimeGSConverter
class	GoogleSheetsBatchWriter.NullableTimeStampGSConverter
class	GoogleSheetsBatchWriter.NullableTinyIntGSConverter
class	GoogleSheetsBatchWriter.NullableVarCharGSConverter
class	GoogleSheetsBatchWriter.NullableVardecimalGSConverter
class	GoogleSheetsBatchWriter.SmallIntGSConverter
class	GoogleSheetsBatchWriter.TimeGSConverter
class	GoogleSheetsBatchWriter.TimeStampGSConverter
class	GoogleSheetsBatchWriter.TinyIntGSConverter
class	GoogleSheetsBatchWriter.VarCharGSConverter
class	GoogleSheetsBatchWriter.VardecimalGSConverter

Field Summary

Fields

Modifier and Type	Field	Description
protected final com.google.api.services.sheets.v4.Sheets	service
protected final String	sheetName
protected String	spreadsheetID
protected final String	tabName
protected final List<List<Object>>	values

Constructor Summary

Constructors

Constructor	Description
GoogleSheetsBatchWriter(OperatorContext context, String name, GoogleSheetsWriter config)

Method Summary

Modifier and Type	Method	Description
void	abort()
void	cleanup()
void	endRecord()	Called after adding all fields in a particular record are added using add{TypeHolder}(fieldId, TypeHolder) methods.
EventBasedRecordWriter.FieldConverter	getNewBigIntConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewBitConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewDateConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewFloat4Converter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewFloat8Converter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewIntConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableBigIntConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableBitConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableDateConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableFloat4Converter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableFloat8Converter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableIntConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableSmallIntConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableTimeConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableTimeStampConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableTinyIntConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableVarCharConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewNullableVarDecimalConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewSmallIntConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewTimeConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewTimeStampConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewTinyIntConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewVarCharConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
EventBasedRecordWriter.FieldConverter	getNewVarDecimalConverter(int fieldId, String fieldName, FieldReader reader)	Add the field value given in valueHolder at the given column number fieldId.
void	init(Map<String,String> writerOptions)	Initialize the writer.
void	startRecord()	Called before starting writing fields in a record.
void	updateSchema(VectorAccessible batch)	Update the schema in RecordWriter.

Methods inherited from class org.apache.drill.exec.store.AbstractRecordWriter

checkForNewPartition, getNewDecimal18Converter, getNewDecimal28DenseConverter, getNewDecimal28SparseConverter, getNewDecimal38DenseConverter, getNewDecimal38SparseConverter, getNewDecimal9Converter, getNewDictConverter, getNewIntervalConverter, getNewIntervalDayConverter, getNewIntervalYearConverter, getNewMapConverter, getNewNullableDecimal18Converter, getNewNullableDecimal28DenseConverter, getNewNullableDecimal28SparseConverter, getNewNullableDecimal38DenseConverter, getNewNullableDecimal38SparseConverter, getNewNullableDecimal9Converter, getNewNullableIntervalConverter, getNewNullableIntervalDayConverter, getNewNullableIntervalYearConverter, getNewNullableUInt1Converter, getNewNullableUInt2Converter, getNewNullableUInt4Converter, getNewNullableUInt8Converter, getNewNullableVar16CharConverter, getNewNullableVarBinaryConverter, getNewRepeatedBigIntConverter, getNewRepeatedBitConverter, getNewRepeatedDateConverter, getNewRepeatedDecimal18Converter, getNewRepeatedDecimal28DenseConverter, getNewRepeatedDecimal28SparseConverter, getNewRepeatedDecimal38DenseConverter, getNewRepeatedDecimal38SparseConverter, getNewRepeatedDecimal9Converter, getNewRepeatedDictConverter, getNewRepeatedFloat4Converter, getNewRepeatedFloat8Converter, getNewRepeatedIntConverter, getNewRepeatedIntervalConverter, getNewRepeatedIntervalDayConverter, getNewRepeatedIntervalYearConverter, getNewRepeatedListConverter, getNewRepeatedMapConverter, getNewRepeatedSmallIntConverter, getNewRepeatedTimeConverter, getNewRepeatedTimeStampConverter, getNewRepeatedTinyIntConverter, getNewRepeatedUInt1Converter, getNewRepeatedUInt2Converter, getNewRepeatedUInt4Converter, getNewRepeatedUInt8Converter, getNewRepeatedVar16CharConverter, getNewRepeatedVarBinaryConverter, getNewRepeatedVarCharConverter, getNewRepeatedVarDecimalConverter, getNewUInt1Converter, getNewUInt2Converter, getNewUInt4Converter, getNewUInt8Converter, getNewUnionConverter, getNewVar16CharConverter, getNewVarBinaryConverter, newPartition, postProcessing, setPartitionVector, supportsField

Methods inherited from class java.lang.Object

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

Field Details

service

protected final com.google.api.services.sheets.v4.Sheets service

tabName

protected final String tabName

sheetName

protected final String sheetName

values

protected final List<List<Object>> values

spreadsheetID

protected String spreadsheetID

Constructor Details

GoogleSheetsBatchWriter

public GoogleSheetsBatchWriter(OperatorContext context,
 String name,
 GoogleSheetsWriter config)

Method Details

init

public void init(Map<String,String> writerOptions)

Description copied from interface: RecordWriter

Initialize the writer.

Parameters:

writerOptions - Contains key, value pair of settings.

updateSchema

public void updateSchema(VectorAccessible batch)
                  throws IOException

Description copied from interface: RecordWriter

Update the schema in RecordWriter. Called at least once before starting writing the records.

Throws:

IOException

startRecord

public void startRecord()

Description copied from interface: RecordWriter

Called before starting writing fields in a record.

endRecord

public void endRecord()

Description copied from interface: RecordWriter

Called after adding all fields in a particular record are added using add{TypeHolder}(fieldId, TypeHolder) methods.

abort

public void abort()

cleanup

public void cleanup()

getNewNullableBigIntConverter

public EventBasedRecordWriter.FieldConverter getNewNullableBigIntConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewNullableBigIntConverter in interface RecordWriter

Overrides:

getNewNullableBigIntConverter in class AbstractRecordWriter

getNewBigIntConverter

public EventBasedRecordWriter.FieldConverter getNewBigIntConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewBigIntConverter in interface RecordWriter

Overrides:

getNewBigIntConverter in class AbstractRecordWriter

getNewNullableIntConverter

public EventBasedRecordWriter.FieldConverter getNewNullableIntConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewNullableIntConverter in interface RecordWriter

Overrides:

getNewNullableIntConverter in class AbstractRecordWriter

getNewIntConverter

public EventBasedRecordWriter.FieldConverter getNewIntConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewIntConverter in interface RecordWriter

Overrides:

getNewIntConverter in class AbstractRecordWriter

getNewNullableSmallIntConverter

public EventBasedRecordWriter.FieldConverter getNewNullableSmallIntConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewNullableSmallIntConverter in interface RecordWriter

Overrides:

getNewNullableSmallIntConverter in class AbstractRecordWriter

getNewSmallIntConverter

public EventBasedRecordWriter.FieldConverter getNewSmallIntConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewSmallIntConverter in interface RecordWriter

Overrides:

getNewSmallIntConverter in class AbstractRecordWriter

getNewNullableTinyIntConverter

public EventBasedRecordWriter.FieldConverter getNewNullableTinyIntConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewNullableTinyIntConverter in interface RecordWriter

Overrides:

getNewNullableTinyIntConverter in class AbstractRecordWriter

getNewTinyIntConverter

public EventBasedRecordWriter.FieldConverter getNewTinyIntConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewTinyIntConverter in interface RecordWriter

Overrides:

getNewTinyIntConverter in class AbstractRecordWriter

getNewNullableFloat8Converter

public EventBasedRecordWriter.FieldConverter getNewNullableFloat8Converter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewNullableFloat8Converter in interface RecordWriter

Overrides:

getNewNullableFloat8Converter in class AbstractRecordWriter

getNewFloat8Converter

public EventBasedRecordWriter.FieldConverter getNewFloat8Converter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewFloat8Converter in interface RecordWriter

Overrides:

getNewFloat8Converter in class AbstractRecordWriter

getNewNullableFloat4Converter

public EventBasedRecordWriter.FieldConverter getNewNullableFloat4Converter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewNullableFloat4Converter in interface RecordWriter

Overrides:

getNewNullableFloat4Converter in class AbstractRecordWriter

getNewFloat4Converter

public EventBasedRecordWriter.FieldConverter getNewFloat4Converter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewFloat4Converter in interface RecordWriter

Overrides:

getNewFloat4Converter in class AbstractRecordWriter

getNewNullableVarDecimalConverter

public EventBasedRecordWriter.FieldConverter getNewNullableVarDecimalConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewNullableVarDecimalConverter in interface RecordWriter

Overrides:

getNewNullableVarDecimalConverter in class AbstractRecordWriter

getNewVarDecimalConverter

public EventBasedRecordWriter.FieldConverter getNewVarDecimalConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewVarDecimalConverter in interface RecordWriter

Overrides:

getNewVarDecimalConverter in class AbstractRecordWriter

getNewNullableVarCharConverter

public EventBasedRecordWriter.FieldConverter getNewNullableVarCharConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewNullableVarCharConverter in interface RecordWriter

Overrides:

getNewNullableVarCharConverter in class AbstractRecordWriter

getNewVarCharConverter

public EventBasedRecordWriter.FieldConverter getNewVarCharConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewVarCharConverter in interface RecordWriter

Overrides:

getNewVarCharConverter in class AbstractRecordWriter

getNewNullableDateConverter

public EventBasedRecordWriter.FieldConverter getNewNullableDateConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewNullableDateConverter in interface RecordWriter

Overrides:

getNewNullableDateConverter in class AbstractRecordWriter

getNewDateConverter

public EventBasedRecordWriter.FieldConverter getNewDateConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewDateConverter in interface RecordWriter

Overrides:

getNewDateConverter in class AbstractRecordWriter

getNewNullableTimeConverter

public EventBasedRecordWriter.FieldConverter getNewNullableTimeConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewNullableTimeConverter in interface RecordWriter

Overrides:

getNewNullableTimeConverter in class AbstractRecordWriter

getNewTimeConverter

public EventBasedRecordWriter.FieldConverter getNewTimeConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewTimeConverter in interface RecordWriter

Overrides:

getNewTimeConverter in class AbstractRecordWriter

getNewNullableTimeStampConverter

public EventBasedRecordWriter.FieldConverter getNewNullableTimeStampConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewNullableTimeStampConverter in interface RecordWriter

Overrides:

getNewNullableTimeStampConverter in class AbstractRecordWriter

getNewTimeStampConverter

public EventBasedRecordWriter.FieldConverter getNewTimeStampConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewTimeStampConverter in interface RecordWriter

Overrides:

getNewTimeStampConverter in class AbstractRecordWriter

getNewNullableBitConverter

public EventBasedRecordWriter.FieldConverter getNewNullableBitConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewNullableBitConverter in interface RecordWriter

Overrides:

getNewNullableBitConverter in class AbstractRecordWriter

getNewBitConverter

public EventBasedRecordWriter.FieldConverter getNewBitConverter(int fieldId,
 String fieldName,
 FieldReader reader)

Description copied from interface: RecordWriter

Add the field value given in valueHolder at the given column number fieldId.

Specified by:

getNewBitConverter in interface RecordWriter

Overrides:

getNewBitConverter in class AbstractRecordWriter