Function descriptions

<?php

public function execute(): array
{
    $result = [];
    foreach ($this->exportEntityDefinitionList->get() as $entityDefinition) {
        if (!$entityDefinition->isActive()) {
            continue;
        }

        $entityIds = $this->retrieveSchedulableEntities->execute(
            $entityDefinition->getEntityTableName(),
            $entityDefinition->getEntityIdentifierFieldName(),
            $entityDefinition->getCode()
        );
        foreach ($entityIds as $entityId) {
            $initializationData = $this->initializationDataFactory->create();
            $initializationData->setArguments(
                [
                    self::ARGUMENT_ENTITY_CODE => $entityDefinition->getCode(),
                    self::ARGUMENT_IDENTIFIER => (int)$entityId,
                    self::ARGUMENT_IS_RETRY => false,
                ]
            );
            $initializationData->setPipelineConfiguration(
                $this->getPipelineConfiguration(
                    $entityDefinition,
                    (int)$entityId
                )
            );
            $result[] = $initializationData;

            $this->markEntityAsScheduled->execute(
                $entityDefinition->getCode(),
                (int)$entityId
            );
        }
    }
    return $result;
}

<?php

/**
 * @param string $entityTableName
 * @param string $entityIdentifierFieldName
 * @param string $entityCode
 * @return array
 */
public function execute(string $entityTableName, string $entityIdentifierFieldName, string $entityCode): array
{
    $connection = $this->resourceConnection->getConnection();
    return $connection->fetchCol(
        $this->modifier->execute(
            $entityTableName,
            $entityIdentifierFieldName,
            $entityCode,
            $connection->select()
        )
    );
}