Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import org.apache.iceberg.types.Types.NestedField._
- import org.apache.iceberg.types._
- import org.apache.iceberg._
- val timestampSchema = new Schema(optional(1, "timestamp", Types.TimestampType.withoutZone()))
- val partitionByDate = PartitionSpec.builderFor(timestampSchema).day("timestamp", "date").build
- DataFiles.builder(partitionByDate).withPath("/path/to/data-1.parquet").withFileSizeInBytes(0).withRecordCount(0).withPartitionPath("date=2018-06-08").build()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement