如何創建將處理avro和parquet之間的轉換的ScaldingSource。 溶液應: 1. Read from parquet format and convert to avro memory representation
2. Write avro objects into a parquet file
注:我注意到層疊有利用節儉和實木複合地板的模塊。我覺得這將是一個開始尋找的好地
我正在編寫一個程序來管理文件,即將文件(如對象)從directory1移動到2.我在級聯中寫了一段代碼,我在考慮如何編寫「管道」來創建流。 有人可以幫我嗎? 謝謝。 // access path to the file input and output and archiving
String inputPath = args[0]; //Directory in HDFS of the I