File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
src/main/java/org/embulk/filter/column Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change 9
9
import org .embulk .spi .PageReader ;
10
10
import org .embulk .spi .Schema ;
11
11
import org .embulk .spi .SchemaConfigException ;
12
+ import org .embulk .spi .time .Timestamp ;
12
13
import org .embulk .spi .type .BooleanType ;
13
14
import org .embulk .spi .type .DoubleType ;
14
15
import org .embulk .spi .type .JsonType ;
@@ -266,11 +267,11 @@ public void timestampColumn(Column outputColumn)
266
267
pageBuilder .setNull (outputColumn );
267
268
}
268
269
else {
269
- pageBuilder .setTimestamp (outputColumn , defaultValue );
270
+ pageBuilder .setTimestamp (outputColumn , Timestamp . ofInstant ( defaultValue ) );
270
271
}
271
272
}
272
273
else {
273
- pageBuilder .setTimestamp (outputColumn , pageReader .getTimestamp (inputColumn ). getInstant () );
274
+ pageBuilder .setTimestamp (outputColumn , pageReader .getTimestamp (inputColumn ));
274
275
}
275
276
}
276
277
}
You can’t perform that action at this time.
0 commit comments