Uses of Class
org.apache.flink.util.Reference

Packages that use Reference

Package	Description
org.apache.flink.runtime.blob
org.apache.flink.runtime.minicluster
org.apache.flink.runtime.state
org.apache.flink.util

Uses of Reference in org.apache.flink.runtime.blob

Fields in org.apache.flink.runtime.blob declared as Reference

Modifier and Type	Field and Description
protected Reference<File>	AbstractBlobCache.storageDir Root directory for local file storage.

Methods in org.apache.flink.runtime.blob with parameters of type Reference

Modifier and Type	Method and Description
static BlobCacheService	BlobUtils.createBlobCacheService(Configuration configuration, Reference<File> fallbackStorageDirectory, BlobView blobView, InetSocketAddress serverAddress) Creates the BlobCacheService from the given configuration, fallback storage directory, blob view and blob server address.
static BlobServer	BlobUtils.createBlobServer(Configuration configuration, Reference<File> fallbackStorageDirectory, BlobStore blobStore) Creates the BlobServer from the given configuration, fallback storage directory and blob store.

Constructors in org.apache.flink.runtime.blob with parameters of type Reference

Constructor and Description
AbstractBlobCache(Configuration blobClientConfig, Reference<File> storageDir, BlobView blobView, org.slf4j.Logger logger, InetSocketAddress serverAddress)
BlobCacheService(Configuration blobClientConfig, Reference<File> storageDir, BlobView blobView, InetSocketAddress serverAddress) Instantiates a new BLOB cache.
BlobServer(Configuration config, Reference<File> storageDir, BlobStore blobStore) Instantiates a new BLOB server and binds it to a free network port.
PermanentBlobCache(Configuration blobClientConfig, Reference<File> storageDir, BlobView blobView, InetSocketAddress serverAddress) Instantiates a new cache for permanent BLOBs which are also available in an HA store.
PermanentBlobCache(Configuration blobClientConfig, Reference<File> storageDir, BlobView blobView, InetSocketAddress serverAddress, BlobCacheSizeTracker blobCacheSizeTracker)
TransientBlobCache(Configuration blobClientConfig, Reference<File> storageDir, InetSocketAddress serverAddress) Instantiates a new BLOB cache.

Uses of Reference in org.apache.flink.runtime.minicluster

Constructor parameters in org.apache.flink.runtime.minicluster with type arguments of type Reference

Constructor and Description
MiniCluster(MiniClusterConfiguration miniClusterConfiguration, Supplier<Reference<RpcSystem>> rpcSystemSupplier)

Uses of Reference in org.apache.flink.runtime.state

Constructors in org.apache.flink.runtime.state with parameters of type Reference

Constructor and Description
TaskExecutorLocalStateStoresManager(boolean localRecoveryEnabled, Reference<File[]> localStateRootDirectories, Executor discardExecutor)

Uses of Reference in org.apache.flink.util

Methods in org.apache.flink.util that return Reference

Modifier and Type	Method and Description
static <V> Reference<V>	Reference.borrowed(V value)
static <V> Reference<V>	Reference.owned(V value)