ETL: Data Fusion JavaScript 轉換資料 Transform

/**
 * @summary Transforms the provided input record into zero or more output records or errors.

 * Input records are available in JavaScript code as JSON objects.

 * @param input an object that contains the input record as a JSON.   e.g. to access a field called 'total' from the input record, use input.total.
 * @param emitter an object that can be used to emit zero or more records (using the emitter.emit() method) or errors (using the emitter.emitError() method)
 * @param context an object that provides access to:
 *            1. CDAP Metrics - context.getMetrics().count('output', 1);
 *            2. CDAP Logs - context.getLogger().debug('Received a record');
 *            3. Lookups - context.getLookup('blacklist').lookup(input.id); or
 *            4. Runtime Arguments - context.getArguments().get('priceThreshold')
 */
function transform(input, emitter, context) {
  emitter.emit(input);
}

function transform(input, emitter, context) {
  // 產生隨機編號
  var id = 'test-' + Math.random().toString(36).substring(2, 15);

  // 轉換的資料
  var transform_input = {
    'id' : id,
  	'custom_field' : 'custom-value',
    'english_first_name' : input.en_first_name,
    'english_last_name' : input.en_last_name,
    'age' : input.age
  };

  // 輸出轉換資料
  emitter.emit(transform_input);
}