()
| 2774 | |
| 2775 | #[test] |
| 2776 | fn test_serialize_timestamp() { |
| 2777 | let json = vec![ |
| 2778 | json!({"timestamp": 1681319393}), |
| 2779 | json!({"timestamp": "1970-01-01T00:00:00+02:00"}), |
| 2780 | ]; |
| 2781 | let schema = Schema::new(vec![Field::new( |
| 2782 | "timestamp", |
| 2783 | DataType::Timestamp(TimeUnit::Second, None), |
| 2784 | true, |
| 2785 | )]); |
| 2786 | let mut decoder = ReaderBuilder::new(Arc::new(schema)) |
| 2787 | .build_decoder() |
| 2788 | .unwrap(); |
| 2789 | decoder.serialize(&json).unwrap(); |
| 2790 | let batch = decoder.flush().unwrap().unwrap(); |
| 2791 | assert_eq!(batch.num_rows(), 2); |
| 2792 | assert_eq!(batch.num_columns(), 1); |
| 2793 | let values = batch.column(0).as_primitive::<TimestampSecondType>(); |
| 2794 | assert_eq!(values.values(), &[1681319393, -7200]); |
| 2795 | } |
| 2796 | |
| 2797 | #[test] |
| 2798 | fn test_serialize_decimal() { |
nothing calls this directly
no test coverage detected