Вы можете написать собственный экстрактор и выход, который может затем выполнять дешифрование / шифрование.Скорее всего, это будет выглядеть примерно так (на абстрактном уровне):
Извлечение:
AtomicFileProcessing=true
d = decrypt(input.baseStream)
for each row in d.Split do outputrow end // or whatever the right processing is
Вывод:
AtomicFileProcessing=true
serialize rows into outputstream
encrypt outputstream and write to output
Обратите внимание, что в разделе примеров на нашей странице GitHub для U-SQL есть несколько примеров, показывающих, как работать с данными на базовом уровне.
Вам может понадобитьсяне загружайте более 500 МБ данных в основную память, хотя, если можете.Поэтому было бы хорошо, если бы шифрование / дешифрование можно было выполнять потоковым способом.