Function getRowsForPackedFile

src/nodeExecutor.ts:62–82

(
  packedFile: Pick<PackedFile, "schemaFields" | "tableSchema">,
  executionContext?: FlowExecutionContext,
)

};

const getRowsForPackedFile = (
  packedFile: Pick<PackedFile, "schemaFields" | "tableSchema">,
  executionContext?: FlowExecutionContext,
): AmendedSchemaField[][] => {
  if (!packedFile.schemaFields || !packedFile.tableSchema) {
    return [];
  }

  if (!executionContext) {
    return chunkSchemaIntoRows(packedFile.schemaFields, packedFile.tableSchema) as AmendedSchemaField[][];
  }

  const cachedRows = executionContext.rowsByPackedFile.get(packedFile as PackedFile);
  if (cachedRows) {
    return cachedRows;
  }

  const rows = chunkSchemaIntoRows(packedFile.schemaFields, packedFile.tableSchema) as AmendedSchemaField[][];
  executionContext.rowsByPackedFile.set(packedFile as PackedFile, rows);
  return rows;
};

const getColumnIndexForPackedFile = (
  packedFile: Pick<PackedFile, "tableSchema">,