全部产品
Search
文档中心

DataWorks:Membuat Fungsi EMR

更新时间:Jun 23, 2025

Topik ini menjelaskan cara membuat fungsi E-MapReduce (EMR).

Prasyarat

  • Kluster EMR Alibaba Cloud telah dibuat, dan aturan arah masuk dengan konten berikut telah ditambahkan ke grup keamanan tempat kluster tersebut berada.

    • Tindakan: Mengizinkan

    • Jenis protokol: TCP Kustom

    • Rentang port: 8898/8898

    • Objek otorisasi: 100.104.0.0/16

  • Instance mesin komputasi EMR telah terhubung dengan ruang kerja Anda. Folder EMR hanya akan ditampilkan setelah Anda menghubungkan instance mesin komputasi EMR dengan ruang kerja di halaman Manajemen Ruang Kerja. Untuk informasi lebih lanjut, lihat Mengelola ruang kerja.

  • Sumber daya yang diperlukan telah diunggah.

Prosedur

  1. Buka halaman DataStudio.

    Masuk ke Konsol DataWorks. Di bilah navigasi atas, pilih wilayah yang diinginkan. Di panel navigasi sisi kiri, pilih Data Development and O&M > Data Development. Pada halaman yang muncul, pilih ruang kerja yang diinginkan dari daftar drop-down dan klik Go to Data Development.

  2. Buat alur kerja. Untuk informasi lebih lanjut, lihat Membuat alur kerja yang dipicu otomatis.

  3. Tulis kode Java dalam lingkungan Java offline, kompres kode menjadi paket JAR, lalu unggah paket tersebut sebagai sumber daya JAR ke DataWorks. Untuk informasi lebih lanjut, lihat Membuat dan menggunakan sumber daya EMR.

  4. Buat fungsi.

    1. Klik alur kerja di bagian Alur Bisnis, klik kanan EMR, lalu pilih Create Solution..

    2. Di kotak dialog Create Function, atur parameter Name, Engine Instance, dan Path.

    3. Klik Create.

    4. Di bagian Function information tab konfigurasi yang muncul, atur parameter.

      Function information section

      Parameter

      Deskripsi

      Function Type

      Jenis fungsi. Nilai valid: Mathematical Operation Functions, Aggregate Functions, String Processing Functions, Date Functions, Window Functions, dan Other Functions.

      Engine Instance

      Kluster EMR yang terhubung dengan ruang kerja saat ini. Secara default, Anda tidak dapat mengubah instance mesin.

      Engine Type

      Jenis mesin komputasi. Secara default, Anda tidak dapat mengubah jenis mesin.

      EMR database

      Database tempat kluster EMR berada. Pilih database dari daftar drop-down. Untuk membuat database, klik New Library. Di kotak dialog New Library, atur parameter dan klik OK.

      Function Name

      Nama fungsi. Anda dapat menggunakan nama ini untuk merujuk fungsi dalam pernyataan SQL. Nama fungsi harus unik secara global dan tidak dapat diubah setelah fungsi dibuat.

      Owner

      Parameter ini diatur secara otomatis.

      Class Name

      Wajib. Nama kelas yang mengimplementasikan fungsi.

      Resource

      Wajib. Sumber daya yang akan digunakan dalam fungsi. Pilih sumber daya dari yang telah dibuat di ruang kerja saat ini dari daftar drop-down. Untuk membuat sumber daya, klik Create Resource. Di kotak dialog Create Resource, atur parameter dan klik Create.

      Description

      Deskripsi fungsi.

      Expression Syntax

      Sintaks fungsi. Contoh: test.

      Parameter Description

      Deskripsi parameter input dan output yang didukung.

      Return Value

      Opsional. Nilai kembali. Contoh: 1.

      Example

      Opsional. Contoh fungsi.

  5. Klik ikon Save di bilah alat atas.

  6. Komitmennya fungsi.

    1. Klik ikon Submit icon di bilah alat atas.

      null

      Anda harus memilih grup sumber daya untuk penjadwalan ketika Anda melakukan commit fungsi EMR. Kami merekomendasikan Anda menggunakan grup sumber daya eksklusif untuk penjadwalan. Jika tidak ada grup sumber daya eksklusif untuk penjadwalan yang tersedia, Anda dapat membeli dan mengonfigurasinya. Untuk informasi lebih lanjut, lihat Membuat dan menggunakan grup sumber daya eksklusif untuk penjadwalan.

    2. Di kotak dialog Commit Node, masukkan komentar Anda di bidang Change description.

    3. Klik OK.

  7. Commit UDF.

    1. Klik ikon Submit di bilah alat atas.

    2. Di kotak dialog Commit Node, masukkan komentar Anda di bidang Change description.

    3. Klik OK.