Home Reference Source Test Repository 
import Hasoop from 'hasoop/src/index.js'
public class | source

Hasoop

Hasoop client, get your own instance by creating an instance.

Constructor Summary

Public Constructor
public

constructor(config: *)

Member Summary

Public Members
public

host: *

public

port: *

public
public

weapp: *

Method Summary

Public Methods
public

async createJob(config: *): *

create job.
public

createLink(config: *): *

create link.
public

deleteJob(jobName: *): *

delete job by job name.
public

async deleteJobAll(): *

delete all jobs on sqoop server.
public

deleteLink(linkName: *): *

delete link by link name.
public

async deleteLinkAll(): *

delete all links on sqoop server.
public

formatUrl(basicPath: *, queryObject: *, otherPath: *): *

use some param to create a sqoop rest api url.
public

get infos of all connectors.
public

getConnectorByConnectorName(connectorName: *): *

get info of connector by connector name.
public

getDriver(): *

get infos of all drivers.
public

getJobAll(): *

get infos of all jobs.
public

getJobByConnectorName(connectorName: *): *

get info of job by connector name.
public

getJobByJobName(JobName: *): *

get info of job by job name.
public

getLinkAll(): *

get infos of all links.
public

getLinkByConnectorName(connectorName: *): *

get info of link by connector name.
public

getLinkByLinkName(linkName: *): *

get info of link by link name.
public

get infos of all submissions.
public

getSubmissionByJobName(jobName: *): *

get info of submission by job name.
public

getVersion(): *

get sqoop server version.
public

jobStatus(jobName: *): *

get status of job by job name.
public

startJob(jobName: *): *

start job by job name.
public

stopJob(jobName: *): *

stop job by job name.
public

async updateJobConfig(oldJobName: *, config: *): *

update job config.
public

updateJobDisable(jobName: *): *

change job to disable by job name.
public

updateJobEnable(jobName: *): *

change job to enable by job name.
public

updateLinkConfig(oldLinkName: *, config: *): *

update link config.
public

updateLinkDisable(linkName: *): *

change link to disable by link name.
public

updateLinkEnable(linkName: *): *

change link to enable by link name.

Public Constructors

public constructor(config: *) source

Params:

NameTypeAttributeDescription
config *

Public Members

public host: * source

public port: * source

public userName: * source

public weapp: * source

Public Methods

public async createJob(config: *): * source

create job.

Params:

NameTypeAttributeDescription
config *

Return:

*

create link.

Params:

NameTypeAttributeDescription
config *

Return:

*

public deleteJob(jobName: *): * source

delete job by job name.

Params:

NameTypeAttributeDescription
jobName *

Return:

*

public async deleteJobAll(): * source

delete all jobs on sqoop server.

Return:

*

delete link by link name.

Params:

NameTypeAttributeDescription
linkName *

Return:

*

public async deleteLinkAll(): * source

delete all links on sqoop server.

Return:

*

public formatUrl(basicPath: *, queryObject: *, otherPath: *): * source

use some param to create a sqoop rest api url.

Params:

NameTypeAttributeDescription
basicPath *
queryObject *
otherPath *

Return:

*

public getConnectorAll(): * source

get infos of all connectors.

Return:

*

public getConnectorByConnectorName(connectorName: *): * source

get info of connector by connector name.

Params:

NameTypeAttributeDescription
connectorName *

Return:

*

public getDriver(): * source

get infos of all drivers.

Return:

*

public getJobAll(): * source

get infos of all jobs.

Return:

*

public getJobByConnectorName(connectorName: *): * source

get info of job by connector name.

Params:

NameTypeAttributeDescription
connectorName *

Return:

*

public getJobByJobName(JobName: *): * source

get info of job by job name.

Params:

NameTypeAttributeDescription
JobName *

Return:

*

public getLinkAll(): * source

get infos of all links.

Return:

*

public getLinkByConnectorName(connectorName: *): * source

get info of link by connector name.

Params:

NameTypeAttributeDescription
connectorName *

Return:

*

public getLinkByLinkName(linkName: *): * source

get info of link by link name.

Params:

NameTypeAttributeDescription
linkName *

Return:

*

public getSubmissionAll(): * source

get infos of all submissions.

Return:

*

public getSubmissionByJobName(jobName: *): * source

get info of submission by job name.

Params:

NameTypeAttributeDescription
jobName *

Return:

*

public getVersion(): * source

get sqoop server version.

Return:

*

public jobStatus(jobName: *): * source

get status of job by job name.

Params:

NameTypeAttributeDescription
jobName *

Return:

*

public startJob(jobName: *): * source

start job by job name.

Params:

NameTypeAttributeDescription
jobName *

Return:

*

public stopJob(jobName: *): * source

stop job by job name.

Params:

NameTypeAttributeDescription
jobName *

Return:

*

public async updateJobConfig(oldJobName: *, config: *): * source

update job config.

Params:

NameTypeAttributeDescription
oldJobName *
config *

Return:

*

public updateJobDisable(jobName: *): * source

change job to disable by job name.

Params:

NameTypeAttributeDescription
jobName *

Return:

*

public updateJobEnable(jobName: *): * source

change job to enable by job name.

Params:

NameTypeAttributeDescription
jobName *

Return:

*

public updateLinkConfig(oldLinkName: *, config: *): * source

update link config.

Params:

NameTypeAttributeDescription
oldLinkName *
config *

Return:

*

public updateLinkDisable(linkName: *): * source

change link to disable by link name.

Params:

NameTypeAttributeDescription
linkName *

Return:

*

public updateLinkEnable(linkName: *): * source

change link to enable by link name.

Params:

NameTypeAttributeDescription
linkName *

Return:

*