Skip to content

Commit

Permalink
Remove no tested types for initial commit
Browse files Browse the repository at this point in the history
  • Loading branch information
yuuteng committed Dec 8, 2023
1 parent bd0ec33 commit d82035a
Showing 1 changed file with 0 additions and 28 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -198,40 +198,12 @@ public Optional<ColumnMapping> toColumnMapping(ConnectorSession session, Connect
.put("time", handle -> {
return Optional.of(timeColumnMapping(handle));
})
.put("timestampntz", handle -> {
return Optional.of(timestampColumnMapping(handle));
})
.put("timestamptz", handle -> {
return Optional.of(timestampTZColumnMapping(handle));
})
.put("timestampltz", handle -> {
return Optional.of(timestampTZColumnMapping(handle));
})
.put("date", handle -> {
return Optional.of(ColumnMapping.longMapping(
DateType.DATE, (resultSet, columnIndex) ->
LocalDate.ofEpochDay(resultSet.getLong(columnIndex)).toEpochDay(),
snowFlakeDateWriter()));
})
.put("object", handle -> {
return Optional.of(ColumnMapping.sliceMapping(
VarcharType.createUnboundedVarcharType(),
StandardColumnMappings.varcharReadFunction(VarcharType.createUnboundedVarcharType()),
StandardColumnMappings.varcharWriteFunction(),
PredicatePushdownController.DISABLE_PUSHDOWN));
})
.put("array", handle -> {
return Optional.of(ColumnMapping.sliceMapping(
VarcharType.createUnboundedVarcharType(),
StandardColumnMappings.varcharReadFunction(VarcharType.createUnboundedVarcharType()),
StandardColumnMappings.varcharWriteFunction(),
PredicatePushdownController.DISABLE_PUSHDOWN));
})
.put("variant", handle -> {
return Optional.of(ColumnMapping.sliceMapping(
VarcharType.createUnboundedVarcharType(), variantReadFunction(), StandardColumnMappings.varcharWriteFunction(),
PredicatePushdownController.FULL_PUSHDOWN));
})
.put("varchar", handle -> {
return Optional.of(varcharColumnMapping(handle.getRequiredColumnSize()));
})
Expand Down

0 comments on commit d82035a

Please sign in to comment.