Recientemente comencé a comprender y trabajar con Cassandra.
He creado dos familias de columnas. Para CF1, una escritura es una inserción en una fila única con todos los valores de las columnas. Por ejemplo: la secuencia de operaciones de inserción podría ser así:
Key Col1 Col2 Col3
k1 c11 c12 c13
k2 c21 c22 c23
Para CF2. una escritura es una inserción en una columna de una fila con marca de tiempo. Por ejemplo: la secuencia de operaciones de inserción podría ser así:
Key timeCol1 timeCol2
k1 ct11
k1 ct11 ct12
k2 ct21
k2 ct21 ct22
Estoy usando YCSB y estoy usando productos de ahorro.cliente.batch_mutate()llamar. Para CF1, envío todos los valores de columna para una fila a través de la llamada. Para CF2, envío los nuevos valores de columna para una fila.
Ahora digamos que opscenter informa las "solicitudes de escritura" como, por ejemplo, 1000operaciones/seg cuando un recuento de registros es, digamos, 10000 registros.
¿Qué significa una operación desde la perspectiva del centro de operaciones? ¿Significa inserciones de filas únicas en todas las familias de columnas? ¿Significa el recuento de cada mutación de una fila? ¿Cómo identifica opscenter una operación única? Desde la perspectiva de la aplicación, una operación significa diferente para ambas familias de columnas.
¿Alguien puede guiarme?
Gracias, arun
Respuesta1
Las métricas "Solicitudes de escritura" y "Solicitudes de lectura" representan la cantidad de operaciones de clientes externos, por lo que una sola llamada a Batch_mutate es 1 solicitud, independientemente de cuántas mutaciones contenga.
Las métricas "CF: Escrituras locales" y "CF: Lecturas locales" representan el número de operaciones recibidas en el nodo local, normalmente desde un nodo coordinador. Para una sola inserción, el número de "CF: Escrituras locales" sería igual a "Solicitudes de escritura" x RF para ese espacio de claves. Para las llamadas por lote_mutate, cada mutación dentro del lote se cuenta por separado en el nivel "CF: Escrituras locales".
Estas operaciones se realizan solo a nivel de fila y no existe ningún tipo de procesamiento/fusión inteligente basado en los datos involucrados. por ejemplo, ejecutar la misma consulta de actualización dos veces producirá 2 operaciones.