Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
Apache Iceberg dan Lake Formation dengan Amazon EMR
Amazon EMR merilis 6.15.0 dan yang lebih tinggi termasuk dukungan untuk kontrol akses berbutir halus berdasarkan Apache Iceberg saat Anda membaca dan menulis data AWS Lake Formation dengan Spark. SQL Amazon EMR mendukung tabel, baris, kolom, dan kontrol akses tingkat sel dengan Apache Iceberg. Dengan fitur ini, Anda dapat menjalankan kueri snapshot pada copy-on-write tabel untuk menanyakan snapshot terbaru dari tabel pada saat komit atau pemadatan tertentu.
Jika Anda ingin menggunakan format Iceberg, atur konfigurasi berikut. Ganti
dengan jalur Amazon S3 tempat tabel Iceberg Anda berada, dan ganti placeholder Region dan ID akun dengan nilai Anda sendiri.DB_LOCATION
spark-sql \ --conf spark.sql.extensions=org.apache.iceberg.spark.extensions.IcebergSparkSessionExtensions,com.amazonaws.emr.recordserver.connector.spark.sql.RecordServerSQLExtension --conf spark.sql.catalog.iceberg_catalog=org.apache.iceberg.spark.SparkCatalog --conf spark.sql.catalog.iceberg_catalog.warehouse=s3://
DB_LOCATION
--conf spark.sql.catalog.iceberg_catalog.catalog-impl=org.apache.iceberg.aws.glue.GlueCatalog --conf spark.sql.catalog.iceberg_catalog.io-impl=org.apache.iceberg.aws.s3.S3FileIO --conf spark.sql.catalog.iceberg_catalog.glue.account-id=ACCOUNT_ID
--conf spark.sql.catalog.iceberg_catalog.glue.id=ACCOUNT_ID
--conf spark.sql.catalog.iceberg_catalog.client.assume-role.region=AWS_REGION
--conf spark.sql.secureCatalog=iceberg_catalog
Jika Anda ingin Lake Formation menggunakan server rekaman untuk mengelola katalog Spark Anda, atur spark.sql.catalog.<managed_catalog_name>.lf.managed
ke true.
Anda juga harus berhati-hati NOT untuk melewati pengaturan peran asumsi berikut:
--conf spark.sql.catalog.my_catalog.client.assume-role.region --conf spark.sql.catalog.my_catalog.client.assume-role.arn --conf spark.sql.catalog.my_catalog.client.assume-role.tags.LakeFormationAuthorizedCaller
Matriks dukungan berikut mencantumkan beberapa fitur inti Apache Iceberg dengan Lake Formation:
Salin di Tulis | Gabung saat Dibaca | |
---|---|---|
Kueri snapshot - Spark SQL |
✓ |
✓ |
Kueri yang dioptimalkan baca - Spark SQL |
✓ |
✓ |
Pertanyaan tambahan |
✓ |
✓ |
Pertanyaan perjalanan waktu |
✓ |
✓ |
Tabel metadata |
✓ |
✓ |
DML |
✓ |
✓ |
DDLperintah |
||
Permintaan sumber data percikan |
||
Sumber data Spark menulis |