Support for joining InstantColumn
@@ -294,6 +294,9 @@ public class DataFrameJoiner {
if (type instanceof DateTimeColumnType) {
return new LongIndex(table2.dateTimeColumn(col2Name));
}
+ if (type instanceof InstantColumnType) {
+ return new LongIndex(table2.instantColumn(col2Name));
+ }
if (type instanceof TimeColumnType) {
return new IntIndex(table2.timeColumn(col2Name));
}
@@ -421,6 +424,11 @@ public class DataFrameJoiner {
DateTimeColumn col2 = (DateTimeColumn) table2.column(col2Name);
long value = col2.getLongInternal(ri);
rowBitMapOneCol = index.get(value);
+ } else if (type instanceof InstantColumnType) {
+ LongIndex index = new LongIndex(result.instantColumn(col2Name));
+ InstantColumn col2 = (InstantColumn) table2.column(col2Name);
+ long value = col2.getLongInternal(ri);
+ rowBitMapOneCol = index.get(value);
} else if (type instanceof TimeColumnType) {
IntIndex index = new IntIndex(result.timeColumn(col2Name));
TimeColumn col2 = (TimeColumn) table2.column(col2Name);
