Skip to content

Commit d121063

Browse files
committed
Default mapping for Map and Union; fix TODOs
1 parent 60a23b9 commit d121063

File tree

2 files changed

+8
-7
lines changed

2 files changed

+8
-7
lines changed

extensions/barrage/src/main/java/io/deephaven/extensions/barrage/util/BarrageUtil.java

+4-3
Original file line numberDiff line numberDiff line change
@@ -513,8 +513,6 @@ public static BarrageTypeInfo<Field> getDefaultType(@NotNull final Field field)
513513
}
514514

515515
return new BarrageTypeInfo<>(columnType, columnComponentType, field);
516-
// TODO NATE NOCOMMIT
517-
// arrowFieldFor(field.getName(), columnType, columnComponentType, field.getMetadata(), false));
518516
}
519517

520518
private static Class<?> getDefaultType(
@@ -606,7 +604,10 @@ private static Class<?> getDefaultType(
606604
throw Exceptions.statusRuntimeException(Code.INVALID_ARGUMENT, exMsg +
607605
" of intervalType(IntervalUnit=" + intervalType.getUnit() + ")");
608606
}
609-
607+
case Map:
608+
return Map.class;
609+
case Union:
610+
return Object.class;
610611
default:
611612
if (arrowField.getType().getTypeID() == ArrowType.ArrowTypeID.List
612613
|| arrowField.getType().getTypeID() == ArrowType.ArrowTypeID.ListView

server/jetty/src/test/java/io/deephaven/server/jetty/JettyBarrageChunkFactoryTest.java

+4-4
Original file line numberDiff line numberDiff line change
@@ -1510,8 +1510,8 @@ public void runTest(final TestNullMode nullMode, final TestWrapMode wrapMode) th
15101510

15111511
final Field innerField = schema.getFields().get(0);
15121512
final Map<String, String> attrs = new LinkedHashMap<>(innerField.getMetadata());
1513-
attrs.put(DH_TYPE_TAG, "java.lang.Object");
1514-
// TODO NATE NOCOMMIT rm attr?
1513+
attrs.remove(DH_TYPE_TAG);
1514+
attrs.remove(DH_COMPONENT_TYPE_TAG);
15151515

15161516
final ArrowType unionType = getWrappedModeType(wrapMode,
15171517
Types.getMinorTypeForArrowType(innerField.getType()));
@@ -1523,8 +1523,8 @@ public void runTest(final TestNullMode nullMode, final TestWrapMode wrapMode) th
15231523

15241524
final Field innerField = schema.getFields().get(0);
15251525
final Map<String, String> attrs = new LinkedHashMap<>(innerField.getMetadata());
1526-
attrs.put(DH_TYPE_TAG, "java.util.Map");
1527-
// TODO NATE NOCOMMIT rm attr?
1526+
attrs.remove(DH_TYPE_TAG);
1527+
attrs.remove(DH_COMPONENT_TYPE_TAG);
15281528

15291529
final ArrowType mapType = new ArrowType.Map(false);
15301530

0 commit comments

Comments
 (0)