Interface HiveMapper
- 
- All Superinterfaces:
- Serializable
 - All Known Implementing Classes:
- DelimitedRecordHiveMapper,- JsonRecordHiveMapper
 
 @Deprecated(since="2.7.1", forRemoval=true) public interface HiveMapper extends Serializable Deprecated, for removal: This API element is subject to removal in a future version.Maps aorg.apache.storm.tuple.Tupeobject to a row in an Hive table.
- 
- 
Method SummaryAll Methods Instance Methods Abstract Methods Deprecated Methods Modifier and Type Method Description org.apache.hive.hcatalog.streaming.RecordWritercreateRecordWriter(org.apache.hive.hcatalog.streaming.HiveEndPoint endPoint)Deprecated, for removal: This API element is subject to removal in a future version.Given a endPoint, returns a RecordWriter with columnNames.List<String>mapPartitions(TridentTuple tuple)Deprecated, for removal: This API element is subject to removal in a future version.Given a TridetnTuple, return a hive partition values list.List<String>mapPartitions(Tuple tuple)Deprecated, for removal: This API element is subject to removal in a future version.Given a tuple, return a hive partition values list.byte[]mapRecord(TridentTuple tuple)Deprecated, for removal: This API element is subject to removal in a future version.Given a TridentTuple, maps to a HiveRecord based on columnFields.byte[]mapRecord(Tuple tuple)Deprecated, for removal: This API element is subject to removal in a future version.Given a tuple, maps to a HiveRecord based on columnFields.voidwrite(org.apache.hive.hcatalog.streaming.TransactionBatch txnBatch, Tuple tuple)Deprecated, for removal: This API element is subject to removal in a future version.
 
- 
- 
- 
Method Detail- 
createRecordWriterorg.apache.hive.hcatalog.streaming.RecordWriter createRecordWriter(org.apache.hive.hcatalog.streaming.HiveEndPoint endPoint) throws org.apache.hive.hcatalog.streaming.StreamingException, IOException, ClassNotFoundExceptionDeprecated, for removal: This API element is subject to removal in a future version.Given a endPoint, returns a RecordWriter with columnNames.- Throws:
- org.apache.hive.hcatalog.streaming.StreamingException
- IOException
- ClassNotFoundException
 
 - 
writevoid write(org.apache.hive.hcatalog.streaming.TransactionBatch txnBatch, Tuple tuple) throws org.apache.hive.hcatalog.streaming.StreamingException, IOException, InterruptedExceptionDeprecated, for removal: This API element is subject to removal in a future version.- Throws:
- org.apache.hive.hcatalog.streaming.StreamingException
- IOException
- InterruptedException
 
 - 
mapPartitionsList<String> mapPartitions(Tuple tuple) Deprecated, for removal: This API element is subject to removal in a future version.Given a tuple, return a hive partition values list.
 - 
mapPartitionsList<String> mapPartitions(TridentTuple tuple) Deprecated, for removal: This API element is subject to removal in a future version.Given a TridetnTuple, return a hive partition values list.
 - 
mapRecordbyte[] mapRecord(Tuple tuple) Deprecated, for removal: This API element is subject to removal in a future version.Given a tuple, maps to a HiveRecord based on columnFields.
 - 
mapRecordbyte[] mapRecord(TridentTuple tuple) Deprecated, for removal: This API element is subject to removal in a future version.Given a TridentTuple, maps to a HiveRecord based on columnFields.
 
- 
 
-