Я в настоящее время разрабатываю новый язык для программирования в непрерывной среде (сравните его с электротехникой), и я получил некоторое представление относительно определенной конструкции языка. Позвольте мне объяснить...
У меня есть класс, который инициализируется ссылкой на ITargetBlock & lt; T & gt; объект. В моих модульных тестах я хотел проверить, есть ли SendAsync & lt; T & gt; метод ITargetBlock & lt; T & gt; назывался. Поэтому я использовал ...
Свинья является средой программирования потока данных для обработки очень больших файлов. Язык свиньи называют латынью Свиньи. Кто-либо знает о хорошем справочнике для PigLatin? Я ищу что-то это...
Я записал пользовательский адаптер для импорта 6K категории с помощью усовершенствованных профилей. Импорт является слишком медленным. Я попытался увеличить число записей от 1 до 5, но оно не помогает. Я также попробовал...
У меня есть пакет SSIS с Потоком данных, который берет источник данных ADO.NET (просто маленькая таблица), выполняет выбор * запрос и производит результаты запроса к плоскому файлу (я также попытался просто вытянуть...
Я ищу Поток данных / Параллельное Программирование API для Java. Я знаю, что существует DataRush, но это не свободно. Чем я интересуюсь, конкретно многоядерная обработка данных, и не распределенный...
Я просто столкнулся с предложенным Повышением:: библиотека Dataflow. Это походит на интересный подход, и я задавался вопросом, существуют ли другие такие альтернативные платформы для C++, и если существует любой связанный...
Я разработал приложение, которое получает Широковещательную передачу и затем запускает Действие, где то Действие запрашивает ContentProvider, который вытаскивает информацию из DNS в режиме реального времени. Я хотел бы...
Насколько я понимаю, свойства процессора NiFi специфичны для этого процессора. Таким образом, добавление нового свойства в процессор будет видно только внутри этого процессора и не будет передано ...
Мы хотели бы объединить наши журналы из нашего приложения и сервисов GCP в одну систему регистрации. Приложения, запущенные в K8s, перенаправляются на экземпляр fluentd, который затем передает данные на наш ...
В облачной платформе Google - Dataflow при потоковой передаче неограниченного PCollection (скажем, из темы PubSub с использованием PubSubIO) существует эффективный способ запуска и остановки конвейера луча в Dataflow? (Пример ...
Я создал лучевой конвейер p для запуска в потоке данных и хочу записать что-то в файл перед запуском моего конвейера. Мой код: импортировать apache_beam как луч из apache_beam.options ....
Я специально ищу написание некоторых алгоритмов обработки сигналов в одном или другом, или, возможно, в некоторой их комбинации . Производительность не имеет большого значения, ясность выражения намерения - это ...
Я собираюсь использовать некоторые методы программирования потока данных в программе clojure, но мне трудно найти много информации из проектов, использующих Java, C # или другие основные языки, которые ...
cross-отправлено в http://social.msdn.microsoft.com/Forums/en-US/tpldataflow/thread/89b3f71d-3777-4fad-9c11-50d8dc81a4a9Я знаю... На самом деле я не использую TplDataflow по максимуму. ATM Я...
Вот фрагмент кода, который мы все написали :public CustomerTO getCustomerByCustDel (final String cust, final int del )throws SQLException { final PreparedStatement query =...
Использование Dataflow CTP (в TPL) Есть ли способ вызвать BatchBlock.TriggerBatch автоматически, если количество элементов в очереди или отложенных элементов меньше, чем BatchSize, после тайм-аута? И ...
Моя проблема заключается в следующем: У меня есть несколько классов python, у которых есть свойства, которые являются производными от других свойств; и эти свойства должны быть кэшированы после вычисления, и кэшированные результаты должны ...
Я не ищу библиотеку нейронных сетей, поскольку я создаю новые типы сетей. Для этого мне нужен хороший язык "потока данных". Конечно, вы можете сделать это на C, C ++, Java и т. Д. но дело ...