Class JsonRecordHiveMapper
- java.lang.Object
-
- org.apache.storm.hive.bolt.mapper.JsonRecordHiveMapper
-
- All Implemented Interfaces:
Serializable,HiveMapper
@Deprecated(since="2.7.1", forRemoval=true) public class JsonRecordHiveMapper extends Object implements HiveMapper
Deprecated, for removal: This API element is subject to removal in a future version.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description JsonRecordHiveMapper()Deprecated, for removal: This API element is subject to removal in a future version.
-
Method Summary
All 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.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.JsonRecordHiveMapperwithColumnFields(Fields columnFields)Deprecated, for removal: This API element is subject to removal in a future version.JsonRecordHiveMapperwithPartitionFields(Fields partitionFields)Deprecated, for removal: This API element is subject to removal in a future version.JsonRecordHiveMapperwithTimeAsPartitionField(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
-
withColumnFields
public JsonRecordHiveMapper withColumnFields(Fields columnFields)
Deprecated, for removal: This API element is subject to removal in a future version.
-
withPartitionFields
public JsonRecordHiveMapper withPartitionFields(Fields partitionFields)
Deprecated, for removal: This API element is subject to removal in a future version.
-
withTimeAsPartitionField
public JsonRecordHiveMapper withTimeAsPartitionField(String timeFormat)
Deprecated, for removal: This API element is subject to removal in a future version.
-
createRecordWriter
public 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 interfaceHiveMapper- Throws:
org.apache.hive.hcatalog.streaming.StreamingExceptionIOExceptionClassNotFoundException
-
write
public 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 interfaceHiveMapper- Throws:
org.apache.hive.hcatalog.streaming.StreamingExceptionIOExceptionInterruptedException
-
mapPartitions
public 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 interfaceHiveMapper
-
mapPartitions
public 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 interfaceHiveMapper
-
mapRecord
public 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 interfaceHiveMapper
-
mapRecord
public 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 interfaceHiveMapper
-
-