Hi,

I have a Trident Storm topology which ingest data from a Kafka Spout to an
Hive table. This table is set with a primary key, an id I generate. Now,
shouldn't the presence of a primary key
guarantee of an update transaction, rather than an insert?

For example, in my table there's a row:

|id|origin|timestamp|
| 2| "LAX"| 150000 |

then, new data comes in and I get

|id|origin|timestamp|
---------------------------
| 2| "LAX"| 150000 |
| 2| "LAX"| 150150 |

I'm wondering if I'm missing something about the ACID support of Hive, and
its implementation in storm-hive, or rather I'm just getting the expected
result.

Thanks for your attention,
Federico

Reply via email to