|
17 | 17 | package org.apache.arrow.adapter.jdbc.consumer.exceptions; |
18 | 18 |
|
19 | 19 | import org.apache.arrow.adapter.jdbc.JdbcFieldInfo; |
20 | | -import org.apache.arrow.vector.types.Types; |
| 20 | +import org.apache.arrow.vector.types.pojo.Field; |
21 | 21 |
|
22 | 22 | /** |
23 | 23 | * Exception while consuming JDBC data. This exception stores the JdbcFieldInfo for the column and |
24 | 24 | * the ArrowType for the corresponding vector for easier debugging. |
25 | 25 | */ |
26 | 26 | public class JdbcConsumerException extends RuntimeException { |
27 | 27 | final JdbcFieldInfo fieldInfo; |
28 | | - final Types.MinorType minorType; |
| 28 | + final Field field; |
29 | 29 |
|
30 | 30 | /** |
31 | 31 | * Construct JdbcConsumerException with all fields. |
32 | 32 | * |
33 | 33 | * @param message error message |
34 | 34 | * @param cause original exception |
35 | 35 | * @param fieldInfo JdbcFieldInfo for the column |
36 | | - * @param minorType ArrowType for the corresponding vector |
| 36 | + * @param field ArrowType for the corresponding vector |
37 | 37 | */ |
38 | 38 | public JdbcConsumerException( |
39 | | - String message, Throwable cause, JdbcFieldInfo fieldInfo, Types.MinorType minorType) { |
| 39 | + String message, Throwable cause, JdbcFieldInfo fieldInfo, Field field) { |
40 | 40 | super(message, cause); |
41 | 41 | this.fieldInfo = fieldInfo; |
42 | | - this.minorType = minorType; |
| 42 | + this.field = field; |
43 | 43 | } |
44 | 44 |
|
45 | | - public Types.MinorType getMinorType() { |
46 | | - return this.minorType; |
| 45 | + public Field getField() { |
| 46 | + return this.field; |
47 | 47 | } |
48 | 48 |
|
49 | 49 | public JdbcFieldInfo getFieldInfo() { |
|
0 commit comments