text: const { processWarehouseMessage } = require("../../../warehouse");
  
  const azureDatalake = "azure_datalake";
  
  function processSingleMessage(message, options) {
    return processWarehouseMessage(message, options);
  }
  
  function getDataTypeOverride(key, val, options) {}
  
  function process(event) {
    const whSchemaVersion = event.request.query.whSchemaVersion || "v1";
    const whStoreEvent = event.destination.Config.storeFullEvent === true;
    const provider = azureDatalake;
    return processSingleMessage(event.message, {
      metadata: event.metadata,
      whSchemaVersion,
      whStoreEvent,
      getDataTypeOverride,
      provider,
      sourceCategory: event.metadata ? event.metadata.sourceCategory : null
    });
  }
  
  exports.process = process;
  