Skip to content

Commit 9594ba8

Browse files
committed
Fix string view type
1 parent 261e077 commit 9594ba8

File tree

2 files changed

+12
-0
lines changed

2 files changed

+12
-0
lines changed

flight/flight-sql-jdbc-core/src/main/java/org/apache/arrow/driver/jdbc/accessor/ArrowFlightJdbcAccessorFactory.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -69,6 +69,7 @@
6969
import org.apache.arrow.vector.VarBinaryVector;
7070
import org.apache.arrow.vector.ViewVarBinaryVector;
7171
import org.apache.arrow.vector.VarCharVector;
72+
import org.apache.arrow.vector.ViewVarCharVector;
7273
import org.apache.arrow.vector.complex.DenseUnionVector;
7374
import org.apache.arrow.vector.complex.FixedSizeListVector;
7475
import org.apache.arrow.vector.complex.LargeListVector;
@@ -167,6 +168,9 @@ public static ArrowFlightJdbcAccessor createAccessor(
167168
} else if (vector instanceof LargeVarCharVector) {
168169
return new ArrowFlightJdbcVarCharVectorAccessor(
169170
(LargeVarCharVector) vector, getCurrentRow, setCursorWasNull);
171+
} else if (vector instanceof ViewVarCharVector) {
172+
return new ArrowFlightJdbcVarCharVectorAccessor(
173+
(ViewVarCharVector) vector, getCurrentRow, setCursorWasNull);
170174
} else if (vector instanceof DurationVector) {
171175
return new ArrowFlightJdbcDurationVectorAccessor(
172176
(DurationVector) vector, getCurrentRow, setCursorWasNull);

flight/flight-sql-jdbc-core/src/main/java/org/apache/arrow/driver/jdbc/accessor/impl/text/ArrowFlightJdbcVarCharVectorAccessor.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -35,6 +35,7 @@
3535
import org.apache.arrow.driver.jdbc.utils.DateTimeUtils;
3636
import org.apache.arrow.vector.LargeVarCharVector;
3737
import org.apache.arrow.vector.VarCharVector;
38+
import org.apache.arrow.vector.ViewVarCharVector;
3839
import org.apache.arrow.vector.util.Text;
3940

4041
/** Accessor for the Arrow types: {@link VarCharVector} and {@link LargeVarCharVector}. */
@@ -62,6 +63,13 @@ public ArrowFlightJdbcVarCharVectorAccessor(
6263
this(vector::get, currentRowSupplier, setCursorWasNull);
6364
}
6465

66+
public ArrowFlightJdbcVarCharVectorAccessor(
67+
ViewVarCharVector vector,
68+
IntSupplier currentRowSupplier,
69+
ArrowFlightJdbcAccessorFactory.WasNullConsumer setCursorWasNull) {
70+
this(vector::get, currentRowSupplier, setCursorWasNull);
71+
}
72+
6573
ArrowFlightJdbcVarCharVectorAccessor(
6674
Getter getter,
6775
IntSupplier currentRowSupplier,

0 commit comments

Comments
 (0)