morphline

1熱度

1回答

Flume morphline攔截器：用於數據清理

我有一個簡單的結構化輸入即時。但它也有像「@」這樣的值存在垃圾或十六進制字符在那裏。我如何使用morphline flume攔截器來清理數據？我的水槽在這裏將是hbase。

0熱度

1回答

使用Morphline的內置命令集可以添加兩個變量的值嗎？

我想知道是否有任何方法在morphlines中添加兩個變量的值，而不必編寫自定義命令。例如，像： addValues { answer : "@{value_one}" + 50 } 任何幫助表示讚賞，感謝

0熱度

1回答

水槽-風箏morphline：com.fasterxml.jackson.core.JsonParseException：意外結束輸入：對於OBJECT

預期接近標記當在水槽工作（1.6 & 1.7）我遇到下面的錯誤 2016-12-02 00:57:11,634 (pool-3-thread-1) [WARN - org.apache.flume.serialization.LineDeserializer.readLine(LineDeserializer.java:143)] Line length exceeds max (2048), t

0熱度

1回答

在本地設置水槽

我可以在我的本地設備上設置水槽嗎？我只能在羣集環境中看到flume安裝指南。我必須設置水槽並且必須將其與morphline整合。

0熱度

1回答

錯誤水槽MorphlineSolrSink readJson java.lang.NoSuchFieldError：USE_DEFAULTS

我想從avro源讀取json並接收Solr。當我嘗試readLine {}並存儲爲字符串它的工作。但嘗試readJson{}它拋出以下錯誤。版本： CDH 5.9.0，包裹錯誤 2017-01-26 06:35:38,604 ERROR org.apache.flume.lifecycle.LifecycleSupervisor: Unable to start SinkRunner: {

0熱度

1回答

使用Morphlines中的ReadJson命令將整個JsonObject保存到變量中？

我已經瀏覽了Morphlines的文檔（在http://cloudera.github.io/cdk/docs/current/cdk-morphlines/morphlinesReferenceGuide.html處可用），並且通過外觀的觀察，無法使用ReadJson {}命令將整個Json對象存儲到Morphlines中的變量。我知道這是可能使用的ReadLine {}命令，此代碼： {

0熱度

1回答

使用Cloudera索引PDF文檔搜索

我一直在嘗試使用Cloudera搜索又名Apache Solr來索引pdf文檔。首先，我能夠對Twitter推文進行索引。後來我嘗試索引PDF文件。我已使用默認架構使用solrctl創建了相應的集合。我使用的morphline文件（我已經掩蓋zkHost這裏的IP地址）... solrLocator : { # Name of solr collection #collecti