Apache Nifi читает содержимое потока файла - PullRequest
Новая
       17

Apache Nifi читает содержимое потока файла

0 голосов
/ 23 февраля 2020

Я хотел бы получить доступ к содержимому файла потока, который должен содержать двоичные данные, но когда я выполняю этот код: 

public void onTrigger(final ProcessContext context, final ProcessSession session) throws ProcessException {

       FlowFile ff = session.get(); 
       Logger.info("Flowfile size : " + ff.getSize());

       session.read(ff, new InputStreamCallback() {
       @Override
       public void process(InputStream in) throws IOException {
          Logger.info("InputStream size : " + in.available());
          …
       }
    }
}

У меня есть это: 

Flowfile size : 46662
InputStream size : 0

Как результат, у меня нет данных для чтения.

Может кто-нибудь подсказать мне, как правильно читать содержимое файла потока?

...