Описание тега twitter-util
Twitter Util is a collection of general purpose Scala tools developed and open sourced by Twitter.
1
ответ
finagle в Java - функция, функция1 и т. д.
Как создать объект Function1 для использования в методе flatMap объекта Future finagle в Java? Пробовал это: Function1<String, String> f = new Function1<String, String>() { @Override public String apply(String s) { return null; } }; Но э…
02 апр '14 в 16:58
3
ответа
Выполнение последовательности функций, которые возвращают будущее последовательно
У меня есть последовательность функций, которые возвращают будущее. Я хочу выполнить их последовательно, то есть после того, как будет завершено выполнение первой функции в будущем, выполнить следующую функцию и так далее. Есть ли способ сделать это…
04 мар '16 в 17:46
2
ответа
Отсутствует authData пользователя разбора
У меня возникли проблемы с анализом библиотеки Android. Данные аутентификации пользователей отсутствуют в результатах запроса. Поэтому ParseTwitterUtils не может определить, связан ли пользователь или нет.
28 ноя '14 в 06:09
3
ответа
Динамически анализировать строку и возвращать функцию в Scala, используя отражение и интерпретаторы
Я пытаюсь динамически интерпретировать код, заданный как String. Например: val myString = "def f(x:Int):Int=x+1". Я ищу метод, который будет возвращать реальную функцию из этого: Например: val myIncrementFunction = myDarkMagicFunctionThatWillBuildMy…
05 янв '16 в 12:58
2
ответа
Получает ли будущее новую нить?
Получит ли будущее, реализованное, как показано ниже, новую тему? Видимо это не так (см. Вывод ниже). Зачем? Что мне делать, если я хочу, чтобы мой код запускался в новом потоке? package MyTest import com.twitter.util._ import scala.language.postfix…
19 фев '16 в 08:12
2
ответа
Отфильтровывать пользователей с помощью TwitterUtils
Есть ли способ извлечь только конкретного пользователя, который публикует твит при использовании TwitterUtils.createStream()? (JAVA) Аргумент "filters" указывает строки, которые должны содержаться в твитах, но я не уверен, как это можно использовать…
13 фев '15 в 22:18
1
ответ
Асинхронное ведение журнала с использованием Twitter Futures в Scala
Я использую твиттер утилитой в своем проекте. Я хочу добавить ведение журнала для отслеживания запроса через компоненты с помощью MDC. Я не мог найти хороший способ добавить это для фьючерсов в твиттере, поскольку нет контекста выполнения, который з…
26 окт '18 в 01:27
1
ответ
Проблема взаимодействия Java-Scala, связанная с возвращаемыми типами BoxedUnit/void
У меня та же проблема, что и в проблемах совместимости Java с обобщениями и боксом Scala, но я не думаю, что решение там будет работать для меня, потому что для этого потребуется модификация стороннего кода. В частности, из Java (скажем, MyJavaClass…
20 июл '15 в 22:07
1
ответ
Принудительный AsyncStream[A] в Seq[A] в Scala
Я специально использую Twitter AsyncStream, и мне нужно взять результаты параллельной обработки и превратить их в Seq, но единственный способ, которым мне удалось получить работу, ужасен. Такое ощущение, что это должен быть один лайнер, но все мои п…
13 май '17 в 00:08
0
ответов
Как указать службу выполнения для будущих обратных вызовов в Twitter Util?
Я не понимаю, как я могу указать определенную службу выполнения из Java, такую как пул потоков, для выполнения моего обратного вызова в будущем. Например, у меня может быть цепочка операций с картой: val executionService = java.util.concurrent.Exe…
10 окт '18 в 16:14
1
ответ
Как мне выполнить код и посмотреть результаты, используя twitter util-eval
Я пытаюсь скомпилировать и выполнить программу "hello world", используя библиотеку twitter util-eval. Но не в состоянии распечатать результаты. Я собираюсь не просто скомпилировать и выполнить пример hello world, большие файлы scala с зависимостями …
27 июн '17 в 02:08
0
ответов
Как вы комбинируете несколько com.twitter.util.Awaitable с семантикой Future.select?
В сервисе у меня есть основной метод, который запускает com.twitter.finagle.ListeningServer а также создает собственный "канал", возвращающий com.twitter.util.Future это никогда не завершается (если нет ошибки). Оба на самом деле com.twitter.util.Aw…
06 ноя '17 в 11:07
2
ответа
Spark SQL: сбой потоковой передачи TwitterUtils по неизвестной причине
Я использую последнюю версию Spark Master и, кроме того, загружаю следующие файлы: - spark-streaming-twitter_2.10-1.1.0-SNAPSHOT.jar - twitter4j-core-4.0.2.jar - twitter4j-stream-4.0.2.jar Моя простая тестовая программа, которую я выполняю в оболочк…
04 авг '14 в 22:09
1
ответ
com.twitter.util.Await не вызывает исключение com.twitter.util.TimeoutException
Я ожидаю, что этот код вызовет TimeoutException, но это не так. Что я делаю не так? import com.twitter.conversions.time._ import com.twitter.util.{Await, Future} object Tmp { def main(args: Array[String]): Unit = { Await.result( Future{ Thread.sleep…
20 авг '18 в 16:14
1
ответ
Twitter's Future.collect не работает одновременно (Scala)
Исходя из фона node.js, я новичок в Scala и попытался использовать Twitter's Future.collect для выполнения нескольких простых параллельных операций. Но мой код показывает последовательное поведение, а не параллельное поведение. Что я делаю неправиль…
02 дек '16 в 12:38
2
ответа
Каковы преимущества будущего Twitter над Scala Future?
Я знаю много причин, по которым Scala Future станет лучше. Есть ли причины использовать вместо этого Twitter Future? За исключением того, что Finagle использует его.
07 окт '15 в 08:53
0
ответов
Как отменить com.twitter.util.Awaitable через событие
Как я могу отменить com.twitter.util.Awaitableкогда происходит какое-то событие? Например, предположим, что есть консольное приложение, которое ожидает завершения Awaitable: object Main extends App { // Create awaitable val myAwaitable:Awaitable = .…
10 июл '18 в 04:27
1
ответ
Есть ли com.twitter.util.Local для Scala Future и ExecutionContext?
ThreadLocal-подобный класс, который сохраняет свое значение через Future.map/Future.flatMap, чрезвычайно полезен для отслеживания запроса, например, для ведения журнала. Существует ли существующая абстракция в библиотеке Scala для использования в ка…
24 дек '15 в 18:04
0
ответов
Хранение твитов с использованием искры в многоядерном кластере
Я хочу хранить твит в реальном времени, следуя некоторым критериям фильтрации, в базе данных MySQL. Я хочу понять, какой подход лучше, учитывая тот факт, что у меня машина с 16 процессорами. Так как в моем случае лучше использовать потоковый API, мо…
09 сен '16 в 09:40
1
ответ
Лучший способ превратить будущее Java в будущее Twitter
В своем приложении я конвертирую java.concurrent.future в Twitter Future следующим образом: val myTwitterFuture = FuturePool.unboundedPool{ myJavaFuture.get} Это правильный способ сделать это или есть другой предпочтительный метод?
14 фев '20 в 19:52