Flink傳遞引數給函式

引數可以使用建構函式或者withparameters(configuration)方法傳遞，引數將會作為函式物件的一部分被序列化並傳遞到task例項中！

1 使用建構函式方式:

package com.daxin

import org.apache.flink.api.common.functions.filterfunction
import org.apache.flink.api.scala.executionenvironment
import org.apache.flink.api.scala._
/**  * created by daxin on 2017/4/18.
*/object passingparameters2functions1 
}val result =tofilter.filter(new myfilter(2))
result.print()
}}

2 withparameters(configuration)方式

這個方法將會攜帶乙個configuration物件作為引數，這個引數將會傳遞給rich function的open方法(關於rich function參見：rich function)。configuration物件是乙個map，儲存key/value鍵值對.

package com.daxin

import org.apache.flink.api.common.functions.richfilterfunction
import org.apache.flink.api.scala.executionenvironment
import org.apache.flink.api.scala._
import org.apache.flink.configuration.configuration
/**  * created by daxin on 2017/4/18.
*/object passingparameters2functions2 
def filter(in: int): boolean = 
}).withparameters(c)
result.print()
}}

3 使用全域性的the executionconfig方式：

package com.daxin

import org.apache.flink.api.common.executionconfig
import org.apache.flink.api.common.functions.
import org.apache.flink.api.scala.executionenvironment
import org.apache.flink.api.scala._
import org.apache.flink.configuration.configuration
/**  * created by daxin on 2017/4/18.
* 傳遞引數3：globally via the executionconfig
*  */
object passingparameters2functions3 
override def map(value: string): string = 
}data.map(new richfunc).print()
}}

flink傳遞引數給函式

官網位址batch 可以使用建構函式或withparameters configuration 方法將引數傳遞給函式。這些引數將作為功能物件的一部分進行序列化，並交付給所有並行任務例項。datasettofilter env.fromelements 1,2,3 tofilter.filter ne...

flink 傳參 啟動 flink傳遞引數給函式

引數可以使用建構函式或者withparameters configuration 方法傳遞，引數將會作為函式物件的一部分被序列化並傳遞到task例項中！官網位址batch 1 使用建構函式方式 dataset tofilter env.fromelements 1,2,3 tofilter.filt...

ajax傳遞map引數給後端

向後端傳遞乙個引數 前端ajax 部分 var map 設定乙個事件觸發ajax ajax else if data 0 else error function 後端 後端controller 部分 public responsebody integer ajaxdemo requestbody m...