public class XmlObjectConnector extends XmlObjectStreamingConnector
DEFAULT_IMPORT
APP, COMMAND, ETL_DRIVER, FORMATTER, IDE_NODE, NO_RANK, WIDGET
Constructor and Description |
---|
XmlObjectConnector() |
Modifier and Type | Method and Description |
---|---|
boolean |
consume(XmlStreamingPackage streamingPackage,
Object message,
AtomicInteger row)
Consume the next record.
|
String |
getName()
Gets the name.
|
String |
getVersion()
Gets the version of the extension module.
|
String |
initQueryLabel()
The init query label.
|
void |
parseNode(XmlUtils xml,
org.w3c.dom.Node node,
XmlObjectConnectorParams params,
Driver driver,
Map<Integer,Boolean> types,
DataSet dataSet,
DataSetRecord record,
XmlUtils.NodeType rootNodeType,
DataSet newDataSet) |
DataSetRecord |
parseXml(XmlUtils xml,
org.w3c.dom.Node root,
XmlObjectConnectorParams params,
Driver driver,
Map<Integer,Boolean> types,
DataSet dataSet,
DataSetRecord record,
XmlUtils.NodeType rootNodeType,
org.w3c.dom.NodeList nodeList,
XmlUtils.NodeType thisNodeType)
Parses the xml and creates a hierarchy of the data sets.
|
ConnectorResult |
populate(XmlObjectConnectorParams params,
DataSet dataSet,
Driver driver)
Populates data set.
|
boolean |
supportsNested()
Supports nested.
|
boolean |
supportsReadStreaming()
Supports read streaming.
|
boolean |
supportsWriteStreaming()
Supports write streaming.
|
beforeStream, canRead, canWrite, cleanUp, closeStream, endStream, getDataSetConnectorParams, getDisplayName, getExt, getVendor, getXmlConfigFileName, getXmlTagName, inlinePersist, isFileConnector, isTextFormat, persist, postPersist, prePersist, startStream, transform, writeMetaData
addValue, basePostPersist, getCommitPolicy, getInputStream, getIoProcessor, getLicensePropertyName, getReader, getType, postPersistWhenEmpty, setCommitPolicy, stream, supportsWorksheets, testConnection
compareTo, getConfigFileName, getExtensionRank, getIconPath, getLocalUnitClassPath
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
supportsReordering, supportsWorksheets, testConnection
getCommitPolicy, setCommitPolicy
public boolean supportsReadStreaming()
DataSetConnector
supportsReadStreaming
in interface DataSetConnector<XmlObjectConnectorParams,ConnectorResult>
supportsReadStreaming
in class XmlObjectStreamingConnector
public boolean supportsWriteStreaming()
DataSetConnector
supportsWriteStreaming
in interface DataSetConnector<XmlObjectConnectorParams,ConnectorResult>
supportsWriteStreaming
in class XmlObjectStreamingConnector
public String getName()
DataSetConnector
getName
in interface DataSetConnector<XmlObjectConnectorParams,ConnectorResult>
getName
in class XmlObjectStreamingConnector
public String getVersion()
ExtensionModule
getVersion
in interface ExtensionModule
getVersion
in class XmlObjectStreamingConnector
public void parseNode(XmlUtils xml, org.w3c.dom.Node node, XmlObjectConnectorParams params, Driver driver, Map<Integer,Boolean> types, DataSet dataSet, DataSetRecord record, XmlUtils.NodeType rootNodeType, DataSet newDataSet) throws Exception
Exception
public DataSetRecord parseXml(XmlUtils xml, org.w3c.dom.Node root, XmlObjectConnectorParams params, Driver driver, Map<Integer,Boolean> types, DataSet dataSet, DataSetRecord record, XmlUtils.NodeType rootNodeType, org.w3c.dom.NodeList nodeList, XmlUtils.NodeType thisNodeType) throws Exception
xml
- the xmlroot
- the root nodeparams
- the parametersdriver
- the etl drivertypes
- the typesdataSet
- the data setrecord
- the recordrootNodeType
- the root node typenodeList
- the node listthisNodeType
- the this node typeException
- in case of any errorpublic boolean consume(XmlStreamingPackage streamingPackage, Object message, AtomicInteger row) throws Exception
StreamingConnector
consume
in interface StreamingConnector<XmlStreamingPackage,XmlProducerPackage>
consume
in class XmlObjectStreamingConnector
streamingPackage
- the streaming packagemessage
- the message to consumerow
- the current row numberException
- in case of any errorpublic ConnectorResult populate(XmlObjectConnectorParams params, DataSet dataSet, Driver driver) throws Exception
DataSetConnector
populate
in interface DataSetConnector<XmlObjectConnectorParams,ConnectorResult>
populate
in class XmlObjectStreamingConnector
params
- the DataSetConnectorParamsdataSet
- the data setdriver
- the driverException
- in case of any errorpublic String initQueryLabel()
DataSetConnector
initQueryLabel
in interface DataSetConnector<XmlObjectConnectorParams,ConnectorResult>
initQueryLabel
in class XmlObjectStreamingConnector
public boolean supportsNested()
DataSetConnector
supportsNested
in interface DataSetConnector<XmlObjectConnectorParams,ConnectorResult>
supportsNested
in class XmlObjectStreamingConnector
Copyright © 2010-2020 Toolsverse. All Rights Reserved.