FailOnCloseDataSink.Factory


public final class FailOnCloseDataSink.Factory implements DataSink.Factory


Factory to create a FailOnCloseDataSink.

Summary

Public constructors

Factory(Cache cache, AtomicBoolean failOnClose)

Creates an instance.

Public methods

DataSink

Creates a DataSink instance.

Public constructors

Factory

public Factory(Cache cache, AtomicBoolean failOnClose)

Creates an instance.

Parameters
Cache cache

The cache to write to when not in fail-on-close mode.

AtomicBoolean failOnClose

An AtomicBoolean whose value is read in each call to open to determine whether to enable fail-on-close for the read that's being started.

Public methods

createDataSink

public DataSink createDataSink()

Creates a DataSink instance.