Package org.apache.drill.exec.store.jdbc

Class JdbcRecordWriter

java.lang.Object

org.apache.drill.exec.store.AbstractRecordWriter

org.apache.drill.exec.store.jdbc.JdbcRecordWriter

All Implemented Interfaces:

RecordWriter

Direct Known Subclasses:

JdbcTableModifyWriter

public class JdbcRecordWriter
extends AbstractRecordWriter

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	JdbcRecordWriter.ApproxNumericJdbcConverter
class	JdbcRecordWriter.BitJDBCConverter
class	JdbcRecordWriter.DateJDBCConverter
class	JdbcRecordWriter.ExactNumericJdbcConverter
class	JdbcRecordWriter.NullableJdbcConverter
class	JdbcRecordWriter.TimeJDBCConverter
class	JdbcRecordWriter.TimeStampJDBCConverter
class	JdbcRecordWriter.VarCharJDBCConverter

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.apache.calcite.sql.SqlDialect	dialect

Constructor Summary

Constructors

Constructor	Description
JdbcRecordWriter(UserBitShared.UserCredentials userCredentials, List<String> tableIdentifier, JdbcWriter 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.
protected InsertStatementBuilder	getInsertStatementBuilder(List<String> tableIdentifier)
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

dialect

protected final org.apache.calcite.sql.SqlDialect dialect

Constructor Details

JdbcRecordWriter

public JdbcRecordWriter(UserBitShared.UserCredentials userCredentials,
 List<String> tableIdentifier,
 JdbcWriter config)

Method Details

getInsertStatementBuilder

protected InsertStatementBuilder getInsertStatementBuilder(List<String> tableIdentifier)

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)

Description copied from interface: RecordWriter

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

startRecord

public void startRecord()

Description copied from interface: RecordWriter

Called before starting writing fields in a record.

endRecord

public void endRecord()
               throws IOException

Description copied from interface: RecordWriter

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

Throws:

IOException

abort

public void abort()

cleanup

public void cleanup()
             throws IOException

Throws:

IOException

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

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

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

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

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

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