infosphere-spl

    1熱度

    1回答

    我試圖從SPL函數(這是從自定義運算符調用)調用submit(),但它不起作用。它不認我流的名字: submit({prop1=value1, prop2=value2}, MyStream); ERROR: An unknown identifier was referenced in the SPL program: MyStream ,是否支持?

    0熱度

    2回答

    自定義運算符可以在其state子句中定義常量,但是如何定義可以跨多個運算符跨多個文件使用的常量? 理想情況下,我正在尋找一種方法來定義命名空間中的常量。

    0熱度

    1回答

    SPL支持submission-time values,它們通過函數調用getSubmissionTimeValue()和/或getSubmissionTimeListValue()來檢索。由於SPL程序中沒有main()函數,我如何在運算符中驗證這些值?

    0熱度

    1回答

    我該如何與運行中的SPL應用程序進行交互?例如,如果我想讓它開始或停止收集某些統計數據,或者如果我想停止導出某些屬性?

    -1熱度

    1回答

    我有一個值爲59.0900的字段..我想將其轉換爲05909 有人可以幫助我that..Im工作的DataStage IBM的InfoSphere

    1熱度

    1回答

    有誰知道是否可以使用SSL將Apache Cassandra與IBM InfoSphere Datastage集成/連接?也許有人會這樣做,可以寫一些關於它的內容?

    0熱度

    1回答

    我想知道infosphere流中是否有兩個功能可用,但我無法在其他任何地方找到它。 1)就我所知,當InfoSphere Streams Application啓動時,所有運算符都部署在羣集中的主機上。以前的操作員的結果是否可以部署特定的操作員?這樣部署就在工作中發生(而不僅僅是在主機發生故障時)。 2)另外,就我所知,標籤存在允許指定將哪些操作符部署到哪些主機的標籤。是否可以在Job運行時更改主

    0熱度

    1回答

    我一直在尋找了一段時間,現在關於如何使用定製的Java操作withing InfoSphere Streams的Java API的 我需要的是寫一個定製的運營商像下面以後。 。 public class Test extends AbstractOperator { private int i; private int num; @Override public synchronized

    0熱度

    1回答

    我正在IBM Streams中探索Java Application Api,因此它看起來很有希望。我能夠創建拓撲並在分佈式模式下以獨立模式運行它們。 現在我想看看如何從Java拓撲調用R腳本。我在想的一種方法是在我的Java拓撲中使用com.ibm.streams.rproject :: RScript運算符。 這裏是我的完整代碼: SPLStream tuples = testTupleStre

    1熱度

    1回答

    我將使用IBM流4.1.1 我不能在我的Java操作使用Elasticsearch客戶端,因爲它具有傳遞性依賴番石榴18.0 LIB <groupId>org.elasticsearch</groupId> <artifactId>elasticsearch</artifactId> <version>2.3.2</version> 當我提交我的工作我看到NoSuchMethodError