()
| 98 | } |
| 99 | |
| 100 | func (sf *storeFlusher) StreamWriter() (table.StreamWriter, error) { |
| 101 | if err := sf.checkBuilder(); err != nil { |
| 102 | metrics.FlushStatistics.Failure.Incr() |
| 103 | return nil, err |
| 104 | } |
| 105 | return sf.builder.StreamWriter(), nil |
| 106 | } |
| 107 | |
| 108 | // Commit flushes data and commits metadata. |
| 109 | func (sf *storeFlusher) Commit() (err error) { |
nothing calls this directly
no test coverage detected