public class HadoopJobObject extends JobObject
Title: Dataspace Framework
Description: Hadoop job object implementation
Copyright: Copyright (c) 2013
Company: StreamScape Technologies
SchemaObject.ConstraintTypes, SchemaObject.Deferable, SchemaObject.Nullability, SchemaObject.ParameterModes, SchemaObject.ReferentialAction, SchemaObject.ViewCheckModes
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
HADOOP_JOB_EVENT_ID |
ACTOR, ASPECTS, ASSERTION, CATALOG, CHARSET, COLLATION, COLLECTION, COLUMN, CONNECTION_FACTORY, CONSTRAINT, CURSOR, DOMAIN, emptyArray, EVENT_PROTOTYPE, FACETS, FILE_DESCRIPTOR, FULL_TEXT_INDEX, FUNCTION, GRANTEE, INDEX, JOB, LABEL, PARAMETER, PROCEDURE, REFERENCE_LINK, REPLICA, REPLICATION_SOURCE, ROUTINE, SCHEMA, SEMANTIC_TYPE, SEQUENCE, SERVER, SPECIFIC_ROUTINE, SUBQUERY, TABLE, TIMER, TRANSIENT_VAR, TRANSITION, TRIGGER, TYPE, VARIABLE, VIEW, WRAPPER
Constructor and Description |
---|
HadoopJobObject(DataspaceStore store,
NameManager.ObjectName name) |
Modifier and Type | Method and Description |
---|---|
void |
compile(com.streamscape.ds.session.Session session,
SchemaObject parentObject) |
void |
describeProperties(com.streamscape.ds.navigator.RowSetNavigatorClient navigator) |
java.lang.String |
getFileDescriptorName() |
FileServerObject |
getFileServerObject() |
DirectoryTableCollection |
getInputDirectory() |
java.lang.String |
getInputFilesPattern() |
JobStatus |
getJobStatus() |
DirectoryTableCollection |
getOutputDirectory() |
java.util.Properties |
getProperties() |
com.streamscape.ds.lib.OrderedHashSet |
getReferences() |
java.lang.String |
getRuntimePath() |
java.lang.String |
getSQL() |
java.lang.String |
getSQL(java.lang.String name) |
java.lang.String |
getTlpClientFactoryName() |
java.lang.String |
getTlpClientFactoryType() |
boolean |
isRaiseJobEvent() |
void |
setFileDescriptorName(java.lang.String fileDescriptorName) |
void |
setFileServerObject(FileServerObject fileServerObject) |
void |
setInputDirectory(DirectoryTableCollection inputDirectory) |
void |
setInputFilesPattern(java.lang.String inputFilesPattern) |
void |
setOutputDirectory(DirectoryTableCollection outputDirectory) |
void |
setProperties(java.util.Properties properties) |
void |
setRaiseJobEvent(boolean raiseJobEvent) |
void |
setRuntimePath(java.lang.String runtimePath) |
void |
setTlpClientFactoryName(java.lang.String tlpClientFactoryName) |
void |
setTlpClientFactoryType(java.lang.String tlpClientFactoryType) |
void |
startJob() |
void |
stopJob() |
destroy, getCatalogName, getChangeTimestamp, getComponents, getJobType, getObjectName, getObjectType, getOwner, getSchemaName
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aggregateObjectStateHolder, getSQLInSchema, recompileObject
public static final java.lang.String HADOOP_JOB_EVENT_ID
public HadoopJobObject(DataspaceStore store, NameManager.ObjectName name)
public void setFileServerObject(FileServerObject fileServerObject)
public FileServerObject getFileServerObject()
public DirectoryTableCollection getInputDirectory()
public void setInputDirectory(DirectoryTableCollection inputDirectory)
public DirectoryTableCollection getOutputDirectory()
public void setOutputDirectory(DirectoryTableCollection outputDirectory)
public java.lang.String getFileDescriptorName()
public void setFileDescriptorName(java.lang.String fileDescriptorName)
public java.lang.String getTlpClientFactoryName()
public void setTlpClientFactoryName(java.lang.String tlpClientFactoryName)
public java.lang.String getTlpClientFactoryType()
public void setTlpClientFactoryType(java.lang.String tlpClientFactoryType)
public java.lang.String getInputFilesPattern()
public void setInputFilesPattern(java.lang.String inputFilesPattern)
public java.util.Properties getProperties()
public void setProperties(java.util.Properties properties)
public java.lang.String getRuntimePath()
public void setRuntimePath(java.lang.String runtimePath)
public boolean isRaiseJobEvent()
public void setRaiseJobEvent(boolean raiseJobEvent)
public void compile(com.streamscape.ds.session.Session session, SchemaObject parentObject)
compile
in interface SchemaObject
compile
in class JobObject
public JobStatus getJobStatus()
getJobStatus
in class JobObject
public void describeProperties(com.streamscape.ds.navigator.RowSetNavigatorClient navigator)
describeProperties
in class JobObject
public java.lang.String getSQL()
public java.lang.String getSQL(java.lang.String name)
public com.streamscape.ds.lib.OrderedHashSet getReferences()
getReferences
in interface SchemaObject
getReferences
in class JobObject
Copyright © 2015-2024 StreamScape Technologies. All rights reserved.