2. 程式人生 > >介面宣告變數的一個實際例子

介面宣告變數的一個實際例子

阿新 • • 發佈：2019-02-01
java自學者，如果錯誤，還請多多指教。實際工作中在重寫UDTF子類的process方法的時候，遇到了一個forward方法，在研究原始碼的過程中對介面的概念更為清晰了。 UDTF介面說明如下： Java UDTF需要繼承com.aliyun.odps.udf.UDTF類。這個類需要實現4個介面。
介面定義 描述
public void setup(ExecutionContext ctx) throws UDFException 初始化方法，在UDTF處理輸入資料前，呼叫使用者 自定義的初始化行為。在每個Worker內setup會 被先呼叫一次。
public void process(Object[] args) throws UDFException 這個方法由框架呼叫，SQL中每一條記錄都會對 應呼叫一次process，process的引數為SQL語句 中指定的UDTF輸入引數。輸入引數以Object[]的 形式傳入，輸出結果通過forward函式輸出。用 戶需要在process函式內自行呼叫forward，以決 定輸出資料。
public void close() throws UDFException UDTF的結束方法，此方法由框架呼叫，並且只會 被呼叫一次，即在處理完最後一條記錄之後。
public void forward(Object ...o) throws UDFException 使用者呼叫forward方法輸出資料，每次forward 代表輸出一條記錄。對應SQL語句UDTF的as子句 指定的列。
其中forward方法如下 protected void forward(Object... outs) throws UDFException { this.collector.collect(outs);
} collector是介面UDTFCollector宣告的變數， private UDTFCollector collector; UDTFCollector宣告如下的collect方法， public interface UDTFCollector extends DataCollector { void collect(Object[] var1); } 既然forward方法是使用者輸出資料的方法，那它究竟如何傳遞引數呢？這就是介面宣告一個變數的用處了。 介面通常被使用在Java程式語言，用來做回撥函式使用 。Java並不允許方法作為引數傳遞使用，因此，其中一個解決辦法則是可以定義一個介面，
把這個介面當成方法的引數，以此來使用該項物件的方法簽名。問題又來了，那什麼是方法簽名呢？ 所謂方法簽名就由方法名+形參列表構成，也就是說，方法名和形引數據型別列表可以唯一的確定一個方法，與方法的返回值一點關係都沒有， 而這也是判斷過載重要依據。 於是歸納如下，forward方法使用UDFCollector宣告的collector裡面的collect方法，於是給forward傳參時就確定了一個對應的方法簽名從而在UDTF函式 解析出輸出引數。

相關推薦

介面宣告變數的一個實際例子

java自學者，如果錯誤，還請多多指教。實際工作中在重寫UDTF子類的process方法的時候，遇到了一個forward方法，在研究原始碼的過程中對介面的概念更為清晰了。 UDTF介面說明如下： Java UDTF需要繼承com.aliyun.odps.udf.UDTF類。

用一個實際例子理解Docker volume工作原理

rip system java字符串 副本 作用 box 令行 高效 mage 要了解Docker Volume，首先我們需要理解Docker文件系統的工作原理。Docker鏡像是由多個文件系統的只讀層疊加而成。當一個容器通過命令docker run啟動時，Docker會加

通過一個實際例子理解Kubernetes裏pod的自動scale - 水平自動伸縮

reat class rtp abi namespace -s true rev rfi kubectl scale命令用於程序在負載加重或縮小時進行pod擴容或縮小，我們通過一些實際例子來觀察scale命令到底能達到什麽效果。 命令行創建一個deployment： kub

通過一個實際例子理解Kubernetes裡pod的自動scale

kubectl scale命令用於程式在負載加重或縮小時進行pod擴容或縮小，我們通過一些實際例子來觀察scale命令到底能達到什麼效果。 命令列建立一個deployment： kubectl run jerry-nginx --image=nginx:1.12.2 kubectl get deploy檢

通過一個實際例子學習SAP UI5的控制元件繪製和渲染

以下面這個UI為例： 首先生成按鈕對應的渲染器，即ButtonRenderer例項： 將渲染好的button對應的原生html程式碼儲存到buffer裡： 接下來依次是這些ui element的渲染器：page, XMLView and UIArea. 把html原始

朱曄和你聊Spring系列S1E8：湊活著用的Spring Cloud（含一個實際業務貫穿所有元件的完整例子）

本文會以一個簡單而完整的業務來闡述Spring Cloud Finchley.RELEASE版本常用元件的使用。如下圖所示，本文會覆蓋的元件有： Spring Cloud Netflix Zuul閘道器伺服器 Spring Cloud Netflix Eureka發現伺服器 Spring Cloud Net

Storm入門之第6章一個實際的例子

本章要闡述一個典型的網路分析解決方案，而這類問題通常利用Hadoop批處理作為解決方案。與Hadoop不同的是，基於Storm的方案會實時輸出結果。 我們的這個例子有三個主要元件（見圖6-1） 一個基於Node.js的web應用，用於測試系統 一個Redis伺服器，用於持久化資料 一個

面向介面程式設計的一個例子

舉個例子說說介面程式設計的思想魅力所在,假如我們模擬世界上所有的事物,生成一個個的類.現在的是經濟社會,大家都可喜歡談錢的事了.那我們就想知道下每類事物的價錢,價值.咋整?首先想到的自然是讓每個類都提供一個函式,然後計算出自己的價錢.但函式名字咋取?隨便亂取可就亂套了,於是

用socket.io實現websocket的一個簡單例子

soc .html www sock 在線 ket log html 簡單例子 http://biyeah.iteye.com/blog/1295196 socket.io的介紹 http://www.cnblogs.com/mazg/p/5467960.html

C語言多線程的一個簡單例子

color oid blog stdlib.h null bsp 等待 creat 多線程 　　多線程的一個簡單例子: 　　 #include <stdio.h> #include <stdlib.h> #include <string.h&

一個經典例子讓你徹徹底底理解java回調機制

pac hid find title tco tail comment 方法 rgs 轉帖請註明本文出自xiaanming的博客（http://blog.csdn.net/xiaanming/article/details/17483273），請尊重他人的辛勤勞動成果，謝謝

dva+antd寫的一個react例子--服務器nginx 的配置

http prefix etc cif return line lec body nbsp location ^~ /crm { rewrite ^/crm/(.*)(\.js|\.css|\.png|\.jpg|\.jpeg|\.gif|index\

Nightmare安裝and一個小例子

lob user tor driver .cn earch .org var query 前端的功能測試 功能測試必須在真正瀏覽器做，現在有四種方法。 使用本機安裝的瀏覽器 使用 Selenium Driver 使用 Headless Chrome 使用 Electr

第一個smarty例子－－分頁顯示數據

nbsp oca AS com tr1 xhtml 建立 xmlns set 模板頁index.tpl: <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.o

論cudnn與cuda之間的關系，和實際例子測試。

網絡 log IT 算法 enter sdn pod uda 例子 1、其中cudnn是一個常見的神經網絡層加速庫文件，其能夠很大程度的把加載到顯卡上的網絡層數據進行優化計算。cuda就像一個傻大粗的加速庫，其主要是依靠的是顯卡 計算速度跟一些算法的優化，而且其也是進行顯卡

支持向量機（SVM）的一個小例子

EDA 由於 pda 其它 oca 測試數據 tempdata data before clc; clear; N=10; %下面的數據是我們實際項目中的10訓練樣例（樣例中有8個屬性） %一個正例九個負例 correctData=[0,0.2,0.8,0,0,0,2,2

netsh interface portproxy的一個簡單例子

get 文檔 let pre interface 簡單例子 配置文件 exe CP netsh interface portproxy的微軟幫助文檔地址： https://technet.microsoft.com/zh-cn/library/cc776297(WS.10

使用java實現快速排序的一個簡單例子

fast val rgs 快速 實現 個數 static void sta public static void main(String[] args) { // 測試排序 Random r = new Random(); int arr[] = new

Sql sever 宣告變數，賦值變數

語句： --宣告變數DECLARE @idcard nvarchar (50) , @rowid nvarchar (50) --給變數賦值SELECT @idcard = '{0}', @rowid = '{1}' SELECT COUNT (1) FRO

vue一個小例子

vue 的一個例子 <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <title>Title</title> <s