org.apache.flink.mesos.util

Class MesosArtifactServer

java.lang.Object

org.apache.flink.mesos.util.MesosArtifactServer

All Implemented Interfaces:

MesosArtifactResolver

public class MesosArtifactServer
extends Object
implements MesosArtifactResolver

A generic Mesos artifact server, designed specifically for use by the Mesos Fetcher.

More information: http://mesos.apache.org/documentation/latest/fetcher/ http://mesos.apache.org/documentation/latest/fetcher-cache-internals/

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MesosArtifactServer.UnknownFileHandler Handle a request for a non-existent file.
static class	MesosArtifactServer.VirtualFileServerHandler Handle HEAD and GET requests for a specific file.

Constructor Summary

Constructors

Constructor and Description
MesosArtifactServer(String prefix, String serverHostname, int configuredPort, org.apache.flink.configuration.Configuration config)

Method Summary

Modifier and Type	Method and Description
URL	addFile(File localFile, String remoteFile) Adds a file to the artifact server.
URL	addPath(org.apache.flink.core.fs.Path path, org.apache.flink.core.fs.Path remoteFile) Adds a path to the artifact server.
URL	baseURL()
int	getServerPort() Get the server port on which the artifact server is listening.
void	removePath(org.apache.flink.core.fs.Path remoteFile)
scala.Option<URL>	resolve(org.apache.flink.core.fs.Path remoteFile)
void	stop() Stops the artifact server.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MesosArtifactServer

public MesosArtifactServer(String prefix,
                           String serverHostname,
                           int configuredPort,
                           org.apache.flink.configuration.Configuration config)
                    throws Exception

Throws:

Exception

Method Detail

baseURL

public URL baseURL()

getServerPort

public int getServerPort()

Get the server port on which the artifact server is listening.

addFile

public URL addFile(File localFile,
                   String remoteFile)
            throws IOException,
                   MalformedURLException

Adds a file to the artifact server.

Parameters:

localFile - the local file to serve.

remoteFile - the remote path with which to locate the file.

Returns:

the fully-qualified remote path to the file.

Throws:

MalformedURLException - if the remote path is invalid.

IOException

addPath

public URL addPath(org.apache.flink.core.fs.Path path,
                   org.apache.flink.core.fs.Path remoteFile)
            throws IOException,
                   MalformedURLException

Adds a path to the artifact server.

Parameters:

path - the qualified FS path to serve (local, hdfs, etc).

remoteFile - the remote path with which to locate the file.

Returns:

the fully-qualified remote path to the file.

Throws:

MalformedURLException - if the remote path is invalid.

IOException

removePath

public void removePath(org.apache.flink.core.fs.Path remoteFile)

resolve

public scala.Option<URL> resolve(org.apache.flink.core.fs.Path remoteFile)

Specified by:

resolve in interface MesosArtifactResolver

stop

public void stop()
          throws Exception

Stops the artifact server.

Throws:

Exception