Class DelimitedRecordHiveMapper
- java.lang.Object
- 
- org.apache.storm.hive.bolt.mapper.DelimitedRecordHiveMapper
 
- 
- All Implemented Interfaces:
- Serializable,- HiveMapper
 
 @Deprecated(since="2.7.1", forRemoval=true) public class DelimitedRecordHiveMapper extends Object implements HiveMapper Deprecated, for removal: This API element is subject to removal in a future version.- See Also:
- Serialized Form
 
- 
- 
Constructor SummaryConstructors Constructor Description DelimitedRecordHiveMapper()Deprecated, for removal: This API element is subject to removal in a future version.
 - 
Method SummaryAll Methods Instance Methods Concrete 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.StringgetFieldDelimiter()Deprecated, for removal: This API element is subject to removal in a future version.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.DelimitedRecordHiveMapperwithColumnFields(Fields columnFields)Deprecated, for removal: This API element is subject to removal in a future version.DelimitedRecordHiveMapperwithFieldDelimiter(String delimiter)Deprecated, for removal: This API element is subject to removal in a future version.DelimitedRecordHiveMapperwithPartitionFields(Fields partitionFields)Deprecated, for removal: This API element is subject to removal in a future version.DelimitedRecordHiveMapperwithTimeAsPartitionField(String timeFormat)Deprecated, for removal: This API element is subject to removal in a future version.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- 
withColumnFieldspublic DelimitedRecordHiveMapper withColumnFields(Fields columnFields) Deprecated, for removal: This API element is subject to removal in a future version.
 - 
withPartitionFieldspublic DelimitedRecordHiveMapper withPartitionFields(Fields partitionFields) Deprecated, for removal: This API element is subject to removal in a future version.
 - 
withFieldDelimiterpublic DelimitedRecordHiveMapper withFieldDelimiter(String delimiter) Deprecated, for removal: This API element is subject to removal in a future version.
 - 
withTimeAsPartitionFieldpublic DelimitedRecordHiveMapper withTimeAsPartitionField(String timeFormat) Deprecated, for removal: This API element is subject to removal in a future version.
 - 
createRecordWriterpublic org.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.Description copied from interface:HiveMapperGiven a endPoint, returns a RecordWriter with columnNames.- Specified by:
- createRecordWriterin interface- HiveMapper
- Throws:
- org.apache.hive.hcatalog.streaming.StreamingException
- IOException
- ClassNotFoundException
 
 - 
writepublic void 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.- Specified by:
- writein interface- HiveMapper
- Throws:
- org.apache.hive.hcatalog.streaming.StreamingException
- IOException
- InterruptedException
 
 - 
mapPartitionspublic List<String> mapPartitions(Tuple tuple) Deprecated, for removal: This API element is subject to removal in a future version.Description copied from interface:HiveMapperGiven a tuple, return a hive partition values list.- Specified by:
- mapPartitionsin interface- HiveMapper
 
 - 
mapPartitionspublic List<String> mapPartitions(TridentTuple tuple) Deprecated, for removal: This API element is subject to removal in a future version.Description copied from interface:HiveMapperGiven a TridetnTuple, return a hive partition values list.- Specified by:
- mapPartitionsin interface- HiveMapper
 
 - 
mapRecordpublic byte[] mapRecord(Tuple tuple) Deprecated, for removal: This API element is subject to removal in a future version.Description copied from interface:HiveMapperGiven a tuple, maps to a HiveRecord based on columnFields.- Specified by:
- mapRecordin interface- HiveMapper
 
 - 
mapRecordpublic byte[] mapRecord(TridentTuple tuple) Deprecated, for removal: This API element is subject to removal in a future version.Description copied from interface:HiveMapperGiven a TridentTuple, maps to a HiveRecord based on columnFields.- Specified by:
- mapRecordin interface- HiveMapper
 
 - 
getFieldDelimiterpublic String getFieldDelimiter() Deprecated, for removal: This API element is subject to removal in a future version.
 
- 
 
-