Описание тега infosphere-spl

Описание тега Вопросы с тегом
SPL (Streams Processing Language) - это специализированный потоково-ориентированный язык, используемый в платформе IBM InfoSphere (большие данные). SPL позволяет пользователям создавать потоки данных, которые связаны и управляются операторами. Программы SPL предназначены для развертывания на распределенном оборудовании для масштабирования. Основными целями SPL являются масштабируемость, расширяемость и удобство использования.
1 ответ

Datastage.. У меня есть поле со значением скажем 59.0900.. Я хочу преобразовать его в 05909

У меня есть поле со значением, скажем 59.0900.. Я хочу преобразовать его в 05909 Может кто-нибудь помочь мне с этим.. Я работаю над информационным пространством IBM инфосферы
23 авг '13 в 16:43
1 ответ

Есть ли способ перехватить кортеж / сек через оператора в IBM Streams (не через консоль Streams)

Я хочу захватить количество кортежей в секунду через оператора и записать его в файл. Я не могу использовать "Оператор газа", чтобы установить частоту кортежей самостоятельно. Кроме того, чтобы добавить еще раз, я не говорю о захвате информации чере…
23 авг '17 в 17:37
1 ответ

Ошибка компиляции MQTTSource Operator в IBM Infosphere Streams

Система: Запуск VMPlayer на Windows Server. Одна виртуальная машина воспроизводит образ виртуального устройства IBM Infosphere Streams (3.2) QuickStart Edition и другого MessageSight(1.1). При использовании MQTTSource Operator я получаю следующую ош…
16 дек '14 в 09:30
1 ответ

Получите метку времени UTC/GMT в инфосфере

Я использовал getTimestamp() метод Infosphere Streams для получения текущей отметки времени. Однако с несколькими экземплярами, работающими в разных часовых поясах, его трудно синхронизировать. Есть ли способ получить метку времени GMT данного момен…
01 июл '14 в 16:10
1 ответ

Как использовать RScript Operator с Java Streams Java Application Api?

Я изучаю Java Application Api в IBM Streams, поэтому он выглядит многообещающе. Я могу создавать топологии и запускать их в автономном режиме в распределенном режиме. Теперь я пытаюсь увидеть, как вызвать R-скрипт из топологии Java. Я думаю, что оди…
09 ноя '15 в 09:57
1 ответ

Как проверить значения времени представления?

SPL поддерживает значения времени отправки, которые извлекаются через вызовы функций getSubmissionTimeValue() и / или getSubmissionTimeListValue(). Так как нет main() функция в программе SPL, как я могу проверить эти значения в операторе?
02 июл '13 в 17:51
1 ответ

Как я могу изменить свойства потока экспорта во время выполнения?

В разделе " Динамическая композиция" говорится, что Свойства также могут быть добавлены, обновлены или удалены во время выполнения, как и подписки. Свойства и подписки времени компиляции служат только начальными настройками. но это не говорит, как э…
02 июл '13 в 16:50
2 ответа

SFTP на другой сервер с использованием инфосферных потоков 3.2

Я пытаюсь написать небольшую программу SPL в Streams 3.2 В этом я должен генерировать файлы, используя filesink, и тот же файл должен быть передан на другой сервер, используя FTPCommand. Я скопировал com.ibm.streamsx.inet пакет в пути $STREAM_INSTAL…
27 окт '17 в 10:53
1 ответ

Может ли вызов функции SPL submit()?

Я пытаюсь вызвать submit() из функции SPL (которая вызывается из пользовательского оператора), но это не работает. Жалуется на название моего потока: submit({prop1=value1, prop2=value2}, MyStream); ОШИБКА: неизвестный идентификатор был указан в прог…
02 июл '13 в 17:27
1 ответ

Ibm Streams проблема загрузки классов оператора Java

Я использую IBM Streams 4.1.1. Я не могу использовать клиент Elasticsearch в своем операторе Java, потому что он имеет транзитивную зависимость guava-18.0 lib <groupId>org.elasticsearch</groupId> <artifactId>elasticsearch</artif…
16 дек '16 в 14:22
1 ответ

Использование пользовательского оператора Java в API Java в потоках инфосферы

Некоторое время я искал, как использовать настраиваемый оператор Java с инфосферными потоками Java API Что мне нужно, так это после написания настраиваемого оператора, как показано ниже... public class Test extends AbstractOperator { private int i; …
29 янв '17 в 13:23
1 ответ

Этап данных веб-службы

Я получаю следующую ошибку: Исключение вызова службы. Я работаю с версией 8.7 IBM InfoSphere DataStage и QualityStage Designer и использую задание сервера. У меня есть 1 последовательный файл, веб-служба, последовательный файл. Есть идеи, что может …
11 июн '14 в 17:53
1 ответ

Отложенное развертывание InfoSphere Streams Operators и внедрение тегов времени выполнения

Я хотел бы знать, доступны ли две функции в потоках инфосферы, но я не мог найти это где-нибудь еще. 1) Насколько мне известно, при запуске приложения InfoSphere Streams все операторы развертываются на хостах в кластере. Можно ли развернуть конкретн…
25 июн '17 в 13:37
1 ответ

Задание свойств экземпляра IBM Streams и их реализация без перезапуска экземпляра

Я должен установить некоторые свойства экземпляра для работы в согласованных региональных проектов. Я установил эти свойства, но они отразились только после перезапуска экземпляра, что, очевидно, привело к отмене всех запущенных заданий. У меня есть…
21 ноя '17 в 20:24
0 ответов

Неправильное поведение запроса IBM Optim Insert

Я новичок здесь и в мире IBM Optim, поэтому я надеюсь, что здесь есть кто-то, кто работал с IBM Optim. Вот проблема: У меня есть производственная и тестовая среда базы данных. В моей производственной базе данных у меня есть несколько пользователей (…
18 ноя '14 в 14:13
1 ответ

Можем ли мы использовать функции времени SPL внутри операторов C++?

Я хочу использовать функцию toTimestamp внутри cpp. Так что я обращаюсь к ней как SPL::Functions::time::toTimestamp(Sys.YYYYMMDDhhmmss,date). Проблема в том, что она не может распознать 'Sys'. Какую библиотеку я должен включить?
06 фев '19 в 10:18
1 ответ

Операция экспорта / импорта IBM Streams внутри экземпляра, а не между двумя экземплярами

Чем отличается операция экспорта / импорта, когда она происходит в одном и том же экземпляре, в отличие от случая, когда это происходит между двумя разными экземплярами. Есть ли разница в производительности между двумя?
14 мар '18 в 22:14
1 ответ

Работает над миграцией SPL 3.0 на 4.2 (TEDA)

Я работаю над миграцией кода 3.0 в новую платформу 4.2. Я сталкиваюсь с несколькими трудностями: Как сделать дедупликацию уровня CDR в новой платформе 4.2? (Примечание: дедупликация таблиц уже выполнена). Где реализовать PostDedupProcessor - пользов…
26 окт '17 в 08:18
1 ответ

Не задана переменная среды STREAMS_ADAPTERS_ODBC

При создании следующего приложения Infosphere streams я получаю сообщение об ошибке, приведенное ниже. Пожалуйста посоветуй. namespace application; use com.ibm.streams.db::*; composite DB { type temp1 = tuple<int32 i, rstring dateTime, timestamp …
23 май '14 в 12:23
1 ответ

Как мы обрабатываем два разных входных потока в onTuple оператора Custom() IBM InfoSphere Streams?

В пользовательском операторе я пытаюсь открыть один файл, который был представлен при запуске, и токенизировать значения из файла и сравнить значения с входными потоками, который является другим файлом.
28 июл '15 в 13:24