Package org.apache.drill.exec.store.splunk

Class SplunkBatchInsertWriter

java.lang.Object

org.apache.drill.exec.store.AbstractRecordWriter

org.apache.drill.exec.store.splunk.SplunkBatchWriter

org.apache.drill.exec.store.splunk.SplunkBatchInsertWriter

All Implemented Interfaces:

RecordWriter

public class SplunkBatchInsertWriter
extends SplunkBatchWriter

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.drill.exec.store.splunk.SplunkBatchWriter

SplunkBatchWriter.ComplexFieldConverter, SplunkBatchWriter.ScalarSplunkConverter, SplunkBatchWriter.VarCharSplunkConverter

Field Summary

Fields inherited from class org.apache.drill.exec.store.splunk.SplunkBatchWriter

destinationIndex, splunkService

Constructor Summary

Constructors

Constructor	Description
SplunkBatchInsertWriter(UserBitShared.UserCredentials userCredentials, List<String> tableIdentifier, SplunkWriter 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.splunk.SplunkBatchWriter

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

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

checkForNewPartition, getNewDecimal18Converter, getNewDecimal28DenseConverter, getNewDecimal28SparseConverter, getNewDecimal38DenseConverter, getNewDecimal38SparseConverter, getNewDecimal9Converter, getNewIntervalConverter, getNewIntervalDayConverter, getNewIntervalYearConverter, getNewNullableDecimal18Converter, getNewNullableDecimal28DenseConverter, getNewNullableDecimal28SparseConverter, getNewNullableDecimal38DenseConverter, getNewNullableDecimal38SparseConverter, getNewNullableDecimal9Converter, getNewNullableIntervalConverter, getNewNullableIntervalDayConverter, getNewNullableIntervalYearConverter, getNewNullableUInt1Converter, getNewNullableUInt2Converter, getNewNullableUInt4Converter, getNewNullableUInt8Converter, getNewNullableVar16CharConverter, getNewNullableVarBinaryConverter, getNewRepeatedBigIntConverter, getNewRepeatedBitConverter, getNewRepeatedDateConverter, getNewRepeatedDecimal18Converter, getNewRepeatedDecimal28DenseConverter, getNewRepeatedDecimal28SparseConverter, getNewRepeatedDecimal38DenseConverter, getNewRepeatedDecimal38SparseConverter, getNewRepeatedDecimal9Converter, getNewRepeatedFloat4Converter, getNewRepeatedFloat8Converter, getNewRepeatedIntConverter, getNewRepeatedIntervalConverter, getNewRepeatedIntervalDayConverter, getNewRepeatedIntervalYearConverter, getNewRepeatedSmallIntConverter, getNewRepeatedTimeConverter, getNewRepeatedTimeStampConverter, getNewRepeatedTinyIntConverter, getNewRepeatedUInt1Converter, getNewRepeatedUInt2Converter, getNewRepeatedUInt4Converter, getNewRepeatedUInt8Converter, getNewRepeatedVar16CharConverter, getNewRepeatedVarBinaryConverter, getNewRepeatedVarCharConverter, getNewRepeatedVarDecimalConverter, getNewUInt1Converter, getNewUInt2Converter, getNewUInt4Converter, getNewUInt8Converter, 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

SplunkBatchInsertWriter

public SplunkBatchInsertWriter(UserBitShared.UserCredentials userCredentials,
 List<String> tableIdentifier,
 SplunkWriter config)

Method Details

updateSchema

public void updateSchema(VectorAccessible batch)

Description copied from class: SplunkBatchWriter

Update the schema in RecordWriter. Called before starting writing the records. In this case, we add the index to Splunk here. Splunk's API is a little sparse and doesn't really do much in the way of error checking or providing feedback if the operation fails.

Specified by:

updateSchema in interface RecordWriter

Overrides:

updateSchema in class SplunkBatchWriter

Parameters:

batch - VectorAccessible The incoming batch