Module org.apache.arrow.adapter.jdbc

Package org.apache.arrow.adapter.jdbc.consumer

Class MapConsumer

java.lang.Object

org.apache.arrow.adapter.jdbc.consumer.BaseConsumer<MapVector>

org.apache.arrow.adapter.jdbc.consumer.MapConsumer

All Implemented Interfaces:

AutoCloseable, JdbcConsumer<MapVector>

public class MapConsumer
extends BaseConsumer<MapVector>

Consumer which consume map type values from ResultSet. Write the data into MapVector.

Field Summary

Fields inherited from class org.apache.arrow.adapter.jdbc.consumer.BaseConsumer

columnIndexInResultSet, currentIndex, vector

Constructor Summary

Constructors

Constructor	Description
MapConsumer(MapVector vector, int index)	Instantiate a MapConsumer.

Method Summary

Modifier and Type	Method	Description
void	consume(ResultSet resultSet)	Consume a specific type value from ResultSet and write it to vector.
static MapConsumer	createConsumer(MapVector mapVector, int index, boolean nullable)	Creates a consumer for MapVector.

Methods inherited from class org.apache.arrow.adapter.jdbc.consumer.BaseConsumer

close, resetValueVector

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MapConsumer

public MapConsumer(MapVector vector,
 int index)

Instantiate a MapConsumer.

Method Details

createConsumer

public static MapConsumer createConsumer(MapVector mapVector,
 int index,
 boolean nullable)

Creates a consumer for MapVector.

consume

public void consume(ResultSet resultSet)
             throws SQLException,
IOException

Description copied from interface: JdbcConsumer

Consume a specific type value from ResultSet and write it to vector.

Throws:

SQLException

IOException