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

Class JdbcTableModifyWriter

java.lang.Object

org.apache.drill.exec.store.AbstractRecordWriter

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

org.apache.drill.exec.store.jdbc.JdbcTableModifyWriter

All Implemented Interfaces:

RecordWriter

public class JdbcTableModifyWriter
extends JdbcRecordWriter

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.drill.exec.store.jdbc.JdbcRecordWriter

JdbcRecordWriter.ApproxNumericJdbcConverter, JdbcRecordWriter.BitJDBCConverter, JdbcRecordWriter.DateJDBCConverter, JdbcRecordWriter.ExactNumericJdbcConverter, JdbcRecordWriter.NullableJdbcConverter, JdbcRecordWriter.TimeJDBCConverter, JdbcRecordWriter.TimeStampJDBCConverter, JdbcRecordWriter.VarCharJDBCConverter

Field Summary

Fields inherited from class org.apache.drill.exec.store.jdbc.JdbcRecordWriter

dialect

Constructor Summary

Constructors

Constructor	Description
JdbcTableModifyWriter(UserBitShared.UserCredentials userCredentials, List<String> tableIdentifier, JdbcWriter config)

Method Summary

Modifier and Type	Method	Description
void	updateSchema(VectorAccessible batch)	Update the schema in RecordWriter.

Methods inherited from class org.apache.drill.exec.store.jdbc.JdbcRecordWriter

abort, cleanup, endRecord, getInsertStatementBuilder, getNewBigIntConverter, getNewBitConverter, getNewDateConverter, getNewFloat4Converter, getNewFloat8Converter, getNewIntConverter, getNewNullableBigIntConverter, getNewNullableBitConverter, getNewNullableDateConverter, getNewNullableFloat4Converter, getNewNullableFloat8Converter, getNewNullableIntConverter, getNewNullableSmallIntConverter, getNewNullableTimeConverter, getNewNullableTimeStampConverter, getNewNullableTinyIntConverter, getNewNullableVarCharConverter, getNewNullableVarDecimalConverter, getNewSmallIntConverter, getNewTimeConverter, getNewTimeStampConverter, getNewTinyIntConverter, getNewVarCharConverter, getNewVarDecimalConverter, init, startRecord

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

Constructor Details

JdbcTableModifyWriter

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

Method Details

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.

Specified by:

updateSchema in interface RecordWriter

Overrides:

updateSchema in class JdbcRecordWriter