Описание тега chronicle-bytes

1 ответ

Чтение сообщений в Chronicle Queue Tailer (v5.16.11) не приводит к автоматическому перемещению индекса к следующему циклу броска

Я использую CQ v5.16.11 (с openjdk 11) для сохранения данных с ежедневными циклами прокрутки. Процесс работает без перерыва с воскресенья по пятницу, поэтому у меня 5 файлов cq4 в неделю. Я запустил процесс в течение 1,5 недель и имею 8 файлов (3 дл…
12 окт '18 в 16:31
0 ответов

Chronicle-Values: как создать класс / объект вне кучи, работающий на RMI

MyClass Last = Values.newNativeReference(MyClass.class); int modelSize = ValueModel.acquire(MyClass.class).sizeInBytes(); Last.bytesStore(BytesStore.wrap(new byte[modelSize]), 0, modelSize); Как заставить последний объект (созданный из кучи) работа…
06 авг '18 в 13:57
1 ответ

Есть ли в Chronicle Bytes метод супербыстрого сравнения byte []?

Я храню 64-битный хэш Murmur3 в виде байтового массива в байтовом объекте Chronicle. Я пытаюсь сортировать эти ключи как можно быстрее физически. Я реализовал быструю сортировку, чтобы сделать это. Я заметил там набор методов сравнения и обмена, но …
14 ноя '18 в 19:27
1 ответ

Сериализация Java-объекта ByteBuffer с помощью Chronicle Wire

Я использовал "javolution", который облегчает мне создание объектов Java, которые могут быть сериализованы в nio.ByteBuffer, которые могут быть в дальнейшем отображены на структуры C. Как я могу добиться того же, используя Chronicle Wire?
07 июл '18 в 14:39
1 ответ

Повторное использование выходного потока Chronicle Bytes

Я использую сторонний двоичный кодер, который принимает OutputStream. Я извлекаю OutputStream из метода writeMarshallable маршалла, похожего на этот: public void writeMarshallable(WireOut wire) { OutputStream outputStream = wire.bytes().outputStream…
22 дек '16 в 14:30
1 ответ

Хроники байтов разделяют DirectBytesStores

Я создал MappedBytes экземпляр в файл, который я использую в качестве общего кэша между различными процессами Java. Я хотел бы иметь возможность отделить дополнительные экземпляры MappedByte (или ByteBuffer или любой другой экземпляр) от оригинала, …
17 окт '18 в 05:48
1 ответ

Хроника байтов от InputStream

Я пытаюсь использовать саксофон для синтаксического анализа json-протобуф сообщений на лету, и хочу избежать создания строковых экземпляров для каждого ответа. Для этого мне нужно создать экземпляр Bytes из InputStream (который предоставляется из Ap…
1 ответ

Хроники байтов, поднимающие сегфо

Следуя принятому решению в разделенных по хронике байтах DirectBytesStores, я теперь настроил свой код таким же образом, как и принятый ответ. Я генерирую 1 000 000 объектов, которые записываю в MappedFile, и я бы хотел, чтобы каждый объект мог упра…
22 окт '18 в 13:33
1 ответ

Получить объект ByteBuffer из байтов<ByteBuffer>

Я пытался получить ссылку на объект ByteBuffer (Direct) из объекта Bytes. Ниже приведен код: TestMessageWire testMessageWire = new TestMessageWire(); testMessageWire.data('H'); testMessageWire.setIntData(100); //Below does not give ByteBuffer with c…
12 июл '18 в 12:52
1 ответ

Читайте Хронику Байт несколько раз и одновременно как поток

Я использую Chronicle Bytes версии 1.7.22. Я хотел бы использовать байты для кэширования вне кучи и сохранения больших носителей (например, изображений, видео). В настоящее время я создаю байты следующим образом: Bytes.elasticByteBuffer(); ИЛИ (для …
17 ноя '17 в 13:02
1 ответ

Уровень журнала, установленный в "TRACE" для хроник-регистратора, вызывает AbstractMethodError

Я установил уровень ведения хроники, как показано ниже rootLogger.level=trace rootLogger.appenderRefs=chronicle rootLogger.appenderRef.stdout.ref=CHRONICLE1 Что вызывает ниже ошибки Exception in thread "main" java.lang.AbstractMethodError: Method ne…
02 апр '19 в 12:54
1 ответ

Многопоточная запись в MappedFile / MappedBytes

Возможно ли теоретически писать с использованием байтов Chornicle из нескольких потоков в разных местах одного и того же файла с отображением памяти (с использованием MappedBytes / MappedFile)? На что нужно обратить внимание? Иногда у меня возникают…
1 ответ

Запись хроники с задержкой в ​​1-2 секунды при прокрутке файла с течением времени

У нас есть однопоточный java-процесс, который записывает сообщения в очередь хроник. Очередь (SingleChronicleQueue) настраивается с помощью RollCycle HOURLY. При почасовой отметке, когда происходит прокрутка файла, запись хроники занимает больше сек…
2 ответа

Chronicle Queue читает любые сообщения с помощью readDocument

В очереди хроник у меня есть два типа сообщений. Я хочу прочитать это сообщение с помощью того же продавца и, если это возможно, тем же методом, например, с помощью tailer.readDocument(). Кто угодно, если это возможно, типы сообщений относятся к раз…
15 мар '21 в 06:16
1 ответ

Значения хроники: какой смысл, если ему все еще нужно выделить экземпляр в куче?

У меня возникли проблемы с пониманием того, как правильно использовать эту библиотеку, потому что она создает мусор при распределении, и это, кажется, намерение? Предназначена ли библиотека для использования с этими характеристиками? Или я что-то уп…
0 ответов

Использование байтов для упаковки ByteBuffer

У меня есть очередь хроник, где у меня есть следующий класс: public class Message extends SelfDescribingMarshallable { private final Bytes&lt;ByteBuffer&gt; text; private long timeStamp; public Message(int bufferSize, long timeStamp) { this.text = B…
26 янв '21 в 18:02
1 ответ

Chronicle Bytes: как записывать байты в обратном порядке на машине с прямым порядком байтов?

я использую Bytes&lt;U&gt;Интерфейс отсюда . Базовый буфер создается следующим образом: Bytes&lt;?&gt; buf = Bytes.elasticHeapByteBuffer(MAX_SIZE); buf.writeLong(l); // writes in little endian Учитывая, что мой машинный порядок байтов имеет обратный…
26 апр '22 в 19:38
0 ответов

Метод выпуска Chronicle Bytes устарел

Недавно я перешел на JDK 17 с JDK 11, что вызвало обновление библиотеки Chronicle Wire. Раньше мы использовали версию 2.17.50 с JDK 11, а теперь перешли на версию Chronicle-Wire 2.22.17 и Chronicle-bytes версии 2.22.21. Следующий код отлично работал…
1 ответ

Как эффективно анализировать и сохранять данные в Chronicle Map

Я пытаюсь найти кратчайший и эффективный путь для анализа значений из json и сохранения некоторых из них на карте хроники. Мое текущее решение: String data = ...; ChronicleMap&lt;CharSequence, Long&gt; map = ...; JSONWire wire = new JSONWire(Bytes.a…
1 ответ

Java-версия продукта Chronicle

Хроника продукта поддерживает Java 8 (openjdk8) или 11 (openjdk11)? Я вижу, что https://stackoverflow.com/tags/chronicle/info упоминает Java 8, но это было давно обновлено.
27 фев '23 в 19:49