Package | Description |
---|---|
com.toolsverse.etl.connector | |
com.toolsverse.etl.connector.json | |
com.toolsverse.etl.connector.text | |
com.toolsverse.etl.connector.xml | |
com.toolsverse.io |
Modifier and Type | Class and Description |
---|---|
class |
BaseStreamingPackage<P extends DataSetConnectorParams>
The base class for streaming packages.
|
Modifier and Type | Method and Description |
---|---|
ConnectorResult |
BaseDataSetConnector.stream(StreamingPackage streamingPackage,
Alias alias,
StreamingConnector connector)
Stream data.
|
Modifier and Type | Class and Description |
---|---|
class |
JsonStreamingPackage
The streaming packages for jsons.
|
Modifier and Type | Class and Description |
---|---|
class |
KeyValueStreamingPackage
The streaming packages for key=value files.
|
class |
TextStreamingPackage
The streaming packages for text files.
|
Modifier and Type | Class and Description |
---|---|
class |
XmlStreamingPackage
The streaming packages for xml files.
|
Modifier and Type | Interface and Description |
---|---|
interface |
StreamingConnector<S extends StreamingPackage,P extends ProducerPackage>
The common interface for all connector classes that can stream data and
consume streams using given
IoProcessor . |
Modifier and Type | Method and Description |
---|---|
boolean |
StreamingProcessor.consume(StreamingConnector connector,
StreamingPackage streamingPackage)
Consume data from stream.
|
Copyright © 2010-2020 Toolsverse. All Rights Reserved.