Гость
Войти | Профиль | Очистить
Map
Действия ...
Форумы / NoSQL, Big Data [игнор отключен] [закрыт для гостей] / Cassandra, запись блоками / 3 сообщений из 3, страница 1 из 1
03.05.2012, 14:19
    #37780501
Devider
Devider
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Cassandra, запись блоками
В кассандру кладутся достаточно большие объемы данных. Соответственно, хочется вместо Mutator.insert() звать Mutator.addInsertion() с последующим Mutator.execute(), получается что-то типа
Код: java
1.
2.
3.
4.
5.
6.
		mutator.addInsertion(key, columnFamilyName,
				createColumn(getNextColunmName(key), values, ttl));
		if (++count > 100){ 
			getMutator().execute();
			count = 0;
		}


Проблема в том, что если приложение, например, падает при count = 99 часть данных теряется. Как этого избежать?
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
03.05.2012, 17:18
    #37780948
neoddd
neoddd
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Cassandra, запись блоками
Можно записывать сначала в текстовый фаил, и если упали, после перезапуска проверить файл. Типа транзакционного лога самодельного что-то.

А вообще странно, что нет (?) системных средств для этого в Кассандре
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
03.05.2012, 17:36
    #37780993
Devider
Devider
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Cassandra, запись блоками
neoddd,

Да вот у меня сомнения что нет. ColumnFamilyTemplate<V, K>.setBatched() часом не из этой оперы?
...
Рейтинг: 0 / 0
| Ответить | Цитировать | Написать  
Форумы / NoSQL, Big Data [игнор отключен] [закрыт для гостей] / Cassandra, запись блоками / 3 сообщений из 3, страница 1 из 1
Целевая тема:
Создать новую тему:
Автор:
Найденые пользователи ...
Разблокировать пользователей ...
Читали тему (0):
Читали форум (0):
Пользователи онлайн (0):
Польз. соглашение
созд. / загр.: 570ms
Закрыть
start [/forum/topic.php?fid=48&tablet=1&tid=1856983]:
 0ms
get settings:
 13ms
get forum list:
 5ms
check forum access:
 1ms
check topic access:
 1ms
track hit:
 73ms
get topic data:
 6ms
get forum data:
 1ms
get page messages:
 121ms
get tp. blocked users:
 2ms
others: 347ms
total:  570ms
x
x
Закрыть


Просмотр
0 / 0
Close
Debug Console [Select Text]