Importar Delta Lake
Descripción
Sección titulada «Descripción»Importa una tabla Delta Lake almacenada en PlaidCloud Document a una tabla de proyecto. Apunte el paso a la carpeta de la tabla, la que contiene su carpeta _delta_log y los archivos de datos. La tabla se lee en su última versión.
El formulario del paso tiene las mismas pestañas que Importar Parquet: Parámetros de importación elige el Archivo de origen, la carpeta de la tabla, y la Tabla de destino; Selección de datos de la tabla asigna las columnas; Filtros de datos filtra las filas. Rellenar lee las columnas y sus tipos del _delta_log de la tabla, con las columnas de partición al final, como texto. Cuando la carpeta no existe o está vacía, Rellenar responde Nada que rellenar con una advertencia que indica la ruta y conserva la asignación que ya tiene.
Los flujos de trabajo de KNIME migrados usan este paso para los nodos Delta Table Reader.
Configuración
Sección titulada «Configuración»input_file: la cuenta de documentos y la ruta de la carpeta de la tabla Delta. Una búsqueda encuentra varias tablas: conschema_mismatchestablecido enunion(valor predeterminado), cada tabla se carga por nombre de columna, las columnas que le faltan a una tabla quedan en NULL y las columnas que la asignación no declara se omiten;errordetiene el paso e indica la tabla y las columnas. Establezcaschema_mismatchcon un asistente de IA o con la API REST.target_frame: la tabla en la que se escriben las filas.source_columnsytarget_columns: la asignación de columnas.source_where,having,aggregate,aggregation_typeydistinct: filtran y resumen las filas, como en otros pasos de importación.use_target_slicer,limit_target_startylimit_target_end: conservan solo un segmento del resultado.delete_file: elimina los archivos importados después de la importación.ascii_only: elimina los caracteres que no son ASCII.skip_if_unchanged: activado de forma predeterminada; una ejecución del flujo de trabajo omite la importación cuando los archivos de origen y la configuración del paso no han cambiado desde la última ejecución correcta.