Function getColumnIndexForPackedFile

src/nodeExecutor.ts:84–107

(
  packedFile: Pick<PackedFile, "tableSchema">,
  columnName: string,
  executionContext?: FlowExecutionContext,
)

};

const getColumnIndexForPackedFile = (
  packedFile: Pick<PackedFile, "tableSchema">,
  columnName: string,
  executionContext?: FlowExecutionContext,
): number => {
  if (!packedFile.tableSchema) {
    return -1;
  }

  if (!executionContext) {
    return packedFile.tableSchema.fields.findIndex((field) => field.name === columnName);
  }

  let columnIndexes = executionContext.columnIndexesByPackedFile.get(packedFile as PackedFile);
  if (!columnIndexes) {
    columnIndexes = new Map<string, number>();
    packedFile.tableSchema.fields.forEach((field, index) => {
      columnIndexes?.set(field.name, index);
    });
    executionContext.columnIndexesByPackedFile.set(packedFile as PackedFile, columnIndexes);
  }

  return columnIndexes.get(columnName) ?? -1;
};

const readPackCached = async (
  packPath: string,