@NotThreadSafe @Path(value="master/lineage") @Produces(value="application/json") @Deprecated public final class LineageMasterClientRestServiceHandler extends Object
Modifier and Type | Field and Description |
---|---|
static String |
CREATE_LINEAGE
Deprecated.
|
static String |
DELETE_LINEAGE
Deprecated.
|
static String |
GET_LINEAGE_INFO_LIST
Deprecated.
|
static String |
REINITIALIZE_FILE
Deprecated.
|
static String |
REPORT_LOST_FILE
Deprecated.
|
static String |
SERVICE_NAME
Deprecated.
|
static String |
SERVICE_PREFIX
Deprecated.
|
static String |
SERVICE_VERSION
Deprecated.
|
Constructor and Description |
---|
LineageMasterClientRestServiceHandler(javax.servlet.ServletContext context)
Deprecated.
Constructs a new
LineageMasterClientRestServiceHandler . |
Modifier and Type | Method and Description |
---|---|
javax.ws.rs.core.Response |
createLineage(String inputFiles,
String outputFiles,
String command,
String outputFile)
Deprecated.
|
javax.ws.rs.core.Response |
deleteLineage(Long lineageId,
boolean cascade)
Deprecated.
|
javax.ws.rs.core.Response |
getLineageInfoList()
Deprecated.
|
javax.ws.rs.core.Response |
getServiceName()
Deprecated.
|
javax.ws.rs.core.Response |
getServiceVersion()
Deprecated.
|
javax.ws.rs.core.Response |
reinitializeFile(String path,
Long blockSizeBytes,
Long ttl,
TtlAction ttlAction)
Deprecated.
|
javax.ws.rs.core.Response |
reportLostFile(String path)
Deprecated.
|
public static final String SERVICE_PREFIX
public static final String SERVICE_NAME
public static final String SERVICE_VERSION
public static final String CREATE_LINEAGE
public static final String DELETE_LINEAGE
public static final String GET_LINEAGE_INFO_LIST
public static final String REINITIALIZE_FILE
public static final String REPORT_LOST_FILE
public LineageMasterClientRestServiceHandler(@Context javax.servlet.ServletContext context)
LineageMasterClientRestServiceHandler
.context
- context for the servlet@GET @Path(value="service_name") public javax.ws.rs.core.Response getServiceName()
@GET @Path(value="service_version") public javax.ws.rs.core.Response getServiceVersion()
@POST @Path(value="create_lineage") public javax.ws.rs.core.Response createLineage(@QueryParam(value="inputFiles") String inputFiles, @QueryParam(value="outputFiles") String outputFiles, @QueryParam(value="command") String command, @QueryParam(value="commandOutputFile") String outputFile)
inputFiles
- a colon-separated list of the lineage input filesoutputFiles
- a colon-separated list of the lineage output filescommand
- the job commandoutputFile
- the job output file@POST @Path(value="delete_lineage") public javax.ws.rs.core.Response deleteLineage(@QueryParam(value="lineageId") Long lineageId, @QueryParam(value="cascade") boolean cascade)
lineageId
- the lineage idcascade
- whether to delete lineage recursively@GET @Path(value="lineage_info_list") public javax.ws.rs.core.Response getLineageInfoList()
@POST @Path(value="reinitialize_file") public javax.ws.rs.core.Response reinitializeFile(@QueryParam(value="path") String path, @QueryParam(value="blockSizeBytes") Long blockSizeBytes, @QueryParam(value="ttl") Long ttl, @QueryParam(value="ttlAction") TtlAction ttlAction)
path
- the file pathblockSizeBytes
- the file block size (in bytes)ttl
- the file time-to-live (in seconds)ttlAction
- action to take after TTL is expired@POST @Path(value="report_lost_file") public javax.ws.rs.core.Response reportLostFile(@QueryParam(value="path") String path)
path
- the file pathCopyright © 2023. All Rights Reserved.