<dependency>
<groupId>org.apache.iceberg</groupId>
<artifactId>iceberg-api</artifactId>
<version>0.11.1</version>
</dependency>
Table table = new HadoopTables(hadoopConf).create(schema, tableLocation);
Schema schema = new Schema(
new Schema.Field("id", Types.IntegerType.get()),
new Schema.Field("name", Types.StringType.get())
);
TableIdentifier tableIdentifier = TableIdentifier.of("my_table");
table.create(tableIdentifier, schema);
Table table = new HadoopTables(hadoopConf).load(tableLocation);
try (DataFileWriter writer = table.newDataFileWriter()) {
writer.write(row1);
writer.write(row2);
// ...
}
try (CloseableIterable<Record> reader = table.newScan().planFiles()) {
for (Record record : reader) {
int id = record.get("id");
String name = record.get("name");
}
}
PlanBuilder builder = table.newScan()
.filter(Expressions.equal("name", "John"))
.select("id", "name");
try (CloseableIterable<Record> reader = builder.planFiles()) {
for (Record record : reader) {
}
}
