diff options
| author | Chris Lu <chris.lu@gmail.com> | 2019-01-08 20:26:19 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2019-01-08 20:26:19 -0800 |
| commit | 2a75a36b275ea7f47a95ad2efc70be22d5ed3fe2 (patch) | |
| tree | e641a46a3492ca92f1c1d707d728bec880453242 | |
| parent | 528e594b0184bad0e338ca14f57e51c6bbe7e89b (diff) | |
| download | seaweedfs-2a75a36b275ea7f47a95ad2efc70be22d5ed3fe2.tar.xz seaweedfs-2a75a36b275ea7f47a95ad2efc70be22d5ed3fe2.zip | |
set cassandra ttl with entry.TTLSec
| -rw-r--r-- | weed/filer2/cassandra/cassandra_store.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/filer2/cassandra/cassandra_store.go b/weed/filer2/cassandra/cassandra_store.go index e8f51dd04..2c1f03182 100644 --- a/weed/filer2/cassandra/cassandra_store.go +++ b/weed/filer2/cassandra/cassandra_store.go @@ -48,8 +48,8 @@ func (store *CassandraStore) InsertEntry(entry *filer2.Entry) (err error) { } if err := store.session.Query( - "INSERT INTO filemeta (directory,name,meta) VALUES(?,?,?)", - dir, name, meta).Exec(); err != nil { + "INSERT INTO filemeta (directory,name,meta) VALUES(?,?,?) USING TTL ? ", + dir, name, meta, entry.TtlSec).Exec(); err != nil { return fmt.Errorf("insert %s: %s", entry.FullPath, err) } |