2016-06-01 8 views
0

Мы можем работать с данными по потоковому объекту [refer]. У меня есть сценарий, в котором мне нужно передать 2 отдельных файла и объединить содержимое, чтобы записать его в файл. Что такое наиболее эффективным способ сделать это ... Я избегаю использования асинхронного объема, так как это создает больше зависимости от процессораПотоковая передача в муле

+0

путем слияния, вы имеете в виду просто объединить два содержимого или вы будете делать какие-либо преобразования тоже? –

+0

Да, я хочу преобразовать и объединить их. – scorpion

+0

Вы пробовали какую-либо методологию в муле до сих пор? –

ответ

0

Streaming обычно только вперед, так что хорошо работает с одним потоковыми вход. Даже если вы прочтете другой потоковый вход для переменной потока, это может быть трудно использовать преобразования на них вместе. Вы пробовали читать один поток как полезную нагрузку, а другой - в переменную потока, а затем работать с данными? BTW, вы будете делать преобразование уровня записи (линии)?

Учитывается ли запись файла 1 с записями файла 2 некоторыми общими данными или они являются независимым набором данных с теми же определениями метаданных?

Если оба они не связаны, возможно, вы можете сначала объединить оба файла в один (файл исходящий с append = true), а затем передать объединенный файл и работать с преобразованием.

Так это зависит от трансформации :)

Смежные вопросы