public class JdbcRecordWriter extends AbstractRecordWriter
Modifier and Type | Field and Description |
---|---|
static org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap<TypeProtos.MinorType,Integer> |
JDBC_TYPE_MAPPINGS |
Constructor and Description |
---|
JdbcRecordWriter(DataSource source,
OperatorContext context,
String name,
JdbcWriter config) |
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.
|
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
public static final org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap<TypeProtos.MinorType,Integer> JDBC_TYPE_MAPPINGS
public JdbcRecordWriter(DataSource source, OperatorContext context, String name, JdbcWriter config)
public void init(Map<String,String> writerOptions)
RecordWriter
writerOptions
- Contains key, value pair of settings.public void updateSchema(VectorAccessible batch)
RecordWriter
public void startRecord()
RecordWriter
public void endRecord() throws IOException
RecordWriter
IOException
public void abort()
public void cleanup() throws IOException
IOException
public EventBasedRecordWriter.FieldConverter getNewNullableIntConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableIntConverter
in interface RecordWriter
getNewNullableIntConverter
in class AbstractRecordWriter
public EventBasedRecordWriter.FieldConverter getNewIntConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewIntConverter
in interface RecordWriter
getNewIntConverter
in class AbstractRecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableBigIntConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableBigIntConverter
in interface RecordWriter
getNewNullableBigIntConverter
in class AbstractRecordWriter
public EventBasedRecordWriter.FieldConverter getNewBigIntConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewBigIntConverter
in interface RecordWriter
getNewBigIntConverter
in class AbstractRecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableSmallIntConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableSmallIntConverter
in interface RecordWriter
getNewNullableSmallIntConverter
in class AbstractRecordWriter
public EventBasedRecordWriter.FieldConverter getNewSmallIntConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewSmallIntConverter
in interface RecordWriter
getNewSmallIntConverter
in class AbstractRecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableTinyIntConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableTinyIntConverter
in interface RecordWriter
getNewNullableTinyIntConverter
in class AbstractRecordWriter
public EventBasedRecordWriter.FieldConverter getNewTinyIntConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewTinyIntConverter
in interface RecordWriter
getNewTinyIntConverter
in class AbstractRecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableFloat4Converter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableFloat4Converter
in interface RecordWriter
getNewNullableFloat4Converter
in class AbstractRecordWriter
public EventBasedRecordWriter.FieldConverter getNewFloat4Converter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewFloat4Converter
in interface RecordWriter
getNewFloat4Converter
in class AbstractRecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableFloat8Converter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableFloat8Converter
in interface RecordWriter
getNewNullableFloat8Converter
in class AbstractRecordWriter
public EventBasedRecordWriter.FieldConverter getNewFloat8Converter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewFloat8Converter
in interface RecordWriter
getNewFloat8Converter
in class AbstractRecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableVarDecimalConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableVarDecimalConverter
in interface RecordWriter
getNewNullableVarDecimalConverter
in class AbstractRecordWriter
public EventBasedRecordWriter.FieldConverter getNewVarDecimalConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewVarDecimalConverter
in interface RecordWriter
getNewVarDecimalConverter
in class AbstractRecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableVarCharConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableVarCharConverter
in interface RecordWriter
getNewNullableVarCharConverter
in class AbstractRecordWriter
public EventBasedRecordWriter.FieldConverter getNewVarCharConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewVarCharConverter
in interface RecordWriter
getNewVarCharConverter
in class AbstractRecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableDateConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableDateConverter
in interface RecordWriter
getNewNullableDateConverter
in class AbstractRecordWriter
public EventBasedRecordWriter.FieldConverter getNewDateConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewDateConverter
in interface RecordWriter
getNewDateConverter
in class AbstractRecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableTimeConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableTimeConverter
in interface RecordWriter
getNewNullableTimeConverter
in class AbstractRecordWriter
public EventBasedRecordWriter.FieldConverter getNewTimeConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewTimeConverter
in interface RecordWriter
getNewTimeConverter
in class AbstractRecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableTimeStampConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableTimeStampConverter
in interface RecordWriter
getNewNullableTimeStampConverter
in class AbstractRecordWriter
public EventBasedRecordWriter.FieldConverter getNewTimeStampConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewTimeStampConverter
in interface RecordWriter
getNewTimeStampConverter
in class AbstractRecordWriter
public EventBasedRecordWriter.FieldConverter getNewNullableBitConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewNullableBitConverter
in interface RecordWriter
getNewNullableBitConverter
in class AbstractRecordWriter
public EventBasedRecordWriter.FieldConverter getNewBitConverter(int fieldId, String fieldName, FieldReader reader)
RecordWriter
valueHolder
at the given column number fieldId
.getNewBitConverter
in interface RecordWriter
getNewBitConverter
in class AbstractRecordWriter
Copyright © 1970 The Apache Software Foundation. All rights reserved.