JdbcRecordWriter (Drill : 1.20.3 API)

java.lang.Object
- org.apache.drill.exec.store.AbstractRecordWriter
- - org.apache.drill.exec.store.jdbc.JdbcRecordWriter

All Implemented Interfaces:: RecordWriter

public class JdbcRecordWriter
extends AbstractRecordWriter

Nested Class Summary

Nested Classes
Modifier and Type	Class and Description
`class`	`JdbcRecordWriter.BigIntJDBCConverter`
`class`	`JdbcRecordWriter.BitJDBCConverter`
`class`	`JdbcRecordWriter.DateJDBCConverter`
`class`	`JdbcRecordWriter.Float4JDBCConverter`
`class`	`JdbcRecordWriter.Float8JDBCConverter`
`class`	`JdbcRecordWriter.IntJDBCConverter`
`class`	`JdbcRecordWriter.NullableBigIntJDBCConverter`
`class`	`JdbcRecordWriter.NullableBitJDBCConverter`
`class`	`JdbcRecordWriter.NullableDateJDBCConverter`
`class`	`JdbcRecordWriter.NullableFloat4JDBCConverter`
`class`	`JdbcRecordWriter.NullableFloat8JDBCConverter`
`class`	`JdbcRecordWriter.NullableIntJDBCConverter`
`class`	`JdbcRecordWriter.NullableSmallIntJDBCConverter`
`class`	`JdbcRecordWriter.NullableTimeJDBCConverter`
`class`	`JdbcRecordWriter.NullableTimeStampJDBCConverter`
`class`	`JdbcRecordWriter.NullableTinyIntJDBCConverter`
`class`	`JdbcRecordWriter.NullableVarCharJDBCConverter`
`class`	`JdbcRecordWriter.NullableVardecimalJDBCConverter`
`class`	`JdbcRecordWriter.SmallIntJDBCConverter`
`class`	`JdbcRecordWriter.TimeJDBCConverter`
`class`	`JdbcRecordWriter.TimeStampJDBCConverter`
`class`	`JdbcRecordWriter.TinyIntJDBCConverter`
`class`	`JdbcRecordWriter.VarCharJDBCConverter`
`class`	`JdbcRecordWriter.VardecimalJDBCConverter`

Field Summary

Fields
Modifier and Type Field and Description

static org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap<TypeProtos.MinorType,Integer> JDBC_TYPE_MAPPINGS

Fields
Modifier and Type	Field and Description
`static org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap<TypeProtos.MinorType,Integer>`	`JDBC_TYPE_MAPPINGS`

Constructor Summary

Constructors
Constructor and Description

JdbcRecordWriter(DataSource source, OperatorContext context, String name, JdbcWriter config)

Constructors
Constructor and Description
`JdbcRecordWriter(DataSource source, OperatorContext context, String name, JdbcWriter config)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and 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 Detail

JDBC_TYPE_MAPPINGS

public static final org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap<TypeProtos.MinorType,Integer> JDBC_TYPE_MAPPINGS

Constructor Detail

JdbcRecordWriter

public JdbcRecordWriter(DataSource source,
                        OperatorContext context,
                        String name,
                        JdbcWriter config)

Method Detail

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