<dependency>
<groupId>org.apache.iceberg</groupId>
<artifactId>iceberg-core</artifactId>
<version>0.12.0</version>
</dependency>
import org.apache.iceberg.Table;
import org.apache.iceberg.catalog.TableIdentifier;
import org.apache.iceberg.data.GenericRecord;
import org.apache.iceberg.data.GenericRecordBuilder;
import org.apache.iceberg.data.Schema;
import org.apache.iceberg.data.random.RandomData;
import org.apache.iceberg.data.random.RandomDataGenerator;
import org.apache.iceberg.flink.CatalogLoader;
import org.apache.iceberg.flink.TableLoader;
import org.apache.iceberg.flink.table.FlinkTables;
import org.apache.iceberg.flink.types.TypeConversions;
public class IcebergExample {
public static void main(String[] args) {
TableIdentifier tableId = TableIdentifier.of("default", "my_table");
Schema schema = new Schema(
TypeConversions.fromLogicalType(new Types.StringType()),
TypeConversions.fromLogicalType(new Types.IntegerType())
);
Table table = new TableLoader(CatalogLoader.defaultCatalog())
.createOrLoad(tableId, schema);
RandomDataGenerator generator = RandomData.generate(schema);
for (int i = 0; i < 100; i++) {
GenericRecord record = new GenericRecordBuilder(schema).build();
generator.fill(record);
table.newAppend().appendFile(record).commit();
}
table.newScan().limit(10).asIterator().forEachRemaining(System.out::println);
table.close();
}
}
